大家好，欢迎来到IT知识分享网。
PS:
1. implements MessageListener
2. create TopicConnection [using jndi]
3. create two session
4. create publisher and subscriber
5. set listener
6. connection start() , publisher.publish(message), onMessage()
7. connection close()
![a simple jsm sample[通俗易懂]](http://images.csdn.net/syntaxhighlighting/OutliningIndicators/None.gif "a simple jsm sample[通俗易懂]插图")
![a simple jsm sample[通俗易懂]](https://yundeesoft.com/wp-content/uploads/2022/11/2022112316405970.jpg "a simple jsm sample[通俗易懂]插图1")
package
jms.chat;
import
javax.jms.
*
;
import
javax.naming.
*
;
import
java.io.
*
;
import
java.io.InputStreamReader;
import
java.util.Properties;
![a simple jsm sample[通俗易懂]](http://images.csdn.net/syntaxhighlighting/OutliningIndicators/ExpandedBlockStart.gif "a simple jsm sample[通俗易懂]插图2")
public
class
Chat
implements
MessageListener
…
{
![a simple jsm sample[通俗易懂]](http://images.csdn.net/syntaxhighlighting/OutliningIndicators/InBlock.gif "a simple jsm sample[通俗易懂]插图6")
private TopicSession pubSession; private TopicSession subSession; private TopicPublisher publisher; private TopicConnection connection; private String username;![a simple jsm sample[通俗易懂]](http://images.csdn.net/syntaxhighlighting/OutliningIndicators/ExpandedSubBlockStart.gif "a simple jsm sample[通俗易懂]插图8")
/**//* Constructor. Establish JMS publisher and subscriber */ public Chat(String topicName, String username, String password) throws Exception …{ // Obtain a JNDI connection Properties env = new Properties(); // … specify the JNDI properties specific to the vendor InitialContext jndi = new InitialContext(env); // Look up a JMS connection factory TopicConnectionFactory conFactory = (TopicConnectionFactory) jndi .lookup(“TopicConnectionFactory“); // Create a JMS connection TopicConnection connection = conFactory.createTopicConnection(username, password); // Create two JMS session objects TopicSession pubSession = connection.createTopicSession(false, Session.AUTO_ACKNOWLEDGE); TopicSession subSession = connection.createTopicSession(false, Session.AUTO_ACKNOWLEDGE); // Look up a JMS topic Topic chatTopic = (Topic) jndi.lookup(topicName); // Create a JMS publisher and subscriber TopicPublisher publisher = pubSession.createPublisher(chatTopic); TopicSubscriber subscriber = subSession.createSubscriber(chatTopic); // Set a JMS message listener subscriber.setMessageListener(this); // Intialize the Chat application set(connection, pubSession, subSession, publisher, username); // Start the JMS connection; allows messages to be delivered connection.start();![a simple jsm sample[通俗易懂]](http://images.csdn.net/syntaxhighlighting/OutliningIndicators/ExpandedSubBlockEnd.gif "a simple jsm sample[通俗易懂]插图12")
} /**//* Initialize the instance variables */ public void set(TopicConnection con, TopicSession pubSess, TopicSession subSess, TopicPublisher pub, String username) …{ this.connection = con; this.pubSession = pubSess; this.subSession = subSess; this.publisher = pub; this.username = username; } /**//* Receive message from topic subscriber */ public void onMessage(Message message) …{ try …{ TextMessage textMessage = (TextMessage) message; String text = textMessage.getText(); System.out.println(text); } catch (JMSException jmse) …{ jmse.printStackTrace(); } } /**//* Create and send message using topic publisher */ protected void writeMessage(String text) throws JMSException …{ TextMessage message = pubSession.createTextMessage(); message.setText(username + “ : “ + text); publisher.publish(message); } /**//* Close the JMS connection */ public void close() throws JMSException …{ connection.close(); } /**//* Run the Chat client */ public static void main(String[] args) …{ try …{ if (args.length != 3) System.out.println(“Topic or username missing“); // args[0]=topicName; args[1]=username; args[2]=password Chat chat = new Chat(args[0], args[1], args[2]); // Read from command line BufferedReader commandLine = new java.io.BufferedReader( new InputStreamReader(System.in)); // Loop until the word “exit” is typed while (true) …{ String s = commandLine.readLine(); if (s.equalsIgnoreCase(“exit“)) …{ chat.close(); // close down connection System.exit(0);// exit program } else chat.writeMessage(s); } } catch (Exception e) …{ e.printStackTrace(); } }![a simple jsm sample[通俗易懂]](http://images.csdn.net/syntaxhighlighting/OutliningIndicators/ExpandedBlockEnd.gif "a simple jsm sample[通俗易懂]插图14")
}
免责声明：本站所有文章内容,图片，视频等均是来源于用户投稿和互联网及文摘转载整编而成，不代表本站观点，不承担相关法律责任。其著作权各归其原作者或其出版社所有。如发现本站有涉嫌抄袭侵权/违法违规的内容,侵犯到您的权益，请在线联系站长,一经查实,本站将立刻删除。 本文来自网络,若有侵权，请联系删除，如若转载，请注明出处：https://yundeesoft.com/13016.html
