【正文】 nnectionFactory(tcp://locahost:61616?=true)。 在 Connection層面配置同步分派，此層面的設(shè)置將覆蓋ConnectionFactory層面的設(shè)置：((ActiveMQConnection)connection).setDispatchAsync(false)。ActiveMQ4支持獨(dú)占的消費(fèi)。屬性默認(rèn)值collisionAvoidanceFactormaximumRedeliveries6initialRedeliveryDelay1000LuseCollisionAvoidancefalseuseExponentialBackOfffalsebackOffMultiplier5 目標(biāo)特色 復(fù)合目標(biāo)，ActiveMQ支持混合目標(biāo)技術(shù)。 (queue, someMessage)。如果有少量的消息并且每條消息的處理都要花費(fèi)很長的時(shí)間，那么可以設(shè)置預(yù)取值為1，這樣同一時(shí)間，ActiveMQ只會(huì)為這個(gè)消費(fèi)者分派一條消息。Java客戶端默認(rèn)使用openwire協(xié)議，所以ActiveMQ服務(wù)地址為tcp://localhost:61616；目前C++客戶端僅支持stomp協(xié)議，所以ActiveMQ服務(wù)地址為tcp://localhost:61613。 隊(duì)列消息堆積過多后有可能阻塞程序，這就意味著當(dāng)消息堆積超過20M后，程序可能出現(xiàn)問題。這時(shí)分布式的消息傳輸就會(huì)出現(xiàn)問題，此問題目前還沒找到原因。但是此模式會(huì)造成消息重復(fù)接收。屬性默認(rèn)值alwaysSessionAsynctrueclientIDnullcloseTimeout15000(毫秒)copyMessageOnSendtruedisableTimeStampsByDefaultfasledispatchAsyncfaslenestedMapAndListEnabledtrueobjectMessageSerializationDeferedfasleoptimizeAcknowledgefalseoptimizedMessageDispatchtrueuseAsyncSendfalseuseCompressionfalseuseRetroactiveConsumerfalse 優(yōu)化優(yōu)化部分請(qǐng)參閱：6. ActiveMQ配置 配置文件 ActiveMQ配置文件：$AcrtiveMQ/conf/ 配置 ActiveMQ服務(wù)IP和端口 transportConnectors transportConnector name=openwire uri=tcp://localhost:61616 discoveryUri=mu lticast://default/ transportConnector name=ssl uri=ssl://localhost:61617/ transportConnector name=stomp uri=stomp://localhost:61613/ /transportConnectors 在transportConnectors標(biāo)識(shí)中配置ActiveMQ服務(wù)IP和端口，其中name屬性指定協(xié)議的名稱，uri屬性指定協(xié)議所對(duì)應(yīng)的協(xié)議名，IP地址和端口號(hào)?？梢詾槊總€(gè)消費(fèi)者指定消息預(yù)取。 如果在一個(gè)目標(biāo)中混合不同類別的目標(biāo)，可以通過使用“queue://”和“topic://”前綴來識(shí)別不同的目標(biāo)。 3．在Session中使用CLIENT_ACKNOWLEDGE簽收模式，并且調(diào)用了recover()方法。但是如果建立了多個(gè)Session和MessageConsumer，那么同一時(shí)刻多個(gè)線程同時(shí)從一個(gè)隊(duì)列中接收消息時(shí)就并不能保證處理時(shí)有序。但是對(duì)于處理消息慢的消費(fèi)者，需要以異步模式分派。高性能的程序一般都能容忍在故障情況下丟失少量數(shù)據(jù)。 } catch (JMSException ex) { ()。類似地，單個(gè)事務(wù)可以用來接收隊(duì)列中的消息并將消息發(fā)送到主題上，反過來也可以?？蛻舳舜a通過忽略異常、重試操作或回滾整個(gè)事務(wù)來處理異常。持久訂閱時(shí)，客戶端向ActiveMQ注冊(cè)一個(gè)識(shí)別自己身份的ID，當(dāng)這個(gè)客戶端處于離線時(shí)，ActiveMQ會(huì)為這個(gè)ID保存所有發(fā)送到主題的消息，當(dāng)客戶端再次連接到ActiveMQ時(shí)，會(huì)根據(jù)自己的ID得到所有當(dāng)自己處于離線時(shí)發(fā)送到主題的消息。它還展示了客戶端可以既是消息的生產(chǎn)者，又可以是消息的消費(fèi)者。 某些客戶端需要一個(gè)目標(biāo)來接收對(duì)發(fā)送至其他客戶端的消息的回復(fù)。 消息過期時(shí)間，send方法中的timeToLive 值加上發(fā)送時(shí)刻的GMT時(shí)間值。JMS不要求嚴(yán)格按照這十個(gè)優(yōu)先級(jí)發(fā)送消息但必須保證加急消息要先于普通消息到達(dá)。然而，如果為這些消息分配了不同的優(yōu)先級(jí)，消息傳送系統(tǒng)將首先嘗試傳送優(yōu)先級(jí)較高的消息。有兩種方法指定傳送模式： 1．使用 setDeliveryMode方法，這樣所有的消息都采用此傳送模式； 2．使用 send方法為每一條消息設(shè)置傳送模式； Java客戶端：傳送模式分別為： 1． 2． ActiveMQMessageProducer方法： void setDeliveryMode(int newDeliveryMode)。對(duì)于這些消息，可靠性是優(yōu)先考慮的因素。 對(duì)隊(duì)列來說，如果當(dāng)一個(gè)Session終止時(shí)它接收了消息但是沒有簽收，那么ActiveMQ將保留這些消息并將再次傳送給下一個(gè)進(jìn)入隊(duì)列的消費(fèi)者。 1．當(dāng)客戶端從receive或onMessage成功返回時(shí)，Session自動(dòng)簽收客戶端的這條消息的收條。另一方面，也可以通過生成和使用持久性消息并使用事務(wù)會(huì)話來獲得最佳可靠性。結(jié)束事務(wù)有兩種方法：提交或者回滾。Message由以下幾部分組成：消息頭，屬性和消息體。然而，它也使得處理選擇標(biāo)準(zhǔn)的消息服務(wù)增加了一些額外開銷。MessageListener只有一個(gè)必須實(shí)現(xiàn)的方法 onMessage()，它只接收一個(gè)參數(shù)，即Message。 MessageConsumer createConsumer(Destination destination, String messageSelector, boolean noLocal)。 void send(Destination destination, Message message, int deliveryMode, int priority,long timeToLive)。 Topic createTopic(String topicName)。 Java客戶端： ActiveMQConnection方法： Session createSession(boolean transacted, int acknowledgeMode)。例如：Connection connection = ()。ConnectionFactory負(fù)責(zé)返回可以與底層消息傳遞系統(tǒng)進(jìn)行通信的 Connection實(shí)現(xiàn)。 ActiveMQConnectionFactory(String userName, String password, String brokerURL) 。啟動(dòng)ActiveMQ以后，登陸：://localhost:8161/admin/，創(chuàng)建一個(gè)Queue，命名為FirstQueue。MessageProducer客戶端用MessageProducer 發(fā)布消息到主題。Connection一個(gè)到 JMS Provider 的連接，客戶端可以用Connection 創(chuàng)建Session 來發(fā)送和接收消息。Reliability (可靠性)隊(duì)列可以長久地保存消息直到消費(fèi)者收到消息。Connection 一個(gè)到 JMS Provider 的連接，客戶端可以Connection 創(chuàng)建Session 來發(fā)送和接收消息。JMSRedelivered(再次發(fā)送)JMS Provider如果一個(gè)客戶端收到一個(gè)設(shè)置JMSRedelivered屬性的消息，則表示可能客戶端曾經(jīng)在早些時(shí)候收到過該消息，但并沒有簽收(acknowledged)。JMSExpiration(消息過期時(shí)間)send方法等于 Destination 的send 方法中的timeToLive 值加上發(fā)送時(shí)刻的GMT 時(shí)間值。這兩種消息傳送模型使用表示不同編程域的 API 對(duì)象（其語義稍有不同）進(jìn)行處理，如下所示：基本類型統(tǒng)一域PTP域Pub/Sub域ConnectionFactoryQueueConnectionFactoryTopicConnectionFactory ConnectionQueueConnectionTopicConnection SessionQueueSessionTopicPublisher Destination（Queue或 Topic）QueueTopic MessageProducerQueueSenderMessageConsumerQueueReceiver QueueBrowserTopicSubscriber JMS消息結(jié)構(gòu) JMS 消息由以下幾部分組成：消息頭，屬性和消息體。 Pub/Sub（使用Topic即主題目標(biāo)）消息從一個(gè)生產(chǎn)者傳送至任意數(shù)量的消費(fèi)者。異步使用可通過向消費(fèi)者注冊(cè) MessageListener 來實(shí)現(xiàn)。Session 是一個(gè)用于生成和使用消息的單線程上下文。 JMS編程模型在 JMS 編程模型中，JMS 客戶端（組件或應(yīng)用程序）通過 JMS 消息服務(wù)交換消息。這種模式下，1）發(fā)送和接收是異步的，發(fā)送者無需等待；2）二者的生命周期未必相同：發(fā)送消息的時(shí)候接收者不一定運(yùn)行，接收消息的時(shí)候發(fā)送者也不一定運(yùn)行；3）一對(duì)多通信：對(duì)于一個(gè)消息可以有多個(gè)接收者。發(fā)送者將消息發(fā)送給消息服務(wù)器，消息服務(wù)器將消息存放在若干隊(duì)列中，在合適的時(shí)候再將消息轉(zhuǎn)發(fā)給接收者。 ConnectionFactory：連接工廠，JMS 用它創(chuàng)建連接； Connection：JMS 客戶端到JMS Provider 的連接； Destination：消息的目的地；Acknowledge：簽收； Session：會(huì)話，一個(gè)發(fā)送或接收消息的線程；MessageProducer：由 Session 對(duì)象創(chuàng)建的用來發(fā)送消息的對(duì)象； MessageConsumer：由 Session 對(duì)象創(chuàng)建的用來接收消息的對(duì)象。連接用于創(chuàng)建會(huì)話。消費(fèi)者可以支持同步或異步消息接收。如果沒有已經(jīng)向隊(duì)列目標(biāo)注冊(cè)的消費(fèi)者，隊(duì)列將保留它收到的消息，并在某個(gè)消費(fèi)者向該隊(duì)列進(jìn)行注冊(cè)時(shí)將消息傳送給該消費(fèi)者。如果沒有已經(jīng)向主題目標(biāo)注冊(cè)的消費(fèi)者，主題不保留其接收到的消息，除非有非活動(dòng)消費(fèi)者注冊(cè)了持久訂閱。表示偶然丟失該消息是被允許的，這兩種模式使開發(fā)者可以在消息傳送的可靠性和吞吐量之間找到平衡點(diǎn)。JMSReplyTo（回復(fù)地址）客戶提供本消息回復(fù)消息的目的地址JMSType(類型)客戶消息類型的識(shí)別符。下面描述 JMS PTP 模型中的主要概念和對(duì)象：名稱描述ConnectionFactory客戶端用 Connecti