RocketMQ版本:3.4.6 ==问题现象== RocketMQ集群的某个topic,在一部分节点上消费有“断层”,这部分数据一致没办法消费。 ==调查过程== 一顿操作猛如虎的调查之后发现, 该Topic的消费者的客户端连接数不正确。 程序中设置的客户端数明明是4个, 但是Web页面上显示的是 ...
分类:
其他好文 时间:
2018-08-16 13:59:53
阅读次数:
143
安装环境 jdk1.7 alibaba-rocketmq-3.2.6.tar.gz VM虚拟机redhat6.5-x64:192.168.1.201 192.168.1.202 192.168.1.203 192.168.1.204 Xshell4 部署方案 IP 主机名 用途 Broker角色 1 ...
分类:
其他好文 时间:
2018-08-15 13:05:58
阅读次数:
182
一、强一致性事务的瓶颈 在《分布式强一致性事务》一文中介绍了分布式事务的常用协议2PC二阶段提交,虽然2PC能在很大程度上实现分布式事务中各节点的ACID,但也存在同步阻塞问题,协调者单点故障,协调者因网络原因导致的通知不周或收不全参与者回复导致的异常等问题。 同时,即使能稳定的使用二阶段提交实现分 ...
分类:
其他好文 时间:
2018-08-12 18:41:15
阅读次数:
137
1.解压后用maven编译 2.修改内存 3.启动名称服务器 4.启动经纪人 5.发送接收测试 6.关闭服务器 7.java测试 ...
分类:
其他好文 时间:
2018-08-11 19:41:26
阅读次数:
166
近日,Apache RocketMQ 社区正式发布4.3版本。此次发布不仅包括提升性能,减少内存使用等原有特性增强,还修复了部分社区提出的若干问题,更重要的是该版本开源了社区最为关心的分布式事务消息,而且实现了对外部组件的零依赖。接下来,本文将详细探秘RocketMQ事务消息的设计原理以及实现机制。 ...
分类:
Web程序 时间:
2018-08-11 13:26:57
阅读次数:
184
RocketMQ 目前有两个版本 alibaba版本和apache版本 一、alibaba版本 使用rocketmq命令查看集群状态,查看topic信息时比较麻烦,而且不直观,这个时候可以使用一些web页面来管理rocketmq。 以前曾使用过一个老版本的工具,适用于alibaba版本(贡献至apa ...
分类:
其他好文 时间:
2018-08-09 13:59:11
阅读次数:
385
安装环境 jdk1.7 alibaba-rocketmq-3.2.6.tar.gz VM虚拟机redhat6.5-x64:192.168.1.201 192.168.1.202 Xshell4 部署方案 安装步骤:【两台机器同样操作 以201为例】 步骤一:解压安装文件alibaba-rocketm ...
分类:
其他好文 时间:
2018-08-09 12:13:29
阅读次数:
194
阿里P8架构师谈:消息中间件介绍、典型使用场景、以及使用原则大型分布式架构里一定会涉及到消息中间件,今天先谈谈消息中间件。本文作者陈睿优知学院创始人曾任职阿里巴巴高级软件工程师、百度研发经理、携程定制旅游CTO常用的消息队列有ActiveMQ,RabbitMQ,ZeroMQ,Kafka,MetaMQ,RocketMQ。一、kafka1、不完全符合jms规范,注重吞吐量,类似udp和tcp2、一般做
分类:
其他好文 时间:
2018-08-06 16:28:43
阅读次数:
181
一、简介 消息队列中间件是分布式系统中重要的组件,主要解决应用耦合,异步消息,流量削锋等问题。实现高性能、高可用、可伸缩和最终一致性架构。使用较多的消息队列有ActiveMQ、RabbitMQ、ZeroMQ、Kafka、MetaMQ、RocketMQ。 二、消息队列应用场景 以下介绍消息队列在实际应 ...
分类:
其他好文 时间:
2018-08-03 16:33:59
阅读次数:
192
批量发送消息可提高传递小消息的性能。同时也需要满足以下特征 批量消息要求必要具有同一topic、相同消息配置 不支持延时消息 建议一个批量消息最好不要超过1MB大小 示例 示例 小于1MB 大于1MB也可以使用分割消息的方式进行多次批量发送。 ...
分类:
其他好文 时间:
2018-08-02 13:58:28
阅读次数:
133