【正文】 ame, String password)。該文檔還指出 Connection應(yīng)該是進(jìn)行客戶端身份驗(yàn)證的地方，除了其他一些事項(xiàng)外，客戶端還可以指定惟一標(biāo)志符。 Connection（支持并發(fā)）在成功創(chuàng)建正確的ConnectionFactory后，下一步將是創(chuàng)建一個(gè)連接，它是JMS定義的一個(gè)接口。 其中brokerURL為ActiveMQ服務(wù)地址和端口。 ActiveMQConnectionFactory(String brokerURL)。 編程模版 ConnectionFactory（支持并發(fā)）要初始化JMS，則需要使用連接工廠。 JMS支持并發(fā) JMS對(duì)象是否支持并發(fā)Destination是ConnectionFactory是Connection是Session否MessageProducer 否MessageConsumer 否3. ActiveMQ安裝 去官方網(wǎng)站下載： ，\bin\。 Recovery and Redelivery (恢復(fù)和重新派送)非持久訂閱狀態(tài)下，不能恢復(fù)或重新派送一個(gè)未簽收的消息。JMS 沒(méi)有給出主題的組織和層次結(jié)構(gòu)的定義，由JMS Provider 自己定義。Destination（Topic和TemporaryTopic）客戶端用Session 創(chuàng)建Destination對(duì)象。ConnectionFactory客戶端用 ConnectionFactory 創(chuàng)建Connection對(duì)象。主題可以被認(rèn)為是消息的傳輸中介，發(fā)布者(publisher)發(fā)布消息到主題，訂閱者(subscribe) 從主題訂閱消息。MessageConsumer客戶端用MessageConsumer 接收隊(duì)列中的消息，如果用戶在receive 方法中設(shè)定了消息選擇條件，那么不符合條件的消息會(huì)留在隊(duì)列中，不會(huì)被接收到。Destination（Queue或TemporaryQueue）客戶端用 Session 創(chuàng)建Destination 對(duì)象。下面描述 JMS PTP 模型中的主要概念和對(duì)象：名稱描述ConnectionFactory客戶端用 ConnectionFactory,創(chuàng)建Connection對(duì)象。 3. JMS Provider需要用到的屬性。JMSReplyTo（回復(fù)地址）客戶提供本消息回復(fù)消息的目的地址JMSType(類型)客戶消息類型的識(shí)別符。JMSPriority(消息優(yōu)先級(jí))send方法從 09 十個(gè)級(jí)別，04 是普通消息，59 是加急消息。表示偶然丟失該消息是被允許的，這兩種模式使開(kāi)發(fā)者可以在消息傳送的可靠性和吞吐量之間找到平衡點(diǎn)。JMSDeliveryMode(傳送模式)send方法兩種模式: PERSISTENT如果沒(méi)有已經(jīng)向主題目標(biāo)注冊(cè)的消費(fèi)者，主題不保留其接收到的消息，除非有非活動(dòng)消費(fèi)者注冊(cè)了持久訂閱?？梢韵蛑黝}目標(biāo)發(fā)送消息的生產(chǎn)者的數(shù)量沒(méi)有限制，并且每個(gè)消息可以發(fā)送至任意數(shù)量的訂閱消費(fèi)者。如果沒(méi)有已經(jīng)向隊(duì)列目標(biāo)注冊(cè)的消費(fèi)者，隊(duì)列將保留它收到的消息，并在某個(gè)消費(fèi)者向該隊(duì)列進(jìn)行注冊(cè)時(shí)將消息傳送給該消費(fèi)者。 PTP（使用 Queue即隊(duì)列目標(biāo)）消息從一個(gè)生產(chǎn)者傳送至一個(gè)消費(fèi)者。消費(fèi)者可以支持同步或異步消息接收。客戶端使用 MessageProducer 向指定的物理目標(biāo)（在 API 中表示為目標(biāo)身份對(duì)象）發(fā)送消息。連接用于創(chuàng)建會(huì)話。在 JMS 編程模型中，JMS 客戶端使用 ConnectionFactory 對(duì)象創(chuàng)建一個(gè)連接，向消息服務(wù)發(fā)送消息以及從消息服務(wù)接收消息均是通過(guò)此連接來(lái)進(jìn)行。 ConnectionFactory：連接工廠，JMS 用它創(chuàng)建連接； Connection：JMS 客戶端到JMS Provider 的連接； Destination：消息的目的地；Acknowledge：簽收； Session：會(huì)話，一個(gè)發(fā)送或接收消息的線程；MessageProducer：由 Session 對(duì)象創(chuàng)建的用來(lái)發(fā)送消息的對(duì)象； MessageConsumer：由 Session 對(duì)象創(chuàng)建的用來(lái)接收消息的對(duì)象。Java Message Service（JMS）是 SUN提出的旨在統(tǒng)一各種 MOM系統(tǒng)接口的規(guī)范，它包含點(diǎn)對(duì)點(diǎn)（Point to Point，PTP）和發(fā)布 /訂閱（Publish/Subscribe，pub/sub）兩種消息模型，提供可靠消息傳輸、事務(wù)和消息過(guò)濾等機(jī)制。發(fā)送者將消息發(fā)送給消息服務(wù)器，消息服務(wù)器將消息存放在若干隊(duì)列中，在合適的時(shí)候再將消息轉(zhuǎn)發(fā)給接收者。1. 背景當(dāng)前，CORBA、DCOM、RMI等RPC中間件技術(shù)已廣泛應(yīng)用于各個(gè)領(lǐng)域。這種模式下，1）發(fā)送和接收是異步的，發(fā)送者無(wú)需等待；2）二者的生命周期未必相同：發(fā)送消息的時(shí)候接收者不一定運(yùn)行，接收消息的時(shí)候發(fā)送者也不一定運(yùn)行；3）一對(duì)多通信：對(duì)于一個(gè)消息可以有多個(gè)接收者。 2．JMS概述 JMS規(guī)范 JAVA 消息服務(wù)(JMS)定義了 Java 中訪問(wèn)消息中間件的接口。 JMS編程模型在 JMS 編程模型中，JMS 客戶端（組件或應(yīng)用程序）通過(guò) JMS 消息服務(wù)交換消息。Connection 是客戶端與消息服務(wù)的活動(dòng)連接。Session 是一個(gè)用于生成和使用消息的單線程上下文。生產(chǎn)者可指定一個(gè)默認(rèn)傳送模式（持久性消息與非持久性消息）、優(yōu)先級(jí)和有效期值，以控制生產(chǎn)者向物理目標(biāo)發(fā)送的所有消息。異步使用可通過(guò)向消費(fèi)者注冊(cè) MessageListener 來(lái)實(shí)現(xiàn)。在此傳送模型中，目標(biāo)是一個(gè)隊(duì)列。 Pub/Sub（使用Topic即主題目標(biāo)）消息從一個(gè)生產(chǎn)者傳送至任意數(shù)量的消費(fèi)者。主題目標(biāo)也支持持久訂閱的概念。這兩種消息傳送模型使用表示不同編程域的 API 對(duì)象（其語(yǔ)義稍有不同）進(jìn)行處理，如下所示：基本類型統(tǒng)一域PTP域Pub/Sub域ConnectionFactoryQueueConnectionFactoryTopicConnectionFactory ConnectionQueueConnectionTopicConnection SessionQueueSessionTopicPublisher Destination（Queue或 Topic）QueueTopic MessageProducerQueueSenderMessageConsumerQueueReceiver QueueBrowserTopicSubscriber JMS消息結(jié)構(gòu) JMS 消息由以下幾部分組成：消息頭，屬性和消息體。和NON_PERSISTENT，PERSISTENTJMSExpiration(消息過(guò)期時(shí)間)send方法等于 Destination 的send 方法中的timeToLive 值加上發(fā)送時(shí)刻的GMT 時(shí)間值。JMSMessageID(信息ID)send方法唯一識(shí)別每個(gè)消息的標(biāo)識(shí)，由JMS Provider 產(chǎn)生。JMSRedelivered(再次發(fā)送)JMS Provider如果一個(gè)客戶端收到一個(gè)設(shè)置JMSRedelivered屬性的消息，則表示可能客戶端曾經(jīng)在早些時(shí)候收到過(guò)該消息，但并沒(méi)有簽收(acknowledged)。如:標(biāo)準(zhǔn)的JMS消息頭包含以下屬性：上圖的10個(gè)屬性 消息體(Body) JMS API 定義了 5種消息體格式，也叫消息類型，可以使用不同形式發(fā)送接收數(shù)據(jù)并可以兼容現(xiàn)有的消息格式，下面描述這 5種類型：消息類型消息體TextMessage，如xml文件內(nèi)容MapMessage鍵/值對(duì)的集合，鍵是 String對(duì)象，值類型可以是Java任何基本類型BytesMessage字節(jié)流StreamMessageJava中的輸入輸出流ObjectMessageJava中的可序列化對(duì)象Message沒(méi)有消息體，只有消息頭和屬性 PTP模型 PTP(PointtoPoint)模型是基于隊(duì)列的，生產(chǎn)者發(fā)消息到隊(duì)列，消費(fèi)者從隊(duì)列接收消息，隊(duì)列的存在使得消息的異步傳輸成為可能。Connection 一個(gè)到 JMS Provider 的連接，客戶端可以Connection 創(chuàng)建Session 來(lái)發(fā)送和接收消息。此處的目標(biāo)為隊(duì)列，隊(duì)列由隊(duì)列名識(shí)別。Reliability (可靠性)隊(duì)列可以長(zhǎng)久地保存消息直到消費(fèi)者收到消息。主題使得消息訂閱者和消息發(fā)布者保持互相獨(dú)立，不需要接觸即可保證消息的傳送。Connection一個(gè)到 JMS Provider 的連接，客戶端可以用Connection 創(chuàng)建Session 來(lái)發(fā)送和接收消息。此處的目標(biāo)為主題，主題由主題名識(shí)別。MessageProducer客戶端用MessageProducer 發(fā)布消息到主題。只有持久訂閱才能恢復(fù)或重新派送一個(gè)未簽收的消息。啟動(dòng)ActiveMQ以后，登陸：://localhost:8161/admin/，創(chuàng)建一個(gè)Queue，命名為FirstQueue?？蛻舳送ㄟ^(guò)創(chuàng)建ConnectionFactory建立到ActveMQ的連接，一個(gè)連接工廠封裝了一組連接配置參數(shù)，這組參數(shù)在配置ActiveMQ時(shí)已經(jīng)定義，例如brokerURL參數(shù)，此參數(shù)傳入的是ActiveMQ服務(wù)地址和端口，支持openwire協(xié)議的默認(rèn)連接為tcp://localhost:61616，支持stomp協(xié)議的默認(rèn)連接為tcp://localhost:61613。 ActiveMQConnectionFactory(String userName, String password, String brokerURL) 。例如：ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory(tcp://:61616)。ConnectionFactory負(fù)責(zé)返回可以與底層消息傳遞系統(tǒng)進(jìn)行通信的 Connection實(shí)現(xiàn)。當(dāng)一個(gè) Connection被創(chuàng)建時(shí)，它的傳輸默認(rèn)是關(guān)閉的，必須使用start()方法開(kāi)啟。例如：Connection connection = ()。例如：()。 Java客戶端： ActiveMQConnection方法： Session createSession(boolean transacted, int acknowledgeMode)。在PTP模式中，Destination被稱作Queue即隊(duì)列；在Pub/Sub模式，Destination被稱作Topic即主題。 Topic createTopic(String topicName)。 MessageProducer MessageProducer是一個(gè)由Session創(chuàng)建的對(duì)象，用來(lái)向Destination發(fā)送消息。 void send(Destination destination, Message message, int deliveryMode, int priority,long timeToLive)。例如：(message)。 MessageConsumer createConsumer(Destination desti