【问题标题】:RabbitMQ best practice for infrequent message publishingRabbitMQ 不频繁发布消息的最佳实践
【发布时间】:2018-11-26 02:37:55
【问题描述】:

我有几个消息生成线程,它们只不经常发布消息(例如消息的短暂爆发,然后休眠 6 小时)。发布后启动新连接并关闭它会更好吗?还是通过心跳保持连接状态更好?

至于消费者线程。处理每条消息不需要很长时间(在心跳间隔内),但大多数时候接收器连接是空闲的,因为没有消息被发布。我注意到,如果连接闲置时间过长,连接会经常断开。这是预期的行为吗?我认为只有当整个消费者线程被长时间运行的消息处理函数阻塞时,连接才会断开,这样整个心跳间隔都无法接收到心跳。

【问题讨论】:

    标签: multithreading rabbitmq pika


    【解决方案1】:

    据我所知,您可以在发送完成后关闭生产者连接,而无需担心任何事情。

    当您与消费者打交道时,您必须小心。 RabbitMQ 使用连接来确定消费者的活跃度。如果连接关闭或断开,rabbit 将认为此消费者已完成或已死亡。

    换句话说,如果你不启用自动确认(自动确认),当你的消息正在处理时,消息状态将为nack,意味着它还没有被确认。如果你现在断开消费者连接,rabbit 会认为这个消费者已经死了,并将消息设置为 status=ready,这样消费者组中的其他消费者就可以接收到这个消息。

    在您的情况下,连接断开可能表明存在一些问题,我建议您打开调试模式以查看来自消费者兔子客户端的详细调试消息。另外,你也可以检查一下rabbit server,那里也可能有一些线索。

    【讨论】:

      猜你喜欢
      • 2016-08-22
      • 2014-01-16
      • 1970-01-01
      • 1970-01-01
      • 2011-01-01
      • 2011-03-07
      • 1970-01-01
      • 2015-02-04
      • 1970-01-01
      相关资源
      最近更新 更多