Spring AMQP客户端挂起

Question

RabbitMQ服务器中存在一种行为，即当达到水印值时，它将不接受后续连接/操作，直到重新平衡自身。RabbitMQ客户机在连接超时后发生这种情况时会优雅地获得超时，但我们使用的是Spring AMQP，它会继续挂起。

复制步骤

o创建RabbitMQ HA群集

o创建一个生成和使用消息的简单程序

• a）使用Spring AMQP
• b）使用RabbitMQ客户端

o使RabbitMQ服务器在内存中达到高水印值，使其无法接受任何新连接或执行任何操作，例如10分钟

o创建Q，从发送消息

• a） SpringAMQP（它将挂起）

Spring二进制文件版本

a） 春兔-1.6.7。释放罐子

b）Spring芯-4.3.6。发布. jar

c） spring-amqp-1.6.7。释放罐子

我们也尝试升级到Spring Rabbit和AMQP 2.0.2版本，但没有帮助。

Answer 1

您没有描述什么是“RabbitMQ客户机”，但是javaamqp客户机默认使用经典套接字。因此，您应该获得与这两个客户端相同的行为（因为SpringAMQP使用该客户端）。也许您指的是其他语言客户端。

对于javaSockets，当连接被阻塞时，线程会卡在不能中断的套接字写入中，也不会超时。

要处理这种情况，必须使用4.0或更高版本的客户机并使用NIO。

下面是演示该技术的示例应用程序。

@SpringBootApplication
public class So48699178Application {

    private static Logger logger = LoggerFactory.getLogger(So48699178Application.class);

    public static void main(String[] args) {
        SpringApplication.run(So48699178Application.class, args);
    }

    @Bean
    public ApplicationRunner runner(RabbitTemplate template, CachingConnectionFactory ccf) {
        ConnectionFactory cf = ccf.getRabbitConnectionFactory();
        NioParams nioParams = new NioParams();
        nioParams.setWriteEnqueuingTimeoutInMs(20_000);
        cf.setNioParams(nioParams);
        cf.useNio();
        return args -> {
            Message message = MessageBuilder.withBody(new byte[100_000])
                    .andProperties(MessagePropertiesBuilder.newInstance()
                            .setDeliveryMode(MessageDeliveryMode.NON_PERSISTENT)
                            .build())
                    .build();
            while (true) {
                try {
                    template.send("foo", message);
                }
                catch (Exception e) {
                    logger.info(e.getMessage());
                }
            }

        };

    }

    @Bean
    public Queue foo() {
        return new Queue("foo");
    }

}

和

2018-02-09 12:00:29.803信息9430---[main]com。实例SO48699178应用程序：java。木卫一。IOException:帧排队失败

2018-02-09 12:00:49.803信息9430---[main]com。实例SO48699178应用程序：java。木卫一。IOException:帧排队失败

2018-02-09 12:01:09.807信息9430---[main]com。实例SO48699178应用程序：java。木卫一。IOException:帧排队失败