<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)  編輯  收藏  
		
    
	
    
	
	





    
	    
    




    





    


    

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


    

		    		
		
    
		
    			
		
		
		
		
    
		
    
		
		
    
		
    
			網站導航:
		
		
    
		
    
			
		
    	
		
    
			 
		
    
		
    
			
		
    
		
    
			
				
		
    		
	
    	

    



    

				

    



    







    
        
	



主站蜘蛛池模板：
国产亚洲精品自在久久|
污污污视频在线免费观看|
亚洲综合色婷婷七月丁香|
在线观看免费成人|
日韩午夜理论免费TV影院|
免费国产草莓视频在线观看黄|
亚洲fuli在线观看|
亚洲人成在线电影|
亚洲日韩国产精品第一页一区|
国产人成免费视频|
宅男666在线永久免费观看|
亚洲成av人片在线观看无码不卡|
国产裸模视频免费区无码|
色影音免费色资源|
久久成人免费电影|
三级黄色在线免费观看|
一区二区三区视频免费|
美女尿口扒开图片免费|
最新亚洲人成无码网www电影|
亚洲日本乱码卡2卡3卡新区|
亚洲综合亚洲国产尤物|
午夜亚洲www湿好大|
国产亚洲精品无码成人|
亚洲熟妇丰满多毛XXXX|
久久精品国产亚洲Aⅴ香蕉|
亚洲国产免费综合|
亚洲成AV人在线观看网址|
亚洲国产精品日韩|
亚洲国产电影av在线网址|
亚洲国产成人乱码精品女人久久久不卡|
免费永久在线观看黄网站|
一本色道久久88亚洲综合|
免费一级e一片在线播放|
亚洲?V无码成人精品区日韩|
亚洲成年人啊啊aa在线观看|
亚洲成a人一区二区三区|
国产亚洲成人在线播放va|
亚洲精品蜜桃久久久久久|
亚洲av中文无码乱人伦在线咪咕
|
亚洲乱码中文字幕小综合|
亚洲性69影院在线观看|