如何解决_AsyncBaseTransport._consume上的RabbitMq Pika ConnectionResetError
使用pika版本1.1.0 rabbitmq版本3.8.5
注意:心跳值配置为900(由于长时间运行而设置了较高的值,因此我必须保持pika和Rabbitmq之间的连接保持活动状态)
一段时间后发生连接丢失,我必须重新启动应用程序才能再次连接Rabbitmq。有人可以向我指出错误的正确方向!
ERROR:pika.adapters.utils.io_services_utils:_AsyncBaseTransport._consume() Failed,aborting connection: error=ConnectionResetError(10054,'An existing connection was forcibly closed by the remote host',None,10054,None); sock=<socket.socket fd=556,family=AddressFamily.AF_INET,type=SocketKind.soCK_STREAM,proto=6,laddr=('0.0.0.0',65083),raddr=('0.0.0.0',5672)>; Caller's stack:
Traceback (most recent call last):
File "pika\adapters\utils\io_services_utils.py",line 1041,in _on_socket_readable
File "pika\adapters\utils\io_services_utils.py",line 791,in _consume
File "pika\adapters\utils\io_services_utils.py",line 79,in retry_sigint_wrap
File "pika\adapters\utils\io_services_utils.py",line 846,in _sigint_safe_recv
ConnectionResetError: [WinError 10054] An existing connection was forcibly closed by the remote host
Traceback (most recent call last):
File "pika\adapters\utils\io_services_utils.py",in _sigint_safe_recv
ConnectionResetError: [WinError 10054] An existing connection was forcibly closed by the remote host
ERROR:pika.adapters.base_connection:connection_lost: StreamLostError: ("Stream connection lost: ConnectionResetError(10054,None)",)
ERROR:pika.adapters.blocking_connection:Unexpected connection close detected: StreamLostError: ("Stream connection lost: ConnectionResetError(10054,)
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。