JMS 實(shí)現(xiàn)方案

1、JMS 實(shí)現(xiàn)方案操作步驟：1.下載ActiveMQ (2.新建web工程3.把a(bǔ)ctivemq-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.創(chuàng)建監(jiān)聽程序（推薦以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 連接，創(chuàng)建topic 監(jiān)聽器*/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創(chuàng)建持久的消息訂閱者，前提：/ Connection必須指定一個(gè)唯一的clientId，當(dāng)前為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.創(chuàng)建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);/設(shè)置持久方式producer.setDeliveryMode(DeliveryMode.PERSISTENT);Message testMessage = jmsSession.createMessage();/發(fā)布刷新文章消息testMessage.setStringProperty(RefreshArticleId, 2046);producer.send(testMessage);/發(fā)布刷新帖子消息testMessage.clearProperties();testMessage.setStringProperty(RefreshThreadId, 331);produce