java - RabbitMQ com.rabbitmq.client.AlreadyClosedException : connection is already closed due to connection error

Question

我正在使用 rabbitmq 作为代理，在我的不同应用程序之间分派(dispatch)请求和响应。当我面对 rabbitmq 的奇怪行为时。它在处理 2500 到 3000 条记录后给了我这个异常。

com.rabbitmq.client.AlreadyClosedException: connection is already closed due to connection error; cause: java.net.SocketException: Connection reset at 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-client-3.5.6.jar:na]

当我尝试在消息之间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- .