我正在使用Java RabbitMQ Client . 我发布了一条消息(basicPublish),然后我关闭了 Channels . 在Consumer中,channel.basicAck抛出异常:
com.rabbitmq.client.AlreadyClosedException: connection is already closed due to connection error; cause: java.util.concurrent.RejectedExecutionException: Task com.rabbitmq.client.impl.ConsumerWorkService$WorkPoolRunnable@665de7c7 rejected from java.util.concurrent.ThreadPoolExecutor@35f53993[Running, pool size = 5, active threads = 5, queued tasks = 0, completed tasks = 5]
如果删除channel.close(),则不会再现错误 . 当我关闭 Channels 时,为什么连接关闭?
发送消息进行交换:
Channel channel = connection.createChannel();
Set<String> expectedMessages = new HashSet<>(MESSAGES_COUNT);
for (int i = 0; i < MESSAGES_COUNT; i++) {
String message = Integer.toString(i);
channel.basicPublish(
TEST_EXCHANGE,
ROUTE_KEY,
TEXT_PLAIN,
message.getBytes("UTF-8")
);
expectedMessages.add(message);
}
channel.close();
消费者:
try {
channel.basicAck(deliveryTag, false);
} catch (Exception e) {
log.error("Error during message handling: " + consumerTag, e);
channel.basicNack(deliveryTag, false, true);
}
1 回答
问题出在错误的connectionFactory设置中 . 不正确:
为了正确的工作: