Tomcat集群和Session复制应用介绍
程序员文章站
2023-12-01 19:53:10
一个配置文件： 复制代码 代码如下:
<cluster classname="org.apache.catalina.ha.tcp.simpletcpcluster"
channelsendoptions="6">
<manager classname="org.apache.catalina.ha.session.backupmanager"
expiresessionsonshutdown="false"
notifylistenersonreplication="true"
mapsendoptions="6"/>
<!--
<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="auto"
port="5000"
selectortimeout="100"
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"/>
<interceptor classname="org.apache.catalina.tribes.group.interceptors.throughputinterceptor"/>
</channel>
<valve classname="org.apache.catalina.ha.tcp.replicationvalve"
filter=".*\.gif|.*\.js|.*\.jpeg|.*\.jpg|.*\.png|.*\.htm|.*\.html|.*\.css|.*\.txt"/>
<deployer classname="org.apache.catalina.ha.deploy.farmwardeployer"
tempdir="/tmp/war-temp/"
deploydir="/tmp/war-deploy/"
watchdir="/tmp/war-listen/"
watchenabled="false"/>
<clusterlistener classname="org.apache.catalina.ha.session.clustersessionlistener"/>
</cluster>
说明如下：
1、cluster
<cluster classname="org.apache.catalina.ha.tcp.simpletcpcluster"
channelsendoptions="6">
1）tomcat集群主元素，在这个元素里面可以配置集群的所有详细信息
2）classname主要的集群类，当前只提供了org.apache.catalina.ha.tcp.simpletcpcluste作为实现类
3）channelsendoptionssession发送方式，默认值是8，这个标识确定通过simpletcpcluste如何发送消息
4） channel.send_options_synchronized_ack = 0x0004
channel.send_options_asynchronous = 0x0008
channel.send_options_use_ack = 0x0002
如果使用(asynchronous)加(use_ack)方式来发送消息，那么值应该是10(8+2)或者0x000b
如果使用(synchronized_ack)加(use_ack)方式来发送消息，那么值应该是6(4+2)或者0x0006
2、manager
<manager classname="org.apache.catalina.ha.session.backupmanager"
expiresessionsonshutdown="false"
notifylistenersonreplication="true"
mapsendoptions="6"/>
<!--
<manager classname="org.apache.catalina.ha.session.deltamanager"
expiresessionsonshutdown="false"
notifylistenersonreplication="true"/>
-->
1）管理tomcat之间的session复制
2）classname当前有两个实现类：org.apache.catalina.ha.session.deltamanager和org.apache.catalina.ha.session.backupmanager
3）deltamanager复制并发送session数据到集群下所有的节点，这个实现类被证明非常可靠、运行得非常好。不过有个局限性就是集群的节点类型要相同，而且要部署相同的应用程序
4）expiresessionsonshutdown当一个web程序被结束时，tomcat分发销毁命令到每个session，并通知所有session listener执行。当集群下某个节点被停止时，如果想销毁所有节点下的的session，设置为true，默认为false
5）notifylistenersonreplication如果设置为true,当session属性被复制和移动的时候，session listener被通知
3、channel
<channel classname="org.apache.catalina.tribes.group.groupchannel">
channel是apache tribes的主组件，channel管理一组子组件，并和它们一起组成了tomcat实例间的通讯框架。在tomcat集群中，deltamanager通过simpletcpcluster调用channel来实现信息传递，而backupmanager自己调用channel以及子组件这些组件来实现信息传递。replicatedcontext也会调用channel传递context属性。
4、membership
<membership classname="org.apache.catalina.tribes.membership.mcastservice"
address="228.0.0.4"
port="45564"
frequency="500"
droptime="3000"/>
membership组件自动检索发现集群里的新节点或已经停止工作的节点，并发出相应的通知。默认使用组播（multicast）实现。
5、receiver
<receiver classname="org.apache.catalina.tribes.transport.nio.nioreceiver"
address="auto"
port="5000"
selectortimeout="100"
maxthreads="6"/>
负责监听接收其他节点传送过来的数据。默认使用non-blocking tcp server sockets。
6、sender
<sender classname="org.apache.catalina.tribes.transport.replicationtransmitter">
<transport classname="org.apache.catalina.tribes.transport.nio.pooledparallelsender"/>
</sender>
管理从一个节点发送到另外一个节点的出站连接和数据信息，允许信息并行发送。默认使用tcp client sockets。
7、interceptor
<interceptor classname="org.apache.catalina.tribes.group.interceptors.tcpfailuredetector"/>
<interceptor classname="org.apache.catalina.tribes.group.interceptors.messagedispatch15interceptor"/>
<interceptor classname="org.apache.catalina.tribes.group.interceptors.throughputinterceptor"/>
channel通过interceptor堆栈进行消息传递，在这里可以自定义消息的发送和接收方式，甚至membership的处理方式。
8、value
<valve classname="org.apache.catalina.ha.tcp.replicationvalve"
filter=".*\.gif|.*\.js|.*\.jpeg|.*\.jpg|.*\.png|.*\.htm|.*\.html|.*\.css|.*\.txt"/>
1）value在调用http request 链中起着拦截器的作用，用来决定什么情况下数据需要被复制。
org.apache.catalina.ha.tcp.replicationvalve，replicationvalue在http request结尾判断当前数据是否需要被复制。
2）filter内容为url或者文件结尾，当访问链接配置filter时，不论实际session有没有改变，集群会认为session没有任何变化，从而不会复制和发送改变的session属性。
9、deployer
<deployer classname="org.apache.catalina.ha.deploy.farmwardeployer"
tempdir="/tmp/war-temp/"
deploydir="/tmp/war-deploy/"
watchdir="/tmp/war-listen/"
watchenabled="false"/>
使集群支持farmed deployment
10、clusterlistener
<clusterlistener classname="org.apache.catalina.ha.session.clustersessionlistener"/>
clusterlistener用来追踪信息发送和接收。
clustersessionlistener用来监听集群组件接收信息，当使用deltamanager的时候，信息被集群接收，并通过clustersessionlistener传递给session manager。
一个配置文件：
复制代码 代码如下:
<cluster classname="org.apache.catalina.ha.tcp.simpletcpcluster"
channelsendoptions="6">
<manager classname="org.apache.catalina.ha.session.backupmanager"
expiresessionsonshutdown="false"
notifylistenersonreplication="true"
mapsendoptions="6"/>
<!--
<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="auto"
port="5000"
selectortimeout="100"
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"/>
<interceptor classname="org.apache.catalina.tribes.group.interceptors.throughputinterceptor"/>
</channel>
<valve classname="org.apache.catalina.ha.tcp.replicationvalve"
filter=".*\.gif|.*\.js|.*\.jpeg|.*\.jpg|.*\.png|.*\.htm|.*\.html|.*\.css|.*\.txt"/>
<deployer classname="org.apache.catalina.ha.deploy.farmwardeployer"
tempdir="/tmp/war-temp/"
deploydir="/tmp/war-deploy/"
watchdir="/tmp/war-listen/"
watchenabled="false"/>
<clusterlistener classname="org.apache.catalina.ha.session.clustersessionlistener"/>
</cluster>
说明如下：
1、cluster
复制代码 代码如下:
<cluster classname="org.apache.catalina.ha.tcp.simpletcpcluster"
channelsendoptions="6">
1）tomcat集群主元素，在这个元素里面可以配置集群的所有详细信息
2）classname主要的集群类，当前只提供了org.apache.catalina.ha.tcp.simpletcpcluste作为实现类
3）channelsendoptionssession发送方式，默认值是8，这个标识确定通过simpletcpcluste如何发送消息
4） channel.send_options_synchronized_ack = 0x0004
channel.send_options_asynchronous = 0x0008
channel.send_options_use_ack = 0x0002
如果使用(asynchronous)加(use_ack)方式来发送消息，那么值应该是10(8+2)或者0x000b
如果使用(synchronized_ack)加(use_ack)方式来发送消息，那么值应该是6(4+2)或者0x0006
2、manager
复制代码 代码如下:
<manager classname="org.apache.catalina.ha.session.backupmanager"
expiresessionsonshutdown="false"
notifylistenersonreplication="true"
mapsendoptions="6"/>
<!--
<manager classname="org.apache.catalina.ha.session.deltamanager"
expiresessionsonshutdown="false"
notifylistenersonreplication="true"/>
-->
1）管理tomcat之间的session复制
2）classname当前有两个实现类：org.apache.catalina.ha.session.deltamanager和org.apache.catalina.ha.session.backupmanager
3）deltamanager复制并发送session数据到集群下所有的节点，这个实现类被证明非常可靠、运行得非常好。不过有个局限性就是集群的节点类型要相同，而且要部署相同的应用程序
4）expiresessionsonshutdown当一个web程序被结束时，tomcat分发销毁命令到每个session，并通知所有session listener执行。当集群下某个节点被停止时，如果想销毁所有节点下的的session，设置为true，默认为false
5）notifylistenersonreplication如果设置为true,当session属性被复制和移动的时候，session listener被通知
3、channel
复制代码 代码如下:
<channel classname="org.apache.catalina.tribes.group.groupchannel">
channel是apache tribes的主组件，channel管理一组子组件，并和它们一起组成了tomcat实例间的通讯框架。在tomcat集群中，deltamanager通过simpletcpcluster调用channel来实现信息传递，而backupmanager自己调用channel以及子组件这些组件来实现信息传递。replicatedcontext也会调用channel传递context属性。
4、membership
复制代码 代码如下:
<membership classname="org.apache.catalina.tribes.membership.mcastservice"
address="228.0.0.4"
port="45564"
frequency="500"
droptime="3000"/>
membership组件自动检索发现集群里的新节点或已经停止工作的节点，并发出相应的通知。默认使用组播（multicast）实现。
5、receiver
复制代码 代码如下:
<receiver classname="org.apache.catalina.tribes.transport.nio.nioreceiver"
address="auto"
port="5000"
selectortimeout="100"
maxthreads="6"/>
负责监听接收其他节点传送过来的数据。默认使用non-blocking tcp server sockets。
6、sender
复制代码 代码如下:
<sender classname="org.apache.catalina.tribes.transport.replicationtransmitter">
<transport classname="org.apache.catalina.tribes.transport.nio.pooledparallelsender"/>
</sender>
管理从一个节点发送到另外一个节点的出站连接和数据信息，允许信息并行发送。默认使用tcp client sockets。
7、interceptor
复制代码 代码如下:
<interceptor classname="org.apache.catalina.tribes.group.interceptors.tcpfailuredetector"/>
<interceptor classname="org.apache.catalina.tribes.group.interceptors.messagedispatch15interceptor"/>
<interceptor classname="org.apache.catalina.tribes.group.interceptors.throughputinterceptor"/>
channel通过interceptor堆栈进行消息传递，在这里可以自定义消息的发送和接收方式，甚至membership的处理方式。
8、value
复制代码 代码如下:
<valve classname="org.apache.catalina.ha.tcp.replicationvalve"
filter=".*\.gif|.*\.js|.*\.jpeg|.*\.jpg|.*\.png|.*\.htm|.*\.html|.*\.css|.*\.txt"/>
1）value在调用http request 链中起着拦截器的作用，用来决定什么情况下数据需要被复制。
org.apache.catalina.ha.tcp.replicationvalve，replicationvalue在http request结尾判断当前数据是否需要被复制。
2）filter内容为url或者文件结尾，当访问链接配置filter时，不论实际session有没有改变，集群会认为session没有任何变化，从而不会复制和发送改变的session属性。
9、deployer
复制代码 代码如下:
<deployer classname="org.apache.catalina.ha.deploy.farmwardeployer"
tempdir="/tmp/war-temp/"
deploydir="/tmp/war-deploy/"
watchdir="/tmp/war-listen/"
watchenabled="false"/>
使集群支持farmed deployment
10、clusterlistener
复制代码 代码如下:
<clusterlistener classname="org.apache.catalina.ha.session.clustersessionlistener"/>
clusterlistener用来追踪信息发送和接收。
clustersessionlistener用来监听集群组件接收信息，当使用deltamanager的时候，信息被集群接收，并通过clustersessionlistener传递给session manager。