如何使用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