账号密码登录
微信安全登录
微信扫描二维码登录

登录后绑定QQ、微信即可实现信息互通

手机验证码登录
找回密码返回
邮箱找回 手机找回
注册账号返回
其他登录方式
分享
  • 收藏
    X
    rocketmq 生产者组
    42
    0
    目前在开发一个rocketmq的管理后台,但是topic的生产者的connection的时候,需要生产者组,看了源码,topic的生产者连接,主要是靠生产者组拿到的,除了研发自己输入这个生产者组之外,有没有其它办法,可以从集群中获取这个topic和生产者组的关系?已尝试办法:1、在broker上抓心跳包,已经可以拿到所有的生产者组,但是不确定是哪个topic的。2、修改源码,目前不可以。3、在broker上抓发送消息的包,有缺陷,如果一直不发消息,就一直拿不到。
    0
    打赏
    收藏
    点击回答
        全部回答
    • 0
    • KYIK爱你 普通会员 1楼

      在 RocketMQ 生产者组中,多个生产者节点( producers)之间通过 RabbitMQ 的生产者消费者模型进行通信和协作。生产者节点将消息发送给消费者节点,消费者节点会将消息消费掉并存储在本地。

      一个简单的生产者组可以分为以下几个部分:

      1. 主节点:负责接收生产者发送的消息,将消息存储在本地。
      2. 从节点:负责消费主节点存储的消息。
      3. 管理者节点:负责监控生产者和消费者的状态,并管理生产者和消费者的组。

      在 RocketMQ 生产者组中,可以使用不同的角色来实现生产和消费的协同:

      • 主节点:生产者节点。
      • 从节点:消费者节点。
      • 管理者节点:管理员节点,负责监控生产者和消费者的状态,处理消息传输和消费失败的情况。

      在 RocketMQ 生产者组中,生产者和消费者的连接可以通过 RabbitMQ 的选举机制来实现。当生产者和消费者数量相等时,会进行一轮投票,产生一个候选人,生产者和消费者可以通过选举的方式来决定谁是主节点。

      此外, RocketMQ 生产者组还可以通过设置主题来实现消息的分类和路由,从而提高消息的效率和准确性。

    更多回答
    扫一扫访问手机版
    • 回到顶部
    • 回到顶部