RocketMq支持任意延迟的延时消息方案
主要特性
支持任意延迟的延时消息，精确到秒，最长延迟时间为1年。
使用方法
配置broker.conf
segmentScale=60 ##每个时间桶的时间范围，单位分钟，默认60，可选值0-60之间，延迟消息并发数越高，配置的值应该越小，如：10
dispatchLogKeepTime=72 ##dispatchLog过期后保存的小时数，默认72
producer
DefaultMQProducer producer = new DefaultMQProducer("please_rename_unique_group_name");
producer.setNamesrvAddr("127.0.0.1:9876");
producer.start();
for (int i = 0; i <
2021-09-05 17:03:51
3.19MB
1
最新版windows rocketmq-all-4.9.1-bin-release.zip最新版windows rocketmq-all-4.9.1-bin-release.zip
2021-09-02 09:09:22
19.06MB
1
rocketmq-console-ng-2.0.0.jar 2020最新的版本，从git上直接拉下来编译的，用压缩文件软件打开直接修改配置文件里面rocketmq的ip就可以用了，不用再去编译一次了，方便一些
2021-09-01 17:21:09
37.5MB
1
个人学习springboot搭建的系统，简单入门应该是可以了，有需要的可以看一看
2021-08-31 16:35:55
62KB
1
rocketmq监控平台,已打包成 tar.gz，已测试，解压可用，记得conf里改nameserver地址
默认端口号为8081(可自行修改). 用于监控RocketMQ消息. 启动方式:。./start.sh
2021-08-28 10:43:33
25.56MB
1
资源中包含RocketMQ的demo，rocketMQ启动压缩包 以及 用于显示控制台的war包，显示控制台需要先启动rocketMQ，然后将war包放到tomcat中，并且修改config.properties文件中的IP地址。
2021-08-26 15:23:40
33.6MB
1
RocketMQ:
支持集群，效率高，同时支持上万队列，支持消息持久化，重试机制等等;
RocketMQ包含的组件
NameServer：单点，供Producer和Consumer获取Broker地址
Producer：产生并发送消息
Consumer：接受并消费消息
Broker：消息暂存，消息转发
RocketMQ优点
强调集群无单点，可扩展
任意一点高可用，水平可扩展
海量消息堆积能力，消息堆积后，写入低延迟。
支持上万个队列
消息失败重试机制
消息可查询
开源社区活跃
成熟度
安装JDK
检查当前虚拟机环境有没有JDK rpm -qa|grep java
卸载 rpm -e
2021-08-26 15:21:58
54KB
1