JMS 实现方案

1、JMS 实现方案操作步骤：1.下载ActiveMQ (2.新建web工程3.把activemq-all-x.x.x.jar拷贝到WEB-INF/lib下4.在META-INF下添加context.xml如下：name=jms/FailoverConnectionFactoryauth=Containertype=org.apache.activemq.ActiveMQConnectionFactorydescription=JMS Connection Factoryfactory=org.apache.activemq.jndi.JNDIReferenceFactorybrokerURL=f

2、ailover:(tcp:/localhost:61616)?initialReconnectDelay=100& maxReconnectAttempts=5brokerName=localhostuseEmbeddedBroker=false/name=jms/NormalConnectionFactoryauth=Containertype=org.apache.activemq.ActiveMQConnectionFactorydescription=JMS Connection Factoryfactory=org.apache.activemq.jndi.JNDIRefer

3、enceFactorybrokerURL=tcp:/localhost:61616brokerName=localhostuseEmbeddedBroker=false/auth=Containertype=factory=org.apache.activemq.jndi.JNDIReferenceFactoryphysicalName=MY.TEST.FOO/auth=Containertype=factory=org.apache.activemq.jndi.JNDIReferenceFactoryphysicalName=MY.TEST.FOO.QUEUE/5.创建监听程序（推荐以Ser

4、vlet的方式）如下：package com.globalzt.servlet;import javax.jms.Connection;import javax.jms.ConnectionFactory;import javax.jms.Destination;import javax.jms.JMSException;import javax.jms.Message;import javax.jms.MessageConsumer;import javax.jms.MessageListener;import javax.jms.Session;import javax.naming.Co

5、ntext;import javax.naming.InitialContext;import javax.naming.NamingException;import javax.servlet.ServletException;import javax.servlet.http.HttpServlet;public class JMSListener extends HttpServlet implements MessageListener private static final long serialVersionUID = 1L;Overridepublic void onMessa

6、ge(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.pri

7、ntln(接收刷新论坛帖子消息，开始刷新帖子ID= + threadId); else System.out.println(接收普通消息，不做任何处理！);private static String checkText(Message msg, String str) try return msg.getStringProperty(str); catch (JMSException e) e.printStackTrace(System.out);return null;/* 初始化JMS 连接，创建topic 监听器*/Overridepublic void init() throws

8、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();conn

9、ection.setClientID(MyClient);Session jmsSession = connection.createSession(false,Session.AUTO_ACKNOWLEDGE);/ 普通消息订阅者，无法接收持久消息MessageConsumer consumer = jmsSession.createConsumer(Destination) envContext.lookup(jms/topic/MyTopic);/ 基于Topic创建持久的消息订阅者，前提：/ Connection必须指定一个唯一的clientId，当前为MyClient TopicSu

10、bscriber 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();6.Servlet配置如下：17.创建JMS测试客户端（此例为JSP，但不限于JSP，Java

11、 Application都可以）pageEncoding=UTF-8import=javax.naming.*,javax.naming.*,javax.jms.*%try InitialContext initCtx = new InitialContext();Context envContext = (Context) initCtx.lookup(java:comp/env);ConnectionFactory connectionFactory = (ConnectionFactory) envContext.lookup(jms/NormalConnectionFactory);C

12、onnection 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);produce