当代理连接丢失时，RabbitMQ 抛出 AlreadyClosedException 而不是 IOException

Question

我正在使用rabbitmq java客户端2.4.1最新版本。

TCP 连接丢失后，仍然调用通道上的方法 这个连接，将会抛出AlreadyClosedException。

这是一个错误吗？我预计会出现 IOException，但 AlreadyClosedException 我 得到了，AlreadyClosedException 是一个 RuntimeException。

如果不是，为什么所有其他错误都会导致 IOException。

 @Test
 public void testConnectionLost() throws IOException{
           ConnectionFactory factory = new ConnectionFactory();
           factory.setRequestedHeartbeat(60);
           factory.setHost("<your rabbitmq host>");


           Connection connection = factory.newConnection();
           Channel channel = connection.createChannel();
           connection.close();

           try {
                   channel.queueDeclare("queueName", false, false, false, null);
                   Assert.fail("Exception expected.");
           }catch (IOException e) {
                   //it will NOT reach here.
                   //Inner exception should be AlreadyClosedException
                   System.out.println(e);
           }catch (AlreadyClosedException e) {
                   // it will reach here.
                   System.out.println(e);

                   //this is strange!
                   //I expected IOException , but AlreadyClosedException I got.
                   //And AlreadyClosedException is a RuntimeException.
           }

谢谢。

Answer 1

如果您的客户端丢失与代理的 TCP 连接，则该连接被视为“关闭”。因此，客户端库抛出 AlreadyClosedException 是适当的（而不是错误）。

换句话说，无论连接如何关闭（通过正常方式或通过意外失败），连接都被视为“关闭”。