如何使用Spring监视amqp/rabbitMQ连接？

Question

我们有两个不同的AMQP服务器（RabbitMQ），并为每个服务器配置一个绑定器。

检查每个amqp服务器的连接状态的最佳方法是什么？

一种方法似乎是使用AmqpTemplate和CachingConnectionFactory，其中一个可以配置主机。但有没有更简单的方法？我也尝试过List<HealthIndicator>。但它只包含一个RabbitHealthIndicator应该有两个。

我们的配置：

spring: 
    cloud: 
    stream: 
     binders: 
     binder1: 
      type: rabbit 
      environment: 
      spring: 
       rabbitmq: 
       host: localhost 
       port: 5672 
       password: guest 
       username: guest 
     binder2: 
      type: rabbit 
      environment: 
      spring: 
       rabbitmq: 
       host: localhost 
       port: 56721 
       password: guest 
       username: guest 

Answer 1

所以，你必须声明一个用于RabbitTemplate更RabbitHealthIndicator第二ConnectionFactory。

http://docs.spring.io/spring-boot/docs/current/reference/html/production-ready-endpoints.html#_writing_custom_healthindicators