spring整合rabbitmq

spring整合rabbitmq的步驟：
在maven的pom文件中添加如下：

創(chuàng)新互聯(lián)服務(wù)項(xiàng)目包括桃山網(wǎng)站建設(shè)、桃山網(wǎng)站制作、桃山網(wǎng)頁制作以及桃山網(wǎng)絡(luò)營(yíng)銷策劃等。多年來，我們專注于互聯(lián)網(wǎng)行業(yè)，利用自身積累的技術(shù)優(yōu)勢(shì)、行業(yè)經(jīng)驗(yàn)、深度合作伙伴關(guān)系等，向廣大中小型企業(yè)、政府機(jī)構(gòu)等提供互聯(lián)網(wǎng)行業(yè)的解決方案，桃山網(wǎng)站推廣取得了明顯的社會(huì)效益與經(jīng)濟(jì)效益。目前，我們服務(wù)的客戶以成都為中心已經(jīng)輻射到桃山省份的部分城市，未來相信會(huì)繼續(xù)擴(kuò)大服務(wù)區(qū)域并繼續(xù)獲得客戶的支持與信任！

com.rabbitmq
amqp-client
3.6.5


org.springframework.boot
spring-boot-starter-amqp
2.1.3

在bean工廠中添加連接工廠和rabbitAdmin實(shí)例

@Bean
public ConnectionFactory connectionFactory(){
        CachingConnectionFactory connectionFactory = new CachingConnectionFactory();
        connectionFactory.setAddresses("192.168.1.177:5672");
        connectionFactory.setUserName("guest");
        connectionFactory.setUserName("guest");
        connectionFactory.setVirtualHost("/");
        return connectionFactory;
}

@Bean
public RabbitAdmin rabbitAdmin(ConnectionFactory connectionFactory){
        RabbitAdmin rabbitAdmin = new RabbitAdmini(connectionFactory);
        rabbitAdmin.setAutoStartup(true);
        return rabbitAdmin;
}

利用rabbitAdmin聲明：

rabbitAdmin.declareBinding(BindingBuilder.bind(new Queue("topic.queue"),false).to(new TopicExchange("topic".false,false)).with("test.#"));

bind：創(chuàng)建隊(duì)列
to ：綁定交換機(jī)
with ：路由key

底層是通過rabbitTemplate調(diào)用execute方法

文章題目：spring整合rabbitmq
網(wǎng)站鏈接：http://m.jiaotiyi.com/article/jgshge.html