提交: 2dd62314104889a981c474da54dd46a35c83f201 - moto_web_app (git)

moto web application

Commit MetaInfo

• 修訂: 2dd62314104889a981c474da54dd46a35c83f201 (tree)
• 時間: 2014-02-04 10:49:38
• 作者: astoria-d <astoria-d@mail...>
• Commiter: astoria-d

Log Message

comet session check added

Change Summary

• add: WEB-INF/classes/motoSample/AtmosFilter.java
• modified: WEB-INF/web.xml

差異

--- /dev/null
+++ b/WEB-INF/classes/motoSample/AtmosFilter.java
@@ -0,0 +1,38 @@
+package motoSample;
+
+import org.atmosphere.cpr.PerRequestBroadcastFilter;
+import org.atmosphere.cpr.BroadcastFilter.BroadcastAction;
+import org.atmosphere.cpr.AtmosphereResource;
+
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import javax.servlet.http.HttpSession;
+
+
+public class AtmosFilter implements PerRequestBroadcastFilter {
+    private final Logger logger = LoggerFactory.getLogger(AtmosFilter.class);
+
+    @Override
+    public BroadcastAction filter(AtmosphereResource atmosphereResource, Object originalMessage, Object message) {
+        HttpSession session = atmosphereResource.session();
+        
+        if (session == null) {
+            logger.info("session expired.");
+            return new BroadcastAction(BroadcastAction.ACTION.ABORT, message);
+        }
+
+        UserBean ubean = (UserBean)session.getAttribute("userBean");
+        if (ubean == null || !ubean.isLoggedIn()) {
+            logger.info("login required.");
+            return new BroadcastAction(BroadcastAction.ACTION.ABORT, message);
+        }
+
+        //logger.info("atmos filter ok.");
+        return new BroadcastAction(message);
+    }
+
+    @Override
+    public BroadcastAction filter(Object originalMessage, Object message) {
+        return new BroadcastAction(message);
+    }
+}

--- a/WEB-INF/web.xml
+++ b/WEB-INF/web.xml
@@ -53,10 +53,20 @@
         <!-- Use it with mvn jetty:run -->
         <load-on-startup>0</load-on-startup>
         <async-supported>true</async-supported>
+
+        <!-- atmosphere filter mapping. -->
+        <init-param>
+            <param-name>org.atmosphere.cpr.sessionSupport</param-name>
+            <param-value>true</param-value>
+        </init-param>
+        <init-param>
+            <param-name>org.atmosphere.cpr.broadcastFilterClasses</param-name>
+            <param-value>motoSample.AtmosFilter</param-value>
+        </init-param>
+
     </servlet>
     <servlet-mapping>
         <servlet-name>AtmosphereServlet</servlet-name>
     	<url-pattern>/chat/*</url-pattern>
     </servlet-mapping>
-
-</web-app>
+
</web-app>