OECP平台对集群session的处理

题外话：程序的架构依赖于系统的架构，系统运行的环境决定了程序设计的方式，单单以集群为例，在程序的开发上与集中化部署就有很大的不同，架构的意义就在 于发现这些不同，设计合理和容易扩展的结构以更小代价的适应未来的这种变化，分层的设计其实也是规避环境变化而造成系统整体的变动的一种方法。
 
Session应该是web开发独有的，必须要面对的。Session让web程序的会话保持变得如此的简单，但是也带来了很多问题，比如：有很多开发人 员享受了session的便利，把大部分东西往session中放，滥用session，造成服务器资源的浪费；跨域session丢失的问题等等。
 
今天就谈一下session在集群环境下的问题。

• 集群的各个节点无法共享同一个session。虽然现在可以通过Ngnix和apache将会话都路由到同一个应用服务器，但是随之而来带来下面一个问题。
• 在一个节点出现故障时，无法平滑的转移到另外一台应用服务器。虽然现在很多应用服务器都可以实现session复制，但是在集群节点非常多的时候，无疑对服务器的资源和效能都是一个极大的浪费。

 
为了解决这些问题，一些大型的互联网站点和应用系统，纷纷抛弃session机制，而采用cookie,cache,db等各种手段来替代 session，但是从复杂性和成本上来看，各种手段都需要重新考量。如果您的系统未来有可能成长为很庞大的规模，您不得不考虑这些问题。
 
OECP平台作为企业应用的业务平台，它是企业应用的核心，关联着组件和平台之间，组件和组件之间，用户和平台之间的交互，在具有一定规模的企业中，它将 承载着巨大的系统负荷，所以平台的开发之初就要设计相关的集群特征。HttpSession则是首要要考虑的。在设计的时候考虑了几种方案：
1、自己实现HttpSession以替换HttpServletRequest下的实现。这是一个比较好的方法，对调用者来说是隐藏的，但是难度比较大，同时requeset下的session依然可用，也不是很好的统一。
2、自己利用session和cache构建一个自己的session map，所有的开发者都需要调用这个session map，session和cache同步是需要必须做到的，否则session存在，cache中却失效了。而且多加了一个东西，依然不能完全替代 session，开发人员需要按照规定的套路走，不是很灵活。
3、依然采用HttpServletRequest的httpsession，但是利用cache做同步，将session同步到分布式cache中。当 一个节点故障需要转移到另外一个节点时，利用全局的cache，依然保证session不会丢失。而且同步cache的操作应该是可插拔的，以适应集中式 部署和分布式部署的环境。
 
我们采用了第3个方案，利用cache同步缓存，已达到session复制的目的。选用什么作为cache的载体呢？其实方案还是挺多的，可以采用 EHCache/JbossCache等java系的Cache组件，也可以采用流行的memdcache，当然也可以适用类似于MongoDB这样的 NoSQL存储系统。我们暂且采用EHCache来实现，未来不排除增加基于MongoDB的实现。下面就直接上代码了：
1、首先要实现HttpSessionListener，在session创建的时候，创建cache；在session销毁的时候，销毁cache。 

java 代码

1. @Override  
2.     public void sessionCreated(HttpSessionEvent event) {   
3.         HttpSession httpSession = event.getSession();   
4.         String sessionId = httpSession.getId();   
5.         SessionMap sessionMap = new SessionMap();   
6.         sessionMap.put("creationTime", httpSession.getCreationTime());// 复制session的创建时间到缓存中，以用来在session转移时使用   
7.         CacheManager.set(WebConstant.OECP_CACHE_SESSION, sessionId, sessionMap);// 初始化缓存 
8.     }   
9.   
10.     @Override  
11.     public void sessionDestroyed(HttpSessionEvent event) {   
12.         HttpSession httpSession = event.getSession();   
13.         String sessionId = httpSession.getId();   
14.         CacheManager.evict(WebConstant.OECP_CACHE_SESSION, sessionId);// 直接清除掉   
15.         httpSession = null;//将session清空   
16.     }   
17.   

2、其次要实现HttpSessionAttributeListener，用来监听session的变化，以保证将最新的session同步到cache中。

java 代码

1. @Override  
2.     public void attributeAdded(HttpSessionBindingEvent event) {   
3.         HttpSession httpSession = event.getSession();   
4.         String attrName = event.getName();   
5.         Object attrValue = event.getValue();   
6.         String sessionId = httpSession.getId();   
7.         SessionMap sessionMap = (SessionMap) CacheManager.get(   
8.                 WebConstant.OECP_CACHE_SESSION, sessionId);   
9.         if (sessionMap == null) {   
10.             sessionMap = new SessionMap();   
11.         }   
12.         if (attrValue instanceof Serializable) {   
13.             sessionMap.put(attrName, (Serializable) attrValue);   
14.         }   
15.         CacheManager.set(WebConstant.OECP_CACHE_SESSION, sessionId, sessionMap);   
16.   
17.     }   
18.   
19.     @Override  
20.     public void attributeRemoved(HttpSessionBindingEvent event) {   
21.         HttpSession httpSession = event.getSession();   
22.   
23.         String attrName = event.getName();   
24.         String sessionId = httpSession.getId();   
25.         SessionMap sessionMap = (SessionMap) CacheManager.get(   
26.                 WebConstant.OECP_CACHE_SESSION, sessionId);   
27.         if (sessionMap != null) {   
28.             sessionMap.remove(attrName);   
29.             CacheManager.set(WebConstant.OECP_CACHE_SESSION, sessionId,   
30.                     sessionMap);   
31.         }   
32.   
33.     }   
34.   
35.     @Override  
36.     public void attributeReplaced(HttpSessionBindingEvent event) {   
37.         attributeAdded(event);   
38.   
39.     }   
40.   

3、最后增加一个SnaFilter，用来做故障时，session的转移（即cache到session的转化）。通过session和cache的同步比较，可以保持cache和session的时效一致性。

java 代码

1. public class SnaFilter implements Filter {   
2.   
3.     private Log logger = LogFactory.getLog(SnaFilter.class);   
4.   
5.     private static boolean cluster = false;   
6.   
7.     @Override  
8.     public void destroy() {   
9.         // TODO 记录系统日志   
10.     }   
11.   
12.     @Override  
13.     public void doFilter(ServletRequest req, ServletResponse res,   
14.             FilterChain chain) throws IOException, ServletException {   
15.         final HttpServletRequest hrequest = (HttpServletRequest) req;   
16.         final HttpServletResponse hresponse = (HttpServletResponse) res;   
17.         String uri = hrequest.getRequestURI();   
18.         logger.debug("开始SNA拦截-----------------" + uri);   
19.         HttpSession httpSession = hrequest.getSession();   
20.         String sessionId = httpSession.getId();   
21.         long sessionTime = httpSession.getCreationTime();   
22.         SessionMap sessionMap = (SessionMap) CacheManager.get(   
23.                 WebConstant.OECP_CACHE_SESSION, sessionId);   
24.         if (sessionMap != null  
25.                 && (Long.valueOf(sessionMap.get("creationTime").toString())) != sessionTime) {// session的创建时间和集群缓存里的session的创建时间不一致，则需要复制session   
26.             // 将cache的数据复制到session中   
27.             initHttpSession(httpSession, sessionMap);   
28.         }   
29.         chain.doFilter(hrequest, hresponse);   
30.   
31.     }   
32.   
33.     private void initHttpSession(HttpSession session,   
34.             SessionMap sessionMap) {   
35.         Set<String> keySet = sessionMap.keySet();   
36.         Iterator<String> it = keySet.iterator();   
37.         while (it.hasNext()) {   
38.             String key = it.next();   
39.             session.setAttribute(key, sessionMap.get(key));   
40.         }   
41.         sessionMap.put("creationTime", session.getCreationTime());   
42.         CacheManager.set(WebConstant.OECP_CACHE_SESSION, session.getId(),   
43.                 sessionMap);   
44.     }   
45.   
46.     @Override  
47.     public void init(FilterConfig chain) throws ServletException {   
48.         cluster = true;   
49.     }   
50.   
51.     public static boolean isCluster() {   
52.         return cluster;   
53.     }   
54.   
55. }   
56.   

以上三个步骤已经基本实现了集群化的session处理，但是还需要其他配置相配合。第一就是ehcache的集群化配置，这个有两种方式，一个是广播 式，将cache同步到各个节点；一个是分布集中式，将缓存都同步到一个节点上。同时以上实现都是基于插件思想的，在需要集群的时候只要配置到 web.xml中，即可。不用的时候可以卸载，一避免浪费资源。这两部分的配置我就省略了，有兴趣的朋友可以查一下。


关于OECP平台的最新进展请继续关注：http://prj.oecp.cn/projects/oecp-platform

 

 

原文：http://www.oecp.cn/hi/yongtree/blog/2461 （含附件）