一、问题复现 1、描述 两个一样的Consumer Group的Consumer订阅同一个Topic,但是是不同的tag,Consumer1订阅Topic的tag1,Consumer2订阅Topic的tag2,然后分别启动。这时候往Topic的tag1里发送10条数据,Topic的tag2里 ...
问题描述 两个一样的Consumer Group的Consumer订阅同一个Topic,但是是不同的tag,Consumer 订阅Topic的tag ,Consumer 订阅Topic的tag ,然后分别启动。这时候往Topic的tag 里发送 条数据,Topic的tag 里发送 条。目测应该是Consumer 和Consumer 分别收到对应的 条消息。结果却是只有Consumer 收到了消息 ...
2022-01-12 10:41 0 1418 推荐指数:
一、问题复现 1、描述 两个一样的Consumer Group的Consumer订阅同一个Topic,但是是不同的tag,Consumer1订阅Topic的tag1,Consumer2订阅Topic的tag2,然后分别启动。这时候往Topic的tag1里发送10条数据,Topic的tag2里 ...
最近做的项目的一个版本需求中,需要用到MQ,对数据记录进行异步落库,这样可以减轻数据库的压力,同时可以抗住大量的数据落库。这里需要说明一下本人用到的MQ是公司自己在阿里的RokectMQ的基础上进行封装的,然后加上自己的东西,形成个性化的开发,且安全性高。这里就不多透露相关公司的信息啦,我就叫 ...
一、问题答案 是不可以的 而且后注册的会替换前注册的,MqConsumer2会替换MqConsumer,并且只结束tag-2的消息 二、为什么呢? 我们从源码的角度来分析下 1.订阅消息的方法 public void subscribe ...
https://github.com/alibaba/RocketMQ/issues/259 saaavsaaa commented 11 days ago 前天上线发现了一次这个情况,更换组名 ...
生产者:代码如上一章 消费者1:代码如前一章 消费者2:与消费者1代码完全相同 注意:此时,消费者1和2监听在同一个队列上,队列会以轮训的方式将10个消息分别交给消费者1和2进行处理。 但是这种情况下,如果消费者1处理的消息比较繁重,而消费者2处理的消息比较轻松地话,实际上应该让消费 ...
生产者:代码如上一章 消费者1:代码如前一章 消费者2:与消费者1代码完全相同 注意:此时,消费者1和2监听在同一个队列上,队列会以轮训的方式将10个消息分别交给消费者1和2进行处理。 但是这种情况下,如果消费者1处理的消息比较繁重,而消费者2处理的消息比较轻松地话,实际上 ...
,192.168.100.2-100。 那么这些PC的网关都需要设置成192.168.1.1才能上网。 电脑可以和路由不是一个网段,但必须和交 ...
下图例子是设置80和88访问,因为80是默认的访问,所以只要设置88就行 进入站点管理--》应用防火墙--》高级设置 这个设置用到了url和host模块 在站点设置里设置要用到的端口: ...