基于memcached-session-manager的tomcat session共享集群
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安装:
参考:Memcached安装和配置
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
# pwd
/usr/local/tomcat7/webapps/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
# pwd
/usr/local/tomcat7/webapps/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
遇到同样的问题。 kryo序列化 测试一直报错。
SEVERE org.apache.catalina.core.StandardContext.startInternal The session manager failed to start
org.apache.catalina.LifecycleException: Failed to start component ]
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)
页:
[1]