我在Azure内部负载平衡器平衡的群集负载中有2个rabbitmq.客户端使用BlockingConnection连接到LB.
当客户端交换消息时,一切正常.但是,当没有活动时,似乎我的客户端已断开连接,并且不再能够接收消息.
我想知道是否有解决此问题的方法？我假设负载平衡器或Rabbitmq由于不活动而正在关闭连接.我想让pika触发rabbitmq的心跳(以便负载均衡器保持连接打开),但是找不到任何好的解决方案.你能建议吗？
编辑1
似乎pika BlockingConnections不支持心跳. Heart beat disables blocking connection
谢谢.
解决方法:
根据Pika doc http://pika.readthedocs.org/en/0.10.0/modules/parameters.html,似乎具有URLParameters指定的heart_interval的Pika BlockingConnentions(例如amqps：// www-data：rabbit_pwd @ rabbit1 / web_messages？heartbeat_interval = 30)可以保持连接打开,但是heart_interval的值不能更大比Rabbit服务器建议的值高.
07002
The heartbeat timeout value defines after what period of time the peer TCP connection should be considered dead by RabbitMQ and client libraries. This value is negotiated between the client and RabbitMQ server at the time of connection. The client must be configured to request heartbeats. In RabbitMQ versions 3.0 and higher, the broker will attempt to negotiate heartbeats by default (although the client can still veto them). The timeout is in seconds, and default value is 60 (580 prior to release 3.5.5).
Heartbeat frames are sent about every timeout / 2 seconds. After two missed heartbeats, the peer is considered to be unreachable. Different clients manifest this differently but the TCP connection will be closed. When a client detects that RabbitMQ node is unreachable due to a heartbeat, it needs to re-connect.
Heartbeats can be disabled by setting the timeout interval to 0.
来自Pika doc的示例代码：
import pika
parameters = pika.URLParameters('amqps://www-data:rabbit_pwd@rabbit1/web_messages?heartbeat_interval=30')
connection = pika.BlockingConnection(parameters)
版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 [email protected] 举报，一经查实，本站将立刻删除。