當前位置:
首頁 >
前端技术
> javascript
>内容正文
javascript
Spring @Configuration – RabbitMQ连接
生活随笔
收集整理的這篇文章主要介紹了
Spring @Configuration – RabbitMQ连接
小編覺得挺不錯的,現在分享給大家,幫大家做個參考.
我一直在轉換必須使用Spring @Configuration機制配置到RabbitMQ的連接的應用程序-最初,我使用xml bean定義文件來描述配置。
這是我的原始配置:
這是一個相當簡單的配置:
- 建立與RabbitMQ服務器的連接,
- 創建一個持久隊列(如果不可用)
- 創造持久的交流
- 并配置一個綁定,以基于稱為“ rube.key”的路由鍵將消息發送到交換機以路由到隊列
可以將其轉換為以下基于@Configuration的java配置:
@Configuration public class RabbitConfig {@Autowiredprivate ConnectionFactory rabbitConnectionFactory;@BeanDirectExchange rubeExchange() {return new DirectExchange("rmq.rube.exchange", true, false);}@Beanpublic Queue rubeQueue() {return new Queue("rmq.rube.queue", true);}@BeanBinding rubeExchangeBinding(DirectExchange rubeExchange, Queue rubeQueue) {return BindingBuilder.bind(rubeQueue).to(rubeExchange).with("rube.key");}@Beanpublic RabbitTemplate rubeExchangeTemplate() {RabbitTemplate r = new RabbitTemplate(rabbitConnectionFactory);r.setExchange("rmq.rube.exchange");r.setRoutingKey("rube.key");r.setConnectionFactory(rabbitConnectionFactory);return r;} }該配置看起來比配置的xml版本要簡單得多。 不過我在這里有點作弊,您應該會看到缺少的connectionFactory,它只是被注入到此配置中,它是從哪里來的。這實際上是基于Spring Boot的應用程序的一部分,并且有一個Spring Boot Auto配置用于RabbitMQ connectionFactory基于在類路徑中是否存在RabbitMQ相關庫。
如果您有興趣進一步探索,這里是完整的配置– https://github.com/bijukunjummen/rg-si-rabbit/blob/master/src/main/java/rube/config/RabbitConfig.java
參考文獻:
- Spring-AMQP項目在這里
- 這里使用RabbitMQ的Spring-Boot入門項目
翻譯自: https://www.javacodegeeks.com/2014/10/spring-configuration-rabbitmq-connectivity.html
總結
以上是生活随笔為你收集整理的Spring @Configuration – RabbitMQ连接的全部內容,希望文章能夠幫你解決所遇到的問題。
- 上一篇: b365水果酵素是真是假(b365水果酵
- 下一篇: 安卓平板炉石传说(安卓平板炉石)