可以让 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 (将#修改为@）