1. 程式人生 > >消息中間件ActiveMQ及Spring整合JMS的介紹

消息中間件ActiveMQ及Spring整合JMS的介紹

gin 擴展 rabbit 快的 系列 conn 內部 consumer targe

一 、消息中間件的基本介紹

1.1 消息中間件

1.1.1 什麽是消息中間件

消息中間件利用高效可靠的消息傳遞機制進行平臺無關的數據交流,並基於數據通信來進行分布式系統的集成。通過提供消息傳遞和消息排隊模型,它可以在分布式環境下擴展進程間的通信。對於消息中間件,常見的角色大致也就有Producer(生產者)、Consumer(消費者)

常見的消息中間件產品:

1ActiveMQ

ActiveMQ 是Apache出品,最流行的,能力強勁的開源消息總線。ActiveMQ 是一個完全支持JMS1.1和J2EE 1.4規範的 JMS Provider實現。我們在本次課程中介紹 ActiveMQ的使用。

(2)RabbitMQ

AMQP協議的領導實現,支持多種場景。淘寶的MySQL集群內部有使用它進行通訊,OpenStack開源雲平臺的通信組件,最先在金融行業得到運用。

(3)ZeroMQ

史上最快的消息隊列系統

(4)Kafka

Apache下的一個子項目 。特點:高吞吐,在一臺普通的服務器上既可以達到10W/s的吞吐速率;完全的分布式系統。適合處理海量數據。

1.1.2 使用ActiveMQ的場景

  1. 進程間通訊,比如在分布式系統中。

  2. 解耦,比如像我們公司有許多開發團隊,每個團隊負責業務的不同模塊,各個開發團隊可以使用MQ來通信。

  3. 在一些高並發場景下,使用MQ的異步特性。

  4. (歡迎補充)

1.2 JMS簡介

1.2.1什麽是JMS

  JMS(Java?Messaging Service)是Java平臺上有關面向消息中間件的技術規範,它便於消息系統中的Java應用程序進行消息交換,並且通過提供標準的產生、發送、接收消息的接口簡化企業應用的開發。

JMS本身只定義了一系列的接口規範,是一種與廠商無關的 API,用來訪問消息收發系統。它類似於 JDBC(java?Database Connectivity):這裏,JDBC 是可以用來訪問許多不同關系數據庫的 API,而 JMS 則提供同樣與廠商無關的訪問方法,以訪問消息收發服務。許多廠商目前都支持 JMS,包括 IBM 的 MQSeries、BEA的 Weblogic JMS service和 Progress 的 SonicMQ,這只是幾個例子。 JMS 使您能夠通過消息收發服務(有時稱為消息中介程序或路由器)從一個 JMS 客戶機向另一個 JML 客戶機發送消息。消息是 JMS 中的一種類型對象,由兩部分組成:報頭和消息主體。報頭由路由信息以及有關該消息的元數據組成。消息主體則攜帶著應用程序的數據或有效負載。

JMS 定義了五種不同的消息正文格式,以及調用的消息類型,允許你發送並接收以一

些不同形式的數據,提供現有消息格式的一些級別的兼容性。

· TextMessage--一個字符串對象

· MapMessage--一套名稱-值對

· ObjectMessage--一個序列化的 Java 對象

· BytesMessage--一個字節的數據流

· StreamMessage -- Java 原始值的數據流

消息中間件ActiveMQ及Spring整合JMS的介紹