常用的有两种方式
- bean创建
- amqp admin创建
两种方式并没有太大的区别，主要是使用习惯以及方式上
🌰举个简单例子：最简单的，对于方式一我们拥有Binding的bean，我们可以在发送消息的时候将其注入方便准确的获取到exchange和routing key
对于方式二，当然也可以用常量的形式来代替上述做法
下面看看两种方式如何写
bean方式
@Bean
public Queue testQueue() {
return new Queue("aaa.test.queue");
}
@Bean
public DirectExchange testExchange() {
return new DirectExchange("aaa.test.exchange");
}
@Bean
public Binding testBinding(DirectExchange testExchange, Queue testQueue) {
return BindingBuilder.bind(testQueue).to(testExchange).with("aaa.test.routingKey");
}
AmqpAdmin方式
@RequiredArgsConstructor(onConstructor_ = @Lazy)
@Component
public class TComponent implements CommandLineRunner {
private final AmqpAdmin amqpAdmin;
@Override
public void run(String... args) throws Exception {
DirectExchange exchange = new DirectExchange("aaa.test.Exchange");
Queue queue = new Queue("aaa.test.queue");
Binding binding = BindingBuilder.bind(queue).to(exchange).with("aaa.test.RoutingKey");
amqpAdmin.declareExchange(exchange);
amqpAdmin.declareQueue(queue);
amqpAdmin.declareBinding(binding);
}
}
启动效果
我们打开rabbitmq management查看
exchange
queue
binding
可以看到exchange、queue、routing key都按照我们的预期创建完毕了
版权声明：本文内容由互联网用户自发贡献，该文观点仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 举报，一经查实，本站将立刻删除。
文章由极客之音整理，本文链接：https://www.bmabk.com/index.php/post/195209.html
