ActiveMQ简单入门实例

忘是亡心i 2021-09-26 13:50 407阅读 0赞

ActiveMQ 是Apache出品，最流行的，能力强劲的开源消息总线。ActiveMQ 是一个完全支持JMS1.1和J2EE 1.4规范的 JMS Provider实现,尽管JMS规范出台已经是很久的事情了,但是JMS在当今的J2EE应用中间仍然扮演着特殊的地位。  
  
主要特点：  
1. 多种语言和协议编写客户端。语言: Java, C, C++, C\#, Ruby, Perl, Python, PHP。应用协议: OpenWire,Stomp REST,WS Notification,XMPP,AMQP  
  
2. 完全支持JMS1.1和J2EE 1.4规范 (持久化,XA消息,事务)  
  
3. 对Spring的支持,ActiveMQ可以很容易内嵌到使用Spring的系统里面去,而且也支持Spring2.0的特性  
  
4. 通过了常见J2EE服务器(如 Geronimo,JBoss 4, GlassFish,WebLogic)的测试,其中通过JCA 1.5 resource adaptors的配置,可以让ActiveMQ可以自动的部署到任何兼容J2EE 1.4 商业服务器上  
  
5. 支持多种传送协议:in-VM,TCP,SSL,NIO,UDP,JGroups,JXTA  
  
6. 支持通过JDBC和journal提供高速的消息持久化  
  
7. 从设计上保证了高性能的集群,客户端-服务器,点对点  
  
8. 支持Ajax  
  
9. 支持与Axis的整合

10. 可以很容易得调用内嵌JMS provider,进行测试

1.下载ActiveMQ   
去官方网站下载：[http://activemq.apache.org/][http_activemq.apache.org]   
我下载的时候是 ActiveMQ 5.13.0 Release版   
  
2.运行ActiveMQ   
解压缩apache-activemq-5.13.0-bin.zip，然后双击apache-activemq-5.13.0\\bin\\activemq.bat运行ActiveMQ程序。   
  
启动ActiveMQ以后，登陆：http://localhost:8161/admin/，创建一个Queue，命名为Queue。   
  
3.创建Eclipse项目并运行   
创建java project完成后，点击项目Build Path->Add to Build Path：activemq-all-5.13.0.jar

4.Producer代码如下：

package com.activemq;  
  
import javax.jms.Connection;  
import javax.jms.ConnectionFactory;  
import javax.jms.Destination;  
import javax.jms.JMSException;  
import javax.jms.MessageProducer;  
import javax.jms.Session;  
import javax.jms.TextMessage;  
import org.apache.activemq.ActiveMQConnection;  
import org.apache.activemq.ActiveMQConnectionFactory;  
  
/\*\*  
 \* 发送端  
 \*   
 \* @author Administrator  
 \*  
 \*/  
public class Producer \{  
  
  
// 默认连接用户名  
private static final String USERNAME = ActiveMQConnection.DEFAULT\_USER;  
// 默认连接密码  
private static final String PASSWORD = ActiveMQConnection.DEFAULT\_PASSWORD;  
// 连接地址  
private static final String URL = "tcp://127.0.0.1:61616";  
  
  
public static void main(String\[\] args) \{  
ConnectionFactory connectionFactory = null; // 连接工厂  
Connection connection = null; // 客户端到JMS provider的连接  
Session session = null; // 一个发送或者接收消息的会话  
Destination destination = null; // 消息的目的  
MessageProducer producer = null; // 消息发送者  
try \{  
// 实例化连接工厂  
connectionFactory = new ActiveMQConnectionFactory(USERNAME, PASSWORD, URL);  
// 通过连接工厂获取连接  
connection = connectionFactory.createConnection();  
// 创建session  
session = connection.createSession(Boolean.TRUE, Session.AUTO\_ACKNOWLEDGE);  
// 启动连接  
connection.start();  
// 创建一个名称为Queue的消息队列  
destination = session.createQueue("Queue");  
// 创建消息生产者  
producer = session.createProducer(destination);  
// 创建一条文本消息  
TextMessage message = session.createTextMessage("我的第一次消息发送:Hello World.....");  
System.out.println("发送消息：Activemq 发送消息" + message);  
// 通过消息生产者发出消息  
producer.send(message);  
// 提交会话  
session.commit();  
// 关闭会话  
session.close();  
\} catch (Exception e) \{  
e.printStackTrace();  
\} finally \{  
try \{  
// 关闭连接  
connection.close();  
\} catch (JMSException e) \{  
e.printStackTrace();  
\}  
\}  
\}  
\}

5. Consumer代码如下：

package com.activemq;  
  
import javax.jms.Connection;  
import javax.jms.ConnectionFactory;  
import javax.jms.Destination;  
import javax.jms.JMSException;  
import javax.jms.MessageConsumer;  
import javax.jms.Session;  
import javax.jms.TextMessage;  
import org.apache.activemq.ActiveMQConnection;  
import org.apache.activemq.ActiveMQConnectionFactory;  
  
/\*\*  
 \* 接收端  
 \* @author Administrator  
 \*  
 \*/  
public class Consumer \{  
  
  
// 默认连接用户名  
private static final String USERNAME = ActiveMQConnection.DEFAULT\_USER;  
// 默认连接密码  
private static final String PASSWORD = ActiveMQConnection.DEFAULT\_PASSWORD;  
// 连接地址  
private static final String URL = "tcp://127.0.0.1:61616";  
  
  
public static void main(String\[\] args) \{  
ConnectionFactory connectionFactory = null; // 连接工厂  
Connection connection = null; // 客户端到JMS provider的连接  
Session session = null; // 一个发送或者接收消息的会话  
Destination destination = null; // 消息的目的  
MessageConsumer consumer = null; // 消息发送者  
  
  
try \{  
// 实例化连接工厂  
connectionFactory = new ActiveMQConnectionFactory(USERNAME, PASSWORD, URL);  
// 通过连接工厂获取连接  
connection = connectionFactory.createConnection();  
// 启动连接  
connection.start();  
// 创建session  
session = connection.createSession(Boolean.TRUE, Session.AUTO\_ACKNOWLEDGE);  
// 创建一个连接Queue的消息队列  
destination = session.createQueue("Queue");  
// 创建消息消费者  
consumer = session.createConsumer(destination);  
  
  
while (true) \{  
TextMessage message = (TextMessage) consumer.receive(100000);  
if (message != null) \{  
System.out.println("我收到的消息:" + message.getText());  
session.commit();  
\} else \{  
break;  
\}  
\}  
// 关闭会话  
session.close();  
\} catch (Exception e) \{  
e.printStackTrace();  
\} finally \{  
try \{  
// 关闭连接  
connection.close();  
\} catch (JMSException e) \{  
e.printStackTrace();  
\}  
\}  
\}  
\}

6.ActiveMQ服务端

浏览器访问http://localhost:8161/admin,使用默认用户名和密码:admin登录查看相关信息和消息消费记录

[http_activemq.apache.org]: http://activemq.apache.org/