So much 【Connection reset by peer】

[lowmanisbusy]

[2021-11-26 15:11:48,548][kombu.mixins][9] WARNING: Connection to broker lost, trying to re-establish connection... (mixins.py[run]:177)�[0m
Traceback (most recent call last):
File "/usr/local/lib/python3.8/dist-packages/kombu/mixins.py", line 172, in run
for _ in self.consume(limit=None, **kwargs):
File "/usr/local/lib/python3.8/dist-packages/kombu/mixins.py", line 194, in consume
conn.drain_events(timeout=safety_interval)
File "/usr/local/lib/python3.8/dist-packages/kombu/connection.py", line 318, in drain_events
return self.transport.drain_events(self.connection, **kwargs)
File "/usr/local/lib/python3.8/dist-packages/kombu/transport/pyamqp.py", line 135, in drain_events
return connection.drain_events(**kwargs)
File "/usr/local/lib/python3.8/dist-packages/amqp/connection.py", line 523, in drain_events
while not self.blocking_read(timeout):
File "/usr/local/lib/python3.8/dist-packages/amqp/connection.py", line 528, in blocking_read
frame = self.transport.read_frame()
File "/usr/local/lib/python3.8/dist-packages/amqp/transport.py", line 299, in read_frame
frame_header = read(7, True)
File "/usr/local/lib/python3.8/dist-packages/amqp/transport.py", line 628, in _read
s = recv(n - len(rbuf))
File "/usr/local/lib/python3.8/dist-packages/gevent/_socket3.py", line 450, in recv
return self._sock.recv(*args)
ConnectionResetError: [Errno 104] Connection reset by peer

As shown above，kombu raise so much error like that，what should I do?

[open-collective-bot[bot]]

Hey @lowmanisbusy 👋,
Thank you for opening an issue. We will get back to you as soon as we can.
Also, check out our Open Collective and consider backing us - every little helps!

We also offer priority support for our sponsors.
If you require immediate assistance please consider sponsoring us.

[auvipy]

provide more detail please

[lowmanisbusy]

my consumer use heartbeat，and my rabbitmq broker's File descriptors and Socket descriptors is enough，but my consumer would be raise "ConnectionResetError: [Errno 104] Connection reset by peer" so often. I can't understand，if I use heartbeat, why my consumer's connection reset by peer?

[lowmanisbusy]

I use kombu "ConsumerMixin" to make my consumer

[lowmanisbusy]

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 OSError:
                if not self.should_stop:
                    raise
            else:
                yield
                elapsed = 0
    debug('consume exiting')

if sokcert.timeout not raise，how heartbeat_check work？I just confused.