會(huì)話是識(shí)別用戶，跟蹤用戶訪問行為的一個(gè)手段，通過cookie（存在客戶端）或session（存在服務(wù)端）來判斷本次請(qǐng)求是那個(gè)客戶端發(fā)送過來；常用的會(huì)話保持有綁定會(huì)話，就是前邊我們聊的在代理上通過算法或通過給客戶端響應(yīng)首部加cookie這種方式來保持同一cookie或同一ip地址的請(qǐng)求始終發(fā)送到同一后端server進(jìn)行響應(yīng)；但是這樣的會(huì)話綁定的方式存在一個(gè)問題，就是當(dāng)后端某一server宕機(jī)，那么之前上面的所有會(huì)話信息將消失，那么后續(xù)的客戶端來請(qǐng)求，代理是否要把請(qǐng)求調(diào)度到后端宕機(jī)的server呢？如果說調(diào)度上去呢，那么用戶之前的會(huì)話信息又沒有了，如果說不調(diào)度呢，那么用戶將不能夠得到服務(wù)；所以對(duì)于這種情況我們需要把會(huì)話都同步到后端所有server上，即便某一臺(tái)或幾臺(tái)后端server宕機(jī)了，不會(huì)導(dǎo)致用戶的會(huì)話信息丟失，同樣服務(wù)也是可用的；這種冗余的方式保存會(huì)話信息，使得用戶的會(huì)話信息能夠在任何一臺(tái)后端server上都會(huì)有；這也意味著只要有用戶來請(qǐng)求，前端調(diào)度器可以任意把請(qǐng)求調(diào)度到后端的某一臺(tái)server上，然后服務(wù)端把本次請(qǐng)求的用戶會(huì)話信息通過廣播的方式，通知給其他后端server，這樣一來這個(gè)客戶端后續(xù)來請(qǐng)求，不管調(diào)度到后端那一臺(tái)server上，因?yàn)楹蠖藄erver上都有這個(gè)客戶端之前請(qǐng)求的會(huì)話信息，所以不管到那一臺(tái)都能夠識(shí)別；對(duì)于tomcat來講，它內(nèi)部就有一個(gè)組件支持這樣的功能，它可以基于多播通信的方式，把會(huì)話信息同步給后端其他節(jié)點(diǎn)，這個(gè)組件就是cluster；

　　示例：使用tomcat cluster組件來定義tomcat的會(huì)話復(fù)制集群

　　環(huán)境說明

　　準(zhǔn)備測試頁面，以及配置tomcatA

　　提示：以上是myapp里的內(nèi)容以及文件目錄結(jié)構(gòu)

　　提示：以上配置表示部署一個(gè)/myapp的應(yīng)用，它的文件路徑在/webapps/myapp，并且在engine上配置了 jvmRoute=“tomcatA”;

　　提示：cluster配置需要注意上面打紅框的位置，在官方配置文檔中，后面的<ClusterListener 的后面沒有把標(biāo)簽閉合了，我們在使用時(shí)需要給它閉合了，否則會(huì)出現(xiàn)語法錯(cuò)，導(dǎo)致tomcat起不來；其次就是我們需要更改接收器的ip地址，默認(rèn)它是auto，auto表示自動(dòng)監(jiān)聽本機(jī)一個(gè)地址，這個(gè)地址也可能是127.0.0.1，如果監(jiān)聽在127.0.0.1，那么主機(jī)就不能夠接收到，其他節(jié)點(diǎn)發(fā)來的會(huì)話信息；說下這個(gè)配置文件吧，cluster組件中主要就是定義了DeltaManager的屬性，該組件用于處理增量會(huì)話的事務(wù)，也就是用這個(gè)管理的功能實(shí)現(xiàn)多節(jié)點(diǎn)復(fù)制會(huì)話信息；其次我們要在其cluster內(nèi)部定義個(gè)chanel，這個(gè)組件主要定義集群通信和各成員的一些屬性，比如成員關(guān)系判定呀，接收器和發(fā)送器；Membership組件用于定義成員關(guān)系判定的，里面主要定義多播地址和端口等屬性，如果多播地址相同，那么就是同一集群的成員，否則不是；Receiver主要用于定義接收器的相關(guān)屬性，比如接收器監(jiān)聽的地址和端口超時(shí)時(shí)長，最大線程等等；Sender用于指定發(fā)送器，發(fā)送器我們這里不需要認(rèn)為手動(dòng)定義，用官方給定的示例即可；后面的Interceptor主要定義了tcp報(bào)文的檢查以及消息摘要，后面兩臺(tái)哦Interceptor主要作用是保證tcp報(bào)文的完整和正確性；Deployer主要用于定義部署應(yīng)用相關(guān)屬性，它的主要作用是如果我們定義了集群，我們可以在集群成員中的一臺(tái)server上部署好應(yīng)用，然后其他成員可以通過網(wǎng)絡(luò)自動(dòng)部署；通常我們建議使用這個(gè)自動(dòng)部署的功能；

　　完整的server.xml配置

<?xml version='1.0' encoding='utf-8'?>
<Server port="8005" shutdown="SHUTDOWN">
 <Listener className="org.apache.catalina.startup.VersionLoggerListener" />
 <Listener className="org.apache.catalina.core.AprLifecycleListener" SSLEngine="on" />
 <Listener className="org.apache.catalina.core.JasperListener" />
 <Listener className="org.apache.catalina.core.JreMemoryLeakPreventionListener" />
 <Listener className="org.apache.catalina.mbeans.GlobalResourcesLifecycleListener" />
 <Listener className="org.apache.catalina.core.ThreadLocalLeakPreventionListener" />
 <GlobalNamingResources>
 <Resource name="UserDatabase" auth="Container"
    type="org.apache.catalina.UserDatabase"
    description="User database that can be updated and saved"
    factory="org.apache.catalina.users.MemoryUserDatabaseFactory"
    pathname="conf/tomcat-users.xml" />
 </GlobalNamingResources>
 <Service name="Catalina">
 <Connector port="8080" protocol="HTTP/1.1"
    connectionTimeout="20000"
    redirectPort="8443" />
 <Connector port="8009" protocol="AJP/1.3" redirectPort="8443" />
 <Engine name="Catalina" defaultHost="localhost" jvmRoute="tomcatA">
  <Realm className="org.apache.catalina.realm.LockOutRealm">
  <Realm className="org.apache.catalina.realm.UserDatabaseRealm"
    resourceName="UserDatabase"/>
  </Realm>

  <Host name="localhost" appBase="webapps"
   unpackWARs="true" autoDeploy="true">
  <Valve className="org.apache.catalina.valves.AccessLogValve" directory="logs"
    prefix="localhost_access_log." suffix=".txt"
    pattern="%h %l %u %t "%r" %s %b" />
  <Context path="/myapp" docBase="/webapps/myapp" reloadable=""/>
  <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="192.168.0.42"
      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"/>

   <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.JvmRouteSessionIDBinderListener"/>
   <ClusterListener className="org.apache.catalina.ha.session.ClusterSessionListener"/>
  </Cluster>
  </Host>
 </Engine>
 </Service>
</Server>

　　給我們定義的應(yīng)用修改器web.xml 在其中加上<distributable/>元素

　　提示：對(duì)于web.xml配置文件，我們可以從/etc/tomcat/中復(fù)制一份到自己的應(yīng)用目錄結(jié)構(gòu)里，然后在非注釋掉位置加上<distributable/>元素即可

　　對(duì)于tomcatB來說，我們也需要準(zhǔn)備好同樣的文件，為了區(qū)分，我們把index.jsp修改成tomcatB ,在配置文件中我們需要修改接收器的監(jiān)聽地址，以及jvmRoute的值，其他的都可以不變

　　到此tomcat會(huì)話復(fù)制集群就配置好了；其實(shí)從上面的配置文件可以看大，tomcat的會(huì)話復(fù)制集群就是利用多播地址通信，一個(gè)請(qǐng)求不管到集群那個(gè)基點(diǎn)，它都會(huì)通過多播通信，把會(huì)話信息以組播的方式發(fā)送給其他成員；這里建議把接收器的地址專門用張網(wǎng)卡配置好地址；接下來我們啟動(dòng)下tomcatA，tomcatB，然后看看日志是否初始集群成功，并接收到集群成員接收器的地址；

　　提示：這里注意一點(diǎn)如果tomcat啟動(dòng)特別慢，就是8005端口要等很久才起來，可以嘗試安裝rng-tools，并啟動(dòng)rngd，這樣可以加快tomcat啟動(dòng)

　　提示：如果在tomcatA的日志中能夠看到tomcatB的接收器地址和端口，那么就表示tomcatA已經(jīng)識(shí)別到tomcatB，并把tomcatB當(dāng)作集群成員加入到集群；同樣在tomcatB的日志中能夠看到tomcatA的接收器地址和端口，表示tomcatB已經(jīng)識(shí)別tomcatA并把它加入到集群；

　　配置nginx負(fù)載均衡后端兩臺(tái)tomcat server

　　提示：這里需要主要反代時(shí)需要把反代的URI和后面proxy_pass后面的URI相同，否則代理后，會(huì)話復(fù)制集群不會(huì)生效；

　　驗(yàn)證：檢查nginx的配置文件語法，啟動(dòng)nginx訪問192.168.0.41/myapp看看有什么變化

　　提示：可以看到訪問192.168.0.41/myapp時(shí)sessionid始終沒有發(fā)生變化，變化的只有后面的jvmRoute的值和頁面的值；這說明我們訪問nginx時(shí)，nginx也基于自己的輪詢算法把請(qǐng)求調(diào)度到后端去了，第一次訪問時(shí)，后端server會(huì)響應(yīng)一個(gè)set-cookie的首部，把當(dāng)前訪問的頁面的session信息響應(yīng)給客戶端，第二次訪問客戶端就會(huì)把上一次訪問相應(yīng)的cookie帶上去訪問，這時(shí)后端server接受到客戶端發(fā)送過來的cookie，然后就在自己內(nèi)存里找對(duì)應(yīng)的session信息；由于后端server是把session信息基于多播通信的方式共享給集群其他節(jié)點(diǎn)，所以第二次不管調(diào)度到那臺(tái)server上，對(duì)應(yīng)server都會(huì)有該客戶端第一次訪問服務(wù)端的session信息；所以我們第二次訪問時(shí)，sessionid還是第一次訪問服務(wù)器的sessionid，后面的tomcatB表示由tomcatB這個(gè)jvmRoute處理的這次請(qǐng)求；

總結(jié)

到此這篇關(guān)于Java應(yīng)用服務(wù)器之tomcat會(huì)話復(fù)制集群配置的文章就介紹到這了,更多相關(guān)java tomcat會(huì)話復(fù)制集群配置內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！