- 42
- 0
目前在开发一个rocketmq的管理后台,但是topic的生产者的connection的时候,需要生产者组,看了源码,topic的生产者连接,主要是靠生产者组拿到的,除了研发自己输入这个生产者组之外,有没有其它办法,可以从集群中获取这个topic和生产者组的关系?已尝试办法:1、在broker上抓心跳包,已经可以拿到所有的生产者组,但是不确定是哪个topic的。2、修改源码,目前不可以。3、在broker上抓发送消息的包,有缺陷,如果一直不发消息,就一直拿不到。
0
打赏
收藏
点击回答
- 共 0 条
- 全部回答
-
KYIK爱你 普通会员 1楼
在 RocketMQ 生产者组中,多个生产者节点( producers)之间通过 RabbitMQ 的生产者消费者模型进行通信和协作。生产者节点将消息发送给消费者节点,消费者节点会将消息消费掉并存储在本地。
一个简单的生产者组可以分为以下几个部分:
- 主节点:负责接收生产者发送的消息,将消息存储在本地。
- 从节点:负责消费主节点存储的消息。
- 管理者节点:负责监控生产者和消费者的状态,并管理生产者和消费者的组。
在 RocketMQ 生产者组中,可以使用不同的角色来实现生产和消费的协同:
- 主节点:生产者节点。
- 从节点:消费者节点。
- 管理者节点:管理员节点,负责监控生产者和消费者的状态,处理消息传输和消费失败的情况。
在 RocketMQ 生产者组中,生产者和消费者的连接可以通过 RabbitMQ 的选举机制来实现。当生产者和消费者数量相等时,会进行一轮投票,产生一个候选人,生产者和消费者可以通过选举的方式来决定谁是主节点。
此外, RocketMQ 生产者组还可以通过设置主题来实现消息的分类和路由,从而提高消息的效率和准确性。
更多回答
网站公告
- 扫一扫访问手机版
回答动态

- 神奇的四哥:发布了悬赏问题阿里云幻兽帕鲁服务器更新之后。服务器里面有部分玩家要重新创建角色是怎么回事啊?预计能赚取 0积分收益

- 神奇的四哥:发布了悬赏问题函数计算不同地域的是不能用内网吧?预计能赚取 0积分收益

- 神奇的四哥:发布了悬赏问题ARMS可以创建多个应用嘛?预计能赚取 0积分收益

- 神奇的四哥:发布了悬赏问题在ARMS如何申请加入公测呀?预计能赚取 0积分收益

- 神奇的四哥:发布了悬赏问题前端小程序接入这个arms具体是如何接入监控的,这个init方法在哪里进行添加?预计能赚取 0积分收益

- 神奇的四哥:发布了悬赏问题阿里云幻兽帕鲁服务器刚到期,是不是就不能再导出存档了呢?预计能赚取 0积分收益

- 神奇的四哥:发布了悬赏问题阿里云幻兽帕鲁服务器的游戏版本不兼容 尝试更新怎么解决?预计能赚取 0积分收益

- 神奇的四哥:发布了悬赏问题阿里云幻兽帕鲁服务器服务器升级以后 就链接不上了,怎么办?预计能赚取 0积分收益

- 神奇的四哥:发布了悬赏问题阿里云幻兽帕鲁服务器转移以后服务器进不去了,怎么解决?预计能赚取 0积分收益

- 神奇的四哥:发布了悬赏问题阿里云幻兽帕鲁服务器修改参数后游戏进入不了,是什么情况?预计能赚取 0积分收益
- 回到顶部
- 回到顶部

