1. 程式人生 > >ActiveMQ實戰之 Topic釋出訂閱訊息

ActiveMQ實戰之 Topic釋出訂閱訊息

分享一下我老師大神的人工智慧教程!零基礎,通俗易懂!http://blog.csdn.net/jiangjunshow

也歡迎大家轉載本篇文章。分享知識,造福人民,實現我們中華民族偉大復興!

               

對於此類訊息,其實就是指使用JMS中的釋出訂閱訊息模型的訊息,下面是一個簡單的例子

訊息釋出者

[java] view plain copy
print ?
  1. package com.googlecode.garbagecan.jmsstudy.activemq.topic;  
  2.   
  3. import org.apache.activemq.ActiveMQConnectionFactory;  
  4.   
  5. import javax.jms.*;  
  6.   
  7. public class
     TopicPublisher {  
  8.     public static void main(String[] args) throws JMSException {  
  9.         ActiveMQConnectionFactory factory = new ActiveMQConnectionFactory(
    "tcp://localhost:61616");  
  10.         Connection connection = factory.createConnection();  
  11.         connection.start();  
  12.           
  13.         Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);  
  14.         Topic topic = session.createTopic("myTopic.messages");  
  15.   
  16.         MessageProducer producer = session.createProducer(topic);  
  17.         producer.setDeliveryMode(DeliveryMode.NON_PERSISTENT);  
  18.   
  19.         while(true) {  
  20.             TextMessage message = session.createTextMessage();  
  21.             message.setText("message_" + System.currentTimeMillis());  
  22.             producer.send(message);  
  23.             System.out.println("Sent message: " + message.getText());  
  24.   
  25.             try {  
  26.                 Thread.sleep(1000);  
  27.             } catch (InterruptedException e) {  
  28.                 e.printStackTrace();  
  29.             }  
  30.         }  
  31.   
  32. //      session.close();  
  33. //      connection.stop();  
  34. //      connection.close();  
  35.     }  
  36. }  
package com.googlecode.garbagecan.jmsstudy.activemq.topic;import org.apache.activemq.ActiveMQConnectionFactory;import javax.jms.*;public class TopicPublisher { public static void main(String[] args) throws JMSException {  ActiveMQConnectionFactory factory = new ActiveMQConnectionFactory("tcp://localhost:61616");  Connection connection = factory.createConnection();  connection.start();    Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);  Topic topic = session.createTopic("myTopic.messages");  MessageProducer producer = session.createProducer(topic);  producer.setDeliveryMode(DeliveryMode.NON_PERSISTENT);  while(true) {   TextMessage message = session.createTextMessage();   message.setText("message_" + System.currentTimeMillis());   producer.send(message);   System.out.println("Sent message: " + message.getText());   try {    Thread.sleep(1000);   } catch (InterruptedException e) {    e.printStackTrace();   }  }//  session.close();//  connection.stop();//  connection.close(); }}

訊息訂閱者(訊息消費者)

[java] view plain copy print ?
  1. package com.googlecode.garbagecan.jmsstudy.activemq.topic;  
  2.   
  3. import org.apache.activemq.ActiveMQConnectionFactory;  
  4.   
  5. import javax.jms.*;  
  6.   
  7. public class TopicSubscriber {  
  8.     public static void main(String[] args) throws JMSException {  
  9.         ActiveMQConnectionFactory factory = new ActiveMQConnectionFactory("tcp://localhost:61616");  
  10.         Connection connection = factory.createConnection();  
  11.         connection.start();  
  12.           
  13.         Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);  
  14.         Topic topic = session.createTopic("myTopic.messages");  
  15.   
  16.         MessageConsumer consumer = session.createConsumer(topic);  
  17.         consumer.setMessageListener(new MessageListener() {  
  18.             public void onMessage(Message message) {  
  19.                 TextMessage tm = (TextMessage) message;  
  20.                 try {  
  21.                     System.out.println("Received message: " + tm.getText());  
  22.                 } catch (JMSException e) {  
  23.                     e.printStackTrace();  
  24.                 }  
  25.             }  
  26.         });  
  27. //      session.close();  
  28. //      connection.stop();  
  29. //      connection.close();  
  30.     }  
  31. }  
package com.googlecode.garbagecan.jmsstudy.activemq.topic;import org.apache.activemq.ActiveMQConnectionFactory;import javax.jms.*;public class TopicSubscriber { public static void main(String[] args) throws JMSException {  ActiveMQConnectionFactory factory = new ActiveMQConnectionFactory("tcp://localhost:61616");  Connection connection = factory.createConnection();  connection.start();    Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);  Topic topic = session.createTopic("myTopic.messages");  MessageConsumer consumer = session.createConsumer(topic);  consumer.setMessageListener(new MessageListener() {   public void onMessage(Message message) {    TextMessage tm = (TextMessage) message;    try {     System.out.println("Received message: " + tm.getText());    } catch (JMSException e) {     e.printStackTrace();    }   }  });//  session.close();//  connection.stop();//  connection.close(); }}

分別執行兩個類,就可以看到Publisher釋出的類,Subscriber都可以接受到。

 

 

 

 

 

 

           

給我老師的人工智慧教程打call!http://blog.csdn.net/jiangjunshow

這裡寫圖片描述