【正文】 存儲中。 高級特征 異步發(fā)送消息 ActiveMQ支持生產(chǎn)者以同步或異步模式發(fā)送消息。 提交 Java客戶端： ActiveMQSession方法： void mit()；例如： try { (())。（換句話說，至目標(biāo)的消息傳送和隨后進(jìn)行的至客戶端的消息傳送不能放在同一個事務(wù)中。這意味著單個會話可以（例如）創(chuàng)建隊列和主題中的生產(chǎn)者，然后使用單個事務(wù)來同時發(fā)送隊列和主題的消息。在事務(wù)進(jìn)行回滾時，將取消所有成功的操作。 使用本地事務(wù)在事務(wù)中生成或使用消息時，ActiveMQ跟蹤各個發(fā)送和接收過程，并在客戶端發(fā)出提交事務(wù)的調(diào)用時完成這些操作。建立持久訂閱的步驟： 1．為連接設(shè)置一個客戶ID； 2．為訂閱的主題指定一個訂閱名稱；上述組合必須唯一。 高級可靠性機(jī)制 創(chuàng)建持久訂閱通過為發(fā)布者設(shè)置PERSISTENT傳送模式，為訂閱者時使用持久訂閱，這樣可以保證Pub/Sub程序接收所有發(fā)布的消息。 MessageProducer Sender = session. createProducer(tempQueue)。 消費(fèi)者接收這條消息時，會從JMSReplyTo字段中提取臨時Destination，并且會通過應(yīng)用程序構(gòu)造一個MessageProducer，以便將響應(yīng)消息發(fā)送回生產(chǎn)者。Message的屬性之一是JMSReplyTo屬性，這個屬性就是用于這個目的的。 Java客戶端： ActiveMQSession方法： TemporaryQueue createTemporaryQueue()。如果發(fā)送后，在消息過期時間之后消息還沒有被發(fā)送到目的地，則該消息被清除。其中deliveryMode為傳送模式，priority為消息優(yōu)先級，timeToLive為消息過期時間。如果消息在特定周期內(nèi)失去意義，那么可以設(shè)置過期時間。 消息優(yōu)先級從09十個級別，04是普通消息，59是加急消息。或者 void send(Destination destination, Message message, int deliveryMode, int priority, long timeToLive)。如果容忍消息丟失，那么使用非持久性消息可以改善性能和減少存儲的開銷。 void send(Message message, int deliveryMode, int priority, long timeToLive)。對于這些消息，可靠性并非主要的考慮因素。這意味著在持久性消息傳送至目標(biāo)時，消息服務(wù)將其放入持久性數(shù)據(jù)存儲。 指定消息傳送模式 ActiveMQ支持兩種消息傳送模式：PERSISTENT和NON_PERSISTENT兩種。對于非持久訂閱，AtiveMQ在用戶Session關(guān)閉時將刪除這些消息。 Java客戶端：簽收模式分別為： 1． 2． 3． ActiveMQConnection方法： Session createSession(boolean transacted, int acknowledgeMode)。 2．客戶端通過調(diào)用消息的acknowledge方法簽收消息。如果事務(wù)回滾，所有已經(jīng)接收的消息將會被再次傳送。 基本可靠性機(jī)制 控制消息的簽收（Acknowledgment）客戶端成功接收一條消息的標(biāo)志是這條消息被簽收。性能和可靠性之間的折衷是設(shè)計時要重點(diǎn)考慮的一個方面。如果事務(wù)中有一個步驟失敗，事務(wù)就回滾，這個事務(wù)中的已經(jīng)執(zhí)行的動作將被撤銷。 (Reading message: + ())。 (msg_text)。如果相等，則消息被消費(fèi)；如果不相等，那么消息會被忽略。按照J(rèn)MS文檔的說法，消息選擇器是一些字符串，它們基于某種語法，而這種語法是SQL92的子集。生產(chǎn)者可在消息中放入應(yīng)用程序特有的屬性，而消費(fèi)者可使用基于這些屬性的選擇標(biāo)準(zhǔn)來表明對消息是否感興趣。 Java客戶端： ActiveMQMessageConsumer方法： Message receive() Message receive(long timeout) Message receiveNoWait()其中timeout為等待時間，單位為毫秒。消息的異步接收是指當(dāng)消息到達(dá)時，ActiveMQ主動通知客戶端。 TopicSubscriber createDurableSubscriber(Topic topic, String name, String messageSelector, boolean noLocal)。 創(chuàng)建 MessageConsumer Java客戶端： ActiveMQSession方法： MessageConsumer createConsumer(Destination destination)。 void send(Message message, int deliveryMode, int priority, long timeToLive)。例如：MessageProducer producer = (destination)。例如：Destination destination = ()。 Java客戶端： ActiveMQSession方法： Queue createQueue(String queueName)。例如：Session session = (false, )。Session是一個發(fā)送或接收消息的線程，可以使用Session創(chuàng)建MessageProducer，MessageConsumer和Message。例如：()。當(dāng)一個程序執(zhí)行完成后，必須關(guān)閉之前創(chuàng)建的Connection，否則ActiveMQ不能釋放資源，關(guān)閉一個Connection同樣也關(guān)閉Session，MessageProducer和MessageConsumer。根據(jù)JMS文檔，Connection的目的是“利用JMS提供者封裝開放的連接”，以及表示“客戶端與提供者服務(wù)例程之間的開放TCP /IP套接字”。 connectionFactory. setBrokerURL(tcp://:61616)。 ActiveMQConnectionFactory(URI brokerURL)。Java客戶端： ActiveMQConnectionFactory構(gòu)造方法： ActiveMQConnectionFactory()。 1．ActiveMQ官方網(wǎng)站： 2．JMS官方網(wǎng)站： 開發(fā) JSM的步驟廣義上說，一個JMS應(yīng)用是幾個 JMS 客戶端交換消息，開發(fā) JMS 客戶端應(yīng)用由以下幾步構(gòu)成： JNDI 得到ConnectionFactory對象； ConnectionFactory創(chuàng)建 Connection對象； Connection 對象創(chuàng)建一個或多個JMS Session； 得到目標(biāo)隊列或主題對象，即Destination 對象； 和Destination 創(chuàng)建MessageProducer和MessageConsumer；。當(dāng)丟失消息能夠被容忍，則用非持久訂閱模式?？梢栽趓eceive 中設(shè)置消息過濾功能，這樣，不符合要求的消息不會被接收。臨時主題不能提供持久訂閱功能。它還提供持久訂閱主題，或使用unsubscribe 方法取消消息的持久訂閱。持久訂閱時，客戶端向JMS 注冊一個識別自己身份的ID，當(dāng)這個客戶端處于離線時，JMS Provider 會為這個ID 保存所有發(fā)送到主題的消息，當(dāng)客戶再次連接到JMS Provider 時，會根據(jù)自己的ID 得到所有當(dāng)自己處于離線時發(fā)送到主題的消息。 PUB/SUB模型JMS Pub/Sub 模型定義了如何向一個內(nèi)容節(jié)點(diǎn)發(fā)布和訂閱消息，這些節(jié)點(diǎn)被稱作主題(topic)。MessageProducer客戶端用MessageProducer 發(fā)送消息到隊列。如果在Session 關(guān)閉時，有一些消息已經(jīng)被收到，但還沒有被簽(acknowledged)，那么，當(dāng)消費(fèi)者下次連接到相同的隊列時，這些消息還會被再次接收。JMS PTP 模型定義了客戶端如何向隊列發(fā)送消息，從隊列接收消息，瀏覽隊列中的消息。 。JMSCorrelationID(回復(fù)ID)客戶用來連接到另外一個消息，典型的應(yīng)用是在回復(fù)消息中連接到原消息。如果發(fā)送后，在消息過期時間之后消息還沒有被發(fā)送到目的地，則該消息被清除。NON_PERSISTENT消息頭由誰設(shè)置描述JMSDestination(目的地)send方法消息發(fā)送的目的地。當(dāng)此消費(fèi)者再次處于活動狀態(tài)時，它將接收此信息。消息首先被傳送至主題目標(biāo)，然后傳送至所有已訂閱此主題的活動消費(fèi)者?？梢韵蜿犃心繕?biāo)發(fā)送消息的生產(chǎn)者的數(shù)量沒有限制，但每條消息只能發(fā)送至、并由一個消費(fèi)者成功使用。 JMS編程域 JMS 支持兩種截然不同的消息傳送模型：PTP（即點(diǎn)對點(diǎn)模型）和 Pub/Sub（即發(fā)布 /訂閱模型），分別稱作：PTP Domain 和 Pub/Sub Domain。消費(fèi)者可使用消息選擇器，借助它，消息服務(wù)可以只向消費(fèi)者發(fā)送與選擇標(biāo)準(zhǔn)匹配的那些消息。會話通過大量確認(rèn)選項或通過事務(wù)來支持可靠傳送。這是一個相當(dāng)重要的對象，大多數(shù)客戶端均使用一個連接來進(jìn)行所有的消息傳送。這些消息傳送操作是使用一組實(shí)現(xiàn) JMS 應(yīng)用編程接口 (API) 的對象（由 JMS Provide提供）來執(zhí)行的。 術(shù)語 JMS Provider：實(shí)現(xiàn)JMS 接口的消息中間件（provider:供應(yīng)者）； PTP：Point to Point，即點(diǎn)對點(diǎn)的消息模型； Pub/Sub：Publish/Subscribe，即發(fā)布/訂閱的消息模型； Queue：隊列目標(biāo)； Topic：主題目標(biāo)；Transaction：事務(wù)。由于沒有一個通用的標(biāo)準(zhǔn)，這些系統(tǒng)很難實(shí)現(xiàn)互操作和無縫連接。面向消息的中間件（Message Oriented Middleware，MOM）較好的解決了以上問題。但是面對規(guī)模和復(fù)雜度都越來越高的分布式系統(tǒng)，這些技術(shù)也顯示出其局限性：（1）同步通信：客戶發(fā)出調(diào)用后，必須等待服務(wù)對象完成處理并返回結(jié)果后才能繼續(xù)執(zhí)行；（2）客戶和服務(wù)對象的生命周期緊密耦合：客戶進(jìn)程和服務(wù)對象進(jìn)程都必須正常運(yùn)行；如果由于服務(wù)對象崩潰或者網(wǎng)絡(luò)故障導(dǎo)致客戶的請求不可達(dá)，客戶會接收到異常；（3）點(diǎn)對點(diǎn)通信：客戶的一次調(diào)用只發(fā)送給某個單獨(dú)的目標(biāo)對象。已有的 MOM系統(tǒng)包括 IBM的 MQSeries、Microsoft的MSMQ和BEA的MessageQ等。JMS 只是接口，并沒有給予實(shí)現(xiàn)，實(shí)現(xiàn) JMS 接口的消息中間件稱為 JMS Provider，例如 ActiveMQ。消息生產(chǎn)者將消息發(fā)送至消息服務(wù)，消息消費(fèi)者則從消息服務(wù)接收這些消息。創(chuàng)建連接時，將分配通信資源以及驗證客戶端。它用于創(chuàng)建發(fā)送的生產(chǎn)者和接收消息的消費(fèi)者，并為所發(fā)送的消息定義發(fā)送順序。同樣，客戶端使用 MessageConsumer 對象從指定的物理目標(biāo)（在 API 中表示為目標(biāo)對象）接收消息。當(dāng)會話線程調(diào)用 MessageListener 對象的 onMessage()方法時，客戶端將使用消息。消息首先被傳送至隊列目標(biāo)，然后根據(jù)隊列傳送策略，從該隊列將消息傳送至向此隊列進(jìn)行注冊的某一個消費(fèi)者，一次只傳送一條消息。在此傳送模型中，目標(biāo)是一個主題。持久訂閱表