jms學習介紹(編輯修改稿)
2024-08-31 09:45 本頁面
【文章內容簡介】 JNDI)throwsJMSException, NamingException {HashtableString, String env =newHashtableString, String()。//設置好連接JMS容器的屬性，不同的容器需要的屬性可能不同，需要查閱相關文檔(,)。(,localhost:1099)。(,yes)。(,)。Context context =newInitialContext()。TopicConnectionFactory topicFactory =(TopicConnectionFactory) (factoryJNDI)。//創(chuàng)建連接topicConnection= ()。topicSession=(false,)。//創(chuàng)建sessiontopic= (Topic) (topicJNDI)。//查找到主題//用session創(chuàng)建一個特定queue的消息接收者topicSubscriber=(topic)。//注冊監(jiān)聽，這里設置的監(jiān)聽是自己，因為本類已經實現(xiàn)了MessageListener接口，//一旦queueReceiver接收到了消息，就會調用本類的onMessage方法(this)。(HelloSubscriber subscribed to topic: + topicJNDI)。()。//啟動連接，這時監(jiān)聽器才真正生效}publicvoidonMessage(Message msg) {try{if(msginstanceofTextMessage) {//把Message轉型成TextMessage并提取消息內容String msgTxt = ((TextMessage) msg).getText()。(HelloSubscriber got message: +msgTxt)。}}catch(JMSException ex) {(Could not get text message: + ex)。()。}}publicvoidclose()throwsJMSException {()。()。}publicstaticvoidmain(String[] args) {try{newHelloSubscriber(TopicConnectionFactory,topic/testTopic)。}catch(Exception ex) {()。}}}程序在控制臺輸出：HelloSubscriber subscribed to topic: topic/testTopicHelloSubscriber got message: Hello World no. 1HelloSubscriber got message: Hello World no. 2HelloSubscriber got message: Hello World no. 3HelloSubscriber got message: Hello World no. 4HelloSubscriber got message: Hello World no. 5HelloSubscriber got message: Hello World no. 6HelloSubscriber got message: Hello World no. 7HelloSubscriber got message: Hello World no. 8HelloSubscriber got message: Hello World no. 9HelloSubscriber got message: Hello World no. 10P2P方式下的消息傳遞lpackageimportimportimportimportimportimportimportimportimportimportimportimportpublicclassHelloQueue {QueueConnectionqueueConnection。//queue方式的JMS連接QueueSessionqueueSession。//queue會話QueueSenderqueueSender。//queue消息發(fā)送者Queuequeue。//消息隊列publicHelloQueue(String factoryJNDI, String topicJNDI)throwsJMSException, NamingException {//連接JMS Provider的環(huán)境參數(shù)HashtableString, String props =newHashtableString, String()。(,)。//JMS provider的主機和端口(,localhost:1099)。(,yes)。(,)。Context context =newInitialContext(props)。//lookup到連接工廠QueueConnectionFactory queueFactory =(Queue
范文總結相關推薦
鄂ICP備17016276號-1