ActiveMq初级操作
（工具：tomcat6.0、activeMq5.3.2、Myeclipse7.0，java1。5）
这是本人第一次发表个人使用ActiveMq，如有错误，请指出。只为与众人共享我的心得。
activeMq是一个开源的支持JMS的框架：（以下为考录他人的信息，如有版权问题，请联系）
一、特性及优势
1、实现JMS1.1规范，支持J2EE1.4以上
2、可运行于任何jvm和大部分web容器（ActiveMQ works great in any JVM）
3、支持多种语言客户端（java, C, C++, AJAX, ACTIONSCRIPT等等）
4、支持多种协议（stomp，openwire，REST）
5、良好的spring支持（ActiveMQ has great Spring Support）
6、速度很快，JBossMQ的十倍（ActiveMQ is very fast; often 10x faster than JBossMQ.）
7、与OpenJMS、JbossMQ等开源jms provider相比，ActiveMQ有Apache的支持，持续发展的优势明显。
二、下载安装
1、下载
http://activemq.apache.org/download.html，在这个页面里有你所需要的各个版本，我用的是最新的版本-ActiveMQ 5.3.2。
2、安装
直接解压至任意目录（如：d:\ apache-activemq-5.1.0），但是我用的时候是解压到D盘的根目录下，我建议各位也这样，不用对它的一些bat进行修改。
3、启动ActiveMQ服务器
方法1：
直接运行bin\activemq.bat
方法2（在JVM中嵌套启动）：（这个我没用过，你可以试试）
cd example
ant embedBroker
4、ActiveMQ消息管理后台系统： http://localhost:8161/admin
打开主页后，你可以看到activeMq中带的一些实例，
三、详细实例
以下为本人的一个简单的实例，希望对各位有所帮助，
我是利用网上的资料，将tomcat和activeMq整合在一起做的一个发送接受的发布订阅的例子（我用的是tomcat6.0，activeMq5.3.2）：
首先整合tomcat和activeMq：
1、准备jar包：
将ActiveMQ lib目录下的5个jar包复制到Tomcat lib目录下：
activemq-core-5.1.0.jar
activemq-web-5.1.0.jar
geronimo-j2ee-management_1.0_spec-1.0.jar
geronimo-jms_1.1_spec-1.1.1.jar
geronimo-jta_1.0.1B_spec-1.0.1.jar
2、修改配置文件：
2.1 修改Tomcat的conf/context.xml文件：
在<context></context>节点中添加以下内容：
<Resource
name="jms/FailoverConnectionFactory"
auth="Container"
type="org.apache.activemq.ActiveMQConnectionFactory"
description="JMS Connection Factory"
factory="org.apache.activemq.jndi.JNDIReferenceFactory"
brokerURL="failover:(tcp://localhost:61616)?initialReconnectDelay=100&maxReconnectAttempts=5"
brokerName="localhost"
useEmbeddedBroker="false"/>
<Resource
name="jms/NormalConnectionFactory"
auth="Container"
type="org.apache.activemq.ActiveMQConnectionFactory"
description="JMS Connection Factory"
factory="org.apache.activemq.jndi.JNDIReferenceFactory"
brokerURL="tcp://localhost:61616"
brokerName="localhost"
useEmbeddedBroker="false"/>
<Resource name="jms/topic/MyTopic"
auth="Container"
type="org.apache.activemq.command.ActiveMQTopic"
factory="org.apache.activemq.jndi.JNDIReferenceFactory"
physicalName="MY.TEST.FOO"/>
<Resource name="jms/queue/MyQueue"
auth="Container"
type="org.apache.activemq.command.ActiveMQQueue"
factory="org.apache.activemq.jndi.JNDIReferenceFactory"
physicalName="MY.TEST.FOO.QUEUE"/>
配置说明：以JNDI的方式定义了ActiveMQ的broker连接url、Topic和Queue。
此处需加以注意的是Listener端的borkerURL使用了failover传输方式：
failover:(tcp://localhost:61616)?initialReconnectDelay=100&maxReconnectAttempts=5
客户端使用普通传输方式：tcp://localhost:61616
failover transport是一种重新连接机制，用于建立可靠的传输。此处配置的是一旦ActiveMQ broker中断，Listener端将每隔100ms自动尝试连接，直至成功连接或重试5次连接失败为止。
failover还支持多个borker同时提供服务，实现负载均衡的同时可增加系统容错性，格式： failover:(uri1,...,uriN)?transportOptions
2.2 在Myeclipse中新建一个jms-test的web工程
在src下，新建一个包com.flvcd.servlet （我想这个你应该会吧，如果不会，我只能说，你不合适干）
然后在修改web.xml，在里面加上：
<servlet>
<servlet-name>jms-listener</servlet-name>
<servlet-class>
com.flvcd.servlet.JMSListener
</servlet-class>
<load-on-startup>1</load-on-startup>
</servlet>
2.3 修改activemq.xml文件：为了支持持久化消息，需修改ActiveMQ的配置文件如下，使用默认的AMQ Message Store方式（索引文件方式）存储消息，据官网介绍是快速、稳定的。数据库存储方式可参照官网相关文档。
<broker xmlns="http://activemq.apache.org/schema/core" brokerName="localhost" persistent="true" useShutdownHook="false">
<persistenceAdapter>
<amqPersistenceAdapter directory="activemq-data" maxFileLength="32mb"/> </persistenceAdapter>
</broker>
(备注：2.3中红色部分直接加到后面就行，不用修改)
然后在src下的包里新建一个类，类名是JMSListener.java
再复制一下代码到你的类中：
package com.flvcd.servlet;
import java.io.*;
import javax.servlet.*;
import javax.servlet.http.*;
import javax.naming.*;
import javax.jms.*;
import org.apache.activemq.ActiveMQConnectionFactory;
public class JMSListener extends HttpServlet implements MessageListener {
public void init(ServletConfig config) throws ServletException {
try {
InitialContext initCtx = new InitialContext();
Context envContext = (Context) initCtx.lookup("java:comp/env");
ConnectionFactory connectionFactory = (ConnectionFactory) envContext
.lookup("jms/FailoverConnectionFactory");
Connection connection = connectionFactory.createConnection();
connection.setClientID("MyClient");
Session jmsSession = connection.createSession(false,
Session.AUTO_ACKNOWLEDGE);
// 普通消息订阅者，无法接收持久消息 //MessageConsumer consumer =
// jmsSession.createConsumer((Destination)
// envContext.lookup("jms/topic/MyTopic"));
// //基于Topic创建持久的消息订阅者，前提：Connection必须指定一个唯一的clientId，当前为MyClient
TopicSubscriber consumer=jmsSession.createDurableSubscriber((Topic)envContext.lookup("jms/topic/MyTopic"), "MySub");
consumer.setMessageListener(this);
connection.start();
} catch (NamingException e) {
e.printStackTrace();
} catch (JMSException e) {
e.printStackTrace();
}
}
public void onMessage(Message message) {
if (checkText(message, "RefreshArticleId") != null) {
String articleId = checkText(message, "RefreshArticleId");
System.out.println("接收刷新文章消息，开始刷新文章ID=" + articleId);
} else if (checkText(message, "RefreshThreadId") != null) {
String threadId = checkText(message, "RefreshThreadId");
System.out.println("接收刷新论坛帖子消息，开始刷新帖子ID=" + threadId);
} else {
System.out.println("接收普通消息，不做任何处理！");
}
}
private static String checkText(Message m, String s) {
try {
return m.getStringProperty(s);
} catch (JMSException e) {
e.printStackTrace(System.out);
return null;
}
}
}
你的监听端建好
现在开始建立你发布端
同样是新建一个类MyPublish.java
然后复制一下代码到你的类里
package com.flvcd.servlet;
import java.io.IOException;
import java.io.PrintWriter;
import javax.jms.Connection;
import javax.jms.ConnectionFactory;
import javax.jms.DeliveryMode;
import javax.jms.Destination;
import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.MessageListener;
import javax.jms.MessageProducer;
import javax.jms.Session;
import javax.naming.Context;
import javax.naming.InitialContext;
import javax.naming.NamingException;
import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
public class MyPublish extends HttpServlet implements MessageListener {
//定义初始化所需要的变量
private InitialContext initCtx;
private Context envContext;
private ConnectionFactory connectionFactory;
private Connection connection;
private Session jmsSession;
private MessageProducer producer;
public void onMessage(Message message) {
// TODO Auto-generated method stub
}
public MyPublish() {
super();
}
public void destroy() {
super.destroy(); // Just puts "destroy" string in log
// Put your code here
}
public void doGet(HttpServletRequest request, HttpServletResponse response)
throws ServletException, IOException {
doPost(request, response);
}
public void doPost(HttpServletRequest request, HttpServletResponse response)
throws ServletException, IOException {
String content=request.getParameter("content");
//设置持久方式
try {
producer.setDeliveryMode(DeliveryMode.PERSISTENT);
Message testMessage = jmsSession.createMessage();
// 发布刷新文章消息
testMessage.setStringProperty("RefreshArticleId", content);
producer.send(testMessage);
// 发布刷新帖子消息
testMessage.clearProperties();
testMessage.setStringProperty("RefreshThreadId", content);
producer.send(testMessage);
} catch (Exception e) {
e.printStackTrace();
}
}
public void init() throws ServletException {
// Put your code here
try {
initCtx = new InitialContext();
envContext = (Context) initCtx.lookup("java:comp/env");
connectionFactory = (ConnectionFactory) envContext.lookup("jms/NormalConnectionFactory");
connection = connectionFactory.createConnection();
jmsSession = connection.createSession(false,Session.AUTO_ACKNOWLEDGE);
producer = jmsSession.createProducer((Destination) envContext.lookup("jms/topic/MyTopic"));
} catch (NamingException e) {
e.printStackTrace();
} catch (JMSException e) {
e.printStackTrace();
}
}
}
最后，建一个MyPublish.jsp页面，加上一下代码
<form action="myPublish.do">
<input type="text" name="content" />
<input type="submit" value="提交" >
</form>
在web.xml中加上一下代码
<servlet>
<description>This is the description of my J2EE component</description>
<display-name>This is the display name of my J2EE component</display-name>
<servlet-name>MyPublish</servlet-name>
<servlet-class>com.flvcd.servlet.MyPublish</servlet-class>
</servlet>
<servlet>
<servlet-mapping>
<servlet-name>MyPublish</servlet-name>
<url-pattern>/myPublish.do</url-pattern>
</servlet-mapping>
将你的工程装载到你的tomcat中
然后先启动activeMq（前面已说明启动方式），然后用Myeclipse启动tomcat，在页面上输入http://localhost：8080/jms-test/MyPublish.jsp，在页面上输入一些英文字符，然后你在后台可以看到你输入的字符，
注意事项，在Myeclipse中导入activeMq的jar包，我用是5.3所以有一个activemq-all-5.3.2.jar，这个jar包是全部的内容都包括，直接用Myeclipse导包方法导入的。
分享到：
相关推荐
【ActiveMQ-JMS简单实例使用Tomcat】是一个关于如何在Tomcat环境下集成并使用ActiveMQ进行JMS消息传递的初级教程。ActiveMQ是一款开源的消息中间件，它遵循JMS（Java Message Service）1.1规范，能兼容J2EE1.4及以上...
在这个"ActiveMQ-JMS简单实例"中，我们将探讨如何在Tomcat服务器上部署并使用ActiveMQ，以及通过代码实现JMS的基本功能。 首先，让我们了解ActiveMQ的核心概念。ActiveMQ作为消息代理，它接收和转发消息，提供持久...
在本文中，我们将探讨如何在Tomcat服务器上设置和使用ActiveMQ的简单实例。 **一、ActiveMQ的特点与优势** 1. **遵循JMS1.1规范**，兼容J2EE1.4及以上版本。 2. **跨平台**，可以在任何JVM和大多数Web容器中运行，...
下面介绍如何将ActiveMQ与Tomcat整合，以便在Web应用中使用JMS。 ##### 准备工作 1. **准备JAR包** 将ActiveMQ `lib` 目录下的5个核心JAR包复制到Tomcat `lib` 目录下： - `activemq-core-5.1.0.jar` - `...
这些jar包包括activemq-core、activemq-web、geronimo-j2ee-management、geronimo-jms和geronimo-jta等，它们是ActiveMQ运行和Tomcat识别其API所必需的。 2. **修改Tomcat配置**：接下来，需要编辑Tomcat的`conf/...
基于Spring+JMS+ActiveMQ+Tomcat的整合ActiveMQSpringDemo实例源码，此实例基于Spring+JMS+ActiveMQ+Tomcat，注解的完整实例，包含jar包，可供学习及设计参考。
基于Spring+JMS+ActiveMQ+Tomcat，做一个Spring4.1.0和ActiveMQ5.11.1整合实例，实现了Point-To-Point的异步队列消息和PUB/SUB（发布/订阅）模型，简单实例，不包含任何业务。
JMS简明教程+JMS规范教程+activemq以及activemq和tomcat的整合+整合实例代码+持久化消息配置以及工程+tomcat服务器的配置+整合需要的lib文件+部署多个tomcat服务器方案等
在"spring-activeMQ-demo"中，我们可以看到如何设置消息生产者（发送消息）和消费者（接收消息）的代码实例，以及如何在Spring环境中启动和关闭ActiveMQ连接。这个例子是学习和理解Spring与ActiveMQ整合的绝佳起点，...
5. **编写Java代码**: 使用JMS API创建生产者和消费者，连接到ActiveMQ服务器并发送/接收消息。 **持久化消息配置** 在ActiveMQ中，持久化消息意味着即使在服务器重启后，消息也不会丢失。这可以通过在发送消息时...
6. **Missian ActiveMQ-JMS简单实例**：这可能是一个具体的项目实例，它展示了如何在Spring应用中使用ActiveMQ实现异步RPC（远程过程调用）。在这种模式下，一个服务通过消息将请求发送到队列，另一端的服务监听队列...
在tomcat 下的context.xml文件中加入 auth="Container" type="org.apache.activemq.ActiveMQConnectionFactory" description="JMS Connection Factory" factory="org.apache.activemq.jndi....
9. **Spring注解**：在提供的实例中，可能包含了使用注解的方式配置Spring与ActiveMQ的集成，如`@EnableJms`启动JMS支持，`@JmsListener`定义消息监听器等。 10. **Tomcat服务器**：Tomcat是一个流行的Java Web...
这个实例代码是将ActiveMQ与Spring进行整合的一个实际项目，可以在Tomcat服务器上运行。由于提供了所有必要的jar包，所以无需额外下载，直接解压后部署到Tomcat即可。这表明该实例考虑到了用户友好性和易用性，避免...
综上所述，"spring jms tomcat 异步消息传递入门实例"旨在引导开发者理解如何在Spring应用中结合Tomcat使用JMS实现异步消息传递，从而提升系统的响应能力和处理大规模并发的能力。通过这个实例，你可以学习到Spring...
ActiveMQ实例主要展示了如何在不同的应用场景中集成并使用Apache ActiveMQ，这是一个功能强大的开源消息代理，它遵循Java消息服务（JMS）规范，提供了消息传递的平台。在这个实例中，我们将深入探讨ActiveMQ如何与...
- **单独应用的开发**：编写 Java 应用程序使用 ActiveMQ 的 JMS API 进行消息收发。 - **结合Spring的开发**：利用 Spring 的支持简化 ActiveMQ 的配置，并通过 Spring 管理连接和事务。 #### 五、ActiveMQ的...
这个实例是基于Java编程语言，利用Spring的JMS（Java消息服务）支持和ActiveMQ作为消息代理，同时在Tomcat服务器上运行。我们将讨论关键概念、配置和代码实现，帮助你理解和应用这个技术栈。 首先，ActiveMQ是...