rabbitmq - 如何为RabbitMQ连接设置自定义名称？

Question

能够通过其连接名称识别 RabbitMQ 客户端会很有用。
我正在使用 Spring Cloud Streams 抽象，并使用默认设置我得到类似的东西:

如何在 Spring Boot 客户端中设置自定义 RabbitMQ 连接名称？

编辑
Spring Boot 1.7+
这是基于 Gary Russell 的回答的解决方案:

@Configuration
public class MessagingConfiguration {
    private final String instanceId = UUID.randomUUID().toString().substring(0, 8); // TODO: Environment/Consul/Eureka
    private final String connectionNamePrefix;
    private AtomicInteger connectionNumber = new AtomicInteger(0);

    public MessagingConfiguration(@Value("${custom.rabbitmq.connection-name-prefix:SpringBootApp}") String connectionNamePrefix) {
        this.connectionNamePrefix = connectionNamePrefix;
    }

    private String generateConnectionName() {
        return connectionNamePrefix + '#' + instanceId + ':' +  connectionNumber.getAndIncrement();
    }

    @Bean
    public SmartInitializingSingleton reconfigureConnectionFactory(final AbstractConnectionFactory cf) {
        return () -> cf.setConnectionNameStrategy(f -> generateConnectionName());
    }
}

它适用于 default configuration ，但不适用于 multiple systems connection .
Spring Boot 2.0.1+

@Configuration
public class MessagingConfiguration {
    private final String instanceId = UUID.randomUUID().toString().substring(0, 8); // TODO: Environment/Consul/Eureka
    private final String connectionNamePrefix;
    private AtomicInteger connectionNumber = new AtomicInteger(0);

    public MessagingConfiguration(@Value("${custom.rabbitmq.connection-name-prefix:SpringBootApp}") String connectionNamePrefix) {
        this.connectionNamePrefix = connectionNamePrefix;
    }

    private String generateConnectionName() {
        return connectionNamePrefix + '#' + instanceId + ':' +  connectionNumber.getAndIncrement();
    }

    @Bean
    public ConnectionNameStrategy defineConnectionNameStrategy() {
        return connectionFactory -> generateConnectionName();
    }
}

注意，有一个 bug在多粘合剂场景中。

Answer 1

从 2.0 1.7 版(参见 the documentation )开始，您可以提供 ConnectionNameStrategy ...

@Bean
public CachingConnectionFactory connectionFactory() {
    CachingConnectionFactory cf = new CachingConnectionFactory("localhost");
    cf.setConnectionNameStrategy(f -> "myConnectionName");
    return cf;
}

编辑

可以在打开连接之前的任何时间设置该策略。例如，如果您想使用 Spring Boot 的自动配置工厂(默认情况下由 Spring Cloud Stream 使用)，您可以执行以下操作...

@Bean
public SmartInitializingSingleton reconfigureCf(final CachingConnectionFactory cf) {
    return () -> cf.setConnectionNameStrategy(f -> "myName");
}

这将在任何事情发生之前运行 start()编。

实际上它被反向移植到 1.7.x .