activemq入门demo

Posted jpfss

tags:

篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了activemq入门demo相关的知识，希望对你有一定的参考价值。

创建maven工程，pom文件如下
[html] view plain copy
 print?
  1. <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"  
  2.     xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">  
  3.     <modelVersion>4.0.0</modelVersion>  
  4.     <groupId>com.tansun</groupId>  
  5.     <artifactId>ActivemqTest</artifactId>  
  6.     <version>0.0.1-SNAPSHOT</version>  
  7.   
  8.     <dependencies>  
  9.         <!-- https://mvnrepository.com/artifact/org.apache.activemq/activemq-all -->  
  10.         <dependency>  
  11.             <groupId>org.apache.activemq</groupId>  
  12.             <artifactId>activemq-all</artifactId>  
  13.             <version>5.15.2</version>  
  14.         </dependency>  
  15.     </dependencies>  
  16.   
  17. </project>  

生产者的类：每运行一次生产者的主方法，就会发送一条消息

[java] view plain copy
 print?
  1. package com.tansun;  
  2.   
  3. import javax.jms.Connection;  
  4. import javax.jms.ConnectionFactory;  
  5. import javax.jms.JMSException;  
  6. import javax.jms.MessageProducer;  
  7. import javax.jms.Queue;  
  8. import javax.jms.Session;  
  9. import javax.jms.TextMessage;  
  10.   
  11. import org.apache.activemq.ActiveMQConnectionFactory;  
  12.   
  13. public class Producer {  
  14.   
  15.     public static void main(String[] args) throws JMSException {  
  16.         // 创建连接工厂  
  17.         ConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://192.168.229.128:61616");  
  18.         // 创建连接  
  19.         Connection connection = connectionFactory.createConnection();  
  20.         // 开启连接  
  21.         connection.start();  
  22.         // 创建会话(不使用事物)  
  23.         Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);  
  24.         // 创建一对一的消息队列  
  25.         Queue queue = session.createQueue("queue test");  
  26.         // 创建生产者  
  27.         MessageProducer producer = session.createProducer(queue);  
  28.         // 创建消息  
  29.         TextMessage message = session.createTextMessage("hello activemq");  
  30.         // 发送消息  
  31.         producer.send(message);  
  32.         // 关闭会话和连接  
  33.         session.close();  
  34.         connection.close();  
  35.     }  
  36.   
  37. }  
消费者的类：消费者使用死循环接收消息并打印到控制台上

[java] view plain copy
 print?
  1. package com.tansun;  
  2.   
  3. import javax.jms.Connection;  
  4. import javax.jms.ConnectionFactory;  
  5. import javax.jms.JMSException;  
  6. import javax.jms.MessageConsumer;  
  7. import javax.jms.Queue;  
  8. import javax.jms.Session;  
  9. import javax.jms.TextMessage;  
  10.   
  11. import org.apache.activemq.ActiveMQConnectionFactory;  
  12.   
  13. public class Consumer {  
  14.   
  15.     public static void main(String[] args) throws JMSException {  
  16.         // 创建连接工厂  
  17.         ConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://192.168.229.128:61616");  
  18.         // 创建连接  
  19.         Connection connection = connectionFactory.createConnection();  
  20.         // 开启连接  
  21.         connection.start();  
  22.         // 创建回话(不使用事物)  
  23.         Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);  
  24.         // 创建一对一的消息队列  
  25.         Queue queue = session.createQueue("queue test");  
  26.         // 创建消费者  
  27.         MessageConsumer consumer = session.createConsumer(queue);  
  28.         // 接收消息  
  29.         while(true){  
  30.             TextMessage message = (TextMessage)consumer.receive();  
  31.             System.out.println(message.getText());  
  32.         }  
  33.     }  
  34.   
  35. }  


以上是关于activemq入门demo的主要内容，如果未能解决你的问题，请参考以下文章

activeMQ功能Demo

ActiveMQ入门系列二：入门代码实例（点对点模式）

JMS Activemq实战例子demo

ActiveMQ入门案例-生产者代码实现

ActiveMQ入门系列三：发布/订阅模式

ActiveMQ的发布者/订阅者模型示例