如何解决可以让 Kombu“发布者”向 Rabbit 服务器发送心跳吗?
我检查了 kombu 4.6 或 5.0.x 代码,只在 heartbeat_check
中找到了 ConsumerMinxins
https://github.com/celery/kombu/blob/e3471a2fc2e3029d125b13f8ebb9299c70a19cba/kombu/mixins.py#L196
def consume(self,limit=None,timeout=None,safety_interval=1,**kwargs):
elapsed = 0
with self.consumer_context(**kwargs) as (conn,channel,consumers):
for i in limit and range(limit) or count():
if self.should_stop:
break
self.on_iteration()
try:
conn.drain_events(timeout=safety_interval)
except socket.timeout:
conn.heartbeat_check()
elapsed += safety_interval
if timeout and elapsed >= timeout:
raise
except socket.error:
if not self.should_stop:
raise
else:
yield
elapsed = 0
debug('consume exiting')
我们的RabbitMQ是云厂商提供的,强制发布者发送心跳,否则会掉线,生产者出现“broken Pipe”异常。
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。