【正文】 ActiveMQ網(wǎng)站顯示不久將會(huì)有支持openwire協(xié)議的C++客戶端程序發(fā)布。 在Windows平臺(tái)監(jiān)控進(jìn)入%JAVA_HOME%/bin，在對(duì)話框中輸入ActiveMQ服務(wù)主機(jī)的地址，JXM的端口和主機(jī)登陸帳號(hào)。 配置連接 URL ActiveMQ支持通過Configuration URI明確的配置連接屬性。 consumer = (queue)。在混合目標(biāo)中，通過“,”來分隔不同的目標(biāo)?？梢匀缦略O(shè)置： Java客戶端： queue = new ActiveMueue(?=true)。 消費(fèi)者優(yōu)先級(jí)在ActveMQ分布式環(huán)境中，在有消費(fèi)者存在的情況下，如果更希望 ActveMQ發(fā)送消息給消費(fèi)者而不是其他的ActveMQ到ActveMQ的傳送，可以如下設(shè)置： Java客戶端： queue = new ActiveMueue(?=10)。 消費(fèi)者特色 消費(fèi)者異步分派在 ActiveMQ4中，支持ActiveMQ以同步或異步模式向消費(fèi)者分派消息。例外的情況：在沒有使用事務(wù)的情況下，生產(chǎn)者以PERSISTENT傳送模式發(fā)送消息。例如：Session session = (true, )。不但單個(gè)會(huì)話可以訪問Queue 或 Topic（任一類型的 Destination ），而且單個(gè)會(huì)話實(shí)例可以用來操縱一個(gè)或多個(gè)隊(duì)列以及一個(gè)或多個(gè)主題，一切都在單個(gè)事務(wù)中進(jìn)行。 刪除持久訂閱 Java客戶端： ActiveMQSession方法： void unsubscribe(String name)。 (msg)。 (tempQueue)。如果關(guān)閉了創(chuàng)建此目標(biāo)的Connection，那么臨時(shí)目標(biāo)被關(guān)閉，內(nèi)容也將消失。 void send(Message message, int deliveryMode, int priority, long timeToLive)。例如：(4)。 如果不指定傳送模式，那么默認(rèn)是持久性消息。 2．NON_PERSISTENT（非持久性消息）保證這些消息最多被傳送一次。對(duì)于非持久訂閱用戶，重啟后，ActiveMQ有可能刪除所有沒有簽收的消息。它可能引起消息的重復(fù)，但是降低了Session的開銷，所以只有客戶端能容忍重復(fù)的消息，才可使用（如果ActiveMQ再次傳送同一消息那么消息頭中的JMSRedelivered將被設(shè)置為true）。在帶事務(wù)的Session中，簽收自動(dòng)發(fā)生在事務(wù)提交時(shí)。消息傳送的可靠性越高，需要的開銷和帶寬就越多。 if (m instanceof TextMessage) { TextMessage message = (TextMessage) m。 該選擇器檢查了傳入消息的 JMSType屬性，并確定了這個(gè)屬性的值是否等于 TOPIC _PUBLISHER。 JMS提供了一種機(jī)制，使用它，消息服務(wù)可根據(jù)消息選擇器中的標(biāo)準(zhǔn)來執(zhí)行消息過濾。 消息的同步接收是指客戶端主動(dòng)去接收消息，客戶端可以采用MessageConsumer的receive()方法去接收下一個(gè)消息。 MessageConsumer MessageConsumer是一個(gè)由Session創(chuàng)建的對(duì)象，用來從Destination接收消息。 創(chuàng)建 MessageProducer Java客戶端： ActiveMQSession方法： MessageProducer createProducer(Destination destination)。在程序中可以使用多個(gè) Queue和Topic。 Session一旦從ConnectionFactory中獲得一個(gè)Connection，就必須從Connection中創(chuàng)建一個(gè)或者多個(gè)Session。一個(gè) Connection可以建立一個(gè)或多個(gè)的Session。 或者 ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory()。注：由于C++客戶端暫時(shí)僅支持stomp協(xié)議，所以需要使用 tcp://localhost:61613。 Reliability (可靠性)當(dāng)所有的消息必須被接收，則用持久訂閱模式。臨時(shí)主題只能由創(chuàng)建它的Connection 所創(chuàng)建的消費(fèi)者消費(fèi)。下面描述 JMS Pub/Sub 模型中的主要概念和對(duì)象：名稱描述 subscription (訂閱)消息訂閱分為非持久訂閱(nondurablesubscription)和持久訂閱(durablesubscription)，非持久訂閱只有當(dāng)客戶端處于激活狀態(tài)，也就是和JMS Provider 保持連接狀態(tài)才能收到發(fā)送到某個(gè)主題的消息，而當(dāng)客戶端處于離線狀態(tài)，這個(gè)時(shí)間段發(fā)到主題的消息將會(huì)丟失，永遠(yuǎn)不會(huì)收到。臨時(shí)隊(duì)列只能由創(chuàng)建它的Connection 所創(chuàng)建的消費(fèi)者消費(fèi)，但是任何生產(chǎn)者都可向臨時(shí)隊(duì)列發(fā)送消息。和郵件系統(tǒng)中的郵箱一樣，隊(duì)列可以包含各種消息，JMS Provider 提供工具管理隊(duì)列的創(chuàng)建、刪除。JMSTimestamp(時(shí)間戳)send方法一個(gè)消息被提交給JMS Provider 到消息被發(fā)出的時(shí)間。表示該消息一定要被送到目的地，否則會(huì)導(dǎo)致應(yīng)用錯(cuò)誤。持久訂閱表示消費(fèi)者已向主題目標(biāo)進(jìn)行注冊(cè)，但在消息傳送時(shí)此消費(fèi)者可以處于非活動(dòng)狀態(tài)。消息首先被傳送至隊(duì)列目標(biāo)，然后根據(jù)隊(duì)列傳送策略，從該隊(duì)列將消息傳送至向此隊(duì)列進(jìn)行注冊(cè)的某一個(gè)消費(fèi)者，一次只傳送一條消息。同樣，客戶端使用 MessageConsumer 對(duì)象從指定的物理目標(biāo)（在 API 中表示為目標(biāo)對(duì)象）接收消息。創(chuàng)建連接時(shí)，將分配通信資源以及驗(yàn)證客戶端。JMS 只是接口，并沒有給予實(shí)現(xiàn)，實(shí)現(xiàn) JMS 接口的消息中間件稱為 JMS Provider，例如 ActiveMQ。但是面對(duì)規(guī)模和復(fù)雜度都越來越高的分布式系統(tǒng)，這些技術(shù)也顯示出其局限性：（1）同步通信：客戶發(fā)出調(diào)用后，必須等待服務(wù)對(duì)象完成處理并返回結(jié)果后才能繼續(xù)執(zhí)行；（2）客戶和服務(wù)對(duì)象的生命周期緊密耦合：客戶進(jìn)程和服務(wù)對(duì)象進(jìn)程都必須正常運(yùn)行；如果由于服務(wù)對(duì)象崩潰或者網(wǎng)絡(luò)故障導(dǎo)致客戶的請(qǐng)求不可達(dá)，客戶會(huì)接收到異常；（3）點(diǎn)對(duì)點(diǎn)通信：客戶的一次調(diào)用只發(fā)送給某個(gè)單獨(dú)的目標(biāo)對(duì)象。由于沒有一個(gè)通用的標(biāo)準(zhǔn)，這些系統(tǒng)很難實(shí)現(xiàn)互操作和無縫連接。這些消息傳送操作是使用一組實(shí)現(xiàn) JMS 應(yīng)用編程接口 (API) 的對(duì)象（由 JMS Provide提供）來執(zhí)行的。會(huì)話通過大量確認(rèn)選項(xiàng)或通過事務(wù)來支持可靠傳送。 JMS編程域 JMS 支持兩種截然不同的消息傳送模型：PTP（即點(diǎn)對(duì)點(diǎn)模型）和 Pub/Sub（即發(fā)布 /訂閱模型），分別稱作：PTP Domain 和 Pub/Sub Domain。消息首先被傳送至主題目標(biāo)，然后傳送至所有已訂閱此主題的活動(dòng)消費(fèi)者。消息頭由誰設(shè)置描述JMSDestination(目的地)send方法消息發(fā)送的目的地。如果發(fā)送后，在消息過期時(shí)間之后消息還沒有被發(fā)送到目的地，則該消息被清除。 。如果在Session 關(guān)閉時(shí)，有一些消息已經(jīng)被收到，但還沒有被簽(acknowledged)，那么，當(dāng)消費(fèi)者下次連接到相同的隊(duì)列時(shí)，這些消息還會(huì)被再次接收。 PUB/SUB模型JMS Pub/Sub 模型定義了如何向一個(gè)內(nèi)容節(jié)點(diǎn)發(fā)布和訂閱消息，這些節(jié)點(diǎn)被稱作主題(topic)。它還提供持久訂閱主題，或使用unsubscribe 方法取消消息的持久訂閱?？梢栽趓eceive 中設(shè)置消息過濾功能，這樣，不符合要求的消息不會(huì)被接收。 1．ActiveMQ官方網(wǎng)站： 2．JMS官方網(wǎng)站： 開發(fā) JSM的步驟廣義上說，一個(gè)JMS應(yīng)用是幾個(gè) JMS 客戶端交換消息，開發(fā) JMS 客戶端應(yīng)用由以下幾步構(gòu)成： JNDI 得到ConnectionFactory對(duì)象； ConnectionFactory創(chuàng)建 Connection對(duì)象； Connection 對(duì)象創(chuàng)建一個(gè)或多個(gè)JMS Session； 得到目標(biāo)隊(duì)列或主題對(duì)象，即Destination 對(duì)象； 和Destination 創(chuàng)建MessageProducer和MessageConsumer；。 ActiveMQConnectionFactory(URI brokerURL)。根據(jù)JMS文檔，Connection的目的是“利用JMS提供者封裝開放的連接”，以及表示“客戶端與提供者服務(wù)例程之間的開放TCP /IP套接字”。例如：()。例如：Session session = (false, )。例如：Destination destination = ()。 void send(Message message, int deliveryMode, int priority, long timeToLive)。 TopicSubscriber createDurableSubscriber(Topic topic, String name, String messageSelector, boolean noLocal)。 Java客戶端： ActiveMQMessageConsumer方法： Message receive() Message receive(long timeout) Message receiveNoWait()其中timeout為等待時(shí)間，單位為毫秒。按照J(rèn)MS文檔的說法，消息選擇器是一些字符串，它們基于某種語法，而這種語法是SQL92的子集。 (msg_text)。如果事務(wù)中有一個(gè)步驟失敗，事務(wù)就回滾，這個(gè)事務(wù)中的已經(jīng)執(zhí)行的動(dòng)作將被撤銷。 基本可靠性機(jī)制 控制消息的簽收（Acknowledgment）客戶端成功接收一條消息的標(biāo)志是這條消息被簽收。 2．客戶端通過調(diào)用消息的acknowledge方法簽收消息。對(duì)于非持久訂閱，AtiveMQ在用戶Session關(guān)閉時(shí)將刪除這些消息。這意味著在持久性消息傳送至目標(biāo)時(shí)，消息服務(wù)將其放入持久性數(shù)據(jù)存儲(chǔ)。 void send(Message message, int deliveryMode, int priority, long timeToLive)。或者 void send(Destination destination, Message message, int deliveryMode, int priority, long timeToLive)。如果消息在特定周期內(nèi)失去意義，那么可以設(shè)置過期時(shí)間。如果發(fā)送后，在消息過期時(shí)間之后消息還沒有被發(fā)送到目的地，則該消息被清除。Message的屬性之一是JMSReplyTo屬性，這個(gè)屬性就是用于這個(gè)目的的。 MessageProducer Sender = session. createProducer(tempQueue)。建立持久訂閱的步驟： 1．為連接設(shè)置一個(gè)客戶ID； 2．為訂閱的主題指定一個(gè)訂閱名稱；上述組合必須唯一。在事務(wù)進(jìn)行回滾時(shí)，將取消所有成功的操作。（換句話說，至目標(biāo)的消息傳送和隨后進(jìn)行的至客戶端的消息傳送不能放在同一個(gè)事務(wù)中。 高級(jí)特征 異步發(fā)送消息 ActiveMQ支持生產(chǎn)者以同步或異步模式發(fā)送消息。 Java客戶端：使用 Connection URI配置異步發(fā)送: cf = new ActiveMQCo