快捷導(dǎo)航

Tomcat集群和Session復(fù)制應(yīng)用介紹

更新時(shí)間：2012年11月27日 11:47:38 作者：

本文將詳細(xì)介紹Tomcat集群和Session復(fù)制應(yīng)用，需要了解的朋友可以參考下

一個(gè)配置文件：

 
<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

復(fù)制代碼代碼如下:

 
<Cluster className="org.apache.catalina.ha.tcp.SimpleTcpCluster" 
channelSendOptions="6"> 

1）Tomcat集群主元素，在這個(gè)元素里面可以配置集群的所有詳細(xì)信息
2）className主要的集群類，當(dāng)前只提供了org.apache.catalina.ha.tcp.SimpleTcpCluste作為實(shí)現(xiàn)類
3）channelSendOptionssession發(fā)送方式，默認(rèn)值是8，這個(gè)標(biāo)識(shí)確定通過SimpleTcpCluste如何發(fā)送消息
4） Channel.SEND_OPTIONS_SYNCHRONIZED_ACK = 0x0004
Channel.SEND_OPTIONS_ASYNCHRONOUS = 0x0008
Channel.SEND_OPTIONS_USE_ACK = 0x0002
如果使用(ASYNCHRONOUS)加(USE_ACK)方式來發(fā)送消息，那么值應(yīng)該是10(8+2)或者0x000B
如果使用(SYNCHRONIZED_ACK)加(USE_ACK)方式來發(fā)送消息，那么值應(yīng)該是6(4+2)或者0x0006
2、Manager

復(fù)制代碼代碼如下:

 
<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復(fù)制
2）className當(dāng)前有兩個(gè)實(shí)現(xiàn)類：org.apache.catalina.ha.session.DeltaManager和org.apache.catalina.ha.session.BackupManager
　 3）DeltaManager復(fù)制并發(fā)送Session數(shù)據(jù)到集群下所有的節(jié)點(diǎn)，這個(gè)實(shí)現(xiàn)類被證明非?？煽俊⑦\(yùn)行得非常好。不過有個(gè)局限性就是集群的節(jié)點(diǎn)類型要相同，而且要部署相同的應(yīng)用程序
4）expireSessionsOnShutdown當(dāng)一個(gè)web程序被結(jié)束時(shí)，tomcat分發(fā)銷毀命令到每個(gè)Session，并通知所有session listener執(zhí)行。當(dāng)集群下某個(gè)節(jié)點(diǎn)被停止時(shí)，如果想銷毀所有節(jié)點(diǎn)下的的Session，設(shè)置為true，默認(rèn)為false
5）notifyListenersOnReplication如果設(shè)置為true,當(dāng)session屬性被復(fù)制和移動(dòng)的時(shí)候，session listener被通知
3、Channel

復(fù)制代碼代碼如下:

Channel是Apache Tribes的主組件，channel管理一組子組件，并和它們一起組成了tomcat實(shí)例間的通訊框架。在tomcat集群中，DeltaManager通過SimpleTcpCluster調(diào)用channel來實(shí)現(xiàn)信息傳遞，而BackupManager自己調(diào)用channel以及子組件這些組件來實(shí)現(xiàn)信息傳遞。ReplicatedContext也會(huì)調(diào)用channel傳遞context屬性。
4、Membership

復(fù)制代碼代碼如下:

 
<Membership className="org.apache.catalina.tribes.membership.McastService" 
address="228.0.0.4" 
port="45564" 
frequency="500" 
dropTime="3000"/> 

MemberShip組件自動(dòng)檢索發(fā)現(xiàn)集群里的新節(jié)點(diǎn)或已經(jīng)停止工作的節(jié)點(diǎn)，并發(fā)出相應(yīng)的通知。默認(rèn)使用組播（Multicast）實(shí)現(xiàn)。
5、Receiver

復(fù)制代碼代碼如下:

 
<Receiver className="org.apache.catalina.tribes.transport.nio.NioReceiver" 
address="auto" 
port="5000" 
selectorTimeout="100" 
maxThreads="6"/> 

負(fù)責(zé)監(jiān)聽接收其他節(jié)點(diǎn)傳送過來的數(shù)據(jù)。默認(rèn)使用non-blocking TCP Server sockets。
6、Sender

復(fù)制代碼代碼如下:

 
<Sender className="org.apache.catalina.tribes.transport.ReplicationTransmitter"> 
<Transport className="org.apache.catalina.tribes.transport.nio.PooledParallelSender"/> 
</Sender> 

管理從一個(gè)節(jié)點(diǎn)發(fā)送到另外一個(gè)節(jié)點(diǎn)的出站連接和數(shù)據(jù)信息，允許信息并行發(fā)送。默認(rèn)使用TCP Client Sockets。
7、Interceptor

復(fù)制代碼代碼如下:

 
<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堆棧進(jìn)行消息傳遞，在這里可以自定義消息的發(fā)送和接收方式，甚至MemberShip的處理方式。
8、Value

復(fù)制代碼代碼如下:

 
<Valve className="org.apache.catalina.ha.tcp.ReplicationValve" 
filter=".*\.gif|.*\.js|.*\.jpeg|.*\.jpg|.*\.png|.*\.htm|.*\.html|.*\.css|.*\.txt"/> 

1）Value在調(diào)用Http Request 鏈中起著攔截器的作用，用來決定什么情況下數(shù)據(jù)需要被復(fù)制。
org.apache.catalina.ha.tcp.ReplicationValve，ReplicationValue在Http Request結(jié)尾判斷當(dāng)前數(shù)據(jù)是否需要被復(fù)制。
2）Filter內(nèi)容為url或者文件結(jié)尾，當(dāng)訪問鏈接配置filter時(shí)，不論實(shí)際session有沒有改變，集群會(huì)認(rèn)為session沒有任何變化，從而不會(huì)復(fù)制和發(fā)送改變的session屬性。
9、Deployer

復(fù)制代碼代碼如下:

 
<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

復(fù)制代碼代碼如下:

 
<ClusterListener className="org.apache.catalina.ha.session.ClusterSessionListener"/> 

Clusterlistener用來追蹤信息發(fā)送和接收。
ClusterSessionListener用來監(jiān)聽集群組件接收信息，當(dāng)使用DeltaManager的時(shí)候，信息被集群接收，并通過ClusterSessionListener傳遞給Session Manager。

您可能感興趣的文章: