第五章JMS概述JavaMessageServiceJ2EE

程序設(shè)計(jì)本章內(nèi)容JMS概述消息傳遞方式JMSAPIWebLogicJMS服務(wù)配置簡(jiǎn)單的JMS編程JMS概述JMS（JavaMessageService）消息服務(wù)（MessageService）用與組件之間的異步通訊。JMSAPI定義了如何建立，發(fā)送，接收，讀取消息的規(guī)范，用于實(shí)現(xiàn)組件之間可靠的，異步的消息傳送。JMS概述JMS概述JMSProvider實(shí)現(xiàn)了JMS定義的接口，可以提供消息服務(wù)，稱之為消息統(tǒng)，如：Weblogic所提供的消息系統(tǒng)。JMSClientJava組件，通過消息系統(tǒng)可以實(shí)現(xiàn)消息的相互傳送。Massage封裝組件之間傳送的信息的對(duì)象。JMSProvider所提供的MessageSerivce需要通過ConnectionFactory和Destination對(duì)象才得以訪問；AdministrativeTool用于在Naming服務(wù)中注冊(cè)ConnectionFactory和Destination。PTP傳遞方式PTP（Pointtopoint）消息傳遞，通過消息隊(duì)列（MessageQueue）來管理消息。組件可以向消息隊(duì)列發(fā)消息，消息隊(duì)列中的某一個(gè)消息只可能被一個(gè)組件所接收。組件接收到消息后需要應(yīng)答（Acknowledge）。PTP傳遞方式Pub/Sub消息傳遞Pub/Sub（Publish/Subscribe）消息傳遞通過“主題”Topic來管理消息。組件可以在Topic上預(yù)定（Subscribe）消息。一個(gè)消息同時(shí)發(fā)給多個(gè)“預(yù)定者”。Pub/Sub消息傳遞SessionBean有兩種消息接收方式：同步（Synchronously）：通過消息接收方法獲取消息，消息還沒有到來時(shí)，該方法阻塞，直到接收到消息或等到一定時(shí)間期限。異步（Asynchronously）：通過監(jiān)聽器的機(jī)制獲取消息，消息到來時(shí)候會(huì)調(diào)用onMessage方法產(chǎn)生動(dòng)作。JMS編程模式JMS編程模式ConnectionFactories：有兩種Connection

Factory（QueueConnectionFactory和TopicConnectionFactory）分別用來產(chǎn)生QueueConnection和TopicConnection對(duì)象。 QueueConnectionFactoryqueueConnectionFactory= (QueueConnectionFactoryctx.lookup("…"); TopicConnectionFactorytopicConnectionFactory= (TopicConnectionFactory)ctx.lookupctx.lookup("…");JMS編程模式Connections代表與消息服務(wù)者的網(wǎng)絡(luò)連接，通過ConnectionFactories產(chǎn)生。 QueueConnectionqueueConnection= queueConnectionFactory.createQueueConnection(); TopicConnectiontopicConnection= topicConnectionFactory.createTopicConnection();JMS編程模式Destinations：有兩種Destinations（Topic和Queue）對(duì)應(yīng)兩種消息服務(wù)。 TopicmyTopic=(Topic)ctx.lookup("…"); QueuemyQueue=(Queue)ctx.lookup("…");JMS編程模式Sessions代表產(chǎn)生消息，消息生產(chǎn)者和消費(fèi)者的“上下文環(huán)境”（Context）。 TopicSessiontopicSession= topicConnection.createTopicSession(false, Session.AUTO_ACKNOWLEDGE QueueSessionqueueSession= queueConnection.createQueueSession(true,0);JMS編程模式MessageProducers。 QueueSenderqueueSender= queueSession.createSender(myQueue); TopicPublishertopicPublisher= topicSession.createPublisher(myTopic); queueSender.send(message); topicPublisher.publish(message);JMS編程模式MessageConsumers queueConnection.start(); Messagem=queueReceiver.receive(); topicConnection.start(); Messagem=topicSubscriber.receive(1000); //timeoutafterasecondListenerMessageListeners用于以異步方式接收消息，MessageListener接口中定義有onMessage方法用于定義消息接收到后的動(dòng)作。Message格式Message格式有三部分組成：消息頭（header）屬性（Properties）（可選）消息體（body）（可選）Message種類Message種類消息體內(nèi)容TextMessageString類型數(shù)據(jù)(例如XML文本).MapMessagename/value對(duì)集合，name為