關於jms
 JMS 是介面，相當於jdbc  ，要真正使用它需要某些廠商進行實現 ，即jms provider
 常見的jms provider 有
      ActiveMQ
      JBoss 社群所研發的 HornetQ  (在jboss6 中預設即可以使用它)
       jbossmq 等
在jboss 5 之前好像一直在用jbossmq ，而從6 開始使用HornetQ  ,hornetq 也可以脫離jboss 單獨使用

hornetq 的配置在jboss-6.0.0.20100429-M3/server/default/deploy/hornetq/目錄進行配置
 hornetq-jms.xml 為配置檔案 ，只要read一下就可以看明白如何新增一個topic queue 等
 </configuration>
       ...
   <queue name="ExpiryQueue">
      <entry name="/queue/ExpiryQueue"/>
   </queue>

   <topic name="testTopic">
      <entry name="/queue/testTopic"/>
   </topic>
</configuration>

但此處用的jms provider 是activemq ,可以單獨執行，而無需j2ee server

下載apache-activemq-5.3.2-bin.tar.gz  解壓縮

運 行bin/activemq  啟動訊息伺服器

然後執行ChatServer , 及   一個多個ChatClient

 然後在ChatServer 命令列視窗中輸入內容就會顯示在客戶端的視窗上，多人聊天

package org.jixiuf.chat; import javax.jms.JMSException; import javax.jms.Message; import javax.jms.MessageConsumer; import javax.jms.MessageListener; import javax.jms.Session; import javax.jms.TextMessage; import javax.jms.Topic; import javax.jms.TopicConnection; import javax.jms.TopicPublisher; import javax.jms.TopicSession; import org.jixiuf.util.JNDIUtil; public class Chat implements MessageListener { TopicConnection conn; TopicSession pubSession; TopicPublisher publisher; Topic topic; MessageConsumer subConsumer; String name; public Chat(String name) { this.name = name; conn = JNDIUtil.getTopicConnection(); topic = JNDIUtil.lookupTopic("testTopic"); } public void startServer() throws JMSException { pubSession = conn.createTopicSession(false, Session.AUTO_ACKNOWLEDGE); publisher = pubSession.createPublisher(topic); } public void publishMsg(String msgStr) { TextMessage msg; try { msg = pubSession.createTextMessage(); msg.setText(msgStr); publisher.publish(msg); } catch (JMSException e) { e.printStackTrace(); } } public void startClient() throws JMSException { TopicSession subSession = conn.createTopicSession(false, Session.AUTO_ACKNOWLEDGE); //subConsumer = subSession.createConsumer(topic); subConsumer = subSession.createConsumer(topic,null,false);//true表示不接收自已釋出的訊息 subConsumer.setMessageListener(this); conn.start();// 注意這個是 } @Override public void onMessage(Message message) { if (message instanceof TextMessage) { TextMessage tmsg = (TextMessage) message; try { System.out.println("定閱的訊息："+tmsg.getText()); } catch (JMSException e) { e.printStackTrace(); } } } }

jndi.properties

java.naming.factory.initial=org.apache.activemq.jndi.ActiveMQInitialContextFactory topic.testTopic=jms.topic23

jndi.proerties 是示例 講解

# START SNIPPET: jndi(來源 www.iocblog.net) #建立InitialContext的工廠類。（必須要） java.naming.factory.initial = org.activemq.jndi.ActiveMQInitialContextFactory #使用ActiveMQ的Broker url（必須要）,這是預設的，不填就是這樣 java.naming.provider.url = tcp://localhost:61616 #是否使用內嵌Broker（可選） #useEmbeddedBroker = true #內嵌Broker使用的xml配置檔案url。這個url可以是在classpath中， #或在檔案路徑中。在檔案路徑中需要採用file:filepath的格式（可選） #brokerXmlConfig = file:src/conf/sample-conf/default.xml #指定connectionFactory的jndi名字，多個名字之間可以逗號分隔。（必須要） #以下為例： #對於topic，使用(TopicConnectionFactory)context.lookup("connectionFactry") #對於queue，(QueueConnectionFactory)context.lookup("connectionFactory") #，(QueueConnectionFactory)context.lookup("connF") connectionFactoryNames = connectionFactory, queueConnectionFactory, topicConnectionFactry ,connF #註冊queue，格式：（必須要） #queue.[jndiName] = [physicalName] #使用時：(Queue)context.lookup("jndiName")，此處是MyQueue queue.MyQueue = example.MyQueue #註冊topic，格式：（必須要） # topic.[jndiName] = [physicalName] #使用時：(Topic)context.lookup("jndiName")，此處是MyTopic topic.MyTopic = example.MyTopic # END SNIPPET: jndi