會話是識別用戶，跟蹤用戶訪問行為的一個手段，通過cookie（存在客戶端）或session（存在服務端）來判斷本次請求是那個客戶端發送過來；常用的會話保持有系結會話，就是前邊我們聊的在代理上通過演算法或通過給客戶端回應首部加cookie這種方式來保持同一cookie或同一ip地址的請求始終發送到同一后端server進行回應；但是這樣的會話系結的方式存在一個問題，就是當后端某一server宕機，那么之前上面的所有會話資訊將消失，那么后續的客戶端來請求，代理是否要把請求調度到后端宕機的server呢？如果說調度上去呢，那么用戶之前的會話資訊又沒有了，如果說不調度呢，那么用戶將不能夠得到服務；所以對于這種情況我們需要把會話都同步到后端所有server上，即便某一臺或幾臺后端server宕機了，不會導致用戶的會話資訊丟失，同樣服務也是可用的；這種冗余的方式保存會話資訊，使得用戶的會話資訊能夠在任何一臺后端server上都會有；這也意味著只要有用戶來請求，前端調度器可以任意把請求調度到后端的某一臺server上，然后服務端把本次請求的用戶會話資訊通過廣播的方式，通知給其他后端server，這樣一來這個客戶端后續來請求，不管調度到后端那一臺server上，因為后端server上都有這個客戶端之前請求的會話資訊，所以不管到那一臺都能夠識別；對于tomcat來講，它內部就有一個組件支持這樣的功能，它可以基于多播通信的方式，把會話資訊同步給后端其他節點，這個組件就是cluster；
示例：使用tomcat cluster組件來定義tomcat的會話復制集群
環境說明
| 名稱 | ip地址 | 埠 |
| 代理Nginx | 192.168.0.41 | 80 |
| 應用服務tomcatA | 192.168.0.42 | 8080 |
| 應用服務tomcatB | 192.168.0.43 | 8080 |
準備測驗頁面，以及配置tomcatA
提示：以上是myapp里的內容以及檔案目錄結構
提示：以上配置表示部署一個/myapp的應用，它的檔案路徑在/webapps/myapp，并且在engine上配置了 jvmRoute=“tomcatA”;
提示：cluster配置需要注意上面打紅框的位置，在官方配置檔案中，后面的<ClusterListener 的后面沒有把標簽閉合了，我們在使用時需要給它閉合了，否則會出現語法錯，導致tomcat起不來；其次就是我們需要更改接收器的ip地址，默認它是auto，auto表示自動監聽本機一個地址，這個地址也可能是127.0.0.1，如果監聽在127.0.0.1，那么主機就不能夠接收到，其他節點發來的會話資訊；說下這個組態檔吧，cluster組件中主要就是定義了DeltaManager的屬性，該組件用于處理增量會話的事務，也就是用這個管理的功能實作多節點復制會話資訊；其次我們要在其cluster內部定義個chanel，這個組件主要定義集群通信和各成員的一些屬性，比如成員關系判定呀，接收器和發送器；Membership組件用于定義成員關系判定的，里面主要定義多播地址和埠等屬性，如果多播地址相同，那么就是同一集群的成員，否則不是；Receiver主要用于定義接收器的相關屬性，比如接收器監聽的地址和埠超時時長，最大執行緒等等；Sender用于指定發送器，發送器我們這里不需要認為手動定義，用官方給定的示例即可；后面的Interceptor主要定義了tcp報文的檢查以及訊息摘要，后面兩臺哦Interceptor主要作用是保證tcp報文的完整和正確性；Deployer主要用于定義部署應用相關屬性，它的主要作用是如果我們定義了集群，我們可以在集群成員中的一臺server上部署好應用，然后其他成員可以通過網路自動部署；通常我們建議使用這個自動部署的功能；
完整的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>View Code
給我們定義的應用修改器web.xml 在其中加上<distributable/>元素
提示：對于web.xml組態檔，我們可以從/etc/tomcat/中復制一份到自己的應用目錄結構里，然后在非注釋掉位置加上<distributable/>元素即可
對于tomcatB來說，我們也需要準備好同樣的檔案，為了區分，我們把index.jsp修改成tomcatB ,在組態檔中我們需要修改接收器的監聽地址，以及jvmRoute的值，其他的都可以不變
到此tomcat會話復制集群就配置好了；其實從上面的組態檔可以看到，tomcat的會話復制集群就是利用多播地址通信，一個請求不管調度到集群到那個節點，它都會通過多播通信，把會話資訊以組播的方式發送給集群其他成員；這里建議把接收器的地址專門用張網卡配置好地址；
啟動下tomcatA，tomcatB，然后看看日志是否初始集群成功，集群中的成員是否都互相識別到對方的接收器地址？
提示：這里注意一點如果tomcat啟動特別慢，就是8005埠要等很久才起來，可以嘗試安裝rng-tools，并啟動rngd，這樣可以加快tomcat啟動
提示：如果在tomcatA的日志中能夠看到tomcatB的接收器地址和埠，那么就表示tomcatA已經識別到tomcatB，并把tomcatB當作集群成員加入到集群；同樣在tomcatB的日志中能夠看到tomcatA的接收器地址和埠，表示tomcatB已經識別tomcatA并把它加入到集群；
配置nginx負載均衡后端兩臺tomcat server
提示：這里需要注意反代時需要把反代的URI和proxy_pass后面的URI相同，否則代理后，會話復制集群不會生效；
驗證：檢查nginx的組態檔語法，啟動nginx訪問192.168.0.41/myapp看看有什么變化
提示：可以看到訪問192.168.0.41/myapp時sessionid始終沒有發生變化，變化的只有后面的jvmRoute的值和頁面的值；這說明我們訪問nginx時，nginx也基于自己的輪詢演算法把請求調度到后端去了，第一次訪問時，后端server會回應一個set-cookie的首部，把當前訪問的頁面的session資訊回應給客戶端（其實在這同時它也會把session資訊通過多播通信的方式，傳遞給集群中的其他節點），第二次訪問客戶端就會把上一次訪問相應的cookie帶上去訪問，這時后端server接受到客戶端發送過來的cookie，然后就在自己記憶體里找對應的session資訊；由于后端server是把session資訊基于多播通信的方式共享給集群其他節點，所以第二次不管調度到那臺server上，對應server都會有該客戶端第一次訪問服務端的session資訊；所以我們第二次訪問時，sessionid還是第一次訪問服務器的sessionid，后面的tomcatB表示由tomcatB這個jvmRoute處理的這次請求；
轉載請註明出處，本文鏈接：https://www.uj5u.com/caozuo/24157.html
標籤：Linux
下一篇：有關在使用aireplay-ng處理5Ghz頻段的wifi時出現“No such Bssid available”的解決方法