用于管理RocketMQ3.2.6集群服务,直接将war包放在tomcat的webapps目录,打开http://ip:8080/rocketmq-console 即可访问,第一次访问不成功,需要修改webapps/rocketmq-console/WEB-INF/classes/config.properties 里的nameserver地址.
2023-03-06 14:40:17
20.87MB
1
rocketMQ 官方提供的C++ sdk工程源码质量不高，编译过程中会有许多报错，包含工程文件环境设置遗漏、源码bug更新不及时等问题，给使用者带来不便。似乎官方对C++sdk不太重视，可能和rocketMQ 的关注度低有关。在这里把自己编译好的动态库放上来供使用者直接下载。还有相关依赖库也附上。
版本 github 目前主干最新版本 MASTER。
编译环境 vs2015 x64 Debug。
2023-02-24 15:34:19
7.49MB
1
最新版 rocketmq-all-4.8.0-bin-release.zip最新版 rocketmq-all-4.8.0-bin-release.zip
2023-01-17 12:14:18
13.23MB
1
go_rocket_mq
转到rocketmq客户端#import导入rocketmq“ github.com/didapinchegit/go_rocket_mq”
#example conf：=＆rocketmq.Config {名称服务器：“ 192.168.1.234:9876”，ClientIp：“ 192.168.1.23”，InstanceName：“ DEFAULT”，}消费者，err：= rocketmq.NewDefaultConsumer（“ C_TEST”，conf）如果err！= nil {log.Panic（err）} Consumer.Subscribe（“ test2”，“ ”）Consumer.Subscribe（“ test3”，“ ”）Consumer.RegisterMessageListener（func（msgs [] * rocketmq.
2023-01-12 15:18:51
21KB
1
rocketmq 管控台中心,
部署到web容器修改相关nameserver配置即可
2023-01-08 17:17:57
20.87MB
1
前言
消息队列 RocketMQ 版是基于 Apache RocketMQ 构建的低延迟、高并发、高可用、高可靠的分布式
消息中间件。消息队列 RocketMQ 版既可为分布式应用系统提供异步解耦和削峰填谷的能力，同时也
具备互联网应用所需的海量消息堆积、高吞吐、可靠重试等特性。
存储选型
顺序消息
局部顺序：适用于性能要求高，以Sharding Key作为分区字段，在同一个区块中严格地按照 。
延时消息
RabbitMQ不支持延迟消息，Active和RocketMQ支持延迟消息。
可靠性
RocketMQ支持异步/同步刷盘;异步/同步Replication。Kafka使用异步刷盘方式，异步
2022-12-20 18:20:14
529KB
1
最新的springboot整合rocketmq消息发送和消费的功能，主要测试通过的案例如下：
功能特性：
- [x] 同步发送
- [x] 同步顺序发送
- [ ] 同步批量发送
- [x] 异步发送
- [x] 异步顺序发送
- [x] 顺序消费
- [ ] 并发消费（广播/集群）
- [x] one-way方式发送
- [x] 事务方式发送
- [ ] 消息轨迹
- [ ] ACL
- [ ] pull消费
经过本人的测试可以直接使用
2022-11-26 16:56:17
171KB
1