Java架構-(十七) 整合spring cloud雲架構 -訊息驅動 Spring Cloud Stream
在使用spring cloud雲架構的時候，我們不得不使用Spring cloud Stream，因為訊息中介軟體的使用在專案中無處不在，我們公司後面做了娛樂方面的APP，在使用spring cloud做架構的時候，其中訊息的非同步通知，業務的非同步處理都需要使用訊息中介軟體機制。spring cloud的官方給出的整合建議（使用rabbit mq和kafka），我看了一下原始碼和配置，只要把rabbit mq整合，kafka只是換了一個pom配置jar包而已，閒話少說，我們就直接進入配置實施：
1. 簡介：
Spring cloud Stream 資料流操作開發包，封裝了與Redis,Rabbit、Kafka等傳送接收訊息。
2. 使用工具：
rabbit，具體的下載和安裝細節我這裡不做太多講解，網上的例項太多了
3. 建立commonservice-mq-producer訊息的傳送者專案，在pom裡面配置stream-rabbit的依賴
Java程式碼
4. 在yml檔案裡面配置rabbit mq
Java程式碼
5. 定義介面ProducerService
Java程式碼
6. 定義繫結
Java程式碼
7. 定義傳送訊息業務ProducerController
Java程式碼
8. 建立commonservice-mq-consumer1訊息的消費者專案，在pom裡面配置stream-rabbit的依賴
Java程式碼
- 定義介面ConsumerService
Java程式碼
- 定義啟動類和訊息消費
Java程式碼
-
分別啟動commonservice-mq-producer、commonservice-mq-consumer1
-
通過postman來驗證訊息的傳送和接收
可以看到接收到了訊息，下一章我們介紹mq的叢集方案。
歡迎大家和我一起學習spring cloud構建微服務雲架構，我這邊會將近期研發的spring cloud微服務雲架構的搭建過程和精髓記錄下來，幫助更多有興趣研發spring cloud框架的朋友，大家來一起探討spring cloud架構的搭建過程及如何運用於企業專案
我本人邀約各大BATJ架構大牛共創Spring Cloud構建微服務架構的交流社群。 （群號：573988200）歡迎各路架構師、開發者，學習與交流使用Spring Cloud諸多強大元件的實戰經驗。
為什麼某些人會一直比你優秀，是因為他本身就很優秀還一直在持續努力變得更優秀，而你是不是還在滿足於現狀內心在竊喜!
合理利用自己每一分每一秒的時間來學習提升自己，不要再用"沒有時間“來掩飾自己思想上的懶惰！趁年輕，使勁拼，給未來的自己一個交代！
希望此文能幫到大家的同時，也聽聽大家的觀點。歡迎留言討論，加關注，分享你的高見！持續更新！
To-陌霖Java架構
分享網際網路最新文章 關注網際網路最新發展