俊星的BLOG

APACHE Geronimo 试用之JMS

1、通过控制台的ActiveMQ创建如下JMS准备环境：
Type     Name     Deployed As     State     Actions
Connection Factory     jms/TestJMSFactory2     Server-wide     running     
Queue     jms/TestJMSQueue2     Server-wide     running
具体常见方法请参考：http://cwiki.apache.org/GMOxDOC21/web-application-for-jms-access.html

2、创建AdminServlet：
package webjms;

import java.io.IOException;
import java.io.PrintWriter;

import javax.annotation.Resource;
import javax.jms.Connection;
import javax.jms.ConnectionFactory;
import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.MessageConsumer;
import javax.jms.Queue;
import javax.jms.Session;
import javax.jms.TextMessage;
import javax.servlet.ServletException;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;

/**
 * Servlet implementation class for Servlet: AdminServlet
 * 
 */
public class AdminServlet extends javax.servlet.http.HttpServlet implements
        javax.servlet.Servlet {
    @Resource(name = "jms/TestJMSFactory2")
    private ConnectionFactory connectionFactory;

    @Resource(name = "jms/TestJMSQueue2")
    private Queue queue;

    public AdminServlet() {
        super();
    }

    protected void doGet(HttpServletRequest request,
            HttpServletResponse response) throws ServletException, IOException {
        PrintWriter out = response.getWriter();
        if (connectionFactory == null) {
            out.println("Connection Factory lookup has failed");
            return;
        }
        if (queue == null) {
            out.println("Queue lookup has failed");
            return;
        }
        Connection connection = null;
        try {
            connection = connectionFactory.createConnection();
            Session session = connection.createSession(false,
                    Session.AUTO_ACKNOWLEDGE);
            MessageConsumer consumer = session.createConsumer(queue);
            connection.start();
            out
                    .println("The following information has been received for updation\n");
            while (true) {
                Message m = consumer.receive();
                if (m instanceof TextMessage) {
                    TextMessage message = (TextMessage) m;
                    out.println(message.getText());
                } else {
                    break;
                }
            }
        } catch (JMSException e) {
            e.printStackTrace();
        } finally {
            if (connection != null) {
                try {
                    connection.close();
                } catch (JMSException e1) {
                }
            }
        }
    }

    protected void doPost(HttpServletRequest request,
            HttpServletResponse response) throws ServletException, IOException {
        doGet(request, response);
    }
}

3、创建UserServlet：
package webjms;

import java.io.IOException;
import java.io.PrintWriter;
import java.util.Enumeration;

import javax.annotation.Resource;
import javax.jms.Connection;
import javax.jms.ConnectionFactory;
import javax.jms.JMSException;
import javax.jms.MessageProducer;
import javax.jms.Queue;
import javax.jms.Session;
import javax.jms.TextMessage;
import javax.servlet.ServletException;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;

public class UserServlet extends javax.servlet.http.HttpServlet implements
        javax.servlet.Servlet {
    @Resource(name = "jms/TestJMSFactory2")
    private ConnectionFactory connectionFactory;
    @Resource(name = "jms/TestJMSQueue2")
    private Queue queue;
    static final long serialVersionUID = 1L;

    public UserServlet() {
        super();
    }

    protected void doGet(HttpServletRequest request,
            HttpServletResponse response) throws ServletException, IOException {
        PrintWriter out = response.getWriter();
        if (connectionFactory == null) {
            out.println("Connection Factory lookup has failed");
            return;
        }

        if (queue == null) {
            out.println("Queue lookup has failed");
            return;
        }

        Connection connection = null;
        try {
            connection = connectionFactory.createConnection();
            connection.start();
            Session session = connection.createSession(false,
                    Session.AUTO_ACKNOWLEDGE);
            MessageProducer producer = session.createProducer(queue);
            TextMessage message = session.createTextMessage();
            Enumeration arr = request.getParameterNames();
            while (arr.hasMoreElements()) {
                String fields = (String) arr.nextElement();
                String paramname[] = request.getParameterValues(fields);
                for (int i = 0; i < paramname.length; i++) {
                    String s = null;
                    s = fields + ":" + paramname[i];
                    message.setText(s);
                    producer.send(message);
                }

            }
            out.println("Your request has been sent to administrator.");
            producer.send(session.createMessage());
        } catch (JMSException e) {
            e.printStackTrace();
        } finally {
            if (connection != null) {
                try {
                    connection.close();
                } catch (JMSException e1) {
                }
            }
        }
    }

    protected void doPost(HttpServletRequest request,
            HttpServletResponse response) throws ServletException, IOException {
        doGet(request, response);
    }
}

4、创建index.jsp文件：
<%@ page language="java" contentType="text/html; charset=ISO-8859-1"
    pageEncoding="ISO-8859-1"%>
<!DOCTYPE html PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN" "http://www.w3.org/TR/html4/loose.dtd">
<html>
<head>
<meta http-equiv="Content-Type" content="text/html; charset=ISO-8859-1">
<title>Sample Web Application accessing JMS Resources</title>
</head>
<body>
<form action="/WebJMS2/UserServlet">
<h1>Please enter the updated information</h1>
<table>
    <tr>
        <td>UserName:</td>
        <td><input type="text" name="username" size="30"></td>
    </tr>
    <tr>
        <td>UserID:</td>
        <td><input type="text" name="userid" size="30"></td>
    </tr>
    <tr>
        <td>Old Address:</td>
        <td><input type="text" name="oldaddress" size="30"></td>
    </tr>
    <tr>
        <td>New Address:</td>
        <td><input type="text" name="newaddress" size="30"></td>
    <tr>
</table>
<input type="submit" value="Submit"></form>
</body>
</html>

5、geronimo-web.xml的配置：
<?xml version="1.0" encoding="UTF-8"?>
<web-app xmlns="http://geronimo.apache.org/xml/ns/j2ee/web-1.2" 
         xmlns:nam="http://geronimo.apache.org/xml/ns/naming-1.2" 
         xmlns:sec="http://geronimo.apache.org/xml/ns/security-1.1" 
         xmlns:sys="http://geronimo.apache.org/xml/ns/deployment-1.2">
  <sys:environment>
    <sys:moduleId>
      <sys:groupId>default</sys:groupId>
      <sys:artifactId>WebJMS2</sys:artifactId>
      <sys:version>1.0</sys:version>
      <sys:type>car</sys:type>
    </sys:moduleId>
    <sys:dependencies>
            <sys:dependency>
                <sys:groupId>org.apache.geronimo.configs</sys:groupId>
                <sys:artifactId>activemq-ra</sys:artifactId>
                <sys:version>2.1.4</sys:version>
                <sys:type>car</sys:type>
            </sys:dependency>
        </sys:dependencies>
  </sys:environment>
  <context-root>/WebJMS2</context-root>
  <nam:resource-ref>
        <nam:ref-name>jms/TestJMSFactory2</nam:ref-name>
        <nam:pattern>
            <nam:groupId>org.apache.geronimo.configs</nam:groupId>
            <nam:artifactId>activemq-ra</nam:artifactId>
            <nam:version>2.1.4</nam:version>
            <nam:name>DefaultActiveMQConnectionFactory</nam:name>
        </nam:pattern>
    </nam:resource-ref>
    <nam:resource-env-ref>
        <nam:ref-name>jms/TestJMSQueue2</nam:ref-name>
        <nam:pattern>
            <nam:groupId>org.apache.geronimo.configs</nam:groupId>
            <nam:artifactId>activemq-ra</nam:artifactId>
            <nam:version>2.1.4</nam:version>
            <nam:name>SendReceiveQueue</nam:name>
        </nam:pattern>
    </nam:resource-env-ref>
</web-app>

6、web.xml文件的配置：
<?xml version="1.0" encoding="UTF-8"?>
<web-app xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xmlns="http://java.sun.com/xml/ns/javaee" 
    xmlns:web="http://java.sun.com/xml/ns/javaee/web-app_2_5.xsd"
    xsi:schemaLocation="http://java.sun.com/xml/ns/javaee http://java.sun.com/xml/ns/javaee/web-app_2_5.xsd"
    id="WebApp_ID" version="2.5">
    <display-name>WebJMS</display-name>
    <welcome-file-list>
        <welcome-file>index.jsp</welcome-file>
    </welcome-file-list>
    <servlet>
        <description></description>
        <display-name>AdminServlet</display-name>
        <servlet-name>AdminServlet</servlet-name>
        <servlet-class>webjms.AdminServlet</servlet-class>
    </servlet>
    <servlet>
        <description></description>
        <display-name>UserServlet</display-name>
        <servlet-name>UserServlet</servlet-name>
        <servlet-class>webjms.UserServlet</servlet-class>
    </servlet>
    <servlet-mapping>
        <servlet-name>AdminServlet</servlet-name>
        <url-pattern>/AdminServlet</url-pattern>
    </servlet-mapping>
    <servlet-mapping>
        <servlet-name>UserServlet</servlet-name>
        <url-pattern>/UserServlet</url-pattern>
    </servlet-mapping>
</web-app>

7、发布及查看运行结果：
将WebJMS.war发布即可，具体请点击此处下载，运行结果的查看可通过下面的两个URL实现：
http://localhost:8080/WebJMS2/
http://localhost:8080/WebJMS2/AdminServlet

posted on 2009-05-12 22:09 俊星 阅读(365) 评论(0)  编辑  收藏


只有注册用户登录后才能发表评论。
网站导航: