RocketMQ（三）：hello world
先启动namesrv 和broker 和 console
然后创建maven项目
这就是demo了，注意pom文件里需要引入依赖
<dependency>
<groupId>org.apache.rocketmq</groupId>
<artifactId>rocketmq-client</artifactId>
<version>4.6.1</version>
</dependency>
还可以发送的时候打包成list 批量去 send
但批量的时候有个条件，消息要具有相同的topic 以及配置，一批消息的大小不要超过1MB。
官网的示例：
异步消息不用shutdown了，因为是异步，还不知道什么时候回调onsuccess和onException呢，shutdown了之后，就没法连接了。
集群消费模式，可以失败重投，广播则不可以，原因很简单了，集群只能一个Consumer消费，那么这个Consumer挂了，肯定还需要其他Consumer去消费，肯定是需要重新投递给Consumer消息的；
消息有没有被消费是由broker说了算
广播是所有Consumer都能去消费，一个Consumer挂了，那还有其他Consumer，所以失败了不需要重投给Consumer
集群消息是指集群化部署消费者
当使用集群消费模式时，MQ 认为任意一条消息只需要被集群内的任意一个消费者处理即可。
特点
- 每条消息只需要被处理一次，broker只会把消息发送给消费集群中的一个消费者
- 在消息重投时，不能保证路由到同一台机器上
- 消费状态由broker维护
当使用广播消费模式时，MQ 会将每条消息推送给集群内所有注册过的客户端，保证消息至少被每台机器消费一次。
特点
- 消费进度由consumer维护
- 保证每个消费者消费一次消息
- 消费失败的消息不会重投
消息过滤，注意:在同一个ConsumerGroup里，tag和selector要保持统一
不能一个ConsumerGroup里，既关注tag-A又关注tag-B
sql过滤，producer端
consumer端
然后在broker的服务器配置一下
结果：
网站声明：如果转载，请联系本站管理员。否则一切后果自行承担。
赞同 0
评论 0 条
- 上周热门
- Kingbase用户权限管理 2020
- 信刻全自动光盘摆渡系统 1749
- 信刻国产化智能光盘柜管理系统 1419
- 银河麒麟添加网络打印机时，出现“client-error-not-possible”错误提示 1013
- 银河麒麟打印带有图像的文档时出错 923
- 银河麒麟添加打印机时，出现“server-error-internal-error” 714
- 麒麟系统也能完整体验微信啦！ 657
- 统信桌面专业版【如何查询系统安装时间】 632
- 统信操作系统各版本介绍 623
- 统信桌面专业版【全盘安装UOS系统】介绍 597
- 本周热议
- 我的信创开放社区兼职赚钱历程 40
- 今天你签到了吗？ 27
- 信创开放社区邀请他人注册的具体步骤如下 15
- 如何玩转信创开放社区—从小白进阶到专家 15
- 方德桌面操作系统 14
- 我有15积分有什么用? 13
- 用抖音玩法闯信创开放社区——用平台宣传企业产品服务 13
- 如何让你先人一步获得悬赏问题信息？（创作者必看） 12
- 2024中国信创产业发展大会暨中国信息科技创新与应用博览会 9
- 中央国家机关政府采购中心：应当将CPU、操作系统符合安全可靠测评要求纳入采购需求 8
热门标签更多
