Active MQ (三) TOMCAT整合

通过与TOMCAT整合，使用TOMCAT的JNDI服务，通过JNDI获取ConnectionFactory等

与MQ提供商API耦合的资源，从而实现真正意义上的JMS编程。

 

1.准备：

将%ACTIVEMQ_HOME%\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

COPY到%TOMCAT6.0_HOME%\lib

(我的ACTIVEMQ是5.1.0所以要和TOMCAT6.0整合)

 

2.配置JNDI

在WEB APP的META-INF目录下新建context.xml，内容如下：

 

<?xml version='1.0' encoding='utf-8'?>
<Context>

    <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/queue/sender" 
        auth="Container" 
        type="org.apache.activemq.command.ActiveMQQueue" 
        factory="org.apache.activemq.jndi.JNDIReferenceFactory" 
        physicalName="MY.TEST.SENDER"/>
   
    <Resource name="jms/queue/receiver" 
        auth="Container" 
        type="org.apache.activemq.command.ActiveMQQueue" 
        factory="org.apache.activemq.jndi.JNDIReferenceFactory" 
        physicalName="MY.TEST.RECEIVER"/>
       
</Context>

 

3.通过ServletContextListener在WEB APP启动时将JNDI中可并发复用的部分保存于application上下文中。

 

JMSInitContextListener.java

 

package listener;

import javax.jms.Connection;
import javax.jms.ConnectionFactory;
import javax.jms.JMSException;
import javax.jms.Queue;
import javax.naming.Context;
import javax.naming.InitialContext;
import javax.naming.NamingException;
import javax.servlet.ServletContext;
import javax.servlet.ServletContextEvent;
import javax.servlet.ServletContextListener;

public class JMSInitContextListener implements ServletContextListener {

 public void contextDestroyed(ServletContextEvent e) {
  // TODO Auto-generated method stub
  
 }

 public void contextInitialized(ServletContextEvent event) {
  ServletContext application = event.getServletContext();
  String jmsConnFactory = application.getInitParameter("jmsConnFactory");
  String jmsQueueSendTo = application.getInitParameter("jmsQueueSendTo");
  String jmsQueueReceiveFrom = application.getInitParameter("jmsQueueReceiveFrom");
  try {
   Context ctxt = new InitialContext();
   
   ConnectionFactory factory = (ConnectionFactory) ctxt.lookup(jmsConnFactory);
   Connection conn = factory.createConnection();
   conn.start();
   Queue queueSendTo = (Queue) ctxt.lookup(jmsQueueSendTo);
   Queue queueReceiveFrom = (Queue) ctxt.lookup(jmsQueueReceiveFrom);
   
   application.setAttribute("jmsConnection", conn);
   application.setAttribute("jmsQueueSendTo", queueSendTo);
   application.setAttribute("jmsQueueReceiveFrom", queueReceiveFrom);
  } catch (NamingException e1) {
   // TODO Auto-generated catch block
   e1.printStackTrace();
  } catch (JMSException e) {
   // TODO Auto-generated catch block
   e.printStackTrace();
  }
 }

}

4.在WEB.XML中申明该Listener

 

<?xml version="1.0" encoding="UTF-8"?>
<web-app version="2.4"
 xmlns="http://java.sun.com/xml/ns/j2ee"
 xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
 xsi:schemaLocation="http://java.sun.com/xml/ns/j2ee
 http://java.sun.com/xml/ns/j2ee/web-app_2_4.xsd">
 
  <context-param>
   <param-name>jmsConnFactory</param-name>
   <param-value>java:comp/env/jms/NormalConnectionFactory</param-value>
  </context-param>
 
  <context-param>
   <param-name>jmsQueueSendTo</param-name>
   <param-value>java:comp/env/jms/queue/sender</param-value>
  </context-param>
 
  <context-param>
   <param-name>jmsQueueReceiveFrom</param-name>
   <param-value>java:comp/env/jms/queue/receiver</param-value>
  </context-param>
 
  <listener>
   <listener-class>listener.JMSInitContextListener</listener-class>
  </listener>
 
  <welcome-file-list>
    <welcome-file>index.jsp</welcome-file>
  </welcome-file-list>
</web-app>

5.创建一测试用的JSP

 

index.jsp 本例子实现的功能是模拟一MQ 消息客户端，模拟与上一节中的消息处理器进行通讯

 

<%@ page language="java" pageEncoding="UTF-8"%>
<jsp:directive.page import="javax.jms.Connection"/>
<jsp:directive.page import="javax.jms.Queue"/>
<jsp:directive.page import="javax.jms.Session"/>
<jsp:directive.page import="javax.jms.MessageProducer"/>
<jsp:directive.page import="javax.jms.TextMessage"/>
<jsp:directive.page import="javax.jms.MessageConsumer"/>
<jsp:directive.page import="javax.jms.Message"/>

<%
String path = request.getContextPath();
String basePath = request.getScheme()+"://"+request.getServerName()+":"+request.getServerPort()+path+"/";

Connection connection = (Connection) application.getAttribute("jmsConnection");
Queue queueSendTo = (Queue) application.getAttribute("jmsQueueSendTo");
Queue queueReceiveFrom = (Queue) application.getAttribute("jmsQueueReceiveFrom");

Session jmsSession = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);

MessageProducer sender = jmsSession.createProducer(queueSendTo);
TextMessage messageToSend = jmsSession.createTextMessage();
messageToSend.setText("Nice to meet u!");
messageToSend.setJMSCorrelationID("99999");
sender.send(messageToSend);

MessageConsumer receiver = jmsSession.createConsumer(queueReceiveFrom, "JMSCorrelationID='99999'");
Message messageReceived = receiver.receive(3000);

receiver.close();
sender.close();
jmsSession.close();
%>

<!DOCTYPE HTML PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN">
<html>
  <head>
    <base href="<%=basePath%>">
   
    <title>JMS Queue Test</title>
 <meta http-equiv="pragma" content="no-cache">
 <meta http-equiv="cache-control" content="no-cache">
 <meta http-equiv="expires" content="0">   
 <meta http-equiv="keywords" content="keyword1,keyword2,keyword3">
 <meta http-equiv="description" content="This is my page">
 <!--
 <link rel="stylesheet" type="text/css" href="styles.css">
 -->
  </head>
 
  <body>
 JMS Queue Test<br>
 <%="Send :" + messageToSend.getText()%><br>
 <%="Send JMSCorrelationID :" + messageToSend.getJMSCorrelationID()%><br>
 <%="-----------------------------------------" %><br>
 <% if (messageReceived instanceof TextMessage) { %>
  <%="Receive : " + ((TextMessage) messageReceived).getText()%><br>
  <%="Receive JMSCorrelationID : " + ((TextMessage) messageReceived).getJMSCorrelationID()%><br>
 <% } %>
  </body>
</html>

6.测试

 

开启MQ，创建对应的QUEUE，运行上一节的消息处理器，启动TOMCAT，进入index.jsp,刷新index.jsp

 

7.参考资料

 

http://activemq.apache.org/tomcat.html