基于memcached-session-manager的tomcat session共享集群

6y45t4

MSM的特性：
   a、支持tomcat 6,tomcat 7,tomcat 8
   b、支持sticky session或no-sticky session
   c、无单点故障
   d、tomcat故障转移
   e、memcached故障转移
   f、附带串行化插件
   g、支持异步session存储，拥有更快的性能


sticky sessions粘性会话：

     安装了MSM的tomcat会优先使用本机内存保存session，当一个请求结束后，MSM会把session发送到memcached节点上存放以作备份，第二次请求时，如果本地有session就直接返回，第二次请求结束，把session修改后的信息更新到后端的memcached服务器，以这样的方式来保持本地的session与memcached上的session同步。当这个tomcat节点宕机时，那么用户的下一次请求就会被前端的负载均衡器路由到另一个tomcat节点上，而这个节点上并没有这个用户的session信息，这个节点就从memcached服务器上去读取session，并把session保存到本地的内存，当请求结束，session又被修改，再送回到memcached进行存放备份

    当后端配置了多台memcached时，MSM在更新session信息时会同时向多个memcached节点更新session，当一个memcached节点故障时，tomcat可以从选择一个正常工作的memcached节点读取session信息来发送给用户的浏览器，让其重置session信息，这样，memcached也达到了高可用的目的



non-sticky session非粘性会话：
   tomcat session为中转session， 假设memcached1为主session ，memcached2 为备session。Request请求到来时，从memcached2加载备session到tomcat，如果memcached2没有就从memcached1上读取session，如果memcached1也没有就读取本地session，如果没有本地session就在本地创建，当请求结束时，将本地的session更新至memcached1和memcached2上，并且清除本地的session


jdk安装：
    略



tomcat7安装：
    略



memcached安装：
    参考：[url=]Memcached安装和配置[/url]

    libevent版本：libevent-2.0.22-stable

    memcached版本：memcached-1.4.36


序列化策略：

    1、内置的JAVA序列化
transcoderFactoryClass="de.javakaffee.web.msm.JavaSerializationTranscoderFactory"    2、kryo序列化：（据说效率最高）

transcoderFactoryClass="de.javakaffee.web.msm.serializer.kryo.KryoTranscoderFactory"    3、javolution序列化：

transcoderFactoryClass="de.javakaffee.web.msm.serializer.javolution.JavolutionTranscoderFactory"    4、xstream序列化：

    5、flexjson序列化：


序列化所需jar包：
    1、内置的JAVA序列化：

1 2 3

memcached-session-manager-2.1.1.jar memcached-session-manager-tc7-2.1.1.jar spymemcached-2.12.2.jar

        2、kryo序列化：

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17

msm相关：         memcached-session-manager-2.1.1.jar         memcached-session-manager-tc7-2.1.1.jar（tomcat7使用）         spymemcached-2.12.2.jar kryo序列化相关：         asm-5.2.4.jar         kryo-4.0.0.jar         kryo-serializers-0.39.jar         minlog-1.3.jar         msm-kryo-serializer-2.1.1.jar         reflectasm-1.09.jar jar包下载地址：     memcached-session-manager-2.1.1.jar，memcached-session-manager-tc7-2.1.1.jar，msm-kryo-serializer-2.1.1.jar：http://repo1.maven.org/maven2/de/javakaffee/msm     spymemcached-2.12.2.jar：http://repo1.maven.org/maven2/net/spy/     asm-5.2.4.jar：http://www.java2s.com/Code/Jar/a/asm.htm     kryo-4.0.0.jar，minlog-1.3.jar，reflectasm-1.09.jar：http://maven.outofmemory.cn/com.esotericsoftware/     kryo-serializers-0.39.jar：http://maven.outofmemory.cn/de.javakaffee/

        3、javolution序列化：

1 2 3 4 5 6 7 8 9 10 11

msm相关：         memcached-session-manager-2.1.1.jar         memcached-session-manager-tc7-2.1.1.jar（tomcat7使用）         spymemcached-2.12.2.jar javolution序列化相关:         msm-javolution-serializer-2.1.1.jar         javolution-5.5.1.jar jar包下载地址：     msm-javolution-serializer-2.1.1.jar：http://repo1.maven.org/maven2/de/javakaffee/msm     javolution-5.5.1.jar：http://www.java2s.com/Code/JarDownload/javolution/

        4、xstream序列化：

1 2 3 4 5 6 7 8 9

msm相关：         memcached-session-manager-2.1.1.jar         memcached-session-manager-tc7-2.1.1.jar（tomcat7使用）         spymemcached-2.12.2.jar xstream序列化相关:         msm-xstream-serializer         xstream         xmlpull         xpp3_min

        5、flexjson序列化：

1 2 3 4 5 6 7

msm相关：         memcached-session-manager-2.1.1.jar         memcached-session-manager-tc7-2.1.1.jar（tomcat7使用）         spymemcached-2.12.2.jar flexjson序列化相关:         msm-flexjson-serializer         flexjson

序列化验证：
    内置的JAVA序列化 和 javolution序列化 测试验证通过

    kryo序列化 测试一直报错未解决

    xstream序列化 和 flexjson序列化 未测试


配置：（采用 javolution序列化）
    1、将 javolution-5.5.1.jar，memcached-session-manager-2.1.1.jar，memcached-session-manager-tc7-2.1.1.jar，msm-javolution-serializer-2.1.1.jar，spymemcached-2.12.2.jar 这5个jar包放到tomcat的lib目录下（如：/usr/local/tomcat7/lib）

    2、修改 /usr/local/tomcat7/conf/context.xml 文件

1 2 3 4 5 6 7 8 9 10 11 12 13 14

##sticky sessions粘性会话 <Context> ........         <Manager className="de.javakaffee.web.msm.MemcachedBackupSessionManager"              memcachedNodes="memcached1:192.168.231.134:22121,memcached2:192.168.231.132:22121"              failoverNodes="memcached1"              requestUriIgnorePattern=".*\.(ico|png|gif|jpg|css|js)$"              transcoderFactoryClass="de.javakaffee.web.msm.serializer.javolution.JavolutionTranscoderFactory"/> ....... </Context> ##failoverNodes="memcached1"告诉MSM优先从memcached2获取session数据，当memcached2不可用时才从memcached1获取session数据

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15

##non-sticky session非粘性会话（sticky="false"） <Context> .......         <Manager className="de.javakaffee.web.msm.MemcachedBackupSessionManager"              memcachedNodes="memcached1:192.168.231.134:22121,memcached2:192.168.231.132:22121"              sticky="false"              sessionBackupAsync="false"              lockingMode="uriPattern:/path1|/path2"              requestUriIgnorePattern=".*\.(ico|png|gif|jpg|css|js)$"              transcoderFactoryClass="de.javakaffee.web.msm.serializer.javolution.JavolutionTranscoderFactory"/> ........ </Context> ##sticky="false"

测试：（sticky sessions粘性会话）
         failoverNodes="memcached1"

         tomcatA：192.168.231.132

         tomcatB：192.168.231.134

    tomcatA：

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21

[iyunv@localhost test]# pwd /usr/local/tomcat7/webapps/test [iyunv@localhost test]# vim index.jsp <%@ page language="java" %> <html>   <head><title>TomcatA</title></head>   <body>     <h1><font color="blue">TomcatA</font></h1>     <table align="centre" border="1">       <tr>         <td>Session ID</td>     <% session.setAttribute("192.168.231.132","192.168.231.132"); %>         <td><%= session.getId() %></td>       </tr>       <tr>         <td>Created on</td>         <td><%= session.getCreationTime() %></td>      </tr>     </table>   </body> </html>

       tomcatB：

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21

[iyunv@master test]# pwd /usr/local/tomcat7/webapps/test [iyunv@master test]# vim index.jsp <%@ page language="java" %> <html>   <head><title>TomcatB</title></head>   <body>     <h1><font color="blue">TomcatB</font></h1>     <table align="centre" border="1">       <tr>         <td>Session ID</td>     <% session.setAttribute("192.168.231.134","192.168.231.134"); %>         <td><%= session.getId() %></td>       </tr>       <tr>         <td>Created on</td>         <td><%= session.getCreationTime() %></td>      </tr>     </table>   </body> </html>

    nginx作负载：

        192.168.231.132


   由上可以看出两台tomcat保存的sessionID是一致的，memcached使用的是memcached2



   关闭memcached2：



   由上可以看出两台tomcat保存的sessionID没变化，memcached使用的是memcached1，memcached是高可用的


   继续关闭memcached1

    换一个浏览器访问



   由上可以看出两台tomcat保存的sessionID不一致了，此时采用的是tomcat本地session数据



    启动memcached1


   由上可以看出两台tomcat保存的sessionID又一致了，memcached使用的是memcached1

longjiayu

遇到同样的问题。 kryo序列化 测试一直报错。

SEVERE [localhost-startStop-1] org.apache.catalina.core.StandardContext.startInternal The session manager failed to start
org.apache.catalina.LifecycleException: Failed to start component [de.javakaffee.web.msm.MemcachedBackupSessionManager[]]
        at org.apache.catalina.util.LifecycleBase.start(LifecycleBase.java:162)
        at org.apache.catalina.core.StandardContext.startInternal(StandardContext.java:5331)
        at org.apache.catalina.util.LifecycleBase.start(LifecycleBase.java:145)
        at org.apache.catalina.core.ContainerBase$StartChild.call(ContainerBase.java:1408)
        at org.apache.catalina.core.ContainerBase$StartChild.call(ContainerBase.java:1398)
        at java.util.concurrent.FutureTask.run(FutureTask.java:266)
        at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
        at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
        at java.lang.Thread.run(Thread.java:745)
Caused by: java.lang.NoClassDefFoundError: org/objenesis/strategy/InstantiatorStrategy
        at de.javakaffee.web.msm.serializer.kryo.KryoTranscoderFactory.getTranscoder(KryoTranscoderFactory.java:64)
        at de.javakaffee.web.msm.serializer.kryo.KryoTranscoderFactory.createTranscoder(KryoTranscoderFactory.java:47)
        at de.javakaffee.web.msm.MemcachedSessionService.createTranscoderService(MemcachedSessionService.java:497)
        at de.javakaffee.web.msm.MemcachedSessionService.startInternal(MemcachedSessionService.java:452)
        at de.javakaffee.web.msm.MemcachedBackupSessionManager.startInternal(MemcachedBackupSessionManager.java:535)
        at org.apache.catalina.util.LifecycleBase.start(LifecycleBase.java:145)