本文主要是介绍spring AMQP代码生成rabbitmq的exchange and queue教程,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!
《springAMQP代码生成rabbitmq的exchangeandqueue教程》使用SpringAMQP代码直接创建RabbitMQexchange和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);
javascript return QueueBuilder.durable(FANOUT_BUILDER_QUEUE_NAME).androidbuild();
}
@Bean
public Binding fanoutBinding(FanoutExchange fanoutExchange, Queue fanoutQueue) {
// .with 实现 routingKey 的匹配
return BindingBuilder.bind(fanoutQueue).to(fanoutExchange);
}
}直接上代码
public static final String FANOUT_BUILDER_EXCHANGE_NAphpME = "fanoutbuild.exchange"; public static final String FANOUT_BUILDER_QUEUE_NAME = "fanoutbuil编程d.queue";
执行结果


绑定关系成立。
总结
这篇关于spring AMQP代码生成rabbitmq的exchange and queue教程的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!