RabbitMQ com.rabbitmq.client.AlreadyClosedException: соединение уже закрыто из-за ошибки подключения

Question

Я использую rabbitmq в качестве брокера, чтобы отправить запрос и ответ между различными приложениями. Пока я сталкиваюсь с странным поведением с кроликом. Это дает мне это исключение после обработки от 2500 до 3000 записей.

com.rabbitmq.client.AlreadyClosedException: соединение уже закрыто из-за ошибки подключения; Причина: java.net.SocketException: . Сброс соединения: com.rabbitmq.client.impl.AMQChannel.ensureIsOpen (AMQChannel.java:195) ~ [amqp-client-3.5.6.jar: na] at com. rabbitmq.client.impl.AMQChannel.transmit (AMQChannel.java:309) ~ [AMQP-клиент-3.5.6.jar: на]

еще одна вещь, когда я попытался запустить его мой клиент с 2-секундная задержка между сообщениями, эта проблема возникла. Это код, который я пытаюсь опубликовать.

 try { 
      byte[] e = jsonMessage.getBytes(RabbitConf.COMMUNICATION_ENCODING); 
      this.channel.basicPublish(exchangeType.name(), rountingKey.name(), (BasicProperties)null, e); 
     } catch (IOException var6) { 
      this.LOG.error("IOException when sending data to rabbit:", var6); 
     } 

Я использую amqp-client 3.6.0 для своего клиента. Любое предложение будет приветствоваться.

Answer 1

Вы можете попробовать играть со значением qos (хотя неясно, из документации, если это оказывает влияние на публиковать сторону):

this.channel.basicQos(1); 

См: http://www.rabbitmq.com/releases/rabbitmq-java-client/current-javadoc/com/rabbitmq/client/Channel.html#basicQos-int-.