2021-01-12 12:12

Client unexpectedly closed TCP connection

Java Error Log :

Exception in thread "main" java.util.concurrent.TimeoutException at com.rabbitmq.utility.BlockingCell.get(BlockingCell.java:76) at com.rabbitmq.utility.BlockingCell.uninterruptibleGet(BlockingCell.java:110) at com.rabbitmq.utility.BlockingValueOrException.uninterruptibleGetValue(BlockingValueOrException.java:36) at com.rabbitmq.client.impl.AMQChannel$BlockingRpcContinuation.getReply(AMQChannel.java:366) at com.rabbitmq.client.impl.AMQConnection.start(AMQConnection.java:292) at com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:824) at com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:778) at com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:868) at com.cts.peg.iot.MQTT_HelloWorld.Send.main(Send.java:21)

RabbitMQ Server Logs :

=INFO REPORT==== 22-Sep-2016::16:15:24 === Starting RabbitMQ 3.6.5 on Erlang R16B03-1 Copyright (C) 2007-2016 Pivotal Software, Inc. Licensed under the MPL. See http://www.rabbitmq.com/

=INFO REPORT==== 22-Sep-2016::16:15:24 === node : rabbit home dir : /var/lib/rabbitmq config file(s) : /etc/rabbitmq/rabbitmq.config (not found) cookie hash : KF/nlWAlT8axIkjGGrzg3A== log : /var/log/rabbitmq/rabbit.log sasl log : /var/log/rabbitmq/rabbit-sasl.log database dir : /var/lib/rabbitmq/mnesia/rabbit

=INFO REPORT==== 22-Sep-2016::16:15:25 === Memory limit set to 3154MB of 7885MB total.

=INFO REPORT==== 22-Sep-2016::16:15:25 === Disk free limit set to 50MB

=INFO REPORT==== 22-Sep-2016::16:15:25 === Limiting to approx 924 file handles (829 sockets)

=INFO REPORT==== 22-Sep-2016::16:15:25 === FHC read buffering: OFF FHC write buffering: ON

=INFO REPORT==== 22-Sep-2016::16:15:25 === Database directory at /var/lib/rabbitmq/mnesia/rabbit is empty. Initialising from scratch...

=INFO REPORT==== 22-Sep-2016::16:15:25 === Priority queues enabled, real BQ is rabbit_variable_queue

=INFO REPORT==== 22-Sep-2016::16:15:33 === Adding vhost '/'

=INFO REPORT==== 22-Sep-2016::16:15:34 === Creating user 'guest'

=INFO REPORT==== 22-Sep-2016::16:15:34 === Setting user tags for user 'guest' to [administrator]

=INFO REPORT==== 22-Sep-2016::16:15:34 === Setting permissions for 'guest' in '/' to '.', '.', '.*'

=INFO REPORT==== 22-Sep-2016::16:15:34 === msg_store_transient: using rabbit_msg_store_ets_index to provide index

=INFO REPORT==== 22-Sep-2016::16:15:34 === msg_store_persistent: using rabbit_msg_store_ets_index to provide index

=WARNING REPORT==== 22-Sep-2016::16:15:34 === msg_store_persistent: rebuilding indices from scratch

=INFO REPORT==== 22-Sep-2016::16:15:50 === started TCP Listener on [::]:5672

=INFO REPORT==== 22-Sep-2016::16:15:58 === Server startup complete; 0 plugins started.

=INFO REPORT==== 22-Sep-2016::17:13:18 === accepting AMQP connection <0.733.0> ( ->

=WARNING REPORT==== 22-Sep-2016::17:13:24 === closing AMQP connection <0.733.0> ( -> client unexpectedly closed TCP connection

RabbitMQ SASL-Server Logs :

empty file


  • 点赞
  • 写回答
  • 关注问题
  • 收藏
  • 复制链接分享
  • 邀请回答


  • weixin_39752087 weixin_39752087 4月前

    Please post questions to rabbitmq-users or Stack Overflow. RabbitMQ uses GitHub issues for specific actionable items engineers can work on, not questions. Thank you.

    点赞 评论 复制链接分享
  • weixin_39752087 weixin_39752087 4月前

    The source code of MQTT_HelloWorld would be welcome. And if you're testing anything against MQTT (as the name of the class suggests it), don't forget to activate the corresponding plugin.

    点赞 评论 复制链接分享
  • weixin_39552317 weixin_39552317 4月前

    The message says it all: a client closed TCP connection without correctly closing MQTT connection first. With Hello, world style programs this usually means the program terminated naturally.

    点赞 评论 复制链接分享
  • weixin_39999781 weixin_39999781 4月前

    Got it solved... It was a Firewall Issue on my Domain Network. Hosted the Code in the server itself and pointed to localhost and it started working.

    点赞 评论 复制链接分享