1.JMS概述
JAVA 消息服務(JMS)定義了Java 中訪問消息中間件的接口。JMS只是接口,并沒有給予實現,實現JMS接口的消息中間件稱為JMS
Provider
消息中間件提供企業數據的異步傳輸,通過消息中間件,一些原本互相孤立的業務組件可以組合成一個可靠的、靈活的系統。也可以模擬實現同步傳輸,但其實質仍然是異步的。
JMS 支持兩種消息類型PTP (Point-to-Point)和Pub/Sub(Publish-Subscribe),分別稱作:PTP Domain 和Pub/Sub
Domain。
PTP的主要特點是:
1)一條消息只有一個使用者
2)不存在時間限制
Pub/Sub主要特點有:
1)一條消息可以有多個使用者
2)存在時間限制。訂閱者可以使用持久方式來訂閱消息,但是也會過期或者取消訂閱
這兩種接口都繼承統一的JMS Parent 接口,JMS 主要接口如下所示:
JMS Parent |
PTPDomain |
Pub/Sub Domain |
ConnectionFactory |
QueueConnectionFactory |
TopicConnectionFactory |
Connection |
QueueConnection |
TopicConnection |
Destination |
Queue |
Topic |
Session |
QueueSession |
TopicSession |
MessageProducer |
QueueSender |
TopicPublisher |
MessageConsumer |
QueueReceiver,QueueBrowser |
TopicSubscriber |
以下是對這些接口的簡單描述:
ConnectionFactory :連接工廠,JMS 用它創建連接
Connection :JMS 客戶端到JMS Provider 的連接
Destination :消息的目的地
Session: 一個發送或接收消息的線程
MessageProducer: 由Session 對象創建的用來發送消息的對象
MessageConsumer: 由Session 對象創建的用來接收消息的對象
2.JMS消息模型
JMS 消息由以下幾部分組成:消息頭,屬性,消息體。
消息頭(Header)
-消息頭包含消息的識別信息和路由信息,消息頭包含一些標準的屬性如:JMSDestination,JMSMessageID等。
消息頭 |
由誰設置 |
JMSDestination |
send 或 publish 方法 |
JMSDeliveryMode |
send 或 publish 方法 |
JMSExpiration |
send 或 publish 方法 |
JMSPriority |
send 或 publish 方法 |
JMSMessageID |
send 或 publish 方法 |
JMSTimestamp |
send 或 publish 方法 |
JMSCorrelationID |
客戶 |
JMSReplyTo |
客戶 |
JMSType |
客戶 |
JMSRedelivered |
JMS Provider |
屬性(Properties)
-除了消息頭中定義好的標準屬性外,JMS提供一種機制增加新屬性到消息頭中,這種新屬性包含以下幾種:
-
應用需要用到的屬性;
-
消息頭中原有的一些可選屬性;
-
JMS Provider 需要用到的屬性。
標準的JMS 消息頭包含以下屬性:
JMSDestination --消息發送的目的地。
JMSDeliveryMode
--傳遞模式,
有兩種模式:PERSISTENT和NON_PERSISTENT,PERSISTENT表示該消息一定要被送到目的地,否則會導致應用錯誤。
NON_PERSISTENT表示偶然丟失該消息是被允許的,這兩種模式使開發者可以在消息傳遞的可靠性和吞吐量之間找到平衡點。
JMSMessageID 唯一識別每個消息的標識,由JMS Provider 產生。
JMSTimestamp 一個消息被提交給JMS Provider 到消息被發出的時間。
JMSCorrelationID 用來連接到另外一個消息,典型的應用是在回復消息中連接到原消息。
JMSReplyTo 提供本消息回復消息的目的地址。
JMSRedelivered如果一個客戶端收到一個設置了JMSRedelivered屬性的消息,則表示可能該客戶端曾經在早些時候收到過該消息,但并沒有簽收(acknowledged)。
JMSType 消息類型的識別符。
JMSExpiration 消息過期時間,等于QueueSender
的send方法中的timeToLive值或TopicPublisher 的publish
方法中的timeToLive值加上發送時刻的GMT時間值。如果timeToLive值等于零,則JMSExpiration被設為零,表示該消息永不過期。如果發送后,在消息過期時間之后消息還沒有被發送到目的地,則該消息被清除。
JMSPriority 消息優先級,從0-9 十個級別,0-4 是普通消息,5-9 是加急消息。JMS 不要求JMS
Provider嚴格按照這十個優先級發送消息,但必須保證加急消息要先于普通消息到達。
消息體(Body) - JMS
API定義了5種消息體格式,也叫消息類型,你可以使用不同形式發送接收數據并可以兼容現有的消息格式,下面描述這5種類型:
消息類型 |
消息體 |
TextMessage |
java.lang.String對象,如xml文件內容 |
MapMessage |
名/值對的集合,名是String對象,值類型可以是Java任何基本類型 |
BytesMessage |
字節流 |
StreamMessage |
Java中的輸入輸出流 |
ObjectMessage |
Java中的可序列化對象 |
Message |
沒有消息體,只有消息頭和屬性 |
Message是以上5類的基礎。最常用的是ObjectMessage和TextMessage
3.消息的同步異步接收
消息的同步接收
同步接收是指客戶端主動去接收消息,JMS
客戶端可以采用MessageConsumer的receive方法去接收下一個消息。
消息的異步接收
異步接收是指當消息到達時,主動通知客戶端。JMS客戶端可以通過注冊一個實現MessageListener接口的對象到MessageConsumer,這樣,每當消息到達時,JMS
Provider 會調用MessageListener中的onMessage 方法。
4.PTP模型
PTP(Point-to-Point)模型是基于隊列的,發送方發消息到隊列,接收方從隊列接收消息,隊列的存在使得消息的異步傳輸成為可能。和郵件系統中的郵箱一樣,隊列可以包含各種消息,JMS
Provider 提供工具管理隊列的創建、刪除。JMS
PTP模型定義了客戶端如何向隊列發送消息,從隊列接收消息,瀏覽隊列中的消息。
下面描述JMS PTP 模型中的主要概念和對象:
名稱 |
描述 |
Queue |
由JMS Provider
管理,隊列由隊列名識別,客戶端可以通過JNDI接口用隊列名得到一個隊列對象。 |
TemporaryQueue |
由QueueConnection 創建,而且只能由創建它的QueueConnection 使用。 |
QueueConnectionFactory |
客戶端用QueueConnectionFactory 創建QueueConnection 對象。 |
QueueConnection |
一個到JMS PTP provider
的連接,客戶端可以用QueueConnection創建QueueSession來發送和接收消息。 |
QueueSession |
提
供一些方法創建QueueReceiver、QueueSender、QueueBrowser和TemporaryQueue。如果在
QueueSession關閉時,有一些消息已經被收到,但還沒有被簽收(acknowledged),那么,當接收者下次連接到相同的隊列時,這些消息
還會被再次接收。 |
QueueReceiver |
客戶端用QueueReceiver接收隊列中的消息,如果用戶在QueueReceiver中設定了消息選擇條件,那么不符合條件的消息會留在隊列中,不會被接收到。 |
QueueSender |
客戶端用QueueSender 發送消息到隊列。 |
QueueBrowser |
客戶端可以QueueBrowser 瀏覽隊列中的消息,但不會收走消息。 |
QueueRequestor |
JMS
提供QueueRequestor類簡化消息的收發過程。QueueRequestor的構造函數有兩個參數:QueueSession和queue,QueueRequestor
通過創建一個臨時隊列來完成最終的收發消息請求。 |
可靠性(Reliability) |
隊列可以長久地保存消息直到接收者收到消息。接收者不需要因為擔心消息會丟失而時刻和隊列保持激活的連接狀態,充分體現了異步傳輸模式的優勢。 |
4.Pub/Sub模型
JMS Pub/Sub 模型定義了如何向一個內容節點發布和訂閱消息,這些節點被稱作主題(topic)。
主題可以被認為是消息的傳輸中介,發布者(publisher)發布消息到主題,訂閱者(subscribe)從主題訂閱消息。主題使得消息訂閱者和消息發布者保持互相獨立,不需要接觸即可保證消息的傳送。
下面描述JMS Pub/Sub 模型中的主要概念和對象:
名稱 |
描述 |
訂閱(subscription) |
消息訂閱分為非持久訂閱(non-durable
subscription)和持久訂閱(durablesubscrip-tion),非持久訂閱只有當客戶端處于激活狀態,也就是和JMS
Provider保持連接狀態才能收到發送到某個主題的消息,而當客戶端處于離線狀態,這個時間段發到主題的消息將會丟失,永遠不會收到。持久訂閱時,客戶端向JMS注冊一個識別自己身份的ID,當這個客戶端處于離線時,JMS
Provider 會為這個ID 保存所有發送到主題的消息,當客戶再次連接到JMS
Provider時,會根據自己的ID得到所有當自己處于離線時發送到主題的消息。 |
Topic |
主題由JMS Provider
管理,主題由主題名識別,客戶端可以通過JNDI接口用主題名得到一個主題對象。JMS沒有給出主題的組織和層次結構的定義,由JMS
Provider 自己定義。 |
TemporaryTopic |
臨時主題由TopicConnection創建,而且只能由創建它的TopicConnection使用。臨時主題不能提供持久訂閱功能。 |
TopicConnectionFactory |
客戶端用TopicConnectionFactory 創建TopicConnection 對象。 |
TopicConnection |
TopicConnection 是一個到JMS Pub/Sub
provider的連接,客戶端可以用TopicConnection創建TopicSession來發布和訂閱消息。 |
TopicSession |
TopicSession提供一些方法創建TopicPublisher、TopicSubscriber、TemporaryTopic。它還提供unsubscribe方法取消消息的持久訂閱。 |
TopicPublisher |
客戶端用TopicPublisher 發布消息到主題。 |
TopicSubscriber |
客戶端用TopicSubscriber接收發布到主題上的消息。可以在TopicSubscriber中設置消息過濾功能,這樣,不符合要求的消息不會被接收。 |
Durable TopicSubscriber |
如果一個客戶端需要持久訂閱消息,可以使用Durable
TopicSubscriber,TopSession提供一個方法createDurableSubscriber創建Durable
TopicSubscriber 對象。 |
恢復和重新派送(Recovery and Redelivery) |
非持久訂閱狀態下,不能恢復或重新派送一個未簽收的消息。只有持久訂閱才能恢復或重新派送一個未簽收的消息。 |
TopicRequestor |
JMS
提供TopicRequestor類簡化消息的收發過程。TopicRequestor的構造函數有兩個參數:TopicSession和topic。TopicRequestor
通過創建一個臨時主題來完成最終的發布和接收消息請求。 |
可靠性(Reliability) |
當所有的消息必須被接收,則用持久訂閱模式。當丟失消息能夠被容忍,則用非持久訂閱模 |
posted on 2008-08-03 17:51
EvanLiu 閱讀(1357)
評論(0) 編輯 收藏 所屬分類:
Java基礎