【正文】 s i 21。queue/testQueue)。(msg)。//創(chuàng)建隊列消息的發(fā)送者localhost:1099)。//消息隊列queueSession。importstatic}ifTopicConnectionFactory topicFactory =topic。/**package(topic, message)。()。throwstopicPublisher= (Topic) (topicJNDI)。=(,JMSException, NamingException {importPub/sub方式的消息傳遞的例子:l TextMessage message = (TextMessage) m。JMSType等信息。()。對P2P方式來說，目的地就是Queue，對pub/sub方式來說，目的地就是Topic。默認情況下，pub/sub方式下的消息不是持久的，這意味著，消息一經(jīng)發(fā)出，不管有沒有人接收，都不會保存下來，而且訂閱者只能接收到自已訂閱之后發(fā)布者發(fā)出的消息。JMS 學(xué)習(xí)介紹JMS是應(yīng)用系統(tǒng)或組件之間相互通信的應(yīng)用程序接口，利用它，我們可以輕易實現(xiàn)在不同JVM之間相互的遠程通信。PUB/SUB方式的工作流程，首先subscriber（訂閱者）向JMS容器訂閱(Listen to)自己感興趣的topic（主題），多個訂閱者可以同時對一個主題進行訂閱，消息發(fā)布者發(fā)布一條消息，所有訂閱了該主題的訂閱者都能收到這個消息。 QueueConnectionFactory queueConnectionFactory = 目的地（Destinations）目的地是消息生產(chǎn)者(producer)消息發(fā)住的目的地，也是消費者(consumer)接收消息的來源地，它有點像信箱，郵遞員把信件投往信箱，收件人從信箱取信件。 TopicConnection topicConnection = ()。MessageListener listener = new MessageListener( { public void onMessage(Message msg) { JMSReplyTo,前面對JMS概念的作了一個基本介紹，下面我們看一個具體的例子程序importthrowslocalhost:1099)。= ()。topicSession)。topic/**publish(String msg)TextMessage message ={TopicpublicQueueSession(,InitialContext(props)。//lookup到連接工廠(queue)。()。i = 11。()。packagepublicvoid()。:service= DataSourceBinding, name=DefaultDS/dependsDefaultDS這個名字就是JMS連接數(shù)據(jù)庫的數(shù)據(jù)源，可以讓其保持默認值。read=truembeanname=SecurityConfwrite=true//attribute/mbean[ex] Bound to JNDI name: queue/ex09:50:28,437 INFO也可以在運行命令時附帶上這個參數(shù)，如下因為JMS工作模式是異步的，()這個方法，系統(tǒng)已經(jīng)啟動了一個新的線程在工作，也就是說退出了這行語句所在的方法之后，這個線程還在工作，它會不斷地去偵聽有沒有新的JMS消息，直到這個Connection被關(guān)閉或不可用。[C] Bound to JNDI name: queue/C09:50:28,406 INFO/securitywrite=true//dependsDefaultDS這個名字保持和前面一致即可，也可以讓其保持默認值。2004112339。void+ ex)。+ topicJNDI)。queueimportnewvoid//連接JMS Provider的環(huán)境參數(shù)//queue方式的JMS連接importpublic(HelloSubscriber subscribed to topic: topicSubscribertopic= ()。(TopicConnectionFactory) (factoryJNDI)。localhost:1099)。import(intvoidparamTopicSession* pub/sub方式的消息發(fā)送程序在消費者端，接收到的總是一個通用的Message對象，你需要把它轉(zhuǎn)型成特定的類型才能提取出里面的內(nèi)容。l當(dāng)你調(diào)用Connection的start()方法之前，消費者是不會接收到任何消息的。連接（Connection）這里說的連接是指客戶端與JMS提供者（容器）之間的連接。和這點類似JDBC編程。P2P方式是一對一的，一條消息只有一個接收者，默認情況下是P2P消息是持久的，也就是說發(fā)送者（sender）產(chǎn)生的一條消息（message）發(fā)送到消息隊列（queue）之上后，只有等到消息接收者（receiver）接收到它，才會從消息隊列中刪除，沒有被接收的消息會一直存在JMS容器里。lll消息生產(chǎn)者（Message Producers）消息生產(chǎn)者也就是消息的產(chǎn)生者或發(fā)送者，在P2P方式下它是QueueSender，在Pub/Sub方式下它是TopicPublisher。這是一個由session來創(chuàng)建的，用來接收來自目的地消息的對象。 //注冊監(jiān)聽 ()。 (msg_text)。 (Reading message: + ())。importHelloPublisher(String factoryJNDI, String topicJNDI)*JMSExceptionnew()。import*topicSession。new(,yes)。=//創(chuàng)建session//用session創(chuàng)建一個特定queue的消息接收者try并提取消息內(nèi)容msgTxt)。(Could not get text message: close()topic/testTopic)。importHelloQueue {new)。//lookup到特定的消息隊列voidvoid(Hello Queue Publishing message: ()。importqueueReceiver。()。}在這里簡單地介紹一下這個數(shù)據(jù)庫，它支持標準的SQL語法和JDBC接口，是一個用純JAVA編寫的數(shù)據(jù)庫，其實它只有一個jar文件而已：，在%JBOSS_HOME%/server/default/lib目錄下你能找到它。)insert into employee values(2, 39。read=truename=:service=Queue,name=testQueue/dependswrite=false[securedTopic] Bound to