ActiveMQ学习总结（2）——ActiveMQ入门实例教程

Dear 丶 2022-01-13 04:57 367阅读 0赞

2019独角兽企业重金招聘Python工程师标准>>> hot3.png

1.下载ActiveMQ

去官方网站下载：http://activemq.apache.org/

2.运行ActiveMQ

解压缩apache-activemq-5.5.1-bin.zip，然后双击apache-activemq-5.5.1\bin\activemq.bat运行ActiveMQ程序。

启动ActiveMQ以后，登陆：http://localhost:8161/admin/，创建一个Queue，命名为FirstQueue。

3.创建Eclipse项目并运行

创建project：ActiveMQ-5.5，并导入apache-activemq-5.5.1\lib目录下需要用到的jar文件，项目结构如下图所示：

08133108_GlYC.jpg

3.1.Sender.java

复制代码

  1. package com.xuwei.activemq;
  3. import javax.jms.Connection;
  4. import javax.jms.ConnectionFactory;
  5. import javax.jms.DeliveryMode;
  6. import javax.jms.Destination;
  7. import javax.jms.MessageProducer;
  8. import javax.jms.Session;
  9. import javax.jms.TextMessage;
  10. import org.apache.activemq.ActiveMQConnection;
  11. import org.apache.activemq.ActiveMQConnectionFactory;
  13. public class Sender {
  15. private static final int SEND_NUMBER = 5;
  17. public static void main(String[] args) {
  19. // ConnectionFactory ：连接工厂，JMS 用它创建连接         ConnectionFactory connectionFactory;
  20. // Connection ：JMS 客户端到JMS Provider 的连接         Connection connection = null;
  21. // Session： 一个发送或接收消息的线程         Session session;
  22. // Destination ：消息的目的地;消息发送给谁.         Destination destination;
  23. // MessageProducer：消息发送者         MessageProducer producer;
  24. // TextMessage message; // 构造ConnectionFactory实例对象，此处采用ActiveMq的实现jar         connectionFactory = new ActiveMQConnectionFactory(
  25.                 ActiveMQConnection.DEFAULT_USER,
  26.                 ActiveMQConnection.DEFAULT_PASSWORD,
  27.                 "tcp://localhost:61616");
  28. try {
  30. // 构造从工厂得到连接对象             connection = connectionFactory.createConnection();
  31. // 启动             connection.start();
  32. // 获取操作连接             session = connection.createSession(Boolean.TRUE,
  33.                     Session.AUTO_ACKNOWLEDGE);
  34. // 获取session注意参数值xingbo.xu-queue是一个服务器的queue，须在在ActiveMq的console配置             destination = session.createQueue("FirstQueue");
  35. // 得到消息生成者【发送者】             producer = session.createProducer(destination);
  36. // 设置不持久化，此处学习，实际根据项目决定             producer.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
  37. // 构造消息，此处写死，项目就是参数，或者方法获取             sendMessage(session, producer);
  38.             session.commit();
  39.         } catch (Exception e) {
  41.             e.printStackTrace();
  42.         } finally {
  44. try {
  46. if (null != connection)
  47.                     connection.close();
  48.             } catch (Throwable ignore) {
  50.             }
  51.         }
  52.     }
  54. public static void sendMessage(Session session, MessageProducer producer)
  55. throws Exception {
  57. for (int i = 1; i <= SEND_NUMBER; i++) {
  59.             TextMessage message = session
  60.                     .createTextMessage("ActiveMq 发送的消息" + i);
  61. // 发送消息到目的地方             System.out.println("发送消息：" + "ActiveMq 发送的消息" + i);
  62.             producer.send(message);
  63.         }
  64.     }
  65. }

复制代码

3.2.Receiver.java

复制代码

  1. package com.xuwei.activemq;
  3. import javax.jms.Connection;
  4. import javax.jms.ConnectionFactory;
  5. import javax.jms.Destination;
  6. import javax.jms.MessageConsumer;
  7. import javax.jms.Session;
  8. import javax.jms.TextMessage;
  9. import org.apache.activemq.ActiveMQConnection;
  10. import org.apache.activemq.ActiveMQConnectionFactory;
  12. public class Receiver {
  14. public static void main(String[] args) {
  16. // ConnectionFactory ：连接工厂，JMS 用它创建连接         ConnectionFactory connectionFactory;
  17. // Connection ：JMS 客户端到JMS Provider 的连接         Connection connection = null;
  18. // Session： 一个发送或接收消息的线程         Session session;
  19. // Destination ：消息的目的地;消息发送给谁.         Destination destination;
  20. // 消费者，消息接收者         MessageConsumer consumer;
  21.         connectionFactory = new ActiveMQConnectionFactory(
  22.                 ActiveMQConnection.DEFAULT_USER,
  23.                 ActiveMQConnection.DEFAULT_PASSWORD,
  24.                 "tcp://localhost:61616");
  25. try {
  27. // 构造从工厂得到连接对象             connection = connectionFactory.createConnection();
  28. // 启动             connection.start();
  29. // 获取操作连接             session = connection.createSession(Boolean.FALSE,
  30.                     Session.AUTO_ACKNOWLEDGE);
  31. // 获取session注意参数值xingbo.xu-queue是一个服务器的queue，须在在ActiveMq的console配置             destination = session.createQueue("FirstQueue");
  32.             consumer = session.createConsumer(destination);
  33. while (true) {
  35. //设置接收者接收消息的时间，为了便于测试，这里谁定为100s                 TextMessage message = (TextMessage) consumer.receive(100000);
  36. if (null != message) {
  38.                     System.out.println("收到消息" + message.getText());
  39.                 } else {
  41. break;
  42.                 }
  43.             }
  44.         } catch (Exception e) {
  46.             e.printStackTrace();
  47.         } finally {
  49. try {
  51. if (null != connection)
  52.                     connection.close();
  53.             } catch (Throwable ignore) {
  55.             }
  56.         }
  57.     }
  58. }

复制代码

4.注意事项

  1. 最后接收者跟发送者在不同的机器上测试
  2. 项目所引用的jar最后在ActiveMQ下的lib中找，这样不会出现版本冲突。

5.测试过程

因为是在单机上测试，所以需要开启两个eclipse，每一个eclipse都有自身的workspace。我们在eclipse1中运行Receiver，在eclipse2中运行Sender。

刚开始eclipse1中运行Receiver以后console介面没有任何信息，在eclipse2中运行Sender以后，eclipse2中的console显示如下信息：

发送消息：ActiveMq 发送的消息1
发送消息：ActiveMq 发送的消息2
发送消息：ActiveMq 发送的消息3
发送消息：ActiveMq 发送的消息4
发送消息：ActiveMq 发送的消息5

而回到eclipse1中发现console界面出现如下信息：

收到消息ActiveMq 发送的消息1
收到消息ActiveMq 发送的消息2
收到消息ActiveMq 发送的消息3
收到消息ActiveMq 发送的消息4
收到消息ActiveMq 发送的消息5

PS:2012-2-27

今天发现测试并不需要开启两个eclipse，在一个eclipse下页可以启动多个程序，并且有多个console，在上面的Receiver.java中，设置一个较大的时间，比如receive(500000)，如下代码所示：

  1. TextMessage message = (TextMessage) consumer.receive(500000);

这个时候运行Receiver.java的话，会使得这个Receiver.java一直运行500秒，在eclipse中可以发现：

08133108_Emno.jpg

点击那个红色方块可以手动停止运行程序。

运行玩receiver以后我们在运行sender，在运行完sender以后，我们要切换到receiver的console，如下图所示：

08133108_gXVQ.jpg

转载于:https://my.oschina.net/zhanghaiyang/blog/599608

发表评论

表情：
评论列表 （有 0 条评论，367人围观）

还没有评论，来说两句吧...

相关阅读

    相关 ActiveMQ入门学习

    *一.ActiveMQ的简介** Activemq ： 是一个实现了JMS的消息中间间。该中间可跨平台，java ，c++ python ，.net都能使用，最近流行...

    灰太狼灰太狼/ 0 赞/ 124 阅读