详见：http://blog.yemou.net/article/query/info/tytfjhfascvhzxcyt180

1.下载ActiveMQ 
去官方网站下载：http://activemq.apache.org/ 
我下载的时候是 ActiveMQ 5.8.0 Release版

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

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

3.创建Eclipse项目并运行 
创建java project：ActiveMQ-5.8，新建lib文件夹 
打开apache-activemq-5.8.0\lib目录 
拷贝 
activemq-broker-5.8.0.jar 
activemq-client-5.8.0.jar 
geronimo-j2ee-management_1.1_spec-1.0.1.jar 
geronimo-jms_1.1_spec-1.1.1.jar 
slf4j-api-1.6.6.jar 
这5个jar文件到lib文件夹中,并Build Path->Add to Build Path

结构如图:

Sender.java

Java代码  

  1. package com.lm.activemq;

  2. /**

  3. * @Header: Sender.java

  4. * 类描述：

  5. * @author: lm

  6. * @date 2013-7-17 上午10:52:42

  7. * @Email

  8. * @company 欢

  9. * @addr 北京市朝阳区劲松

  10. */

  11. import javax.jms.Connection;

  12. import javax.jms.ConnectionFactory;

  13. import javax.jms.DeliveryMode;

  14. import javax.jms.Destination;

  15. import javax.jms.MessageProducer;

  16. import javax.jms.Session;

  17. import javax.jms.TextMessage;

  18. import org.apache.activemq.ActiveMQConnection;

  19. import org.apache.activemq.ActiveMQConnectionFactory;

  20. public class Sender {

  21. private static final int SEND_NUMBER = 5;

  22. public static void main(String[] args) {

  23. // ConnectionFactory ：连接工厂，JMS 用它创建连接

  24. ConnectionFactory connectionFactory; // Connection ：JMS 客户端到JMS

  25. // Provider 的连接

  26. Connection connection = null; // Session： 一个发送或接收消息的线程

  27. Session session; // Destination ：消息的目的地;消息发送给谁.

  28. Destination destination; // MessageProducer：消息发送者

  29. MessageProducer producer; // TextMessage message;

  30. // 构造ConnectionFactory实例对象，此处采用ActiveMq的实现jar

  31. connectionFactory = new ActiveMQConnectionFactory(

  32. ActiveMQConnection.DEFAULT_USER,

  33. ActiveMQConnection.DEFAULT_PASSWORD, "tcp://localhost:61616");

  34. try { // 构造从工厂得到连接对象

  35. connection = connectionFactory.createConnection();

  36. // 启动

  37. connection.start();

  38. // 获取操作连接

  39. session = connection.createSession(Boolean.TRUE,

  40. Session.AUTO_ACKNOWLEDGE);

  41. // 获取session注意参数值xingbo.xu-queue是一个服务器的queue，须在在ActiveMq的console配置

  42. destination = session.createQueue("FirstQueue");

  43. // 得到消息生成者【发送者】

  44. producer = session.createProducer(destination);

  45. // 设置不持久化，此处学习，实际根据项目决定

  46. producer.setDeliveryMode(DeliveryMode.NON_PERSISTENT);

  47. // 构造消息，此处写死，项目就是参数，或者方法获取

  48. sendMessage(session, producer);

  49. session.commit();

  50. } catch (Exception e) {

  51. e.printStackTrace();

  52. } finally {

  53. try {

  54. if (null != connection)

  55. connection.close();

  56. } catch (Throwable ignore) {

  57. }

  58. }

  59. }

  60. public static void sendMessage(Session session, MessageProducer producer)

  61. throws Exception {

  62. for (int i = 1; i <= SEND_NUMBER; i++) {

  63. TextMessage message = session.createTextMessage("ActiveMq 发送的消息"

  64. + i);

  65. // 发送消息到目的地方

  66. System.out.println("发送消息：" + "ActiveMq 发送的消息" + i);

  67. producer.send(message);

  68. }

  69. }

  70. }

Receiver.java

Java代码  

  1. package com.lm.activemq;

  2. /**

  3. * @Header: Receiver.java

  4. * 类描述：

  5. * @author: lm

  6. * @date 2013-7-17 上午10:52:58

  7. * @Email

  8. * @company 欢

  9. * @addr 北京市朝阳区劲松

  10. */

  11. import javax.jms.Connection;

  12. import javax.jms.ConnectionFactory;

  13. import javax.jms.Destination;

  14. import javax.jms.MessageConsumer;

  15. import javax.jms.Session;

  16. import javax.jms.TextMessage;

  17. import org.apache.activemq.ActiveMQConnection;

  18. import org.apache.activemq.ActiveMQConnectionFactory;

  19. public class Receiver {

  20. public static void main(String[] args) {

  21. // ConnectionFactory ：连接工厂，JMS 用它创建连接

  22. ConnectionFactory connectionFactory;

  23. // Connection ：JMS 客户端到JMS Provider 的连接

  24. Connection connection = null;

  25. // Session： 一个发送或接收消息的线程

  26. Session session;

  27. // Destination ：消息的目的地;消息发送给谁.

  28. Destination destination;

  29. // 消费者，消息接收者

  30. MessageConsumer consumer;

  31. connectionFactory = new ActiveMQConnectionFactory(

  32. ActiveMQConnection.DEFAULT_USER,

  33. ActiveMQConnection.DEFAULT_PASSWORD, "tcp://localhost:61616");

  34. try {

  35. // 构造从工厂得到连接对象

  36. connection = connectionFactory.createConnection();

  37. // 启动

  38. connection.start();

  39. // 获取操作连接

  40. session = connection.createSession(Boolean.FALSE,

  41. Session.AUTO_ACKNOWLEDGE);

  42. // 获取session注意参数值xingbo.xu-queue是一个服务器的queue，须在在ActiveMq的console配置

  43. destination = session.createQueue("FirstQueue");

  44. consumer = session.createConsumer(destination);

  45. while (true) {

  46. // 设置接收者接收消息的时间，为了便于测试，这里谁定为100s

  47. TextMessage message = (TextMessage) consumer.receive(100000);

  48. if (null != message) {

  49. System.out.println("收到消息" + message.getText());

  50. } else {

  51. break;

  52. }

  53. }

  54. } catch (Exception e) {

  55. e.printStackTrace();

  56. } finally {

  57. try {

  58. if (null != connection)

  59. connection.close();

  60. } catch (Throwable ignore) {

  61. }

  62. }

  63. }

  64. }

5.测试过程 
先运行:Receiver.java 
再运行:Sender.java

可以看到结果 
Sender运行后: 
发送消息：ActiveMq 发送的消息1 
发送消息：ActiveMq 发送的消息2 
发送消息：ActiveMq 发送的消息3 
发送消息：ActiveMq 发送的消息4 
发送消息：ActiveMq 发送的消息5

Receiver运行后: 
收到消息ActiveMq 发送的消息1 
收到消息ActiveMq 发送的消息2 
收到消息ActiveMq 发送的消息3 
收到消息ActiveMq 发送的消息4 
收到消息ActiveMq 发送的消息5

要想看到不同的输出内容,通过点击如下图的按钮切换console

在Receiver.java中，可以设置一个时间，比如receive(500000)，如下代码所示：

Java代码  

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

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

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

转载于:https://www.cnblogs.com/grefr/p/6094979.html

java 消息机制 ActiveMQ入门实例相关推荐

  1. ActiveMQ入门实例

    1.下载ActiveMQ 去官方网站下载:http://activemq.apache.org/ 2.运行ActiveMQ 解压缩apache-activemq-5.5.1-bin.zip,然后双击a ...

  2. JMS(Java消息服务)(Activemq简单介绍)

    是什么? JMS(java消息服务)是规范,它定义了一些规则,一些接口.具体实现由各种做这个产品的厂家或开源组织来实现. 为什么? 在JMS还没有诞生前,每个企业都会有自己的一套内部消息系统,比如项目 ...

  3. Java消息队列--ActiveMq 初体验

    1.下载安装ActiveMQActiveMQ官网下载地址:http://activemq.apache.org/download.htmlActiveMQ 提供了Windows 和Linux.Unix ...

  4. Java 消息机制之回调详解

    1. 概述 Java 中的回调机制是一个比较常见的机制,只是有可能在你的程序中使用得比较少,在一些大型的框架中回调机制随处可见.而在之前的博文<Java设计模式--观察者模式>及 Andr ...

  5. java消息队列ActiveMQ之Comsumer

    1.需要添加在上一篇博客中说到的依赖jar包 2.创建创建消费者 package com.activemq.demo;import java.util.concurrent.atomic.Atomic ...

  6. Java 反射机制快速入门及常见方法全归纳。

    目录 一.反射机制 1.基本介绍 2.原理示意图 3.反射基本代码实现 4.反射性能 二.Class 类 1.基本介绍 2.获取 Class类对象的方式 3.有 Class对象的类 三.类加载 1.基 ...

  7. java jna 例子_JNA入门实例

    JNI是Java调用原生函数的唯一机制,JNA就是建立在JNI之上,JNA简化了Java调用原生函数的过程.JNA提供了一个动态的C语言编写的转发器(实际上也是一个动态链接库,在Linux-i386中 ...

  8. Java操作Excel表格入门实例

    算法学累了 换个知识学一下 这次算是复习 首先 操作表格需要用到第三方的库 Java本身没有 需要引入类库 如果你会使用Maven 那么直接导入刷新就行 <dependency><g ...

  9. Map实现java缓存机制的简单实例

    缓存是Java中主要的内容,主要目的是缓解项目访问数据库的压力以及提升访问数据的效率,以下是通过Map实现java缓存的功能,并没有用cache相关框架. 一.缓存管理类 CacheMgr.java ...

最新文章

  1. 继承ViewGroup研究（汇总） 一、二、三
  2. python 类-如何理解python的类与对象？
  3. 一个 Dubbo 服务启动要两个小时
  4. [C++]MySQL数据库操作实例
  5. linux 中如何查看块设备,在linux中,如何确定使用块设备的进程？
  6. 如何linux安装apache服务器,Linux中如何安装Apache服务器
  7. AndroidGUI24：TabHost常用技巧
  8. 10.深入分布式缓存:从原理到实践 --- EVCache探秘
  9. react取消捕获_React生命周期
  10. day9-mysql集群
  11. Apache Echarts实现矢量地图
  12. 红旗Linux中文教程
  13. 衣服尺寸里面A，B是什么意思
  14. c语言求最小值函数min的用法,C语言--min的宏定义
  15. linux写makefile用tab报错,隐含规则 - linux makefile教程
  16. 热招 | 我们是 Towhee 产研团队
  17. . 显示隐藏文件夹选项消失时如何还原
  18. LinkedList一定比ArrayList的插入和删除效率高吗
  19. 51NOD 1278 相离的圆(二分 + 排序 好题)
  20. IDEA中大小写切换

热门文章

  1. 用 GRUB 引导自己的操作系统
  2. 一个简单json数据提交实例
  3. 安装python及web.py
  4. 软件架构最佳实践和案例分析
  5. golang中的strings.EqualFold
  6. 磁盘基准测试Bonnie++
  7. 用树莓派获取天气状况
  8. STM32的时钟系统RCC详细整理
  9. C/C++ 中的0长数组（柔性数组）
  10. 两个线程并发执行以下代码，假设a是全局变量，初始为1，那么以下输出______是可能的？