/**
* jms操作基類，用於統一獲取連線，關閉連線
* * @author sunjun
*/public class jmsbase
return new activemqconnectionfactory(url);
}/**
* 建立connection
* * @return
* @throws exception
*/protected connection getconnection() throws exception
/*** 關閉session，connection
* * @param session
* @param connection
* @throws jm***ception
*/protected void close(session session, connection connection)
throws jm***ception
}
/**
* 傳送jms訊息，ptp，傳送乙個持久的文字訊息到佇列test.queue1上，即使activemq重啟，訊息也不會丟失
* * @author sunjun
*/public class publisher extends jmsbase
} /**
* 接收jms訊息，ptp，接收佇列test.queue1上的所有訊息
* 接收有兩種方式：主動去receive，通過見聽器非同步接收
* * @author sunjun
*/public class receiver extends jmsbase implements messagelistener
/*** 接收所有訊息
* * @param sync
* @param consumer
* @throws jm***ception
*/private void receivemessage(boolean sync, messageconsumer consumer)
throws jm***ception }
} else }
} @override
public void onmessage(message message)
} catch (jm***ception e) }
}執行傳送和接收，接收端收到訊息如下：
receive a text message：text message content. at time 2010-11-1 22:40:16
receive a text message：text message content. at time 2010-11-1 22:40:16
JMS學習筆記
一 概述 jms是用於面向訊息的中介軟體相互通訊的應用程式介面 api 既支援點對點 p2p 的域，也支援發布 訂閱 publish subscibe 型別的域 提供兩大功能 訊息生產和訊息消費 jms提供的訊息服務包括兩種機制 1 p2p 單個消費者消費掉 queue佇列 client1傳送訊息給...
JMS學習 十二
在ejb3中，乙個mdb 訊息驅動bean 就是乙個實現了messagelistener介面的pojo。下面就是乙個簡單的mdb。messagedriven activationconfig public class mdb implements messagelistener catch jm c...
JMS學習筆記（四） JMS開發步驟
1.jms開發步驟 乙個jms 應用是幾個 jms 客戶端交換訊息，開發 jms客戶端應用由以下幾步構成 1 用jndi 得到connectionfactory 物件 2 用connectionfactory 建立connection 物件 3 用connection 物件建立乙個或多個 jms s...