【正文】 n不可用了（比如JMS Server重啟了），我們的應用程序就會開始不工作了，所以我們要有一種機制去檢測我們的Connection是否有效，如果已經(jīng)斷掉，應該試圖去重新連接，并通知系統(tǒng)管理員。JMS編程其他注意事項創(chuàng)建一個JMS Connection、查找ConnectionFactory和Destination都是需要很大的系統(tǒng)開銷的操作，所以我們的應用程序應避免頻繁地去做這些操作。[securedTopic] Bound to JNDI name: topic/securedTopic09:50:28,484 INFOwrite=falserole/dependsname=:service=Queue,name=testQueue/attribute/mbean這是定義一個名叫testTopic的示例，如果你要定義一個新的topic，只需要復制這段代碼，改一下name屬性即可。read=true))insert into employee values(2, 39。employee_name varchar(50),在這里簡單地介紹一下這個數(shù)據(jù)庫，它支持標準的SQL語法和JDBC接口，是一個用純JAVA編寫的數(shù)據(jù)庫，其實它只有一個jar文件而已：，在%JBOSS_HOME%/server/default/lib目錄下你能找到它。}close()}()。= (Queue) (topicJNDI)。queueReceiver。importimport()。(Hello Queue Publishing message: HelloQueue(ConnectionFactory,voidvoidsend(String msg)//lookup到特定的消息隊列queueConnection)。newHelloQueue {importimport}topic/testTopic)。close()(Could not get text message: msgTxt)。并提取消息內(nèi)容tryvoid//一旦queueReceiver接收到了消息，就會調用本類的onMessage方法=//用session創(chuàng)建一個特定queue的消息接收者= (Topic) (topicJNDI)。//創(chuàng)建session=(,yes)。(,newtopicSession。*importimport}()。String msg =i = 1。newclose()JMSExceptionmsg*//通過連接工廠的JNDI名查找ConnectionFactoryHelloPublisher(String factoryJNDI, String topicJNDI)//主題topicSession。*/publicimportimport (Reading message: + ())。Message m = ()。 (msg_text)。消息（Messages）JMS消息包括三個部分：消息頭（Header），屬性（Properties），消息體（Body）其中消息頭是必須的，后兩個是可選的。 //注冊監(jiān)聽 ()。消息監(jiān)聽器（Message Listener）消息監(jiān)聽器是一個充當消息的異步事件處理器的對象，它實現(xiàn)了MessageListener接口，這個接口只有一個方法onMessage，在這個方法里，你可以定義當接收到消息之后的要做的操作。兩種接收者都有一個receive方法，這是一個同步的方法，也就是說程序執(zhí)行到這個方法會被阻塞，直到收到消息為止。這是一個由session來創(chuàng)建的，用來接收來自目的地消息的對象。消息生產(chǎn)者（Message Producers）消息生產(chǎn)者也就是消息的產(chǎn)生者或發(fā)送者，在P2P方式下它是QueueSender，在Pub/Sub方式下它是TopicPublisher。TopicSession topicSession = (false, )。l連接也分兩種：QueueConnection和TopicConnection，分別對應于P2P連接和Pub/Sub連接。TopicConnection的。l這種方式有點像郵政通信，信件只有一個接收者，信件在接收之前，會一直存放在信箱里。要學習JMS，有幾個概念必須要搞清楚：llP2P方式是一對一的，一條消息只有一個接收者，默認情況下是P2P消息是持久的，也就是說發(fā)送者（sender）產(chǎn)生的一條消息（message）發(fā)送到消息隊列（queue）之上后，只有等到消息接收者（receiver）接收到它，才會從消息隊列中刪除，沒有被接收的消息會一直存在JMS容器里。l這點類似JDBC編程。JMS提供者（JMS Provider）JMS提供者，也叫JMS服務器或JMS容器，也就是JMS服務的提供者，主流的J2EE容器一般都提供JMS服務（比如JBoss，BEA WebLogic，IBM WebSphere，Oracle Application Server等都支持）和 TopicConnectionFactory topicConnectionFactory = Queue myQueue = (Queue) (MyQueue)。連接（Connection）這里說的連接是指客戶端與JMS提供者（容器）之間的連接。消息消費者（Message Consumer）消息消費者也就是消息的接收者或使用者，在P2P方式下這是QueueReceiver，在Pub/Sub方式下它是TopicSubscriber。當你調用Connection的start()方法之前，消費者是不會接收到任何消息的。如果我們不想它被阻塞，就需要異步的接收消息，這時我們得用消息臨聽器（Message Listener）了。(listener)。l消息選擇器是一個包含一個表達式的字符串，這個表達式的語法類似SQL的條件表達式，在createReceiver, createSubscriber這些方法里有一個參數(shù)讓你指定一個消息選擇器，由這些方法創(chuàng)建的消費者就只能收到與消息選擇器匹配的消息了。TextMessage message = ()。在消費者端，接收到的總是一個通用的Message對象，你需要把它轉型成特定的類型才能提取出里面的內(nèi)容。import* pub/sub方式的消息發(fā)送程序TopicSessiontopicPublisher。publicInitialContext(env)。TopicConnectionFactory topicFactory =paramthrowsvoid(intimportimport在不同的JVM中，只要保證它們各自能夠連通JMS容器(JMS Provider)TopicSessionJMSException, NamingException {HashtableString, String env =localhost:1099)。(,(T