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

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

整合spring AMQP和spring boot及spring cloud整合。以及在整合中需要注意及工作中踩過的坑。如同如下圖：

本文主要內(nèi)容：

使用代碼創(chuàng)建rabbitAdmin，通過rabbitAdmin操作MQ

本文是《RabbitMQ精講系列》教程中的第十八篇 高級(jí)應(yīng)用整合的第一篇。如果對(duì)RabbitMQ感興趣的朋友，可以從第一章開始。

RabbitMQ整合Spring AMQP實(shí)戰(zhàn)

在Spring AMQP整合中，重要的組件：

RabbitAdmin類可以和好的操作RabbitMQ,在spring中直接進(jìn)行注入即可：

注意：

autoStartup必須設(shè)置為ture,否則spring容器不會(huì)加載類.

為什么要獲取RabbitAdmin？

????RabitAdmin底層實(shí)現(xiàn)就是從spring容器中獲取Exchange、Bingding、Routingkey以及Queue的@Bean聲明。

使用RabbitTemplate的execute方法執(zhí)行對(duì)應(yīng)的聲明、修改、刪除等一系列的RabbitMQ基礎(chǔ)功能操作。

代碼演示：

添加pom文件：

<!-- rabbitmq--> <dependency> ??<groupId>com.rabbitmq</groupId> ??<artifactId>amqp-client</artifactId> ??<version>3.6.5</version> </dependency> <!-- spring?啟動(dòng)--> <dependency> ??<groupId>org.springframework.boot</groupId> ??<artifactId>spring-boot-starter-amqp</artifactId> </dependency>

需要注意：

如果spring boot 是1.5.6版本的時(shí)候，rabbit的版本號(hào)可以使用3.6.5以上

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

創(chuàng)建rabbitMQConfig:

1:先獲取到ConnectionFactory.

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

創(chuàng)建ConnectionFactory:

2:獲取rabbitAdmin的代碼：

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

進(jìn)行測(cè)試：

因?yàn)樵赗abbitMQConfig中我們已經(jīng)將rabbitAdmin由spring容器管理了。所以在這里，我們直接使用autowired就可以。如下圖：

我們先在頁(yè)面管控臺(tái)查看：

并沒有。啟動(dòng)后，在查看，是否已經(jīng)創(chuàng)建。

測(cè)試類啟動(dòng)成功：

在頁(yè)面管控臺(tái)查看，exchange交換機(jī)是否已經(jīng)創(chuàng)建：

已經(jīng)創(chuàng)建成功。說明，rabbitAdmin我們成功了。

通過rabbitAdmin創(chuàng)建Queue:

創(chuàng)建綁定關(guān)系：

啟動(dòng)后，查看test_spring_direct_queue是否綁定了test_spring_direct交換機(jī)。

我們發(fā)現(xiàn)綁定成功了。

綁定方式二：使用BindingBuilder的鏈?zhǔn)?/p>

rabbitAdmin.declareBinding( ? ? ?BindingBuilder.bind(new?Queue("test_spring_topic_queue",false)) ? ?//創(chuàng)建隊(duì)列 ? ? ?.to(new?TopicExchange("test_spring_topic",false,false)) ? ?//綁定交換機(jī) ? ? ?.with("user.#") ? ?//設(shè)置routingkey );

需要注意的：當(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對(duì)象獲取的，如下圖。那么在springAMQP模式下怎么聲明呢?在下節(jié)課中，我們將要講解到的。

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

本文名稱：rabbitMQ精講系列第十八篇高級(jí)整合應(yīng)用第一篇
本文地址：http://www.rwnh.cn/article10/pcopgo.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供品牌網(wǎng)站制作、網(wǎng)站收錄、全網(wǎng)營(yíng)銷推廣、建站公司、響應(yīng)式網(wǎng)站、做網(wǎng)站

廣告

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請(qǐng)盡快告知，我們將會(huì)在第一時(shí)間刪除。文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng)，如需處理請(qǐng)聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時(shí)需注明來源： 創(chuàng)新互聯(lián)