开发者社区 问答 正文

消息中间件MetaQ中的Consumer是指什么?

消息中间件MetaQ中的Consumer是指什么?

展开
收起
三分钟热度的鱼 2024-04-18 14:32:28 113 分享 版权
1 条回答
写回答
取消 提交回答
  • Consumer,即消息的消费者,负责消费消息,consumer与nameserver集群中的随机一个节点建立长连接,定期的从nameServer中获取topic路由信息,并向提供Topic服务的Master、Slave建立长连接,并且定时向Master、Slave发送心跳。Consumer既可以从Master上面订阅消息,也可以从Slave上面订阅消息,订阅规则由Broker配置决定。Consumer每隔30s从Name server获取topic的最新队列情况,这意味着Broker不可用时,Consumer最多最需要30s才能感知。Consumer每隔30s(由ClientConfig中heartbeatBrokerInterval决定)向所有关联的broker发送心跳,Broker每隔10s扫描所有存活的连接,若某个连接2分钟内没有发送心跳数据,则关闭连接;并向该Consumer Group的所有Consumer发出通知,Group内的Consumer重新分配队列,然后继续消费。

    2024-04-18 14:39:22
    赞同 2 展开评论
问答分类:
问答地址: