当前位置: 移动技术网 > IT编程>开发语言>Java > Tomcat集群和Session复制应用介绍

Tomcat集群和Session复制应用介绍

2019年07月22日  | 移动技术网IT编程  | 我要评论
一个配置文件: 复制代码 代码如下: <cluster classname="org.apache.catalina.ha.tcp.simpletcpcluster"

一个配置文件:

复制代码 代码如下:

<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。

如您对本文有疑问或者有任何想说的,请 点击进行留言回复,万千网友为您解惑!

相关文章:

验证码:
移动技术网