在本章學(xué)習(xí)中，我們主要是和應(yīng)用整合的。下面來看看本章我們主要內(nèi)容：

公司主營業(yè)務(wù)：網(wǎng)站制作、成都網(wǎng)站建設(shè)、移動網(wǎng)站開發(fā)等業(yè)務(wù)。幫助企業(yè)客戶真正實(shí)現(xiàn)互聯(lián)網(wǎng)宣傳，提高企業(yè)的競爭能力。創(chuàng)新互聯(lián)建站是一支青春激揚(yáng)、勤奮敬業(yè)、活力青春激揚(yáng)、勤奮敬業(yè)、活力澎湃、和諧高效的團(tuán)隊(duì)。公司秉承以“開放、自由、嚴(yán)謹(jǐn)、自律”為核心的企業(yè)文化，感謝他們對我們的高要求，感謝他們從不同領(lǐng)域給我們帶來的挑戰(zhàn)，讓我們激情的團(tuán)隊(duì)有機(jī)會用頭腦與智慧不斷的給客戶帶來驚喜。創(chuàng)新互聯(lián)建站推出肥西免費(fèi)做網(wǎng)站回饋大家。

整合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版本的時(shí)候，rabbit的版本號可以使用3.6.5以上

如果spring boot的版本是2.1.x的時(shí)候，rabbit的版本號可以使用5.7.x

創(chuàng)建rabbitMQConfig:

1:先獲取到ConnectionFactory.

注意：是amqp.rabbit下的。如下圖：

創(chuàng)建ConnectionFactory:

2:獲取rabbitAdmin的代碼：

注意：setAutoStartUp必須設(shè)置為true

進(jìn)行測試：

因?yàn)樵赗abbitMQConfig中我們已經(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>

需要注意的：當(dāng)時(shí)fanout的時(shí)候，在bingdingBuilder的時(shí)候沒有with.因?yàn)閒anout的不需要routingkey。

本節(jié)總結(jié)：

????使用spring的@Bean注解怎么創(chuàng)建connection工廠及怎么創(chuàng)建rabbitAdmin以及怎么使用。

下節(jié)預(yù)告：

????我們知道在rabbitMQ的基礎(chǔ)API中得到隊(duì)列、binding以及路由是通過channel對象獲取的，如下圖。那么在springAMQP模式下怎么聲明呢?在下節(jié)課中，我們將要講解到的。

本文出自凱哥Java(kaigejava) 個(gè)人博客(www.kaigejava.com)