zoukankan      html  css  js  c++  java
  • activemq入门demo

    创建maven工程,pom文件如下

    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>  

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

    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. }  
    消费者的类:消费者使用死循环接收消息并打印到控制台上

    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. }  


  • 相关阅读:
    ueditor
    六月随笔
    ueditor基本配置
    does not support the Select property
    A simple paging control pagesize control just support url querystring
    为什么LoadPostData 执行不了, why the LoadPostData method was not be implement
    How to make a test environment for Mobile site develope
    外部组件异常
    CommunityServer Telligent.Registration.DLL 3.1.20913.0已破 cracked
    Radgrid 与 文件下载
  • 原文地址:https://www.cnblogs.com/jpfss/p/8650463.html
Copyright © 2011-2022 走看看