會話是識別用戶,跟蹤用戶訪問行爲的一個手段,經過cookie(存在客戶端)或session(存在服務端)來判斷本次請求是那個客戶端發送過來;經常使用的會話保持有綁定會話,就是前邊咱們聊的在代理上經過算法或經過給客戶端響應首部加cookie這種方式來保持同一cookie或同一ip地址的請求始終發送到同一後端server進行響應;可是這樣的會話綁定的方式存在一個問題,就是當後端某一server宕機,那麼以前上面的全部會話信息將消失,那麼後續的客戶端來請求,代理是否要把請求調度到後端宕機的server呢?若是說調度上去呢,那麼用戶以前的會話信息又沒有了,若是說不調度呢,那麼用戶將不可以獲得服務;因此對於這種狀況咱們須要把會話都同步到後端全部server上,即使某一臺或幾臺後端server宕機了,不會致使用戶的會話信息丟失,一樣服務也是可用的;這種冗餘的方式保存會話信息,使得用戶的會話信息可以在任何一臺後端server上都會有;這也意味着只要有用戶來請求,前端調度器能夠任意把請求調度到後端的某一臺server上,而後服務端把本次請求的用戶會話信息經過廣播的方式,通知給其餘後端server,這樣一來這個客戶端後續來請求,無論調度到後端那一臺server上,由於後端server上都有這個客戶端以前請求的會話信息,因此無論到那一臺都可以識別;對於tomcat來說,它內部就有一個組件支持這樣的功能,它能夠基於多播通訊的方式,把會話信息同步給後端其餘節點,這個組件就是cluster;前端
示例:使用tomcat cluster組件來定義tomcat的會話複製集羣nginx
環境說明web
名稱 | ip地址 | 端口 |
代理Nginx | 192.168.0.41 | 80 |
應用服務tomcatA | 192.168.0.42 | 8080 |
應用服務tomcatB | 192.168.0.43 | 8080 |
準備測試頁面,以及配置tomcatA算法
提示:以上是myapp裏的內容以及文件目錄結構apache
提示:以上配置表示部署一個/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上部署好應用,而後其餘成員能夠經過網絡自動部署;一般咱們建議使用這個自動部署的功能;tomcat
完整的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>
給咱們定義的應用修改器web.xml 在其中加上<distributable/>元素cookie
提示:對於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信息響應給客戶端,第二次訪問客戶端就會把上一次訪問相應的cookie帶上去訪問,這時後端server接受到客戶端發送過來的cookie,而後就在本身內存裏找對應的session信息;因爲後端server是把session信息基於多播通訊的方式共享給集羣其餘節點,因此第二次無論調度到那臺server上,對應server都會有該客戶端第一次訪問服務端的session信息;因此咱們第二次訪問時,sessionid仍是第一次訪問服務器的sessionid,後面的tomcatB表示由tomcatB這個jvmRoute處理的此次請求;