在本章學(xué)習(xí)中，我們主要是和應(yīng)用整合的。下面來看看本章我們主要內(nèi)容：
整合spring AMQP和spring boot及spring cloud整合。以及在整合中需要注意及工作中踩過的坑。如同如下圖：
本文主要內(nèi)容：
使用代碼創(chuàng)建rabbitAdmin，通過rabbitAdmin操作MQ
本文是《RabbitMQ精講系列》教程中的第十八篇 高級應(yīng)用整合的第一篇。如果對RabbitMQ感興趣的朋友，可以從第一章開始。
RabbitMQ整合Spring AMQP實(shí)戰(zhàn)
在Spring AMQP整合中，重要的組件：
RabbitAdmin類可以和好的操作RabbitMQ,在spring中直接進(jìn)行注入即可：
注意：
autoStartup必須設(shè)置為ture,否則spring容器不會加載類.
為什么要獲取RabbitAdmin？
RabitAdmin底層實(shí)現(xiàn)就是從spring容器中獲取Exchange、Bingding、Routingkey以及Queue的@Bean聲明。
使用RabbitTemplate的execute方法執(zhí)行對應(yīng)的聲明、修改、刪除等一系列的RabbitMQ基礎(chǔ)功能操作。
代碼演示：
添加pom文件：
需要注意：
如果spring boot 是1.5.6版本的時候，rabbit的版本號可以使用3.6.5以上
如果spring boot的版本是2.1.x的時候，rabbit的版本號可以使用5.7.x
創(chuàng)建rabbitMQConfig:
1:先獲取到ConnectionFactory.
注意：是amqp.rabbit下的。如下圖：
創(chuàng)建ConnectionFactory:
2:獲取rabbitAdmin的代碼：
注意：setAutoStartUp必須設(shè)置為true
進(jìn)行測試：
因為在RabbitMQConfig中我們已經(jīng)將rabbitAdmin由spring容器管理了。所以在這里，我們直接使用autowired就可以。如下圖：
我們先在頁面管控臺查看：
并沒有。啟動后，在查看，是否已經(jīng)創(chuàng)建。
測試類啟動成功：
在頁面管控臺查看，exchange交換機(jī)是否已經(jīng)創(chuàng)建：
已經(jīng)創(chuàng)建成功。說明，rabbitAdmin我們成功了。
通過rabbitAdmin創(chuàng)建Queue:
創(chuàng)建綁定關(guān)系：
啟動后，查看test_spring_direct_queue是否綁定了test_spring_direct交換機(jī)。
我們發(fā)現(xiàn)綁定成功了。
綁定方式二：使用BindingBuilder的鏈?zhǔn)?/p>
rabbitAdmin.declareBinding( |
需要注意的：當(dāng)時fanout的時候，在bingdingBuilder的時候沒有with.因為fanout的不需要routingkey。
本節(jié)總結(jié)：
使用spring的@Bean注解怎么創(chuàng)建connection工廠及怎么創(chuàng)建rabbitAdmin以及怎么使用。
下節(jié)預(yù)告：
我們知道在rabbitMQ的基礎(chǔ)API中得到隊列、binding以及路由是通過channel對象獲取的，如下圖。那么在springAMQP模式下怎么聲明呢?在下節(jié)課中，我們將要講解到的。
本文出自凱哥Java(kaigejava) 個人博客(www.kaigejava.com)
創(chuàng)新互聯(lián)www.cdcxhl.cn，專業(yè)提供香港、美國云服務(wù)器，動態(tài)BGP最優(yōu)骨干路由自動選擇，持續(xù)穩(wěn)定高效的網(wǎng)絡(luò)助力業(yè)務(wù)部署。公司持有工信部辦法的idc、isp許可證， 機(jī)房獨(dú)有T級流量清洗系統(tǒng)配攻擊溯源，準(zhǔn)確進(jìn)行流量調(diào)度，確保服務(wù)器高可用性。佳節(jié)活動現(xiàn)已開啟，新人活動云服務(wù)器買多久送多久。
重慶分公司
重慶分公司
