整合flume采集日志sink到阿里的RocketMQ代码
2023-01-09 17:00:48 3KB RocketMQ
1
rocketmq 管控台中心, 部署到web容器修改相关nameserver配置即可
2023-01-08 17:17:57 20.87MB rocketmq
1
前言 消息队列 RocketMQ 版是基于 Apache RocketMQ 构建的低延迟、高并发、高可用、高可靠的分布式 消息中间件。消息队列 RocketMQ 版既可为分布式应用系统提供异步解耦和削峰填谷的能力,同时也 具备互联网应用所需的海量消息堆积、高吞吐、可靠重试等特性。 存储选型 顺序消息 局部顺序:适用于性能要求高,以Sharding Key作为分区字段,在同一个区块中严格地按照 。 延时消息 RabbitMQ不支持延迟消息,Active和RocketMQ支持延迟消息。 可靠性 RocketMQ支持异步/同步刷盘;异步/同步Replication。Kafka使用异步刷盘方式,异步
2022-12-20 18:20:14 529KB rocketmq开发规范
1
最新的springboot整合rocketmq消息发送和消费的功能,主要测试通过的案例如下: 功能特性: - [x] 同步发送 - [x] 同步顺序发送 - [ ] 同步批量发送 - [x] 异步发送 - [x] 异步顺序发送 - [x] 顺序消费 - [ ] 并发消费(广播/集群) - [x] one-way方式发送 - [x] 事务方式发送 - [ ] 消息轨迹 - [ ] ACL - [ ] pull消费 经过本人的测试可以直接使用
2022-11-26 16:56:17 171KB springBoot RocketMq
1
个人使用的资源包,包含dockerfile文件,以及各个组件所使用的yaml
2022-11-07 21:02:27 75.86MB RocketMQ
1
RocketMQ是一款阿里巴巴开源的消息中间件
2022-09-24 11:00:53 46.35MB rocketmq
1
rocketmq-exporter jar linux
2022-09-19 09:01:02 30.46MB rocketmq_exporer prometheus
1
RocketMQ-Console是RocketMQ项目的扩展插件,是一个图形化管理控制台,提供Broker集群状态查看,Topic管理,Producer、Consumer状态展示,消息查询等常用功能,这个功能在安装好RocketMQ后需要额外单独安装、运行。 使用方式:上传至linux服务器后,以jar包方式运行 -jar包运行 java -jar rocketmq-console-ng-1.0.1.jar --server.port=9999 --rocketmq.config.namesrvAddr=192.168.207.128:9876;192.168.207.129:9876 (ip替换为RocketMQ集群节点ip)
2022-08-29 15:56:50 31.75MB rocketmq-console
1
rocketMq 的 docker-compose安装包 具体使用查看:https://blog.csdn.net/qq23001186/article/details/126337637
2022-08-15 12:04:45 7KB docker-compose rocketmq
1