當前位置：首頁 > 科技 > 軟件

使用RabbitMQ和Spring Cloud Stream實現異步通信

來源：責編：時間：2023-12-08 09:15:02 214觀看

導讀1 異步通信在現代軟件系統和應用程序互聯的環境中，通信方式對系統性能、用戶體驗和軟件操作的靈活性具有重要影響。其中一種重要的通信方式是異步通信。異步通信允許發送方在發送消息后繼續進行其他操作，不必即時等待接

1 異步通信

在現代軟件系統和應用程序互聯的環境中，通信方式對系統性能、用戶體驗和軟件操作的靈活性具有重要影響。其中一種重要的通信方式是異步通信。異步通信允許發送方在發送消息后繼續進行其他操作，不必即時等待接收方的響應，從而實現了解耦和流暢的操作。相比之下，同步通信模型需要發送方等待接收方的響應，類似于面對面的對話方式。

異步通信的優勢：

可擴展性：隨著系統的增長，需要處理大量請求或消息。異步通信可以更好地分布和管理這些請求。多個進程可以并行運行，不用等待一個進程完成，從而提高吞吐量。
彈性：在分布式系統中，故障或停機是不可避免的。通過異步通信，如果一個服務暫時停止，整個系統并不會停止運行。消息會被存儲，等到服務恢復后再進行處理，確保不丟失數據或事務。
改善用戶體驗：在涉及用戶交互的系統中，采用異步操作可以確保用戶不需要長時間等待。例如，在現代 Web 應用程序中，像數據獲取這樣的任務可以在后臺進行，能夠讓用戶在不必要的延遲下繼續與應用程序進行交互。
資源優化：異步系統更具成本效益。資源不需要始終等待（有時處于空閑狀態），而是在實際需要進行處理時進行動態分配和使用。
靈活性和模塊化：異步通信促進了解耦的系統設計。各個組件或服務可以獨立更新、維護或擴展，而不會影響整個系統。

鑒于這些優勢，異步通信在許多現代系統設計中都起著核心作用，特別是在微服務架構、事件驅動設計和實時 Web 應用程序中。

2 RabbitMQ簡介

在眾多可用的消息傳遞解決方案中，RabbitMQ憑借其多功能性和強大的功能集占據了主要地位。

2.1 什么是RabbitMQ

RabbitMQ是一個開源的消息代理，通過消息隊列促進應用程序內部或不同應用程序之間的通信。RabbitMQ充當中間人，確保消息被接收、存儲和傳遞到正確的位置。

2.2 歷史與背景

RabbitMQ于2007年由Rabbit Technologies Ltd開發，后于2010年被VMware收購。主要使用Erlang語言編寫，Erlang語言在構建強大、可伸縮和分布式系統方面具有優勢。

2.3 核心概念

交換機：這是RabbitMQ中的路由機制。當發送消息時，消息會被發送到一個交換機，然后根據特定的規則和綁定決定將消息發送到哪個隊列。
隊列：這是存儲等待處理消息的數據結構。應用程序或消費者連接到這些隊列來消費消息。
綁定：這是交換機用來確定將消息路由到哪個隊列的規則。
生產者和消費者：在RabbitMQ世界中，生產者是發送消息的實體/應用程序，消費者是接收并處理消息的實體/應用程序。

2.4 RabbitMQ主要特點

持久性：RabbitMQ可以將消息持久化到磁盤，即使代理重新啟動，也不會丟失消息。
靈活的路由：通過不同類型的交換機（直連、主題、扇出和頭部），RabbitMQ可以根據應用程序的需要提供多樣化的路由邏輯。
集群和高可用性：RabbitMQ支持集群，以確保高可用性。這意味著即使集群中的一個節點失敗，系統仍然可用。
插件架構：RabbitMQ支持廣泛的插件，允許用戶擴展其功能。這使得它適應各種應用程序需求。
多協議支持：雖然RabbitMQ通常與AMQP（高級消息隊列協議）相關聯，但它還支持其他消息協議，如MQTT、STOMP等。
管理和監控：RabbitMQ附帶了一個全面的管理界面，并提供了用于監視和管理代理的API。

2.5 為什么選擇RabbitMQ

組織機構之所以傾向于選擇RabbitMQ，是因為它可靠、易于使用，并且擁有強大的社區支持。RabbitMQ的插件架構支持企業根據自己的需求定制代理，而其對多種協議的支持使其成為適應各種應用程序需求的多功能選擇。無論是要集成微服務、確保分布式系統中的通信，還是構建實時應用程序，RabbitMQ都是一個靠譜的選擇。

3 Spring Cloud Stream簡介

3.1 Spring Cloud Stream概述

Spring Cloud Stream是Spring Cloud大集合中的一個框架，旨在為構建事件驅動的微服務提供基礎。它通過抽象掉樣板代碼和特定代理配置，為多個消息代理平臺提供了簡化的連接模型。

3.2 核心原則和組件

Binder抽象：這是Spring Cloud Stream設計的核心。Binder SPI（服務提供者接口）允許框架將應用程序核心邏輯與特定的消息代理橋接。結果是，開發人員可以專注于編寫業務邏輯，而無需被復雜的代理配置所困擾。
持久的發布/訂閱語義：使用Spring Cloud Stream，您可以擁有長時間存在的訂閱，系統確保消息的持久性，甚至可以為您管理消費者偏移量。
內容類型協商：Spring Cloud Stream具有內置的消息轉換機制。基于內容類型頭，它可以將消息有效載荷轉換為所需的數據類型，簡化了數據的編組和解組過程。
分區：對于需要大規模消息處理的場景，該框架為微服務的多個實例之間的數據分區提供了本地支持，確保了高效的數據處理。

3.3 工作原理

在其核心，Spring Cloud Stream通過三個主要接口進行操作：Source、Processor和Sink。

Source：表示消息通道的生產者端，負責發送消息。
Processor：結合了Source和Sink的功能。它接收消息并處理，然后發送轉換后的消息。
Sink：表示消費者端，負責接收消息。

只需使用@EnableBinding注解注釋Spring Beans，并指定其中之一的接口，即可快速定義消息的輸入和輸出通道。

3.4 支持的Binder

Spring Cloud Stream的主要優勢之一是其廣泛支持的Binder，提供與各種消息代理的集成。開箱即用，它提供對RabbitMQ、Apache Kafka等流行平臺的支持。由于社區積極維護，因此經常引入更多的Binder和改進。

3.5 擴展和集成

Spring Cloud Stream與其他Spring項目無縫集成。例如，使用Spring Cloud Function，可以支持無服務器架構；使用Spring Cloud Data Flow，可以使用簡單的DSL定義復雜的數據管道。

Spring Cloud Stream通過其抽象層和豐富的功能，以可擴展和可維護的方式簡化了創建事件驅動的微服務的過程。通過處理底層消息平臺的復雜性，它使開發人員能夠專注于最重要的事情：構建有影響力的業務邏輯。

4 將RabbitMQ與Spring Cloud Stream集成

4.1 設置階段

首先，需要一個正在運行的RabbitMQ實例。可以使用Docker、云提供商或本地安裝。此外，考慮到Spring Cloud Stream是構建在Spring Boot之上的，對Spring Boot有一定的了解將會有益。

4.2 逐步集成

(1) 項目設置：

使用Spring Initializr創建一個新的Spring Boot項目。
添加依賴項：Spring Cloud Stream和RabbitMQ binder。

(2 ) 配置：

在您的application.properties或application.yml文件中，配置RabbitMQ連接設置，如spring.rabbitmq.host、spring.rabbitmq.port和憑證。

(3) 定義通道：

使用@EnableBinding注解定義消息通道。可以使用預定義的接口如Source、Sink，或者自定義接口。

@EnableBinding(Source.class)public class MessagingConfiguration {}

(4) 發布消息：

在服務或控制器中注入Source bean。
使用output()方法獲取MessageChannel實例并發送消息。

@Autowiredprivate Source source;public void publishMessage(String data) {    source.output().send(MessageBuilder.withPayload(data).build());}

(5) 接收消息：

在方法上使用@StreamListener注解來消費指定通道的消息。

@StreamListener(Sink.INPUT)public void consumeMessage(String message) {    System.out.println("Received: " + message);}

(6) 錯誤處理：

Spring Cloud Stream提供了集中的錯誤處理機制。通過定義ListenerContainerCustomizer類型的bean，可以自定義錯誤處理程序。

@Beanpublic ListenerContainerCustomizer<AbstractMessageListenerContainer> customizer() {    return (container, destName, group) -> {        container.setErrorHandler(errorHandler());    };}public ErrorHandler errorHandler() {    return e -> {        // 處理異常    };}

(7) 微調和高級配置：

可以通過屬性文件自定義各種特定于RabbitMQ的設置，如交換機、路由鍵和持久性。例如，可以設置spring.cloud.stream.rabbit.bindings.``<channelName>.producer.routingKeyExpression來定義自定義的路由鍵。

4.3 集成的優勢

簡化開發：通過抽象RabbitMQ的細節，Spring Cloud Stream提供了統一的API，簡化了代碼庫。
增強可伸縮性：通過Spring Cloud Stream利用RabbitMQ的功能，確保您的應用程序能夠有效擴展。
可靠性：Spring Cloud Stream的錯誤處理機制與RabbitMQ的持久性和重試機制結合使用，確保消息可靠處理。
靈活性：這種集成使您在將來可以自由切換到另一個消息代理，只需進行最小的代碼更改，這要歸功于Spring Cloud Stream的綁定器抽象。

5 總結

通過使用RabbitMQ結合Spring Cloud Stream，開發人員可以輕松實現異步通信模式，確保其服務具有可擴展性、彈性，并能快速響應。借助這些工具提供的簡單配置和抽象層，設置和管理異步通信通道變得輕而易舉。

本文鏈接：http://www.www897cc.com/showinfo-26-39518-0.html使用RabbitMQ和Spring Cloud Stream實現異步通信

聲明：本網頁內容旨在傳播知識，若有侵權等問題請及時與本網聯系，我們將在第一時間刪除處理。郵件：2376512515@qq.com

上一篇：基于Python和Surprise庫，新手也能動手搭建推薦系統

下一篇：企業級直播云服務的挑戰與架構演進

標簽：

熱門焦點

影音體驗是真的強簡單聊聊iQOO Pad

大公司的好處就是產品線豐富，非常細分化的東西也能給你做出來，例如早先我們看到了新的vivo Pad2，之后我們又在iQOO Neo8 Pro的發布會上看到了iQOO的首款平板產品iQOO Pad。雖
小米平板5 Pro 12.4簡評：多專多能兼顧影音娛樂的大屏利器

疫情帶來了網課，網課盤活了安卓平板，安卓平板市場雖然中途停滯了幾年，但好的一點就是停滯的這幾年行業又有了新的發展方向，例如超窄邊框、高刷新率、多攝鏡頭組合等，這就讓安卓
天貓精靈Sound Pro體驗：智能音箱沒有音質？來聽聽我的

這幾年除了手機作為智能生活終端最主要的核心之外，第二個可以成為中心點的產品是什么？——是智能音箱。手機在執行命令的時候有兩種操作方式，手和智能語音助手，而智能音箱只
vivo TWS Air開箱體驗：真輕臻好聽

在vivo S15系列新機的發布會上，vivo的最新款真無線藍牙耳機vivo TWS Air也一同發布，本次就這款耳機新品給大家帶來一個簡單的分享。外包裝盒上，vivo TWS Air保持了vivo自家產
騰訊VS網易，最卷游戲暑期檔，誰能笑到最后？

作者：無銹缽來源：財經無忌7月16日晚，上海1862時尚藝術中心。伴隨著幻象的精準命中，碩大的熒幕之上，比分被定格在了14：12，被寄予厚望的EDG戰隊以絕對的優勢戰勝了BLG戰隊，拿下了總決
AMD的AI芯片轉單給三星可能性不大與臺積電已合作至2nm制程

據 DIGITIMES 消息，英偉達 AI GPU 出貨逐季飆升，接下來 AMD MI 300 系列將在第 4 季底量產。而半導體業內人士表示，近日傳出 AMD 的 AI 芯片將轉單給
iQOO Neo8 Pro即將開售：到手價3099元起安卓性能最強旗艦

5月23日，iQOO如期舉行了新品發布會，全新的iQOO Neo8系列也正式與大家見面，包含iQOO Neo8和iQOO Neo8 Pro兩個版本，其中標準版搭載高通驍龍8+，而Pro版更
質感不錯！OPPO K11渲染圖曝光：旗艦IMX890傳感器首次下放

一直以來，OPPO K系列機型都保持著較為均衡的產品體驗，歷來都是2K價位的明星機型，去年推出的OPPO K10和OPPO K10 Pro兩款機型憑借各自的出色配置，堪稱有
利用職權私自解除被封帳號 Meta開除20多名員工

11月18日消息，據外媒援引知情人士表示，過去一年時間內，Facebook母公司Meta解雇或處罰了20多名員工以及合同工，指控這些人通過內部系統以不當方式重置用戶帳號，其

日韩成人免费在线_国产成人一二_精品国产免费人成电影在线观..._日本一区二区三区久久久久久久久不

使用RabbitMQ和Spring Cloud Stream實現異步通信

1 異步通信

2 RabbitMQ簡介

2.1 什么是RabbitMQ

2.2 歷史與背景

2.3 核心概念

2.4 RabbitMQ主要特點

2.5 為什么選擇RabbitMQ

3 Spring Cloud Stream簡介

3.2 核心原則和組件

3.3 工作原理

3.4 支持的Binder

3.5 擴展和集成

4 將RabbitMQ與Spring Cloud Stream集成

4.2 逐步集成

4.3 集成的優勢

5 總結

影音體驗是真的強簡單聊聊iQOO Pad

小米平板5 Pro 12.4簡評：多專多能兼顧影音娛樂的大屏利器

天貓精靈Sound Pro體驗：智能音箱沒有音質？來聽聽我的

vivo TWS Air開箱體驗：真輕臻好聽

騰訊VS網易，最卷游戲暑期檔，誰能笑到最后？

AMD的AI芯片轉單給三星可能性不大與臺積電已合作至2nm制程

iQOO Neo8 Pro即將開售：到手價3099元起安卓性能最強旗艦

質感不錯！OPPO K11渲染圖曝光：旗艦IMX890傳感器首次下放

利用職權私自解除被封帳號 Meta開除20多名員工

最新推薦

猜你喜歡

熱門推薦

相關資訊