容器化.NET应用连接RabbitMQ遇握手超时及连接重置问题求助

我们有两个分别向RabbitMQ发布和订阅消息的.NET应用，本地通过Visual Studio启动运行完全正常，但构建为容器运行后出现连接失败问题。

RabbitMQ日志错误 #

2022-11-01 09:29:15.998692+00:00 [info] <0.1560.868> accepting AMQP connection <0.1560.868>
2022-11-01 09:31:22.599983+00:00 [error] <0.2112.868> closing AMQP connection <0.2112.868>
2022-11-01 09:31:22.599983+00:00 [error] <0.2112.868> {handshake_timeout,frame_header}

.NET容器错误信息 #

RabbitMQ.Client.Exceptions.BrokerUnreachableException: None of the specified endpoints were reachable
---> RabbitMQ.Client.Exceptions.PossibleAuthenticationFailureException: Possibly caused by authentication failure
---> RabbitMQ.Client.Exceptions.OperationInterruptedException: The AMQP operation was interrupted: AMQP close-reason, initiated by Library, code=541, text='Unexpected Exception', classId=0, methodId=0, cause=System.IO.IOException: Unable to read data from the transport connection: Connection reset by peer.
---> System.Net.Sockets.SocketException (104): Connection reset by peer
at System.Net.Sockets.NetworkStream.Read(Byte[] buffer, Int32 offset, Int32 count)
--- End of inner exception stack trace ---
  at System.Net.Sockets.NetworkStream.Read(Byte[] buffer, Int32 offset, Int32 count)
  at System.IO.BufferedStream.ReadByteSlow()
  at System.IO.BufferedStream.ReadByte()
  at RabbitMQ.Client.Impl.InboundFrame.ReadFrom(Stream reader, Byte[] frameHeaderBuffer, ArrayPool`1 pool, UInt32 maxMessageSize)
  at RabbitMQ.Client.Impl.SocketFrameHandler.ReadFrame()
  at RabbitMQ.Client.Framing.Impl.Connection.MainLoopIteration()
  at RabbitMQ.Client.Framing.Impl.Connection.MainLoop()
  at RabbitMQ.Client.Impl.SimpleBlockingRpcContinuation.GetReply(TimeSpan timeout)
  at RabbitMQ.Client.Impl.ModelBase.ConnectionStartOk(IDictionary`2 clientProperties, String mechanism, Byte[] response, String locale)
  at RabbitMQ.Client.Framing.Impl.Connection.StartAndTune()
  --- End of inner exception stack trace ---
  at RabbitMQ.Client.Framing.Impl.Connection.StartAndTune()
  at RabbitMQ.Client.Framing.Impl.Connection.Open(Boolean insist)
  at RabbitMQ.Client.Framing.Impl.Connection..ctor(IConnectionFactory factory, Boolean insist, IFrameHandler frameHandler, String clientProvidedName)
  at RabbitMQ.Client.Framing.Impl.Connection..ctor(IConnectionFactory factory, Boolean insist, IFrameHandler frameHandler, ArrayPool`1 memoryPool, String clientProvidedName)
  at RabbitMQ.Client.Framing.Impl.AutorecoveringConnection.Init(IFrameHandler fh)
  at RabbitMQ.Client.Framing.Impl.AutorecoveringConnection.Init(IEndpointResolver endpoints)
  at RabbitMQ.Client.ConnectionFactory.CreateConnection(IEndpointResolver endpointResolver, String clientProvidedName)
  --- End of inner exception stack trace ---

相关版本信息：

• RabbitMQ版本：3.10.5
• Erlang版本：24.3.4
• .NET版本：6.0.10
• RabbitMQ Client Library版本：6.2.1

排查与解决步骤 #

1. 验证网络连通性 #

• 确认.NET容器与RabbitMQ容器处于同一Docker网络，或者.NET容器能通过正确的主机名/IP访问RabbitMQ。本地运行用localhost，容器环境需替换为RabbitMQ容器的服务名（如docker-compose配置中的服务名）或宿主机IP（使用host网络模式时）。
• 在.NET容器内执行ping <rabbitmq-host>或telnet <rabbitmq-host> 5672（若无telnet可临时安装），验证5672端口是否可达。

2. 检查认证配置 #

• 确认容器环境中配置的RabbitMQ用户名、密码、虚拟主机（vhost）与本地完全一致，避免拼写错误、大小写不匹配等问题。
• 登录RabbitMQ管理后台（若启用），检查该用户是否拥有对应vhost的读写权限，且用户状态正常。

3. 调整握手与协议参数 #

• RabbitMQ日志中的{handshake_timeout,frame_header}表示AMQP握手超时，可调整.NET客户端的RequestedHeartbeat参数，比如设置为60秒，避免超时断开：

  var factory = new ConnectionFactory();
  factory.RequestedHeartbeat = TimeSpan.FromSeconds(60);
  

• 检查SSL配置一致性：若本地未启用SSL但容器环境启用，或反之，会导致握手失败。确保客户端Ssl.Enabled配置与RabbitMQ的SSL设置匹配。

4. 排查资源限制 #

• 检查容器的CPU、内存配额，是否因资源不足导致RabbitMQ或.NET应用无法处理握手请求，可临时调高资源配额测试。
• 查看RabbitMQ系统日志，排查是否存在Erlang进程内存不足、文件描述符数量不足等警告信息。

内容的提问来源于stack exchange，提问作者Kent Ho