Spring Boot Actuator监控rabbitmq java中的代码

要在Spring Boot Actuator中监控RabbitMQ，您需要在pom.xml中添加以下依赖项：

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-amqp</artifactId>
</dependency>
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-actuator</artifactId>
</dependency>

然后，在您的应用程序中，您可以配置RabbitMQ连接和管理器，如下所示：

@Configuration
public class RabbitConfig {

    @Value("${spring.rabbitmq.host}")
    private String rabbitHost;

    @Value("${spring.rabbitmq.port}")
    private Integer rabbitPort;

    @Value("${spring.rabbitmq.username}")
    private String rabbitUsername;

    @Value("${spring.rabbitmq.password}")
    private String rabbitPassword;

    @Bean
    public ConnectionFactory connectionFactory() {
        CachingConnectionFactory connectionFactory = new CachingConnectionFactory(rabbitHost, rabbitPort);
        connectionFactory.setUsername(rabbitUsername);
        connectionFactory.setPassword(rabbitPassword);
        return connectionFactory;
    }

    @Bean
    public RabbitAdmin rabbitAdmin(ConnectionFactory connectionFactory) {
        return new RabbitAdmin(connectionFactory);
    }

    @Bean
    public RabbitTemplate rabbitTemplate(ConnectionFactory connectionFactory) {
        return new RabbitTemplate(connectionFactory);
    }
}

接下来，您可以在您的应用程序中添加以下端点：

@Component
@Endpoint(id = "rabbit")
public class RabbitMQEndpoint {

    @Autowired
    private RabbitAdmin rabbitAdmin;

    @Autowired
    private RabbitTemplate rabbitTemplate;

    @ReadOperation
    public String getExchanges() {
        List<String> exchangeNames = rabbitAdmin.getExchangeNames();
        return StringUtils.collectionToCommaDelimitedString(exchangeNames);
    }

    @ReadOperation
    public String getQueues() {
        List<String> queueNames = rabbitAdmin.getQueueNames();
        return StringUtils.collectionToCommaDelimitedString(queueNames);
    }

    @ReadOperation
    public String getConnections() {
        List<Connection> connections = rabbitAdmin.getConnections();
        return StringUtils.collectionToCommaDelimitedString(connections);
    }

    @WriteOperation
    public void sendMessage(
            @Selector String exchange,
            @Selector String routingKey,
            @Selector String message) {
        rabbitTemplate.convertAndSend(exchange, routingKey, message);
    }
}

这将添加三个读操作和一个写操作的端点。您可以使用以下URL访问这些端点：

- /actuator/rabbit/exchanges
- /actuator/rabbit/queues
- /actuator/rabbit/connections
- /actuator/rabbit/sendMessage?exchange=&routingKey=&message=

请注意，您需要在application.properties文件中配置RabbitMQ连接属性，例如：

spring.rabbitmq.host=localhost
spring.rabbitmq.port=5672
spring.rabbitmq.username=user
spring.rabbitmq.password=pass