RocketMQ(1)-架构原理 RocketMQ是阿里开源的分布式消息中间件，跟其它中间件相比，RocketMQ的特点是纯JAVA实现；集群和HA实现相对简单；在发生宕机和其它故障时消息丢失率更低。 一、RocketMQ专业术语 先讲专业术语的含义，后面会画流程图来更好的去理解它们。 Produc ...
分类：
其他好文 时间：
2020-09-17 13:29:44
阅读次数：
27
一、安装包下载 地址：http://mirror.bit.edu.cn/apache/rocketmq/ 二、安装RocketMQ # unzip rocketmq-all-4.4.0-bin-release.zip -d /usr/local/ 1、修改配置文件: /usr/local/rocke ...
分类：
其他好文 时间：
2020-09-16 12:10:41
阅读次数：
30
前言用过MQ的同学，可能会遇到过消息堆积的问题。而我最近也踩上了这个坑，但是发现结果竟然是这么一个意料之外的原因而导致的。正文那一晚月和风高，我正准备踏上回家的路，突然收到告警短信轰炸！“MQ消息堆积告警[TOPIC:XXX]”肥壕心里“万只草泥马崩腾~”第一反应是：“怎么肥事？刚下班就来搞事情？？？”于是乎赶回公司赶紧打开电脑，登上RocketMQ后台查看（公司自己搭建的开源版RocketMQ）
分类：
其他好文 时间：
2020-08-17 17:54:23
阅读次数：
123
最近看了@JavaGuide发布的一篇『面试官问我如何保证Kafka不丢失消息?我哭了！』，这篇文章承接这个主题，来聊聊如何保证RocketMQ不丢失消息。0x00.消息的发送流程一条消息从生产到被消费，将会经历三个阶段：生产阶段，Producer新建消息，然后通过网络将消息投递给MQBroker存储阶段，消息将会存储在Broker端磁盘中消息阶段，Consumer将会从Broker拉取消息以上任
分类：
其他好文 时间：
2020-08-05 18:15:11
阅读次数：
81
两个回调方法：发送消息成功之后执行事务的executeLocalTransaction，回查时候调用的checkLocalTransaction。 思路：执行事务的时候，调用service的方法，这个方法需要用事务注解，方法参数中传入唯一id，事务方法最后判断如果id不为空，往事务表中插入唯一id， ...
分类：
其他好文 时间：
2020-08-04 16:41:25
阅读次数：
99
https://zhuanlan.zhihu.com/p/159017211 看着这算法凌乱的很，太复杂了！说实话，确实挺复杂，蛮罗嗦的，但是代数法可以得到如下表格： 假设4个queueConsumer有2个可以整除Consumer有3个不可整除Consumer有5个无法都分配queue[0]Con ...
分类：
其他好文 时间：
2020-07-29 10:19:02
阅读次数：
69
==背景== 物联网场景，在设备端写了一个小的API服务程序，这个程序包括： 1、向平台上报设备数据 2、创建消费者客户端，用来监听平台的下行命令 ==问题== 平台层需要知道设备的状态：在线 or 离线。我能想到的解决办法 1、设备上报心跳数据，平台通过心跳来判断设备是否在线。 2、rocketm ...
分类：
其他好文 时间：
2020-07-24 15:29:50
阅读次数：
91
前置知识 以RocketMQ为例 使用IDR启动RocketMQ，参考Eclpse启动RocketMq 大多数消息中间件都支持固定延时队列，比如RocketMQ支持的默认延时等级messageDelayLevel=1s 5s 10s 30s 1m 2m 3m 4m 5m 6m 7m 8m 9m 10 ...
分类：
其他好文 时间：
2020-07-22 15:55:58
阅读次数：
67
启动RocketMQ 启动nameserver 修改broker配置参数，新增 messageDelayLevel=1s 2s 4s 8s 16s 32s 64s 128s 256s 512s 1024s 2048s 4096s 8192s 16384s 32768s 65536s 131072s ...
分类：
其他好文 时间：
2020-07-22 15:54:34
阅读次数：
43
启动RocketMQ 启动nameserver 修改broker配置参数，新增 messageDelayLevel=1s 2s 4s 8s 16s 32s 64s 128s 256s 512s 1024s 2048s 4096s 8192s 16384s 32768s 65536s 131072s ...
分类：
其他好文 时间：
2020-07-22 15:51:28
阅读次数：
83
