tomcat基于session会话保持以及msm会话保持
Posted
tags:
篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了tomcat基于session会话保持以及msm会话保持相关的知识，希望对你有一定的参考价值。
实验一、基于tomcat集群会话保持
一、实验环境：
一台nginx服务器，两台tomcat集群，出于实验的原因，我就把nginx也放在其中一台的tomcat服务器上。也就是一共两台机器，都是centos7的环境。
二、实验原理：
DeltaManager会话管理器是tomcat默认的集群会话管理器，它主要用于集群中各个节点之间会话状态的同步维护。集群增量会话管理器的职责是将某节点的会话该变同步到集群内其他成员节点上，它属于全节点复制模式，所谓全节点复制是指集群中某个节点的状态变化后需要同步到集群中剩余的节点，非全节点方式可能只是同步到其中某个或若干节点。在集群中全节点会话复制的一个大致步骤如图所示，客户端发起一个请求，假设通过一定的负载均衡设备分发策略分到其中一个结点node1，如果还未存在session对象的话web容器将会创建一个会话对象，接着执行一些逻辑处理，在对客户端响应之前有个重要的事情是要把session对象同步到集群中其他节点上，最后再响应客户端。当客户端第二次发起请求时，假如分发到node3节点上，由于同步了node1的session会话，所以在执行逻辑时并不会取不到session的值。如果删除某个会话对象，则要同时通知其他节点把相应会话删除，如果修改了某个会话的某些属性也同样要更新到其他节点的会话中。
三、实验拓扑图：
四、实验步骤：
第一步：搭建nginx服务
配置文件如下：vim /etc/nginx/nginx.conf
第二步：安装tomcat环境，这个不需要说了，注意的地方就是先需要实现Java环境。
第三步：配置tomcat，支持会话保持，两边的tomcat都是一样的配置。
<Cluster className="org.apache.catalina.ha.tcp.SimpleTcpCluster" channelSendOptions="8">
<Manager className="org.apache.catalina.ha.session.DeltaManager"
expireSessionsOnShutdown="false"
notifyListenersOnReplication="true"/>
<Channel className="org.apache.catalina.tribes.group.GroupChannel">
<Membership className="org.apache.catalina.tribes.membership.McastService"
address="228.0.0.4" port="45564" frequency="500" dropTime="3000"/>
<Receiver className="org.apache.catalina.tribes.transport.nio.NioReceiver"
address="172.17.254.171" port="4000" autoBind="100" selectorTimeout="5000" maxThreads="6"/>
<Sender className="org.apache.catalina.tribes.transport.ReplicationTransmitter">
<Transport className="org.apache.catalina.tribes.transport.nio.PooledParallelSender"/>
</Sender>
<Interceptor className="org.apache.catalina.tribes.group.interceptors.TcpFailureDetector"/>
<Interceptor className="org.apache.catalina.tribes.group.interceptors.MessageDispatch15Interceptor"/>
</Channel>
<Valve className="org.apache.catalina.ha.tcp.ReplicationValve" filter="/"/>
<Valve className="org.apache.catalina.ha.session.JvmRouteBinderValve"/>
<ClusterListener className="org.apache.catalina.ha.session.ClusterSessionListener"/>
</Cluster>
第四步：编写一个小教本进行测试。
Tomcat1： vim /usr/local/tomcat/webapps/test/index.jsp
<%@ page language="java" %>
<html>
<head><title>TomcatA</title></head>
<body>
<h1><font color="blue">TomcatA </h1>
<table border="1">
<tr>
<td>Session ID</td>
<% session.setAttribute("abc","abc"); %>
<td><%= session.getId() %></td>
</tr>
<tr>
<td>Created on</td>
<td><%= session.getCreationTime() %></td>
</tr>
</table>
</body>
</html>
Tomcat2：
<%@ page language="java" %>
<html>
<head><title>TomcatB</title></head>
<body>
<h1><font color="blue">TomcatB </h1>
<table border="1">
<tr>
<td>Session ID</td>
<% session.setAttribute("abc","abc"); %>
<td><%= session.getId() %></td>
</tr>
<tr>
<td>Created on</td>
<td><%= session.getCreationTime() %></td>
</tr>
</table>
</body>
</html>
第五步：需要在当前脚本所在目录下自定义一个WEB-INF的目录，加上一个分布式存储的标签
mkdir test/WEB-INF
cp /usr/local/tomcat/conf/web.xml /usr/local/tomcat/webapps/test/WEB-INF/
vim web.xml
第六步：测试结果，发现结果都是一样的，说明实验成功
易错点：tomcat是通过组播的方式复制session的，所以组播地址最好加上路由，避免自动绑定的ip地址不在一个网段上，不然就把Receiver的IP自动获取改成自己手动配置。
实验二：tomcat结合memcached实现seesion共享
一、实验环境：两台tomcat，一台nginx负载均衡器，两台memcache缓存
二、实验原理：虽然由tomcat自身带的机制可以实现session复制，但是这只是能实现小并发的情况，大并发的session复制对于tomcat来说资源消耗太大，每一个会话复制上千台机器负载太大，所以需要新的机制来实现这个问题，这就是我们所说的memcache缓存可以解决的问题，也就是我们常说的memcached-session-manager-2.1.1.jar，简称msm.把用户访问的session都存储到一台memcache上，就能实现数据的一致性。
三、实验拓扑图：
四、实验步骤：
第一步：下载tomcat需要的支持memcache的库文件。每个tomcat都需要。
下载如下jar文件至各tomcat节点的tomcat安装目录下的lib目录中，其中的${version}要换成你所需要的版本号，tc${6,7,8}要换成与tomcat版本相同的版本号。
memcached-session-manager-${version}.jar
memcached-session-manager-tc${6,7,8}-${version}.jar
spymemcached-${version}.jar
msm-javolution-serializer-${version}.jar
javolution-${version}.jar
第二步：定义tomcat需要的会话管理器。
分别在两个tomcat上的某host上定义一个用于测试的context容器，并在其中创建一个会话管理器，如下所示：
<Context path="/test" docBase="/usr/local/tomcat/webapps/test" reloadable="true">
<Manager className="de.javakaffee.web.msm.MemcachedBackupSessionManager"
memcachedNodes="n1:172.16.100.9:11211,n2:172.16.100.10:11211"
failoverNodes="n1"
requestUriIgnorePattern=".*\.(ico|png|gif|jpg|css|js)$"
transcoderFactoryClass="de.javakaffee.web.msm.serializer.javolution.JavolutionTranscoderFactory"/>
</Context>
第三步：提供测试页面
别为两个context提供测试页面：
tomcatA:
# mkdir -pv /usr/local/tomcat/webapps/test/WEB-INF/{classes,lib}
# vim /usr/local/tomcat/webapps/test/index.jsp
添加如下内容：
<%@ page language="java" %>
<html>
<head><title>TomcatA</title></head>
<body>
<h1><font color="red">TomcatA</font></h1>
<table border="1">
<tr>
<td>Session ID</td>
<% session.setAttribute("magedu.com","magedu.com"); %>
<td><%= session.getId() %></td>
</tr>
<tr>
<td>Created on</td>
<td><%= session.getCreationTime() %></td>
</tr>
</table>
</body>
</html>
tomcatB:
# mkdir -pv /usr/local/tomcat/webapps/test/WEB-INF/{classes,lib}
# vim /usr/local/tomcat/webapps/test/index.jsp
添加如下内容：
<%@ page language="java" %>
<html>
<head><title>TomcatB</title></head>
<body>
<h1><font color="blue">TomcatB.magedu.com</font></h1>
<table border="1">
<tr>
<td>Session ID</td>
<% session.setAttribute("magedu.com","magedu.com"); %>
<td><%= session.getId() %></td>
</tr>
<tr>
<td>Created on</td>
<td><%= session.getCreationTime() %></td>
</tr>
</table>
</body>
</html>
第四步：配置反向代理
vim /etc/nginx/nginx.conf
upstream tomcat_cluster {
#ip_hash;
server 172.17.254.171:8080 weight=1;
server 172.17.254.181:8080 weight=2;
}
server {
listen 80;
server_name xiaomi;
root /usr/local/tomcat/webapps/ROOT;
# Load configuration files for the default server block.
include /etc/nginx/default.d/*.conf;
index index.jsp;
location ~* \.(jsp|do)$ {
proxy_pass http://tomcat_cluster;
}
测试页面：
以上是关于tomcat基于session会话保持以及msm会话保持的主要内容，如果未能解决你的问题，请参考以下文章
Tomcat基于MSM+Memcached实现Session共享
Nginx反代至Tomcat基于memcached的session保持