Java應(yīng)用服務(wù)器之tomcat會(huì)話復(fù)制集群配置的示例詳解
會(huì)話是識(shí)別用戶,跟蹤用戶訪問(wèn)行為的一個(gè)手段,通過(guò)cookie(存在客戶端)或session(存在服務(wù)端)來(lái)判斷本次請(qǐng)求是那個(gè)客戶端發(fā)送過(guò)來(lái);常用的會(huì)話保持有綁定會(huì)話,就是前邊我們聊的在代理上通過(guò)算法或通過(guò)給客戶端響應(yīng)首部加cookie這種方式來(lái)保持同一cookie或同一ip地址的請(qǐng)求始終發(fā)送到同一后端server進(jìn)行響應(yīng);但是這樣的會(huì)話綁定的方式存在一個(gè)問(wèn)題,就是當(dāng)后端某一server宕機(jī),那么之前上面的所有會(huì)話信息將消失,那么后續(xù)的客戶端來(lái)請(qǐng)求,代理是否要把請(qǐng)求調(diào)度到后端宕機(jī)的server呢?如果說(shuō)調(diào)度上去呢,那么用戶之前的會(huì)話信息又沒(méi)有了,如果說(shuō)不調(diào)度呢,那么用戶將不能夠得到服務(wù);所以對(duì)于這種情況我們需要把會(huì)話都同步到后端所有server上,即便某一臺(tái)或幾臺(tái)后端server宕機(jī)了,不會(huì)導(dǎo)致用戶的會(huì)話信息丟失,同樣服務(wù)也是可用的;這種冗余的方式保存會(huì)話信息,使得用戶的會(huì)話信息能夠在任何一臺(tái)后端server上都會(huì)有;這也意味著只要有用戶來(lái)請(qǐng)求,前端調(diào)度器可以任意把請(qǐng)求調(diào)度到后端的某一臺(tái)server上,然后服務(wù)端把本次請(qǐng)求的用戶會(huì)話信息通過(guò)廣播的方式,通知給其他后端server,這樣一來(lái)這個(gè)客戶端后續(xù)來(lái)請(qǐng)求,不管調(diào)度到后端那一臺(tái)server上,因?yàn)楹蠖藄erver上都有這個(gè)客戶端之前請(qǐng)求的會(huì)話信息,所以不管到那一臺(tái)都能夠識(shí)別;對(duì)于tomcat來(lái)講,它內(nèi)部就有一個(gè)組件支持這樣的功能,它可以基于多播通信的方式,把會(huì)話信息同步給后端其他節(jié)點(diǎn),這個(gè)組件就是cluster;
示例:使用tomcat cluster組件來(lái)定義tomcat的會(huì)話復(fù)制集群
環(huán)境說(shuō)明
名稱 | ip地址 | 端口 |
代理Nginx | 192.168.0.41 | 80 |
應(yīng)用服務(wù)tomcatA | 192.168.0.42 | 8080 |
應(yīng)用服務(wù)tomcatB | 192.168.0.43 | 8080 |
準(zhǔn)備測(cè)試頁(yè)面,以及配置tomcatA
提示:以上是myapp里的內(nèi)容以及文件目錄結(jié)構(gòu)
提示:以上配置表示部署一個(gè)/myapp的應(yīng)用,它的文件路徑在/webapps/myapp,并且在engine上配置了 jvmRoute=“tomcatA”;
提示:cluster配置需要注意上面打紅框的位置,在官方配置文檔中,后面的<ClusterListener 的后面沒(méi)有把標(biāo)簽閉合了,我們?cè)谑褂脮r(shí)需要給它閉合了,否則會(huì)出現(xiàn)語(yǔ)法錯(cuò),導(dǎo)致tomcat起不來(lái);其次就是我們需要更改接收器的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ā)來(lái)的會(huì)話信息;說(shuō)下這個(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í)長(zhǎng),最大線程等等;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)用,然后其他成員可以通過(guò)網(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來(lái)說(shuō),我們也需要準(zhǔn)備好同樣的文件,為了區(qū)分,我們把index.jsp修改成tomcatB ,在配置文件中我們需要修改接收器的監(jiān)聽地址,以及jvmRoute的值,其他的都可以不變
到此tomcat會(huì)話復(fù)制集群就配置好了;其實(shí)從上面的配置文件可以看大,tomcat的會(huì)話復(fù)制集群就是利用多播地址通信,一個(gè)請(qǐng)求不管到集群那個(gè)基點(diǎn),它都會(huì)通過(guò)多播通信,把會(huì)話信息以組播的方式發(fā)送給其他成員;這里建議把接收器的地址專門用張網(wǎng)卡配置好地址;接下來(lái)我們啟動(dòng)下tomcatA,tomcatB,然后看看日志是否初始集群成功,并接收到集群成員接收器的地址;
提示:這里注意一點(diǎn)如果tomcat啟動(dòng)特別慢,就是8005端口要等很久才起來(lái),可以嘗試安裝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的配置文件語(yǔ)法,啟動(dòng)nginx訪問(wèn)192.168.0.41/myapp看看有什么變化
提示:可以看到訪問(wèn)192.168.0.41/myapp時(shí)sessionid始終沒(méi)有發(fā)生變化,變化的只有后面的jvmRoute的值和頁(yè)面的值;這說(shuō)明我們?cè)L問(wèn)nginx時(shí),nginx也基于自己的輪詢算法把請(qǐng)求調(diào)度到后端去了,第一次訪問(wèn)時(shí),后端server會(huì)響應(yīng)一個(gè)set-cookie的首部,把當(dāng)前訪問(wèn)的頁(yè)面的session信息響應(yīng)給客戶端,第二次訪問(wèn)客戶端就會(huì)把上一次訪問(wèn)相應(yīng)的cookie帶上去訪問(wèn),這時(shí)后端server接受到客戶端發(fā)送過(guò)來(lái)的cookie,然后就在自己內(nèi)存里找對(duì)應(yīng)的session信息;由于后端server是把session信息基于多播通信的方式共享給集群其他節(jié)點(diǎn),所以第二次不管調(diào)度到那臺(tái)server上,對(duì)應(yīng)server都會(huì)有該客戶端第一次訪問(wèn)服務(wù)端的session信息;所以我們第二次訪問(wèn)時(shí),sessionid還是第一次訪問(wèn)服務(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)文章希望大家以后多多支持腳本之家!
相關(guān)文章
Java Fluent Mybatis 分頁(yè)查詢與sql日志輸出詳解流程篇
Java中常用的ORM框架主要是mybatis, hibernate, JPA等框架。國(guó)內(nèi)又以Mybatis用的多,基于mybatis上的增強(qiáng)框架,又有mybatis plus和TK mybatis等。今天我們介紹一個(gè)新的mybatis增強(qiáng)框架 fluent mybatis關(guān)于分頁(yè)查詢、sql日志輸出流程2021-10-10IDEA報(bào)java:?java.lang.OutOfMemoryError:?Java?heap?space錯(cuò)誤
這篇文章主要給大家介紹了關(guān)于IDEA報(bào)java:?java.lang.OutOfMemoryError:?Java?heap?space錯(cuò)誤的解決辦法,文中將解決的辦法介紹的非常詳細(xì),需要的朋友可以參考下2024-01-01SpringBoot使用異步線程池實(shí)現(xiàn)生產(chǎn)環(huán)境批量數(shù)據(jù)推送
本文主要介紹了SpringBoot使用異步線程池實(shí)現(xiàn)生產(chǎn)環(huán)境批量數(shù)據(jù)推送,文中通過(guò)示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧2022-02-02Spring Boot與Kotlin定時(shí)任務(wù)的示例(Scheduling Tasks)
這篇文章主要介紹了Spring Boot與Kotlin定時(shí)任務(wù)的示例(Scheduling Tasks),小編覺(jué)得挺不錯(cuò)的,現(xiàn)在分享給大家,也給大家做個(gè)參考。一起跟隨小編過(guò)來(lái)看看吧2018-03-03使用Java實(shí)現(xiàn)百萬(wàn)Excel數(shù)據(jù)導(dǎo)出
這篇文章主要為大家詳細(xì)介紹了如何使用Java實(shí)現(xiàn)百萬(wàn)Excel數(shù)據(jù)導(dǎo)出,文中的示例代碼講解詳細(xì),具有一定的借鑒價(jià)值,有需要的小伙伴可以參考一下2024-03-03