【正文】 tory).setDispatchAsync(false)。 在 Connection層面配置同步分派，此層面的設置將覆蓋ConnectionFactory層面的設置：((ActiveMQConnection)connection).setDispatchAsync(false)。 在消費者層面以Destination URI配置同步分派，此層面的設置將覆蓋ConnectionFactory和 Connection層面的設置: queue = new ActiveMueue(?=false)。 consumer = (queue)。 消費者優(yōu)先級在ActveMQ分布式環(huán)境中，在有消費者存在的情況下，如果更希望 ActveMQ發(fā)送消息給消費者而不是其他的ActveMQ到ActveMQ的傳送，可以如下設置： Java客戶端： queue = new ActiveMueue(?=10)。 consumer = (queue)。 獨占的消費者 ActiveMQ維護隊列消息的順序并順序把消息分派給消費者。但是如果建立了多個Session和MessageConsumer，那么同一時刻多個線程同時從一個隊列中接收消息時就并不能保證處理時有序。有時候有序處理消息是非常重要的。ActiveMQ4支持獨占的消費。ActiveMQ挑選一個MessageConsumer，并把一個隊列中所有消息按順序分派給它。如果消費者發(fā)生故障，那么ActiveMQ將自動故障轉移并選擇另一個消費者?？梢匀缦略O置： Java客戶端： queue = new ActiveMueue(?=true)。 consumer = (queue)。 再次傳送策略在以下三種情況中，消息會被再次傳送給消費者： 1．在使用事務的Session中，調用rollback()方法； 2．在使用事務的Session中，調用mit()方法之前就關閉了Session。 3．在Session中使用CLIENT_ACKNOWLEDGE簽收模式，并且調用了recover()方法?？梢酝ㄟ^設置ActiveMQConnectionFactory和ActiveMQConnection來定制想要的再次傳送策略。屬性默認值collisionAvoidanceFactormaximumRedeliveries6initialRedeliveryDelay1000LuseCollisionAvoidancefalseuseExponentialBackOfffalsebackOffMultiplier5 目標特色 復合目標，ActiveMQ支持混合目標技術。它允許在一個JMS目標中使用一組 JMS目標。例如可以利用混合目標在同一操作中用向12個隊列發(fā)送同一條消息或者在同一操作中向一個主題和一個隊列發(fā)送同一條消息。在混合目標中，通過“,”來分隔不同的目標。 Java客戶端：例如：Queue queue = new ActiveMueue(,)。 (queue, someMessage)。 如果在一個目標中混合不同類別的目標，可以通過使用“queue://”和“topic://”前綴來識別不同的目標。例如：Queue queue = new ActiveMueue(,topic://)。 (queue, someMessage)。 目標選項Java客戶端：例如： 屬性默認值variableageLimit0falsefalsefaslenullfalse0Queue = new ActiveMueue(?=falseamp。=10)。 consumer = (queue)。 消息預取 ActiveMQ的目標之一就是高性能的數(shù)據(jù)傳送，所以ActiveMQ使用“預取限制”來控制有多少消息能及時的傳送給任何地方的消費者。一旦預取數(shù)量達到限制，那么就不會有消息被分派給這個消費者直到它發(fā)回簽收消息（用來標識所有的消息已經(jīng)被處理）?？梢詾槊總€消費者指定消息預取。如果有大量的消息并且希望更高的性能，那么可以為這個消費者增大預取值。如果有少量的消息并且每條消息的處理都要花費很長的時間，那么可以設置預取值為1，這樣同一時間，ActiveMQ只會為這個消費者分派一條消息。 Java客戶端：在ConnectionFactory層面為所有消費者配置預取值: tcp://localhost:61616?=50在 ConnectionFactory層面為隊列消費者配置預取值: tcp://localhost:61616?=1使用“目標選項”為一個消費者配置預取值: queue = new ActiveMueue(?=10)。 consumer = (queue)。 配置連接 URL ActiveMQ支持通過Configuration URI明確的配置連接屬性。例如：當要設置異步發(fā)送時，可以通過在 Configuration URI中使用 jms.$PROPERTY來設置。 tcp://localhost:61616?=true以下的選項在URI必須以“jms.”為前綴。屬性默認值alwaysSessionAsynctrueclientIDnullcloseTimeout15000(毫秒)copyMessageOnSendtruedisableTimeStampsByDefaultfasledispatchAsyncfaslenestedMapAndListEnabledtrueobjectMessageSerializationDeferedfasleoptimizeAcknowledgefalseoptimizedMessageDispatchtrueuseAsyncSendfalseuseCompressionfalseuseRetroactiveConsumerfalse 優(yōu)化優(yōu)化部分請參閱：6. ActiveMQ配置 配置文件 ActiveMQ配置文件：$AcrtiveMQ/conf/ 配置 ActiveMQ服務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標識中配置ActiveMQ服務IP和端口，其中name屬性指定協(xié)議的名稱，uri屬性指定協(xié)議所對應的協(xié)議名，IP地址和端口號。上述IP地址和端口可以根據(jù)實際需要指定。Java客戶端默認使用openwire協(xié)議，所以ActiveMQ服務地址為tcp://localhost:61616；目前C++客戶端僅支持stomp協(xié)議，所以ActiveMQ服務地址為tcp://localhost:61613。 分布式部署分布式部署請參閱： 監(jiān)控 ActiveMQ本節(jié)將使用JXM和JXM控制臺（）監(jiān)控ActiveMQ。 配置 JXM broker brokerName=emv219 useJmx=true xmlns= managementContext managementContext connectorPort=1099 jmxDomainName=/ /managementContext /broker 配置JXM步驟如下： 1．設置broker標識的useJmx屬性為true； 2．取消對managementContext標識的注釋（系統(tǒng)默認注釋 managementContext標識），監(jiān)控的默認端口為1099。 在Windows平臺監(jiān)控進入%JAVA_HOME%/bin，在對話框中輸入ActiveMQ服務主機的地址，JXM的端口和主機登陸帳號。 7. 目前存在問題 C++客戶端丟失消息問題 ActiveMQ版本：ActiveMQ C++客戶端版本：ActiveMQ CPP Release 測試中發(fā)現(xiàn)，當 C++客戶端異常退出時（即沒有正常調用close函數(shù)關閉連接），ActiveMQ并不能檢測到C++客戶端的連接已經(jīng)中斷，這時如果向隊列中發(fā)送消息，那么第一條消息就會丟失，這時ActiveMQ才能檢測到這個連接是中斷的。在ActiveMQ論壇反應此問題后，開發(fā)人員答復并建議使用CLIENT_ACKNOWLEDGE簽收模式。但是此模式會造成消息重復接收。測試ActiveMQ 。 隊列消息堆積過多后有可能阻塞程序，這就意味著當消息堆積超過20M后，程序可能出現(xiàn)問題。在mial list中其他用戶對此問題的描述是：send方法會阻塞或拋出異常。 目前版本的 C++客戶端僅支持 stomp協(xié)議目前版本的 C++客戶端程序（ActiveMQ CPP Release）僅支持stomp協(xié)議，因此傳輸消息的速度應該沒有使用openwire協(xié)議的Java客戶端快。ActiveMQ網(wǎng)站顯示不久將會有支持openwire協(xié)議的C++客戶端程序發(fā)布。 分布式部署問題 ActiveMQ版本：ActiveMQ 測試選用上述兩個未正式發(fā)布的版本，未選用正式發(fā)布的ActiveMQ Release版本是因為此版本bug較多。在測試中發(fā)現(xiàn)，如果重啟其中一臺機器上的ActiveMQ，其他機器的 ActiveMQ有可能會打印： at (:358) at (:267) at (:156) at (:136) at (:595) WARN TransportConnection Unexpected extra broker info mand received: BrokerInfo {mandId = 6, responseRequired = false, brokerId = ID:emv219n3394511744587701571:0, brokerURL = tcp://emv219n:61616, sl aveBroker = false, masterBroker = false, faultTolerantConfiguration = false,networkConnection = false, duplexConnection = false, peerBrokerInfos = [], brokerName = emv219, connectionId = 0}. INFO FailoverTransport Transport failed, attempting to automatically reconnect due to: 。這時分布式的消息傳輸就會出現(xiàn)問題，此問題目前還沒找到原因。