rabbitMQ精講系列第十八篇 高級整合應用第一篇

在本章學習中，我們主要是和應用整合的。下面來看看本章我們主要內容：

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

本文主要內容：

使用代碼創建rabbitAdmin，通過rabbitAdmin操作MQ

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

RabbitMQ整合Spring AMQP實戰

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

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

注意：

autoStartup必須設置為ture,否則spring容器不會加載類.

為什么要獲取RabbitAdmin？

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

使用RabbitTemplate的execute方法執行對應的聲明、修改、刪除等一系列的RabbitMQ基礎功能操作。

代碼演示：

添加pom文件：

需要注意：

如果spring boot 是1.5.6版本的時候，rabbit的版本號可以使用3.6.5以上

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

創建rabbitMQConfig:

1:先獲取到ConnectionFactory.

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

創建ConnectionFactory:

2:獲取rabbitAdmin的代碼：

注意：setAutoStartUp必須設置為true

進行測試：

因為在RabbitMQConfig中我們已經將rabbitAdmin由spring容器管理了。所以在這里，我們直接使用autowired就可以。如下圖：

我們先在頁面管控臺查看：

并沒有。啟動后，在查看，是否已經創建。

測試類啟動成功：

在頁面管控臺查看，exchange交換機是否已經創建：

已經創建成功。說明，rabbitAdmin我們成功了。

通過rabbitAdmin創建Queue:

創建綁定關系：

啟動后，查看test_spring_direct_queue是否綁定了test_spring_direct交換機。

我們發現綁定成功了。

綁定方式二：使用BindingBuilder的鏈式

需要注意的：當時fanout的時候，在bingdingBuilder的時候沒有with.因為fanout的不需要routingkey。

本節總結：

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

下節預告：

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

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