1. 程式人生 > >架構設計之Spring-Session分散式叢集會話管理

架構設計之Spring-Session分散式叢集會話管理

前言

通常在web開發中,會話管理是很重要的一部分,用於儲存與使用者相關的一些資料。對於JAVA開發者來說,專案中的session一般由Tomcat或者jetty容器來管理。

特點介紹

儘管使用特定的容器可以很好地實現會話管理,但是獨立容器掛掉或者由於其他原因重啟會導致使用者資訊丟失,並且無法支援分散式叢集會話管理。

上圖舉例:

12.png

這是一個簡單的負載均衡叢集架構模型,後端三臺Tomcat服務,假設每臺服務都使用自己的會話管理,而叢集策略是基於加權輪詢的方式實現。試想一下,使用者是不是永遠無法登陸系統?

當然,你可能會想,我可以使用基於IP_hash的方式實現負載均衡嘛。但是如果地區分佈相對單一,產生的hash值分佈可能也不會太均勻,那就起不到負載均衡的作用了。

一般來說,有兩種解決方案,session複製和session統一管理。對於session複製,簡單的幾臺還是可以的,但是如果上百臺甚至上千臺就要考慮複製成本問題了。

對於統一session管理可以是關係型資料庫,比如MySql(基本不用,考慮到效率問題);非關係型資料庫 redis,memcache等等。

解決方案

  • 基於Tomcat的會話外掛實現tomcat-redis-session-manager 和tomcat-memcache-session-manager,會話統一由NoSql管理。對於專案本身來說,無須改動程式碼,只需要簡單的配置Tomcat的server.xml就可以解決問題。但是外掛太依賴於容器,並且對於Tomcat各個版本的支援不是特別的好

  • 重寫Tomcat的session管理,程式碼耦合度高,不利於維護。

  • 使用開源的session管理框架,比如spring_session,既不需要修改Tomcat配置,又無須重寫程式碼,只需要配置相應的引數即可。

功能實現

下面,主要是基於spring_session實現的分散式叢集會話管理案例。

專案需要使用到spring_Mvc4.2.5,spring_session-1.2.2和redis-3.2.8(需要自行安裝redis服務)。

配置相關JAR包(spring mvc相關jar包依賴自行配置):

<dependency>
  <groupId>org.springframework.session</groupId>
    <artifactId>spring-session-data-redis</artifactId>
    <version>1.2.2.RELEASE</version>
</dependency>

spring-mvc.xml

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xmlns:context="http://www.springframework.org/schema/context" xmlns:mvc="http://www.springframework.org/schema/mvc"
    xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-4.0.xsd
        http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-4.0.xsd
        http://www.springframework.org/schema/mvc http://www.springframework.org/schema/mvc/spring-mvc-4.0.xsd">
    
    <description>Spring MVC Configuration</description>
    
    <!-- 載入配置屬性檔案 -->
    <context:property-placeholder ignore-unresolvable="true" location="classpath:config.properties" />
    <!-- 使用Annotation自動註冊Bean,只掃描@Controller -->
    <context:component-scan base-package="com.itstyle.web" use-default-filters="false"><!-- base-package 如果多個,用“,”分隔 -->
        <context:include-filter type="annotation" expression="org.springframework.stereotype.Controller"/>
    </context:component-scan>
    <mvc:annotation-driven/>
    <!--啟動Spring MVC的註解功能,設定編碼方式,防止亂碼--> 
    <bean class="org.springframework.web.servlet.mvc.annotation.AnnotationMethodHandlerAdapter">  
      <property name="messageConverters">     
         <list>     
             <bean class = "org.springframework.http.converter.StringHttpMessageConverter">     
                <property name = "supportedMediaTypes">  
                      <list>  
                          <value>text/html;charset=UTF-8</value>
                     </list>     
                </property>     
             </bean>     
         </list>     
      </property>   
    </bean>  
    <!-- REST中根據URL字尾自動判定Content-Type及相應的View -->
    <bean id="contentNegotiationManager" class="org.springframework.web.accept.ContentNegotiationManagerFactoryBean">
        <property name="mediaTypes" >
            <map> 
                <entry key="xml" value="application/xml"/> 
                <entry key="json" value="application/json"/> 
            </map>
        </property>
        <property name="ignoreAcceptHeader" value="true"/>
        <property name="favorPathExtension" value="true"/>
    </bean>
    
    <!-- 定義檢視檔案解析 -->
    <bean class="org.springframework.web.servlet.view.InternalResourceViewResolver">
        <property name="prefix" value="${web.view.prefix}"/>
        <property name="suffix" value="${web.view.suffix}"/>
    </bean>
    
    <!-- 對靜態資原始檔的訪問, 將無法mapping到Controller的path交給default servlet handler處理 -->
    <mvc:default-servlet-handler />
    
    <!-- 靜態資源對映  SpringMVC會自動給靜態資源Response新增快取頭Cache-Control和Expires值 cache-period="31536000"-->
    <mvc:resources mapping="/static/**" location="/static/" />
    
    <!-- 定義無Controller的path<->view直接對映(首頁或者登陸頁) -->
    <mvc:view-controller path="/" view-name="redirect:${web.view.login}"/>

</beans>

config.properties

#============================#
#===== System settings ======#
#============================#

#產品資訊設定
productName=科幫網  srping session
copyrightYear=2017
version=V1.0.0

#分頁配置
page.pageSize=10
#索引頁路徑
web.view.index=/index
#登陸頁面
web.view.login=/login
#檢視檔案存放路徑
web.view.prefix=/WEB-INF/views/

web.view.suffix=.jsp

#靜態檔案字尾
web.staticFile=.css,.js,.png,.jpg,.gif,.jpeg,.bmp,.ico,.swf,.psd,.htc,.htm,.html,.crx,.xpi,.exe,.ipa,.apk

spring-redis.xml

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:context="http://www.springframework.org/schema/context"
    xmlns:aop="http://www.springframework.org/schema/aop" xmlns:tx="http://www.springframework.org/schema/tx"
    xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.0.xsd
            http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-3.0.xsd
            http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-3.0.xsd
            http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-3.0.xsd" default-autowire="byName" default-lazy-init="true">
        
        <!-- 載入資原始檔  其中包含變數資訊,必須在Spring配置檔案的最前面載入,即第一個載入-->
        <context:property-placeholder location="classpath:redis.properties" />
        <!-- redis -->
        <bean id="jedisPoolConfig" class="redis.clients.jedis.JedisPoolConfig"/>
        
        <bean id="jedisConnectionFactory"
            class="org.springframework.data.redis.connection.jedis.JedisConnectionFactory">
            <property name="hostName" value="${redis.host}" />
            <property name="port" value="${redis.port}" />
            <property name="password" value="${redis.password}" />
            <property name="timeout" value="${redis.timeout}" />
            <property name="poolConfig" ref="jedisPoolConfig" />
            <property name="usePool" value="true" />
        </bean>
         
        <bean id="redisTemplate" class="org.springframework.data.redis.core.StringRedisTemplate">
            <property name="connectionFactory" ref="jedisConnectionFactory" />
        </bean>
         
        <!-- 將session放入redis -->
        <context:annotation-config/>
        <bean id="redisHttpSessionConfiguration" class="org.springframework.session.data.redis.config.annotation.web.http.RedisHttpSessionConfiguration">
            <property name="maxInactiveIntervalInSeconds" value="1800" />
        </bean>
</beans>

redis.properties

#redis中心 
redis.host=127.0.0.1
redis.port=6379
redis.password=123456
redis.maxIdle=100 
redis.maxActive=300 
redis.maxWait=1000 
redis.testOnBorrow=true 
redis.timeout=100000

web.xml

<?xml version="1.0" encoding="UTF-8"?>
<web-app id="WebApp_ID" version="2.4" xmlns="http://java.sun.com/xml/ns/j2ee" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://java.sun.com/xml/ns/j2ee http://java.sun.com/xml/ns/j2ee/web-app_2_4.xsd">
    <display-name>spring_session</display-name>
    <context-param>
        <param-name>contextConfigLocation</param-name>
        <param-value>classpath:spring-redis.xml</param-value>
    </context-param>
    <!-- spring session -->
    <filter>
       <filter-name>springSessionRepositoryFilter</filter-name>
       <filter-class>org.springframework.web.filter.DelegatingFilterProxy</filter-class>
    </filter>
    <filter-mapping>
        <filter-name>springSessionRepositoryFilter</filter-name>
        <url-pattern>/*</url-pattern>
    </filter-mapping>
    <listener>
        <listener-class>org.springframework.web.context.ContextLoaderListener</listener-class>
    </listener>
    <filter>
        <filter-name>encodingFilter</filter-name>
        <filter-class>org.springframework.web.filter.CharacterEncodingFilter</filter-class>
        <init-param>
            <param-name>encoding</param-name>
            <param-value>UTF-8</param-value>
        </init-param>
        <init-param>
            <param-name>forceEncoding</param-name>
            <param-value>true</param-value>
        </init-param>
    </filter>
    <filter-mapping>
        <filter-name>encodingFilter</filter-name>
        <url-pattern>/*</url-pattern>
    </filter-mapping>
    <servlet>
        <servlet-name>springServlet</servlet-name>
        <servlet-class>org.springframework.web.servlet.DispatcherServlet</servlet-class>
        <init-param>
            <param-name>contextConfigLocation</param-name>
            <param-value>classpath*:/spring-mvc*.xml</param-value>
        </init-param>
        <load-on-startup>1</load-on-startup>
    </servlet>
    <servlet-mapping>
        <servlet-name>springServlet</servlet-name>
        <url-pattern>/</url-pattern>
    </servlet-mapping>
    <welcome-file-list>
      <welcome-file>login</welcome-file>
    </welcome-file-list>
</web-app>

測試功能

最後,啟動專案訪問http://localhost:8080/spring_session/login

1.png
登入redis服務,執行以下命令:

KEYS *

123.png

注意,對比sessionId是一致的。

網上很多同學,啟動的時候找不到 springSessionRepositoryFilter,注意在spring-redis.xml加入

參考:http://docs.spring.io/spring-session/docs/current/reference/html5/

原文:http://blog.52itstyle.com/archives/759/

相關推薦

架構設計Spring-Session分散式叢集會話管理

前言 通常在web開發中,會話管理是很重要的一部分,用於儲存與使用者相關的一些資料。對於JAVA開發者來說,專案中的session一般由Tomcat或者jetty容器來管理。 特點介紹 儘管使用特定的容器可以很好地實現會話管理,但是獨立容器掛掉或者由於其他原因重啟會導致使用者資訊丟失,並且無法支援分散式叢集會

架構設計「資料庫叢集方案」

在之前的文章中,我們知道資料庫服務可能已經成為了很多系統的效能關鍵點,甚至是瓶頸了。也給大家介紹了資料庫伺服器從主備架構、到主從架構、再到主主架構的基礎方案。但如果單臺機器已經不能滿足完整業務資料儲存的時候,我們就需要考慮採用多機甚至多中心的部署方案了。 今天我們就再來聊一聊,在多機環境下,資料庫叢集的架構方

高效能網站架構設計快取篇(6)- Redis 叢集命令

叢集cluster info :列印叢集的資訊cluster nodes :列出叢集當前已知的所有節點( node),以及這些節點的相關資訊。節點cluster meet <ip> <port> :將 ip 和 port 所指定的節點新增到叢集當中,讓它成為叢集的一份子。cluster

Spring系列學習Spring Session MongoDB會話管理

英文原文:https://spring.io/projects/spring-session-data-mongodb 目錄 概述 特性 快速開始 學習 文件 概述 Spring會話MongoDB提供了一個API和實現,用於通過利用Spring Data Mong

Spring系列學習Spring Session 使用者會話管理

英文原文:https://spring.io/projects/spring-session 目錄 概述 特性 模組 快速開始 學習 文件  示例 概述 Spring Session提供了用於管理使用者會話資訊的API和實現。 特性 Sp

高效能網站架構設計快取篇(5)- Redis 叢集(上)

叢集技術是構建高效能網站架構的重要手段,試想在網站承受高併發訪問壓力的同時,還需要從海量資料中查詢出滿足條件的資料,並快速響應,我們必然想到的是將資料進行切片,把資料根據某種規則放入多個不同的伺服器節點,來降低單節點伺服器的壓力。 上一篇我們講到了 Redis 的主從複製技術,當實現了多節點的 master

高效能網站架構設計快取篇(6)- Redis 叢集(中)

昨天晚上釣魚回來,大發神經,寫了篇概括程式設計師生活現狀的文章,沒想到招來眾多人的口誅筆伐,大有上升到政治層面的趨勢。 我也許不會再發表任何衝擊心靈的文章,我希望給大家帶來更多的正能量,所以那篇文章已被我刪除。 我的本意只是想讓各位看過文章之後能冷靜地思考自己的程式人生,不管是對是錯,人都有選擇的權力,走

Spring Cloud分散式叢集服務搭建發現與註冊

springBoot簡化了一個工程開發的配置過程,但對於叢集化服務,spring有一套叫做springCloud的解決方案,它利用Spring Boot的開發便利性巧妙地簡化了分散式系統基礎設施的開發,如服務發現註冊、配置中心、訊息匯流排、負載均衡、斷路器、資料監控等,都可以

架構設計基礎:單服務.叢集.分散式,基本區別和聯絡

一、分散式簡介 1、架構簡介 現在的網際網路,幾乎常見的複雜系統都會使用分散式架構,如果在不清楚概念之前,剛接觸分散式架構這個名詞會感覺十分的高大上,其實在對比單服務,叢集服務之後,你就會發現本質上都是一樣的。 絮叨一句:所謂Java架構師,基本就是看被單服務,叢集,分散式不斷暴打的頻率,架構師因為被虐頻率高

分布式架構設計電商平臺

用戶服 base 介紹 val 重要 本地 交互 pac 一定的 分布式架構設計之電商平臺 何為軟件架構?不同人的答案會有所不同,而我認為一個好的軟件架構除了要具備業務功能外,還應該具備一定的高性能、高可用、高伸縮性及可拓展等非功能需求。而軟件架構是由業務架構和技術架構

SoC嵌入式軟件架構設計三:代碼分塊(Bank)設計原則

post 介紹 讀寫 cor 層次 clas rom bank 分配 上一節講述了在沒有MMU的CPU(如80251、MIPS M控制器系列、ARM cortex m系列)上實現虛擬內存管理的集成硬件設計方法。新設計的內存管理管理單元要實現虛擬內存管理還須要

SaaS架構設計如何轉化成SaaS多租戶模式

分享一下我老師大神的人工智慧教程!零基礎,通俗易懂!http://blog.csdn.net/jiangjunshow 也歡迎大家轉載本篇文章。分享知識,造福人民,實現我們中華民族偉大復興!        

架構設計六個複雜度來(續)

這篇繼上篇架構設計之六個複雜度來源 沒有講完的剩下的三個內容低成本、安全、規模等。   一、低成本 當我們的架構方案只涉及幾臺或者十幾臺伺服器時,一般情況下成本並不是我們重點關注的目標,但如果架構方案設計幾百甚至上千上萬臺伺服器,成本就會變成一個非常重要的架構設計考慮點。例如,A方案需要100

阿里架構設計初體驗,送給準備進階架構的朋友(個人總結)

1 基本概念和目的 架構設計的目的是為了解決系統複雜度帶來的問題,並不是要面面俱到,不需要每個架構都具備高效能、高可用、高擴充套件等特點,而是要識別出實際業務實際情況的複雜點,然後有有針對性地解決問題,即:有的放矢,而不是貪大求全。 在實際情況中,不一定每個系統都要做架

小牛帶你架構設計服務限流

v閱讀目錄 v部落格前言 限流可以認為服務降級的一種,限流就是限制系統的輸入和輸出流量已達到保護系統的目的。一般來說系統的吞吐量是可以被測算的,為了保證系統的穩定執行,一旦達到的需要限制的閾值,就需要限制流量並採取一些措施以完成限制流量的目的。比如:延遲處理,拒絕處理,

架構設計「資料庫從主備到主主的高可用方案」

在網際網路專案中,當業務規模越來越大,資料越來越多,隨之而來的就是資料庫壓力會越來越大。慢慢就會發現,資料庫層可能已經成為了整個系統的關鍵點和效能瓶頸了,因此實現資料層的高可用就成為了我們專案中經常要解決的問題。 本文我們就來聊一聊如何實現資料儲存層的高可用方案。在保障資料層的高效能與高穩定方面,最容易想到的

spring-session redis叢集配置步驟總結

<?xml version="1.0" encoding="UTF-8"?> <beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSc

spring bootSpring session配置

一.為什麼要spring-session 在傳統單機web應用中,一般使用tomcat/jetty等web容器時,使用者的session都是由容器管理。瀏覽器使用cookie中記sessionId,容器根據sessionId判斷使用者是否存在會話session。這裡的限制是,session儲

高效能網站架構設計快取篇(3)- Redis 的配置

我們說Redis是一個強大的Key-Value儲存系統,在前面我們已遇到了兩個問題: 1、redis server 啟動後,獨佔程序,能不能修改為後臺服務呢? 2、redis server 服務是單執行緒的,而我的機器是多核的,能不能在同一臺機器上開啟多個例項更充分的利用 cpu 資源呢?但6379埠已經

高效能網站架構設計快取篇(1)- Redis的安裝與使用

一、什麼 Redis REmote DIctionary Server,簡稱 Redis,是一個類似於Memcached的Key-Value儲存系統。相比Memcached,它支援更豐富的資料結構,包括string(字串)、list(連結串列)、set(集合)、zset(sorted set --有序集合)