提交: 9cff5fc9af03e5a87470e20aa16a25a46fb0ddd8 - moto_web_app (git)

moto web application

Commit MetaInfo

• 修订版: 9cff5fc9af03e5a87470e20aa16a25a46fb0ddd8 (tree)
• 时间: 2014-01-24 16:45:10
• 作者: astoria-d <astoria-d@mail...>
• Commiter: astoria-d

Log Message

inter browsers ajax push notification updated.

更改概述

• modified: .gitignore
• modified: WEB-INF/classes/motoSample/ChatBean.java
• modified: WEB-INF/classes/motoSample/LoginFilter.java
• modified: WEB-INF/classes/motoSample/PushBean.java
• modified: secured/chat.xhtml

差异

--- a/.gitignore
+++ b/.gitignore
@@ -4,3 +4,4 @@ deleted/*
 this-proj-is-jsf2.0-named-annotation.txt
 data-source-memo.txt
 aaa.txt
+jboss.cmd-shortcut.lnk

--- a/WEB-INF/classes/motoSample/ChatBean.java
+++ b/WEB-INF/classes/motoSample/ChatBean.java
@@ -6,6 +6,7 @@ import javax.faces.bean.ViewScoped;
 import javax.faces.bean.ManagedProperty;
 import javax.faces.context.FacesContext;
 import javax.servlet.http.HttpServletRequest;
+import javax.servlet.http.HttpSession;
 
 import java.util.logging.Logger;
 import javax.inject.Inject;
@@ -25,6 +26,9 @@ import javax.faces.component.html.HtmlCommandLink;
 
 import java.util.Date;
 import java.text.SimpleDateFormat;
+import java.util.UUID;
+import java.util.Map;
+import java.util.Hashtable;
 
 
 @ManagedBean
@@ -40,6 +44,10 @@ public class ChatBean implements Serializable {
     //inject user bean
     @ManagedProperty("#{userBean}")
     private UserBean userBean;
+    
+    @ManagedProperty("#{pushBean}")
+    private PushBean pushBean;
+    
     
     private String msg;
     private String chatRoom;
@@ -49,6 +57,8 @@ public class ChatBean implements Serializable {
     
     public final static int LIST_LOAD_SIZE = 10;
 
+    private String viewId = null;
+    
     public void setMsg(String msg) {
         this.msg = msg;
     }
@@ -70,15 +80,26 @@ public class ChatBean implements Serializable {
         //log.info("getLoadLink");
         return loadLink;
     }
+    public String getViewId() {
+        if (viewId == null)
+            viewId = UUID.randomUUID().toString();
+        return viewId;
+    }
+    public void setViewId(String viewId) {
+        this.viewId = viewId;
+    }
     
 
-    //userBean injection. setter only.
+    //session bean injection. setter only.
     public void setUserBean(UserBean userBean) {
         this.userBean = userBean;
     }
+    public void setPushBean(PushBean pushBean) {
+        this.pushBean = pushBean;
+    }
 
     ///chat list data
-    public class ChatMessage {
+    public static class ChatMessage {
         private String uname;
         private String msg;
         private String date;
@@ -91,10 +112,26 @@ public class ChatBean implements Serializable {
         public String getDate() {
             return date;
         }
+        public void setUname(String uname) {
+            this.uname = uname;
+        }
+        public void setMsg(String msg) {
+            this.msg = msg;
+        }
+        public void setDate(String date) {
+            this.date = date;
+        }
+    }
+
+    public class ViewMsgList {
+        public String viewId;
+        public String chatRoom;
+        public ArrayList<ChatMessage> msgList;
     }
 
 	private void initMsgList(){
-        log.info("initMsgList: " + chatRoom);
+        log.info("initMsgList: " + chatRoom + ", msgList: " 
+            + (msgList == null ? "null" : msgList.hashCode()) + ", viewId: " + getViewId());
         try {
             Connection conn = Resources.getConnection();
             String uid = userBean.getUid();
@@ -128,27 +165,44 @@ public class ChatBean implements Serializable {
         catch (SQLException se) {
             log.severe("sql err!!!");
         }
+
+	    //register viewlist in the session to receive ajax push notification update.
+	    HttpSession session = (HttpSession) context.getExternalContext().getSession(true);
+	    Map<String, ViewMsgList> viewMap = (Map<String, ViewMsgList>) session.getAttribute("viewMap");
+	    if (viewMap == null) {
+	        viewMap = new Hashtable<String, ViewMsgList>();
+	        session.setAttribute("viewMap", viewMap);
+	    }
+	    ViewMsgList mvl = new ViewMsgList();
+	    mvl.viewId = viewId;
+	    mvl.chatRoom = chatRoom;
+	    mvl.msgList = msgList;
+	    viewMap.put(viewId, mvl);
 	}
     
 	public ArrayList<ChatMessage> getMsgList(){
         //log.info("getMsgList: " + chatRoom);
 		return msgList;
 	}
-	    
+
+    public static String formatDate() {
+        Date d = new Date();
+        SimpleDateFormat df = new SimpleDateFormat("yyyy/MM/dd HH:mm:ss");
+        return df.format(d);
+    }
+    
     public void doPost() {
         //skip empty message....
         if (msg.equals(""))
             return;
         
-        Date d = new Date();
-        SimpleDateFormat df = new SimpleDateFormat("yyyy/MM/dd HH:mm:ss");
-
         /*
         log.info("user = " + userBean.getUid());
         log.info("chat room = " + chatRoom);
         log.info("date = " + df.format(d));
         */
 
+        String dt = formatDate();
         try {
             Connection conn = Resources.getConnection();
             String sqlString = "insert into tb_chat_msg (user_id , chat_room , message , msg_date, deleted) values (?, ?, ?, ?, ?)";
@@ -158,28 +212,32 @@ public class ChatBean implements Serializable {
             ps.setString(1, userBean.getUid());
             ps.setString(2, chatRoom);
             ps.setString(3, msg);
-            ps.setString(4, df.format(d));
+            ps.setString(4, dt);
             ps.setString(5, "false");
 
             int cnt = ps.executeUpdate();
-            log.info(cnt + " records inserted.");
+            log.info(cnt + " records inserted from the view " + viewId);
 
             conn.close();
 
+            /*
+            no need!!! will be added in jms subscriber onMessage() method.
             //add msgList...
             ChatMessage m = new ChatMessage();
             m.uname = userBean.getUid();
             m.msg = msg;
-            m.date = df.format(d);
+            m.date = dt;
             if (msgList == null) {
                 msgList = new ArrayList<ChatMessage>();
             }
             msgList.add(m);
+            */
         }
         catch (SQLException se) {
             log.severe("sql err!!!");
         }
         
+        pushBean.doPush(viewId, chatRoom, msg, userBean.getUid(), dt);
     }
 
     public void loadOldMsg() {
@@ -235,14 +293,14 @@ public class ChatBean implements Serializable {
 
     @PostConstruct
     public void postInit() {
-        log.info("postInit");
+        log.info("postInit @" + this.hashCode());
         //log.info("PostConstruct userBean: " + userBean);
         //log.info("PostConstruct getFlights: " + userBean.getFlights());
         ArrayList<SelectItem> flights = userBean.getFlights();
         if (flights != null) {
             chatRoom = userBean.getFlights().get(0).getValue().toString();
 
-            log.info("method: " + ((HttpServletRequest) context.getExternalContext().getRequest()).getMethod());
+            //log.info("method: " + ((HttpServletRequest) context.getExternalContext().getRequest()).getMethod());
             if (((HttpServletRequest) context.getExternalContext().getRequest()).getMethod().equals("GET")) {
                 log.info("get access. init chat list");
                 //in get access, the chat room is not selected..
@@ -252,7 +310,7 @@ public class ChatBean implements Serializable {
                 initLoadLink();
             }
         }
-        
+        //log.info("viewId = " + viewId);
     }
 
 }

--- a/WEB-INF/classes/motoSample/LoginFilter.java
+++ b/WEB-INF/classes/motoSample/LoginFilter.java
@@ -34,8 +34,8 @@ public class LoginFilter implements Filter {
         // Get the userBean from session attribute
         UserBean ubean = (UserBean)session.getAttribute("userBean");
         
-        logger.info("cpath:" + ((HttpServletRequest) request).getContextPath());
-        logger.info("uri:" + ((HttpServletRequest) request).getRequestURI());
+        //logger.info("cpath:" + ((HttpServletRequest) request).getContextPath());
+        //logger.info("uri:" + ((HttpServletRequest) request).getRequestURI());
 
         String req_url = ((HttpServletRequest) request).getRequestURI().replace(((HttpServletRequest) request).getContextPath(), "");
         logger.info("request_url:" + req_url);

--- a/WEB-INF/classes/motoSample/PushBean.java
+++ b/WEB-INF/classes/motoSample/PushBean.java
@@ -6,6 +6,10 @@ import javax.faces.bean.SessionScoped;
 import javax.faces.bean.ManagedProperty;
 import javax.faces.context.FacesContext;
 import javax.faces.event.ActionEvent;
+import javax.faces.component.UIComponent;
+import javax.faces.component.UIInput;
+
+import javax.servlet.http.HttpSession;
 
 import java.util.logging.Logger;
 import javax.inject.Inject;
@@ -18,7 +22,7 @@ import org.richfaces.application.push.MessageException;
 
 import javax.jms.MessageListener;
 import javax.jms.Message;
-import javax.jms.TextMessage;
+import javax.jms.MapMessage;
 
 import javax.naming.Context;
 import javax.naming.InitialContext;
@@ -35,6 +39,10 @@ import javax.jms.TopicSubscriber;
 import javax.jms.TopicPublisher;
 import javax.jms.JMSException;
 
+import java.util.Map;
+import java.util.Hashtable;
+import java.util.Enumeration;
+
 
 @ManagedBean
 @SessionScoped
@@ -44,8 +52,9 @@ public class PushBean implements MessageListener, Serializable {
     private Logger log;
 
     @Inject
-    private FacesContext context;
+    private FacesContext context = null;
 
+    /*
     private int msgCnt = 0;
     public void setMsgCnt(int msgCnt) {
         this.msgCnt = msgCnt;
@@ -53,6 +62,9 @@ public class PushBean implements MessageListener, Serializable {
     public int getMsgCnt() {
         return msgCnt;
     }
+    */
+    
+    private Hashtable<String, ChatBean.ViewMsgList> viewMap;
     
     private static final String PUSH_JMS_TOPIC = "motoTest";
 
@@ -75,9 +87,9 @@ public class PushBean implements MessageListener, Serializable {
     private TopicSubscriber subscriber = null;
 
     @PostConstruct
-    public void initJms() throws JMSException, NamingException {
+    public void initPushBean() throws JMSException, NamingException {
 
-        log.info("initJms");
+        log.info("initPushBean");
 
         if (connection == null) {
             TopicConnectionFactory tcf = getTopicConnectionFactory();
@@ -108,31 +120,83 @@ public class PushBean implements MessageListener, Serializable {
         // Start the JMS connection; allows messages to be delivered
         connection.start( );
         log.info("connection start ok.");
-    }
 
-    public void doPush(ActionEvent event) throws MessageException, JMSException {
-        log.info("push: ");
+        //get list of receiver view of this session....
+	    HttpSession req_session = (HttpSession) context.getExternalContext().getSession(true);
+	    viewMap = (Hashtable<String, ChatBean.ViewMsgList>) req_session.getAttribute("viewMap");
+	    if (viewMap == null) {
+	        viewMap = new Hashtable<String, ChatBean.ViewMsgList>();
+	        req_session.setAttribute("viewMap", viewMap);
+	    }
+    }
 
-        TopicKey topicKey = new TopicKey("flight_no_001");
-        TopicsContext topicsContext = TopicsContext.lookup();
-        topicsContext.publish(topicKey, "empty message");
+    //this method is invoked from the sender side.
+    public void doPush(String viewId, String chatRoom, String msg, String uid, String date) {
+        //UIComponent view = event.getComponent();
+        //log.info("view: " + view);
+        //log.info("viewId: " + view.findComponent("viewId"));
         /*
+        String viewId = (String)((UIInput)view.findComponent("viewId")).getValue();
+        String chatRoom = (String)((UIInput)view.findComponent("chatRoom")).getValue();
+        String msg = (String)((UIInput)view.findComponent("msg")).getSubmittedValue();
+        String uid = (String)((UIInput)view.findComponent("uid")).getValue();
         */
-
-        TextMessage message = session.createTextMessage();
-        message.setText("msgggggg");
+        log.info("push from view " + viewId + ", msg=" + msg);
+
+        try {
+        MapMessage message = session.createMapMessage();
+        message.setString("viewId", viewId);
+        message.setString("chatRoom", chatRoom);
+        message.setString("msg", msg);
+        message.setString("uid", uid);
+        message.setString("date", date);
         publisher.publish(message);
 
-        //String uid = userBean.getUid();
-        //log.info("message ");
+        //deliver jms message
         log.info("message published by " + this.hashCode());
+        //log.info("context: " + context);
+
+        //notify ajax.
+        TopicKey topicKey = new TopicKey(chatRoom);
+        TopicsContext topicsContext = TopicsContext.lookup();
+        topicsContext.publish(topicKey, "notify");
+        /*
+        */
+        }
+        catch (JMSException je) {
+            log.severe("jms exeption!!");
+        }
+        catch (MessageException me) {
+            log.severe("message exeption!!");
+        }
     }
 
+    //this method is invoked on the receiver side.
     public void onMessage(Message message) {
-        //String uid = userBean.getUid();
-        msgCnt++;
+        //msgCnt++;
         log.info("message received by " + this.hashCode());
-        
+        //log.info("viewMap size: " + viewMap.size());
+        MapMessage mmsg = (MapMessage)message;
+
+        for (Enumeration<ChatBean.ViewMsgList> em = viewMap.elements(); em.hasMoreElements(); ) {
+            ChatBean.ViewMsgList vml = em.nextElement();
+            //update the view only if it has the same chat room
+            try {
+                if (!mmsg.getString("chatRoom").equals(vml.chatRoom))
+                    continue;
+
+                ChatBean.ChatMessage m = new ChatBean.ChatMessage();
+                m.setUname(mmsg.getString("uid"));
+                m.setMsg(mmsg.getString("msg"));
+                m.setDate(mmsg.getString("date"));
+                vml.msgList.add(m);
+
+                log.info("update msgview list!!: " + vml.viewId);
+            }
+            catch (JMSException je) {
+                log.severe("get message error!!");
+            }
+        }
     }
 
     @PreDestroy

--- a/secured/chat.xhtml
+++ b/secured/chat.xhtml
@@ -11,17 +11,20 @@
 
             user : #{userBean.uname} <br />
 
+            <h:outputText value="#{chatBean.viewId}"/>
+            <br />
+
     		<h:form xmlns:a4j="http://richfaces.org/a4j"
     		    xmlns:rich="http://richfaces.org/rich">
 
+                <h:inputHidden id="viewId" value="#{chatBean.viewId}"/>
+
                 <a4j:push address="#{chatBean.chatRoom}">
-                <!--a4j:push address="motoTest"-->
-                    <a4j:ajax event="dataavailable" render="msgList msgCnt" />
+                    <a4j:ajax event="dataavailable" render="chatTable" />
                 </a4j:push>
-
                <h:outputText id="msgCnt" value="#{pushBean.msgCnt}"/>
-
+
                 chat room : 
-                <h:selectOneMenu id="charRoom" value="#{chatBean.chatRoom}" onchange="submit()" 
+                <h:selectOneMenu id="chatRoom" value="#{chatBean.chatRoom}" onchange="submit()" 
                     valueChangeListener="#{chatBean.chatRoomChanged}" >
                     <f:selectItems value="#{userBean.flights}"/>
                 </h:selectOneMenu>
@@ -59,8 +62,8 @@
                     input text: <h:inputText id="msg" value="#{chatBean.msg}"/>
                 </h:panelGroup>
 
-                <h:commandButton value="post" action="#{chatBean.doPost}" actionListener="#{pushBean.doPush}" >
-                    <f:ajax execute="charRoom msg" render="chatTable" />
+                <h:commandButton value="post" action="#{chatBean.doPost}" >
+                    <f:ajax execute="viewId chatRoom msg" render="chatTable" />
                 </h:commandButton>
     		</h:form>