2. 程式人生 > >每天學點SpringCloud（十三）：SpringCloud-Stream整合RabbitMQ

每天學點SpringCloud（十三）：SpringCloud-Stream整合RabbitMQ

阿新 • • 發佈：2018-12-09

我們知道，當微服務越來越來多的時候，僅僅是feign的http呼叫方式已經滿足不了我們的使用場景了。這個時候系統就需要接入訊息中介軟體了。相比較於傳統的Spring專案、SpringBoot專案使用訊息中介軟體的很多配置不同，SpringCloud Stream抽象了中介軟體產品的不同，在SpringCloud中你僅僅需要修改幾行配置檔案就可以靈活的切換中介軟體產品而不需要修改任何程式碼。

現在我們以SpringCloud Stream整合RabbitMQ為例來學習一下

建立生產者

1. 引入依賴

1
2
3
4
 
<dependency>
            <groupId>org.springframework.cloud</groupId>
 <artifactId>spring-cloud-starter-stream-rabbit</artifactId>
 </dependency>

2. 定義配置檔案

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
 
spring:
  cloud:
    stream:
 binders:
 test:
 type: rabbit
 environment:
 spring:
 rabbitmq:
 addresses: 10.0.20.132
 port: 5672
 username: root
 password: root
 virtual-host: /unicode-pay
 bindings:
 testOutPut:
 destination: testRabbit
 content-type: application/json
 default-binder: test

現在來解釋一下這些配置的含義

  1. binders： 這是一組binder的集合，這裡配置了一個名為test的binder，這個binder中是包含了一個rabbit的連線資訊
  2. bindings：這是一組binding的集合，這裡配置了一個名為testOutPut的binding，這個binding中配置了指向名test的binder下的一個交換機testRabbit。
  3. 擴充套件： 如果我們專案中不僅集成了rabbit還集成了kafka那麼就可以新增一個型別為kafka的binder、如果專案中會使用多個交換機那麼就使用多個binding，

3.建立通道

1
2
3
4
5
6
7
8
 
public interface  MqMessageSource {

    String TEST_OUT_PUT = "testOutPut";

 @Output(TEST_OUT_PUT)
 MessageChannel testOutPut();

}

這個通道的名字就是上方binding的名字

4. 傳送訊息

1
2
3
4
5
6
7
8
9
10
11
12
 
@EnableBinding(MqMessageSource.class)
public class MqMessageProducer {
    @Autowired
 @Output(MqMessageSource.TEST_OUT_PUT)
 private MessageChannel channel;


 public void sendMsg(String msg) {
 channel.send(MessageBuilder.withPayload(msg).build());
 System.err.println("訊息傳送成功："+msg);
 }
}

這裡就是使用上方的通道來發送到指定的交換機了。需要注意的是withPayload方法你可以傳入任何型別的物件，但是需要實現序列化介面

5. 建立測試介面

EnableBinding註解繫結的類預設是被Spring管理的，我們可以在controller中注入它

1
2
3
4
5
6
7
8
 
@Autowired
private MqMessageProducer mqMessageProducer;

@GetMapping(value = "/testMq")
public String testMq(@RequestParam("msg")String msg){
 mqMessageProducer.sendMsg(msg);
 return "傳送成功";
}

生產者的程式碼到此已經完成了。

建立消費者

1. 引入依賴

1
2
3
4
 
<dependency>
            <groupId>org.springframework.cloud</groupId>
 <artifactId>spring-cloud-starter-stream-rabbit</artifactId>
 </dependency>

2. 定義配置檔案

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
 
spring:
  cloud:
    stream:
 binders:
 test:
 type: rabbit
 environment:
 spring:
 rabbitmq:
 addresses: 10.0.20.132
 port: 5672
 username: root
 password: root
 virtual-host: /unicode-pay
 bindings:
 testInPut:
 destination: testRabbit
 content-type: application/json
 default-binder: test

這裡與生產者唯一不同的地方就是testIntPut了，相信你已經明白了，它是binding的名字，也是通道與交換機繫結的關鍵

3.建立通道

1
2
3
4
5
6
7
8
 
public interface  MqMessageSource {

    String TEST_IN_PUT = "testInPut";

 @Input(TEST_IN_PUT)
 SubscribableChannel testInPut();

}

4. 接受訊息

1
2
3
4
5
6
7
8
 
@EnableBinding(MqMessageSource.class)
public class MqMessageConsumer {
 @StreamListener(MqMessageSource.TEST_IN_PUT)
 public void messageInPut(Message<String> message) {
 System.err.println(" 訊息接收成功：" + message.getPayload());
 }

}

這個時候啟動Eureka、訊息生產者和消費者，然後呼叫生產者的介面應該就可以接受到來自mq的訊息了。

GitHub地址：https://github.com/2388386839/spring-cloud-demo。程式碼所在模組：cloud-demo-consumer，cloud-demo-provider-2

如果對您有所幫助，請記得幫忙點一個star哦

本文出自http://zhixiang.org.cn,轉載請保留

相關推薦

每天學點SpringCloud（十三）：SpringCloud-Stream整合RabbitMQ

我們知道，當微服務越來越來多的時候，僅僅是feign的http呼叫方式已經滿足不了我們的使用場景了。這個時候系統就需要接入訊息中介軟體了。相比較於傳統的Spring專案、SpringBoot專案使用訊息中介軟體的很多配置不同，SpringCloud Stream抽象了中介軟體產品的不同，在SpringClou

Spring Boot （十三）： Spring Boot 整合 RabbitMQ

1. 前言 RabbitMQ 是一個訊息佇列，說到訊息佇列，大家可能多多少少有聽過，它主要的功能是用來實現應用服務的非同步與解耦，同時也能起到削峰填谷、訊息分發的作用。 訊息佇列在比較主要的一個作用是用來做應用服務的解耦，訊息從訊息的生產者傳遞到訊息佇列，消費者從訊息佇列中獲取訊息並進行消費，生產者不需要

每天學點SpringCloud（十）：SpringCloud監控

今天我們來學習一下actuator這個元件，它不是SpringCloud之後才有的，而是SpringBoot的一個starter，Spring Boot Actuator。我們使用SpringCloud的時候需要使用這個元件對應用程式進行監控與管理 在SpringBoot2.0版本中，actuat

每天學點SpringCloud（九）：SpringCloud最常用配置詳解

Eureka 屬性名 說明 預設值 eureka.server.enable-self-preservation 關閉註冊中心的保護機制，Eureka 會統計15分鐘之內心跳失敗的比例低

每天學點Linux（三）Linux下VIM的使用

本文參考文章： Vim 101: A Beginner’s Guide to Vim 如果你屬於以下人群，學習VIM是有益的： - 系統管理者 - 程式設計人員 - 使用HTML，LaTeX或者其他置標語言 - 純文字重度使用者 vi/vim的

每天學點SpringCloud（一）：使用SpringBoot2.0.3整合SpringCloud

prope long mapping .org -- xsd pom.xml 開始學習 conf 最近開始學習SpringCloud，在此把我學習的過程記錄起來，跟大家分享一下，一起學習。想學習SpringCloud的同學趕快上車吧。 本次學習使用得SpringBoot版本

每天學點SpringCloud（三）：自定義Eureka集群負載均衡策略

log util domain 避免 can val 如果 dba filters 相信看了 每天學點SpringCloud（一）：簡單服務提供者消費者調用，每天學點SpringCloud（二）：服務註冊與發現Eureka這兩篇的同學都了解到了我的套路，沒錯，本篇博客同樣是

每天學點SpringCloud（六）：Hystrix使用

artifact 接下來 文件中 系統 lba eureka nal .get com Hystrix是一個實現斷路器模式的庫。什麽是斷路器模式呢？就像我們家庭中的電閘一樣，如果有那一處出現意外，那麽電閘就會立刻跳閘來防止因為這一處意外而引起更大的事故，直到我們確認處理完那

每天學點SpringCloud（七）：路由器和過濾器-Zuul

root 什麽是 app ati artifact lap 做了 定義 mailto 為什麽要使用Zuul先來看一下下方這個圖 假如現在我們具有四個微服務，分別是用戶、訂單、支付、催收微服務，它們的調用方式分別是使用http、restful、thrift、kafka。這個時

每天學點SpringCloud（八）：使用Apollo做配置中心

val override config 數據庫文件 ntc rgb fan lin 相對 由於Apollo支持的圖形化界面相對於我們更加的友好，所以此次我們使用Apollo來做配置中心本篇文章實現了使用Apollo配置了dev和fat兩個環境下的屬性配置。Apollo官方文

（十三）Java springcloud B2B2C o2o多使用者商城 springcloud架構 - SSO單點登入之OAuth2.0 根據token獲取使用者資訊(4)

上一篇我根據框架中OAuth2.0的使用總結，畫了SSO單點登入之OAuth2.0 登出流程，今天我們看一下根據使用者token獲取yoghurt資訊的流程： /** * 根據token獲取使用者資訊 * @param accessToken * @return * @

每天學點linux--（用shell實現將一個資料夾下面的所有檔案拷貝到另一個資料夾下/shell下如何重新命名一個檔案）

一、用shell實現將一個資料夾下面的所有檔案拷貝到另一個資料夾下 收穫： 1、在if test -d $1的時候，if後面一定要有空格 2、在使用變數的時候一定要用$！ 3、學會`commad`的用法 下面給出程式碼，還有一些不完善的地方，有空補全一下，第一次shell

把握linux內核設計思想（十三）：內存管理之進程地址空間

color 區域 left ons 文章 進程的地址空間 tmp ica interval 【版權聲明：尊重原創，轉載請保留出處：blog.csdn.net/shallnet。文章僅供學習交流，請勿用於商業用途】 進程地址空間由進程可尋址的虛擬內存組成

每天一個linux命令（16）：tail命令

nvi 系統 strong 維基百科 ron .com linux tro 聯系 版權聲明更新：2017-05-20博主：LuckyAlan聯系：[email protected]/* */聲明：吃水不忘挖井人，轉載請註明出處！ 1 文章介紹 本文介紹了Linu

每天一個linux命令（11）：cat命令

部分 ron linu mv命令 平臺 linux下 一個 介紹 inux 版權聲明更新：2017-05-15博主：LuckyAlan聯系：[email protected]/* */聲明：吃水不忘挖井人，轉載請註明出處！ 1 文章介紹 本文介紹了Linux下面

每天一個linux命令（9）：cp命令

系統 lin 維基 介紹 參考 vip 聲明 com 開發平臺 版權聲明更新：2017-05-13博主：LuckyAlan聯系：[email protected]/* */聲明：吃水不忘挖井人，轉載請註明出處！ 1 文章介紹 本文介紹了Linux下面的cp命令。

OpenCV探索之路（十三）：詳解掩膜mask

ret 如果 拷貝 ace 設置 之路 動作 與運算 區域 在OpenCV中我們經常會遇到一個名字:Mask(掩膜)。很多函數都使用到它，那麽這個Mask到底什麽呢？ 一開始我接觸到Mask這個東西時，我還真是一頭霧水啊，也對無法理解Mask到底有什麽用。經過查閱大量資料後

springCloud（1）：微服務簡介

spring cloud 微服務 一、什麽是微服務微服務架構風格是一種將一個單一應用程序開發為一組小型服務的方法，每個服務運行在自己的進程中，服務間通信采用輕量級通信機制（通常用HTTP資源API）。二、微服務架構特性1、每個微服務可獨立運行在自己的進程裏2、一系列獨立運行的微服務共同構建起整個系

springCloud（3）：微服務的註冊與發現（Eureka）

springcloud 微服務的註冊與發現 eureka 一、簡介服務消費者需要一個強大的服務發現機制，服務消費者使用這種機制獲取服務提供者的網絡信息。即使服務提供者的信息發生變化，服務消費者也無須修改配置。服務提供者、服務消費者、服務發現組件三者之間的關系大致如下： 1.各個微服務在啟動時，將自

springCloud（5）：Eureka的元數據與Eureka Server的rest端點

springcloud eureka的元數據 eureka server的rest端點 一、Eureka的元數據1.1、簡介Eureka的元數據有兩種：標準元數據和自定義元數據。標準元數據指的是主機名、IP地址、端口號、狀態頁和健康檢查等信息，這些信息都會被發布在服務註冊表中，用於服務之間的調用。