<rt id="bn8ez"></rt>
<label id="bn8ez"></label>
  • 

    • <span id="bn8ez"></span>
    

    <label id="bn8ez"><meter id="bn8ez"></meter></label>
    

    
    

    




    







												


        


    


    俊星的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 俊星 閱讀(375) 評論(0)  編輯  收藏  
		
    
	
    
	
	





    
	    
    




    





    


    

	
    
		
    
				
		
	
		
    
		
		
    只有注冊用戶登錄后才能發表評論。
    
		
    
			
		
    
			
		
    
		
		
    
		


    

		    		
		
    
		
    			
		
		
		
		
    
		
    
		
		
    
		
    
			網站導航:
		
		
    
		
    
			
		
    	
		
    
			 
		
    
		
    
			
		
    
		
    
			
				
		
    		
	
    	

    



    

				

    



    







    
        
	



主站蜘蛛池模板：
亚洲乱码一二三四区麻豆|
亚洲日韩一中文字暮|
99re视频精品全部免费|
亚洲日本va在线观看|
亚洲毛片av日韩av无码|
99国产精品免费视频观看|
亚洲欧美日韩中文字幕在线一区|
亚洲国产精品国产自在在线|
16女性下面扒开无遮挡免费|
色多多免费视频观看区一区|
亚洲短视频男人的影院|
国产免费爽爽视频免费可以看|
国产午夜无码精品免费看|
亚洲另类自拍丝袜第五页|
精品久久久久久亚洲|
成人性生交大片免费看午夜a|
最近免费中文字幕中文高清|
亚洲视频一区二区三区四区|
亚洲线精品一区二区三区影音先锋|
在人线av无码免费高潮喷水|
久久九九免费高清视频|
亚洲中文字幕久久精品无码A|
亚洲成AV人片在线观看无码|
国产高清在线免费|
0588影视手机免费看片|
国产99精品一区二区三区免费|
中文文字幕文字幕亚洲色|
久久精品国产精品亚洲精品|
又粗又大又猛又爽免费视频
|
久久精品视频免费播放|
美女又黄又免费的视频|
亚洲美女精品视频|
亚洲开心婷婷中文字幕|
五月天婷亚洲天综合网精品偷|
丁香花免费高清视频完整版|
暖暖在线视频免费视频|
特黄aa级毛片免费视频播放|
亚洲精品123区在线观看|
亚洲视频在线免费播放|
国产av无码专区亚洲av桃花庵|
亚洲高清偷拍一区二区三区|