【正文】 事務(wù)中接收信息，不管是從PTP模式的非臨時隊列接收消息還是從Pub/Sub模式持久訂閱中接收消息。 // msg_text is a String (message)。可以將消息選擇器作為MessageConsumer創(chuàng)建的一部分?；蛘邔崿F(xiàn)MessageListener接口，每當(dāng)消息到達(dá)時，ActiveMQ會調(diào)用MessageListener中的onMessage()函數(shù)。其中messageSelector為消息選擇器；noLocal標(biāo)志默認(rèn)為false，當(dāng)設(shè)置為true時限制消費者只能接收和自己相同的連接（Connection）所發(fā)布的消息，此標(biāo)志只適用于主題，不適用于隊列；name標(biāo)識訂閱主題所對應(yīng)的訂閱名稱，持久訂閱時需要設(shè)置此參數(shù)。其中deliveryMode為傳送模式，priority為消息優(yōu)先級，timeToLive為消息過期時間。 或者 Destination destination = ()。 Destination Destination是一個客戶端用來指定生產(chǎn)消息目標(biāo)和消費消息來源的對象。 關(guān)閉Connection Java客戶端： ActiveMQConnection方法： void close()。該文檔還指出 Connection應(yīng)該是進行客戶端身份驗證的地方，除了其他一些事項外，客戶端還可以指定惟一標(biāo)志符。 其中brokerURL為ActiveMQ服務(wù)地址和端口。 編程模版 ConnectionFactory（支持并發(fā)）要初始化JMS，則需要使用連接工廠。 Recovery and Redelivery (恢復(fù)和重新派送)非持久訂閱狀態(tài)下，不能恢復(fù)或重新派送一個未簽收的消息。Destination（Topic和TemporaryTopic）客戶端用Session 創(chuàng)建Destination對象。主題可以被認(rèn)為是消息的傳輸中介，發(fā)布者(publisher)發(fā)布消息到主題，訂閱者(subscribe) 從主題訂閱消息。Destination（Queue或TemporaryQueue）客戶端用 Session 創(chuàng)建Destination 對象。 3. JMS Provider需要用到的屬性。JMSPriority(消息優(yōu)先級)send方法從 09 十個級別，04 是普通消息，59 是加急消息。JMSDeliveryMode(傳送模式)send方法兩種模式: PERSISTENT可以向主題目標(biāo)發(fā)送消息的生產(chǎn)者的數(shù)量沒有限制，并且每個消息可以發(fā)送至任意數(shù)量的訂閱消費者。 PTP（使用 Queue即隊列目標(biāo)）消息從一個生產(chǎn)者傳送至一個消費者?？蛻舳耸褂?MessageProducer 向指定的物理目標(biāo)（在 API 中表示為目標(biāo)身份對象）發(fā)送消息。在 JMS 編程模型中，JMS 客戶端使用 ConnectionFactory 對象創(chuàng)建一個連接，向消息服務(wù)發(fā)送消息以及從消息服務(wù)接收消息均是通過此連接來進行。Java Message Service（JMS）是 SUN提出的旨在統(tǒng)一各種 MOM系統(tǒng)接口的規(guī)范，它包含點對點（Point to Point，PTP）和發(fā)布 /訂閱（Publish/Subscribe，pub/sub）兩種消息模型，提供可靠消息傳輸、事務(wù)和消息過濾等機制。1. 背景當(dāng)前，CORBA、DCOM、RMI等RPC中間件技術(shù)已廣泛應(yīng)用于各個領(lǐng)域。 2．JMS概述 JMS規(guī)范 JAVA 消息服務(wù)(JMS)定義了 Java 中訪問消息中間件的接口。Connection 是客戶端與消息服務(wù)的活動連接。生產(chǎn)者可指定一個默認(rèn)傳送模式（持久性消息與非持久性消息）、優(yōu)先級和有效期值，以控制生產(chǎn)者向物理目標(biāo)發(fā)送的所有消息。在此傳送模型中，目標(biāo)是一個隊列。主題目標(biāo)也支持持久訂閱的概念。和NON_PERSISTENT，PERSISTENTJMSMessageID(信息ID)send方法唯一識別每個消息的標(biāo)識，由JMS Provider 產(chǎn)生。如:標(biāo)準(zhǔn)的JMS消息頭包含以下屬性：上圖的10個屬性 消息體(Body) JMS API 定義了 5種消息體格式，也叫消息類型，可以使用不同形式發(fā)送接收數(shù)據(jù)并可以兼容現(xiàn)有的消息格式，下面描述這 5種類型：消息類型消息體TextMessage，如xml文件內(nèi)容MapMessage鍵/值對的集合，鍵是 String對象，值類型可以是Java任何基本類型BytesMessage字節(jié)流StreamMessageJava中的輸入輸出流ObjectMessageJava中的可序列化對象Message沒有消息體，只有消息頭和屬性 PTP模型 PTP(PointtoPoint)模型是基于隊列的，生產(chǎn)者發(fā)消息到隊列，消費者從隊列接收消息，隊列的存在使得消息的異步傳輸成為可能。此處的目標(biāo)為隊列，隊列由隊列名識別。主題使得消息訂閱者和消息發(fā)布者保持互相獨立，不需要接觸即可保證消息的傳送。此處的目標(biāo)為主題，主題由主題名識別。只有持久訂閱才能恢復(fù)或重新派送一個未簽收的消息。客戶端通過創(chuàng)建ConnectionFactory建立到ActveMQ的連接，一個連接工廠封裝了一組連接配置參數(shù)，這組參數(shù)在配置ActiveMQ時已經(jīng)定義，例如brokerURL參數(shù)，此參數(shù)傳入的是ActiveMQ服務(wù)地址和端口，支持openwire協(xié)議的默認(rèn)連接為tcp://localhost:61616，支持stomp協(xié)議的默認(rèn)連接為tcp://localhost:61613。例如：ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory(tcp://:61616)。當(dāng)一個 Connection被創(chuàng)建時，它的傳輸默認(rèn)是關(guān)閉的，必須使用start()方法開啟。例如：()。在PTP模式中，Destination被稱作Queue即隊列；在Pub/Sub模式，Destination被稱作Topic即主題。 MessageProducer MessageProducer是一個由Session創(chuàng)建的對象，用來向Destination發(fā)送消息。例如：(message)。例如：MessageConsumer consumer = (destination)。例如：Message message = ()。 Java客戶端：例如：public final String SELECTOR = “JMSType = ‘TOPIC_PUBLISHER’”。 下例演示接收消息并轉(zhuǎn)換為合適的消息類型： Message m = ()。對于其他程序，低可靠性可以降低開銷和提高性能，例如發(fā)送消息時可以更改消息的優(yōu)先級或者指定消息的過期時間。簽收可以由ActiveMQ發(fā)起，也可以由客戶端發(fā)起，取決于Session簽收模式的設(shè)置。 3．此選項指示Session不必確保對傳送消息的簽收。如果這時有消息過期或者高優(yōu)先級的消息到來，那么這時消息的傳送將會和最初的有所不同。雖然這樣增加了消息傳送的開銷，但卻增加了可靠性。例如：()。其中deliveryMode為傳送模式，priority為消息優(yōu)先級，timeToLive為消息過期時間?；蛘?void send(Destination destination, Message message, int deliveryMode, int priority, long timeToLive)。只有創(chuàng)建臨時目標(biāo)的Connection所創(chuàng)建的客戶端才可以從臨時目標(biāo)中接收消息，但是任何的生產(chǎn)者都可以向臨時目標(biāo)中發(fā)送消息。 Java客戶端：如下所示代碼段，將創(chuàng)建臨時的Destination，并將它放置在TextMessage的JMSReplyTo屬性中：Destination tempQueue = ()。 (REPLYTO_TEXT)。name標(biāo)識訂閱主題所對應(yīng)的訂閱名稱，持久訂閱時需要設(shè)置此參數(shù)。也就是說，可以將單個會話的上下文中執(zhí)行的一個或多個生產(chǎn)者或消費者操作組成一個本地事務(wù)。其中transacted為使用事務(wù)標(biāo)識，acknowledgeMode為簽收模式。在默認(rèn)大多數(shù)情況下，AcitveMQ是以異步模式發(fā)送消息。 在 Connection層面配置異步發(fā)送，此層面的設(shè)置將覆蓋ConnectionFactory層面的設(shè)置: ((ActiveMQConnection)connection).setUseAsyncSend(true)。 consumer = (queue)。如果消費者發(fā)生故障，那么ActiveMQ將自動故障轉(zhuǎn)移并選擇另一個消費者。例如可以利用混合目標(biāo)在同一操作中用向12個隊列發(fā)送同一條消息或者在同一操作中向一個主題和一個隊列發(fā)送同一條消息。=10)。 consumer = (queue)。 配置 JXM broker brokerName=emv219 useJmx=true xmlns= managementContext managementContext connectorPort=1099 jmxDomainName=/ /managementContext /broker 配置JXM步驟如下： 1．設(shè)置broker標(biāo)識的useJmx屬性為true； 2．取消對managementContext標(biāo)識的注釋（系統(tǒng)默認(rèn)注釋 managementContext標(biāo)識），監(jiān)控的默認(rèn)端口為1099。 目前版本的 C++客戶端僅支持 stomp協(xié)議目前版本的 C++客戶端程序（ActiveMQ CPP Release）僅支持stomp協(xié)議，因此傳輸消息的速度應(yīng)該沒有使用openwire協(xié)議的Java客戶端快。 分布式部署問題 ActiveMQ版本：ActiveMQ 測試選用上述兩個未正式發(fā)布的版本，未選用正式發(fā)布的ActiveMQ Release版本是因為此版本bug較多。 7. 目前存在問題 C++客戶端丟失消息問題 ActiveMQ版本：ActiveMQ C++客戶端版本：ActiveMQ CPP Release 測試中發(fā)現(xiàn)，當(dāng) C++客戶端異常退出時（即沒有正常調(diào)用close函數(shù)關(guān)閉連接），ActiveMQ并不能檢測到C++客戶端的連接已經(jīng)中斷，這時如果向隊列中發(fā)送消息，那么第一條消息就會丟失，這時ActiveMQ才能檢測到這個連接是中斷的。例如：當(dāng)要設(shè)置異步發(fā)送時，可以通過在 Configuration URI中使用 jms.$PROPERTY來設(shè)置。 消息預(yù)取 ActiveMQ的目標(biāo)之一就是高性能的數(shù)據(jù)傳送，所以ActiveMQ使用“預(yù)取限制”來控制有多少消息能及時的傳送給任何地方的消費者。 Java客戶端：例如：Queue queue = new ActiveMueue(,)。 consumer = (queue)。 consumer = (queue)。這樣的意義：可以以異步模式向處理消息慢的消費者分配消息；以同步模式向處理消息快的消費者分配消息。在這種情況下，send方法都是同步的，并且一直阻塞直到ActiveMQ發(fā)回確認(rèn)消息：消息已經(jīng)存儲在持久性數(shù)據(jù)存儲中。 提交 Java客戶端： ActiveMQSession方法： void mit()；例如：