Queue是RocketMQ中的另一个重要概念。在对该概念进行分析介绍前，我们先来看一张图： 为了简化分析过程，在这张图中没有包含Slave Broker。Broker1，Broker2和Broker3都是Master Broker。如果各Master Broker有Slave Broker，Slave Broker中的结构和其对应的Master Broker完全相同。 从本质上来说...
Lemon
Cancel
Topic，Topic分片和Queue
Spring集成RocketMQ
Maven依赖 fastjson-1.2.44.jar netty-all-4.1.19.Final.jar rocketmq-client-4.2.0.jar rocketmq-common-4.2.0.jar rocketmq-remoting-4.2.0.jar slf4j-api-1.7.25.jar slf4j-nop-1.7.25.jar <!-- RocketMQ --...
如何搭建RocketMQ集群 - 双主集群部署
服务器环境 IP 角色 模式 192.168.2.222 nameServer1,brokerServer1 Master1 192.168.2.223 nameServer2,brokerServer2 Mast...
RocketMQ术语
Producer 消息生产者，生产者的作用就是将消息发送到MQ，生产者本身既可以产生消息，如读取文本信息等。也可以对外提供接口，由外部应用来调用接口，再由生产者将收到的消息发送到MQ。 Producer Group 生产者组，简单来说就是多个发送同一类消息的生产者称之为一个生产者组。在这里可以不用关心，只要知道有这么一个概念即可。 Consumer 消息消费者，简单来说，消费MQ上的消息...
RocketMQ实际部署
上传安装包 解压RocketMQ压缩包 在安装目录下创建存储路径 mkdir -p data/store/{commitlog,consumequeue,index} 进入conf目录下修改日志配置文件 mkdir -p /home/weblogic/apache-rocketm...
RocketMQ如何在控制台查看死信队列
RocketMQ的ACK机制其中涉及到了消息消费重试，当重试次数达到默认的16次后（可以通过配置文件修改）如果对应的消息还没被成功消费的话，该消息就会投递到DLQ死信队列。 不过，在使用控制台查询死信消息队列的时候会报错org.apache.rocketmq.client.exception.MQClientException: Can not find Message Queue f...
RocketMQ配置项
客户端的公共配置类：ClientConfig 参数名 默认值 说明 NamesrvAddr NameServer地址列表，多个NameServer地址用分号隔开 clientIP 本机IP 客户端本机IP地址，...
关于RocketMQ
RocketMQ队列的长度 RocketMQ没有内存Buffer概念，RocketMQ的队列都是持久化磁盘，数据定期清除。RocketMQ同其他MQ有非常显著的区别，RocketMQ的内存Buffer抽象成一个无限长度的队列，不管有多少数据进来都能装得下，这个无限是有前提的，Broker会定期删除过期的数据，例如Broker只保存3天的消息，那么这个Buffer虽然长度无限，但是3天前的数据...
CentOS7安装RocketMQ
上传安装包 JDK1.8 (注意一定要使用1.8以上版本，1.7版本不能识别RocketMQ中的metaspace特性，该特性由1.8最新提出) 。 RocketMQ压缩包，下载选择binary版。 解压RocketMQ压缩包 修改配置文件 在conf文件中可以看到以下文件夹，对应rocketmq的不同部署模式：...
删除下载未完整的依赖文件
set REPOSITORY_PATH=E:\repository rem 正在搜索... for /f "delims=" %%i in ('dir /b /s "%REPOSITORY_PATH%\*lastUpdated*"') do ( del /s /q %%i ) rem 搜索完毕 pause 记得路径修改为你自己所在依赖包的位置，然后把.txt文件后缀改为.bat ，双击运...