Apache ActiveMQ教程（六）
Apache ActiveMQ教程（六）4、Publisher端（publish.jsp）实现：
在jms-test目录下新建publish.jsp文件：
<%@ page language="java" import="javax.jms.*" pageEncoding="GBK"%>
<%@ page language="java" import="javax.naming.*"%>
<%@ page language="java" import="org.apache.activemq.ActiveMQConnectionFactory"%>
<%
try {
InitialContext initCtx = new InitialContext();
Context envContext = (Context) initCtx.lookup("java:comp/env");
ConnectionFactory connectionFactory = (ConnectionFactory) envContext.lookup("jms/NormalConnectionFactory");
Connection connection = connectionFactory.createConnection();
Session jmsSession = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
MessageProducer producer = jmsSession.createProducer((Destination) envContext.lookup("jms/topic/MyTopic"));
//设置持久方式
producer.setDeliveryMode(DeliveryMode.PERSISTENT);
Message testMessage = jmsSession.createMessage();
//发布刷新文章消息
testMessage.setStringProperty("RefreshArticleId", "2046");
producer.send(testMessage);
//发布刷新帖子消息
testMessage.clearProperties();
testMessage.setStringProperty("RefreshThreadId", "331");
producer.send(testMessage);
} catch (NamingException e) {
e.printStackTrace();
} catch (JMSException e) {
e.printStackTrace();
}
%>
Publisher和Listner之间通过Message的setStringProperty和getStringProperty方法，实现对应的业务逻辑。
上述示例代码中，RefreshArticleId代表刷新某篇文章，RefreshThreadId代表刷新某个帖子，property值保持对应的ID。当然用户可根据实际需求灵活地使用。
5、运行Demo：
5.1 启动ActiveMQ服务器
5.2 启动Tomcat服务器：JMSListener将自动连接ActiveMQ broker，日志信息:
Successfully connected to tcp://localhost:61616
5.3 访问http://localhost:8080/jms-test/publish.jsp
Tomcat服务器日志将提示：
接收刷新文章消息，开始刷新文章ID=2046
接收刷新论坛帖子消息，开始刷新帖子ID=331
5.4 访问http://localhost:8161/admin/topics.jsp查看MY.TEST.FOO的消息日志，分别发送和接收2条。
至此，已成功完成ActiveMQ与Tomcat的基本整合！
Publisher和Listener完全可以独立部署到不同的Web服务器上，并通过ActiveMQ来进行消息传递，实现用户所需的业务逻辑。
测试持久消息的具体步骤：
l 启动Publisher所在Web服务器
l 启动ActiveMQ
l 访问publish.jsp发送消息，此时Listener还未启动，消息将保存在ActiveMQ的bin\activemq-data目录下，查看日志可以看到发送2条，接收0条
l 启动Listener所在Web服务器，将自动接收到ActiveMQ的持久消息并处理，查看日志：发送2条，接收2条，表明持久消息应用成功！
页:
[1]