如何在Spring boot AMQP中获取通道对象并创建类型为“x-consistent-hash”的交换

Question

提到的在RabbitMQ中创建一致散列交换的示例一致散列交换Github使用通道来创建交换：

private static String CONSISTENT_HASH_EXCHANGE_TYPE = "x-consistent-hash";
...
Channel ch = conn.createChannel();
...
ch.exchangeDeclare("e1", CONSISTENT_HASH_EXCHANGE_TYPE, true, false, null);

@Configuration
@EnableAutoConfiguration
public class AMQPConfig {

    public static final String QUEUENAME = "consistentHashing-Q1";
    public static final String EXCHANGENAME = "consistentHashing-DE1";
    public static final String RK = "consistentHashing-RK1";


    @Bean
    public Queue queue() {
        return QueueBuilder.nonDurable(QUEUENAME).autoDelete().build();
    }

    @Bean
    public DirectExchange directExchange()  {
        return ExchangeBuilder.directExchange(EXCHANGENAME).autoDelete().withArgument("Type", "x-consistent-hash").build();
    }

    @Bean
    public Binding binding(Queue queue, Exchange exchange)    {
        return BindingBuilder.bind(queue).to(exchange).with(RK).noargs();
    }
}

1. 想知道如何在Spring boot中获取通道对象

Answer 1

能够使用以下代码在Spring BootAMQP中创建一致性哈希交换：

@Bean
public CustomExchange customExchange()  {
    CustomExchange customExchange = new CustomExchange(EXCHANGENAME, "x-consistent-hash", false, true);
    customExchange.addArgument("hash-header", "client-id");
    return customExchange;
}

Answer 2

Spring AMQP没有将自定义交换声明为@Bean定义的机制，但是您可以使用RabbitTemboard来获得一个通道来自己声明它。

Exchange.DeclareOk = rabbitTemplate.execute(channel -> channel.exchangeDeclare(...));