spring AMQP代码生成rabbitmq的exchange and queue教程
作者：RR1335
使用Spring AMQP代码直接创建RabbitMQ exchange和queue,并确保绑定关系自动成立,简化消息队列配置,此经验分享供参考,欢迎支持脚本之家
spring AMQP代码生成rabbitmq的exchange and queue
@Configuration
public class FanoutConfigure {
@Bean
public FanoutExchange fanoutExchange() {
return ExchangeBuilder.fanoutExchange(FANOUT_BUILDER_EXCHANGE_NAME).build();
// return new FanoutExchange(FANOUT_BUILDER_EXCHANGE_NAME);
}
@Bean
public Queue fanoutQueue() {
// return new Queue(FANOUT_BUILDER_QUEUE_NAME, true);
return QueueBuilder.durable(FANOUT_BUILDER_QUEUE_NAME).build();
}
@Bean
public Binding fanoutBinding(FanoutExchange fanoutExchange, Queue fanoutQueue) {
// .with 实现 routingKey 的匹配
return BindingBuilder.bind(fanoutQueue).to(fanoutExchange);
}
}直接上代码
public static final String FANOUT_BUILDER_EXCHANGE_NAME = "fanoutbuild.exchange";
public static final String FANOUT_BUILDER_QUEUE_NAME = "fanoutbuild.queue";执行结果
绑定关系成立。
总结
以上为个人经验，希望能给大家一个参考，也希望大家多多支持脚本之家。