複製鏈接
請複製以下鏈接發送給好友

JMS

(Java平台上的專業技術規範)

鎖定
JMS即Java消息服務(Java Message Service)應用程序接口,是一個Java平台中關於面向消息中間件(MOM)的API,用於在兩個應用程序之間,或分佈式系統中發送消息,進行異步通信。Java消息服務是一個與具體平台無關的API,絕大多數MOM提供商都對JMS提供支持。
JMS是一種與廠商無關的 API,用來訪問收發系統消息,它類似於JDBC(Java Database Connectivity)。這裏,JDBC 是可以用來訪問許多不同關係數據庫的 API,而 JMS 則提供同樣與廠商無關的訪問方法,以訪問消息收發服務。許多廠商都支持 JMS,包括 IBM 的 MQSeries、BEA的 Weblogic JMS service和 Progress 的 SonicMQ。 JMS 使您能夠通過消息收發服務(有時稱為消息中介程序或路由器)從一個 JMS 客户機向另一個 JMS客户機發送消息。消息是 JMS 中的一種類型對象,由兩部分組成:報頭和消息主體。報頭由路由信息以及有關該消息的元數據組成。消息主體則攜帶着應用程序的數據或有效負載。根據有效負載的類型來劃分,可以將消息分為幾種類型,它們分別攜帶:簡單文本(TextMessage)、可序列化的對象 (ObjectMessage)、屬性集合 (MapMessage)、字節流 (BytesMessage)、原始值流 (StreamMessage),還有無有效負載的消息 (Message)。
中文名
JMS
外文名
Java Messaging Service
性    質
API
平    台
Java平台
定    義
Java消息服務
提供者
Apache ActiveMQ等

JMS專業技術規範

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

JMS歷史

Java消息服務是一個在 Java標準化組織(JCP)內開發的標準(代號JSR 914)。2001年6月25日,Java消息服務發佈JMS 1.0.2b,2002年3月18日Java消息服務發佈 1.1,統一了消息域。

JMS體系架構

JMS由以下元素組成。
JMS提供者
連接面向消息中間件的,JMS接口的一個實現。提供者可以是Java平台的JMS實現,也可以是非Java平台的面向消息中間件的適配器。
JMS客户
生產或消費基於消息的Java的應用程序或對象。
JMS生產者
創建併發送消息的JMS客户。
JMS消費者
接收消息的JMS客户。
JMS消息
包括可以在JMS客户之間傳遞的數據的對象
JMS隊列
一個容納那些被髮送的等待閲讀的消息的區域。與隊列名字所暗示的意思不同,消息的接受順序並不一定要與消息的發送順序相同。一旦一個消息被閲讀,該消息將被從隊列中移走。
JMS主題
一種支持發送消息給多個訂閲者的機制。

JMS對象模型

JMS對象模型包含如下幾個要素: [1] 
1)連接工廠。連接工廠(ConnectionFactory)是由管理員創建,並綁定到JNDI樹中。客户端使用JNDI查找連接工廠,然後利用連接工廠創建一個JMS連接。
2)JMS連接。JMS連接(Connection)表示JMS客户端和服務器端之間的一個活動的連接,是由客户端通過調用連接工廠的方法建立的。
3)JMS會話。JMS會話(Session)表示JMS客户與JMS服務器之間的會話狀態。JMS會話建立在JMS連接上,表示客户與服務器之間的一個會話線程。
4)JMS目的。JMS目的(Destination),又稱為消息隊列,是實際的消息源。
5)JMS生產者和消費者。生產者(Message Producer)和消費者(Message Consumer)對象由Session對象創建,用於發送和接收消息。
6)JMS消息通常有兩種類型:
① 點對點(Point-to-Point)。在點對點的消息系統中,消息分發給一個單獨的使用者。點對點消息往往與隊列(javax.jms.Queue)相關聯。
② 發佈/訂閲(Publish/Subscribe)。發佈/訂閲消息系統支持一個事件驅動模型,消息生產者和消費者都參與消息的傳遞。生產者發佈事件,而使用者訂閲感興趣的事件,並使用事件。該類型消息一般與特定的主題(javax.jms.Topic)關聯。

JMS模型

Java消息服務應用程序結構支持兩種模型:
點對點或隊列模型
發佈者/訂閲者模型
在點對點或隊列模型下,一個生產者向一個特定的隊列發佈消息,一個消費者從該隊列中讀取消息。這裏,生產者知道消費者的隊列,並直接將消息發送到消費者的隊列。這種模式被概括為:
只有一個消費者將獲得消息
生產者不需要在接收者消費該消息期間處於運行狀態,接收者也同樣不需要在消息發送時處於運行狀態。
每一個成功處理的消息都由接收者簽收
發佈者/訂閲者模型支持向一個特定的消息主題發佈消息。0或多個訂閲者可能對接收來自特定消息主題的消息感興趣。在這種模型下,發佈者和訂閲者彼此不知道對方。這種模式好比是匿名公告板。這種模式被概括為:
多個消費者可以獲得消息
在發佈者和訂閲者之間存在時間依賴性。發佈者需要建立一個訂閲(subscription),以便客户能夠訂閲。訂閲者必須保持持續的活動狀態以接收消息,除非訂閲者建立了持久的訂閲。在那種情況下,在訂閲者未連接時發佈的消息將在訂閲者重新連接時重新發布。
使用Java語言,JMS提供了將應用與提供數據的傳輸層相分離的方式。同一組Java類可以通過JNDI中關於提供者的信息,連接不同的JMS提供者。這一組類首先使用一個連接工廠以連接到隊列或主題,然後發送或發佈消息。在接收端,客户接收或訂閲這些消息。

JMS傳遞方式

JMS有兩種傳遞消息的方式。標記為NON_PERSISTENT的消息最多投遞一次,而標記為PERSISTENT的消息將使用暫存後再轉送的機理投遞。如果一個JMS服務離線,那麼持久性消息不會丟失但是得等到這個服務恢復聯機時才會被傳遞。所以默認的消息傳遞方式是非持久性的。即使使用非持久性消息可能降低內務和需要的存儲器,並且這種傳遞方式只有當你不需要接收所有的消息時才使用。
雖然JMS規範並不需要JMS供應商實現消息的優先級路線,但是它需要遞送加快的消息優先於普通級別的消息。JMS定義了從0到9的優先級路線級別,0是最低的優先級而9則是最高的。更特殊的是0到4是正常優先級的變化幅度,而5到9是加快的優先級的變化幅度。舉例來説: topicPublisher.publish (message, DeliveryMode.PERSISTENT, 8, 10000); //Pub-Sub 或 queueSender.send(message,DeliveryMode.PERSISTENT, 8, 10000);//P2P  這個代碼片斷,有兩種消息模型,映射遞送方式是持久的,優先級為加快型,生存週期是10000 (以毫秒度量)。如果生存週期設置為零,這則消息將永遠不會過期。當消息需要時間限制否則將使其無效時,設置生存週期是有用的。
JMS定義了五種不同的消息正文格式,以及調用的消息類型,允許你發送並接收以一些不同形式的數據,提供現有消息格式的一些級別的兼容性。
· StreamMessage -- Java原始值的數據流
· MapMessage--一套名稱-值對
· TextMessage--一個字符串對象
· ObjectMessage--一個序列化的 Java對象
· BytesMessage--一個未解釋字節的數據流

JMS應用程序

ConnectionFactory 接口(連接工廠)
用户用來創建到JMS提供者的連接的被管對象。JMS客户通過可移植的接口訪問連接,這樣當下層的實現改變時,代碼不需要進行修改。管理員在JNDI名字空間中配置連接工廠,這樣,JMS客户才能夠查找到它們。根據消息類型的不同,用户將使用隊列連接工廠,或者主題連接工廠。
Connection 接口(連接)
連接代表了應用程序和消息服務器之間的通信鏈路。在獲得了連接工廠後,就可以創建一個與JMS提供者的連接。根據不同的連接類型,連接允許用户創建會話,以發送和接收隊列和主題到目標。
Destination 接口(目標)
目標是一個包裝了消息目標標識符的被管對象,消息目標是指消息發佈和接收的地點,或者是隊列,或者是主題。JMS管理員創建這些對象,然後用户通過JNDI發現它們。和連接工廠一樣,管理員可以創建兩種類型的目標,點對點模型的隊列,以及發佈者/訂閲者模型的主題。
Session 接口(會話)
表示一個單線程的上下文,用於發送和接收消息。由於會話是單線程的,所以消息是連續的,就是説消息是按照發送的順序一個一個接收的。會話的好處是它支持事務。如果用户選擇了事務支持,會話上下文將保存一組消息,直到事務被提交才發送這些消息。在提交事務之前,用户可以使用回滾操作取消這些消息。一個會話允許用户創建消息,生產者來發送消息,消費者來接收消息。
MessageConsumer 接口(消息消費者)
由會話創建的對象,用於接收發送到目標的消息。消費者可以同步地(阻塞模式),或(非阻塞)接收隊列和主題類型的消息。
MessageProducer 接口(消息生產者)
由會話創建的對象,用於發送消息到目標。用户可以創建某個目標的發送者,也可以創建一個通用的發送者,在發送消息時指定目標。
Message 接口(消息)
是在消費者和生產者之間傳送的對象,也就是説從一個應用程序傳送到另一個應用程序。一個消息有三個主要部分:
消息頭(必須):包含用於識別和為消息尋找路由的操作設置。
一組消息屬性(可選):包含額外的屬性,支持其他提供者和用户的兼容。可以創建定製的字段和過濾器(消息選擇器)。
一個消息體(可選):允許用户創建五種類型的消息(文本消息,映射消息,字節消息,流消息和對象消息)。
消息接口非常靈活,並提供了許多方式來定製消息的內容。

JMS提供者

JMS流程圖 JMS流程圖
要使用Java消息服務,你必須要有一個JMS提供者,管理會話和隊列。既有開源的提供者也有專有的提供者。
開源的提供者包括:
Apache ActiveMQ
JBoss 社區所研發的 HornetQ
Joram
Coridan的MantaRay
The OpenJMS Group的OpenJMS
專有的提供者包括:
BEA的BEA WebLogic Server JMS
TIBCO Software的EMS
GigaSpaces Technologies的GigaSpaces
Softwired 2006的iBus
IONA Technologies的IONA JMS
SeeBeyond的IQManager(2005年8月被Sun Microsystems併購)
webMethods的JMS+ -
my-channels的Nirvana
Sonic Software的SonicMQ
SwiftMQ的SwiftMQ
IBM的WebSphere MQ
參考資料