ActiveMQ简单实例

梦里梦外; 2022-08-18 12:07 259阅读 0赞

1.下载ActiveMQ

去官方网站下载：[http://activemq.apache.org/][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/][http_localhost_8161_admin]，创建一个Queue，命名为FirstQueue。

3.创建Eclipse项目并运行

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

![2012022109290964.jpg][]

3.1. Sender.java

import javax.jms.Connection;
    import javax.jms.ConnectionFactory;
    import javax.jms.DeliveryMode; 
    import javax.jms.Destination; 
    import javax.jms.MessageProducer;
    import javax.jms.Session; 
    import javax.jms.TextMessage;
    import org.apache.activemq.ActiveMQConnection;
    import org.apache.activemq.ActiveMQConnectionFactory; 
    public class Sender { 
    	private static final int SEND_NUMBER = 5;
    	public static void main(String[] args) {
    		// ConnectionFactory ：连接工厂，JMS 用它创建连接
    		ConnectionFactory connectionFactory; 
    		// Connection ：JMS 客户端到JMS Provider 的连接
    		Connection connection = null; 
    		// Session： 一个发送或接收消息的线程 
    		Session session; 
    		// Destination ：消息的目的地;消息发送给谁. 
    		Destination destination;
    		// MessageProducer：消息发送者
    		MessageProducer producer;
    		// TextMessage message; 
    		// 构造ConnectionFactory实例对象，此处采用ActiveMq的实现jar
    		connectionFactory = new ActiveMQConnectionFactory( ActiveMQConnection.DEFAULT_USER, ActiveMQConnection.DEFAULT_PASSWORD, "tcp://localhost:61616");
    		try { // 构造从工厂得到连接对象 
    			connection = connectionFactory.createConnection(); 
    			// 启动 connection.start(); 
    			// 获取操作连接
    			session = connection.createSession(Boolean.TRUE, Session.AUTO_ACKNOWLEDGE); 
    			// 获取session注意参数值xingbo.xu-queue是一个服务器的queue，须在在ActiveMq的console配置 
    			destination = session.createQueue("FirstQueue");
    			// 得到消息生成者【发送者】
    			producer = session.createProducer(destination); 
    			// 设置不持久化，此处学习，实际根据项目决定
    			producer.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
    			// 构造消息，此处写死，项目就是参数，或者方法获取
    			sendMessage(session, producer); session.commit(); 
    			} catch (Exception e) {
    				e.printStackTrace();
    				} finally {
    					try {
    						if (null != connection) connection.close(); 
    						} catch (Throwable ignore) {
    							
    						}
    					} 
    		}
    	
    	public static void sendMessage(Session session, MessageProducer producer) throws Exception {
    		for (int i = 1; i <= SEND_NUMBER; i++) { 
    			TextMessage message = session .createTextMessage("ActiveMq 发送的消息" + i); // 发送消息到目的地方 System.out.println("发送消息：" + "ActiveMq 发送的消息" + i); producer.send(message); } } }
    		}
    	}</span>
    }

3.2.接受者Receiver.java

import javax.jms.ConnectionFactory;
    import javax.jms.Destination; 
    import javax.jms.MessageConsumer;
    import javax.jms.Session; 
    import javax.jms.TextMessage; 
    import org.apache.activemq.ActiveMQConnection;
    import org.apache.activemq.ActiveMQConnectionFactory; 
    public class Receiver { public static void main(String[] args) {
    	// ConnectionFactory ：连接工厂，JMS 用它创建连接
    	ConnectionFactory connectionFactory; 
    	// Connection ：JMS 客户端到JMS Provider 的连接 
    	Connection connection = null; 
    	// Session： 一个发送或接收消息的线程 
    	Session session; 
    	// Destination ：消息的目的地;消息发送给谁.
    	Destination destination; 
    	// 消费者，消息接收者 
    	MessageConsumer consumer; connectionFactory = new ActiveMQConnectionFactory( ActiveMQConnection.DEFAULT_USER, ActiveMQConnection.DEFAULT_PASSWORD, "tcp://localhost:61616"); 
    	try { 
    		// 构造从工厂得到连接对象 
    		connection = connectionFactory.createConnection();
    		// 启动 
    		connection.start();
    		// 获取操作连接 
    		session = connection.createSession(Boolean.FALSE, Session.AUTO_ACKNOWLEDGE);
    		// 获取session注意参数值xingbo.xu-queue是一个服务器的queue，须在在ActiveMq的console配置
    		destination = session.createQueue("FirstQueue"); consumer = session.createConsumer(destination); 
    		while (true) { 
    			//设置接收者接收消息的时间，为了便于测试，这里谁定为100s
    			TextMessage message = (TextMessage) consumer.receive(100000); 
    			if (null != message) { 
    				System.out.println("收到消息" + message.getText());
    				} else {
    					break;
    					} 
    			} 
    		} catch (Exception e) {
    			e.printStackTrace();
    			}
    	finally { 
    		try {
    			if (null != connection) connection.close();
    			} catch (Throwable ignore) {
    				
    			}
    		}
    	}
    }
    		}
    	}
    }

4.注意事项

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

5.测试过程

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

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

发送消息：ActiveMq 发送的消息Test1  
发送消息：ActiveMq 发送的消息Test2

而回到eclipse1中发现控制台界面出现如下信息：

收到消息ActiveMq 发送的消息Test1  
收到消息ActiveMq 发送的消息Test2

[http_activemq.apache.org]: http://activemq.apache.org/
[http_localhost_8161_admin]: http://localhost:8161/admin/
[2012022109290964.jpg]: /images/20220731/b85ff72ded0b4c05861b94003edfc461.png

发表评论取消回复

表情：

评论列表（有 0 条评论，259人围观）

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

相关阅读

相关 ActiveMQ简单的HelloWorld实例

在上一篇博文[JMS 规范简介][JMS]，我们介绍了JMS的两种消息模型：点对点和发布订阅模型，以及消息被消费的两个方式：同步和异步，JMS编程模型的对象，最后说了JMS的优

清疚/ 2023年10月16日 22:49/ 0 赞/ 80 阅读

相关 activeMQ简单示例

消息队列：消息队列中间件是分布式系统中重要的组件，主要解决应用耦合，异步消息，流量削锋等问题。实现高性能，高可用，可伸缩和最终一致性架构。使用较多的消息队列有A

系统管理员/ 2023年02月23日 05:18/ 0 赞/ 57 阅读

相关 ActiveMQ 简单Demo

可以根据这篇文章来安装会快速很多 [https://blog.csdn.net/i2blue/article/details/117422616][https_blog.c

╰+攻爆jí腚メ/ 2022年10月07日 09:56/ 0 赞/ 238 阅读

相关 ActiveMQ简单实例

1.下载ActiveMQ 去官方网站下载：[http://activemq.apache.org/][http_activemq.apache.org] 2.运行Activ

梦里梦外;/ 2022年08月18日 12:07/ 0 赞/ 260 阅读

相关 ActiveMQ入门实例

1.下载ActiveMQ 去官方网站下载：[http://activemq.apache.org/][http_activemq.apache.org] 2.运行Ac

谁借莪１个温暖的怀抱￠/ 2022年07月18日 05:58/ 0 赞/ 248 阅读

相关 ActiveMQ测试实例

ActiveMQ的安装与启动 1 下载ActiveMQ：http://activemq.apache.org/download.html 2 下载后解压到任意文件夹，解

一时失言乱红尘/ 2022年07月18日 05:29/ 0 赞/ 257 阅读

相关一个简单的JMS实例（activeMQ）

选择ActiveMQ。建立一个简单的Maven工程，pom.xml如下： <project xmlns="http://maven.apache.org/POM/

「爱情、让人受尽委屈。」/ 2022年07月18日 00:07/ 0 赞/ 216 阅读

相关 ActiveMQ实例教程

Spring+Maven实现ActiveMQ实例。一.先贴出pom.xml,了解需要的类库 <?xml version="1.0" encoding="UTF-8

àì夳堔傛蜴生んèń/ 2022年06月11日 04:10/ 0 赞/ 313 阅读

相关深入浅出JMS(三)--ActiveMQ简单的HelloWorld实例

第一篇博文[深入浅出JMS(一)–JMS基本概念][JMS_JMS]，我们介绍了JMS的两种消息模型：点对点和发布订阅模型，以及消息被消费的两个方式：同步和异步，JMS编程模型

Myth丶恋晨/ 2022年06月09日 13:47/ 0 赞/ 251 阅读

相关 ActiveMQ简单入门实例

ActiveMQ 是Apache出品，最流行的，能力强劲的开源消息总线。ActiveMQ 是一个完全支持JMS1.1和J2EE 1.4规范的 JMS Provider实现,尽管

忘是亡心i/ 2021年09月26日 13:50/ 0 赞/ 451 阅读