美文网首页
redis集群+spring-session入门

redis集群+spring-session入门

作者: Jonclex | 来源:发表于2019-01-04 15:36 被阅读0次

Spring-Session介绍
Spring-Session使用的场景?
HttpSession是通过Servlet容器进行创建和管理的,在单机环境中。通过Http请求创建的Session信息是存储在Web服务器内存中,如Tomcat。

假如当用户通过浏览器访问应用服务器,session信息中保存了用户的登录信息,并且session信息没有过期失,效那么用户就一直处于登录状态,可以做一些登录状态的业务操作!
但是现在很多的服务器都采用分布式集群的方式进行部署,一个Web应用,可能部署在几台不同的服务器上,通过LVS或者Nginx等进行负载均衡(一般使用Nginx+Tomcat实现负载均衡)。此时来自同一用户的Http请求将有可能被分发到不同的web站点中去(如:第一次分配到A站点,第二次可能分配到B站点)。那么问题就来了,如何保证不同的web站点能够共享同一份session数据呢?
假如用户在发起第一次请求时候访问了A站点,并在A站点的session中保存了登录信息,当用户第二次发起请求,通过负载均衡请求分配到B站点了,那么此时B站点能否获取用户保存的登录的信息呢?答案是不能的,因为上面说明,Session是存储在对应Web服务器的内存的,不能进行共享,此时Spring-session就出现了,来帮我们解决这个session共享的问题!
如何进行Session共享呢?
简单点说就是请求http请求经过Filter职责链,根据配置信息过滤器将创建session的权利由tomcat交给了Spring-session中的SessionRepository,通过Spring-session创建会话,并保存到对应的地方。
实际上实现Session共享的方案很多,其中一种常用的就是使用Tomcat、Jetty等服务器提供的Session共享功能,将Session的内容统一存储在一个数据库(如MySQL)或缓存(如Redis)中

基于XML配置方式的Spring Session
1.添加项目依赖

首先新建一个Maven的Web项目,新建好之后在pom文件中添加下面的依赖:

<groupId>org.spring</groupId>
<artifactId>learn-spring-session</artifactId>
<version>1.0-SNAPSHOT</version>
<packaging>war</packaging>
<name>First Learn Spring Session</name>

<properties>
  <jdk.version>1.7</jdk.version>
  <spring.version>4.2.6.RELEASE</spring.version>
  <spring-session.version>1.3.1.RELEASE</spring-session.version>
</properties>

<dependencies>
    <!-- https://mvnrepository.com/artifact/javax.servlet/servlet-api  -->
    <dependency>
        <groupId>javax.servlet</groupId>
        <artifactId>javax.servlet-api</artifactId>
        <version>3.0.1</version>
        <scope>provided</scope>
    </dependency>

    <dependency>
        <groupId>org.springframework.session</groupId>
        <artifactId>spring-session-data-redis</artifactId>
        <version>${spring-session.version}</version>
        <type>pom</type>
    </dependency>
     <dependency>
        <groupId>org.springframework</groupId>
        <artifactId>spring-web</artifactId>
        <version>${spring.version}</version>
    </dependency>


</dependencies>

2.web.xml配置

<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>
<dispatcher>REQUEST</dispatcher>
<dispatcher>ERROR</dispatcher>
</filter-mapping>

3.Xml的配置

<bean id="redisCacheManager" class="org.springframework.cache.support.SimpleCacheManager">   
    <property name="caches">  
        <set>  
            <bean class="com.ieslab.dap.cache.RedisCache">  
                <property name="redisTemplate" ref="redisTemplate" />  
                <property name="name" value="default"/>  
            </bean>  
        </set>  
    </property>  
</bean>  

<!-- redis 相关配置 -->  
<bean id="redisPoolConfig" class="redis.clients.jedis.JedisPoolConfig">  
    <property name="maxIdle" value="${redis.maxIdle}" />        
    <property name="maxTotal" value="${redis.maxTotal}" />     
    <property name="maxWaitMillis" value="${redis.maxWait}" />  
    <property name="testOnBorrow" value="${redis.testOnBorrow}" />  
</bean>  

<!-- <bean id="redisConnectionFactory"  
    class="org.springframework.data.redis.connection.jedis.JedisConnectionFactory"  
    p:host-name="${redis.host}" p:port="${redis.port}" p:password="${redis.pass}" p:database="${redis.database}" p:pool-config-ref="redisPoolConfig" />  

<bean id="redisTemplate" class="org.springframework.data.redis.core.RedisTemplate">  
    <property name="connectionFactory" ref="redisConnectionFactory" /> 
    <property name="keySerializer">   
        <bean class="org.springframework.data.redis.serializer.StringRedisSerializer" />   
    </property>
    <property name="defaultSerializer">
        <bean class="org.springframework.data.redis.serializer.JdkSerializationRedisSerializer" />   
    </property>  
</bean>  -->
<!--配置文件加载-->  
<bean id="resourcePropertySource" class="org.springframework.core.io.support.ResourcePropertySource">  
    <constructor-arg name="name" value="redis.properties"/>  
    <constructor-arg name="resource" value="classpath:redis.properties"/>  
</bean>
<!--redisCluster配置-->  
<bean id="redisClusterConfiguration" class="org.springframework.data.redis.connection.RedisClusterConfiguration">  
    <constructor-arg name="propertySource" ref="resourcePropertySource"/>  
</bean>  
<!-- redis服务器中心 -->  
<bean id="jedisConnectionFactory"  class="org.springframework.data.redis.connection.jedis.JedisConnectionFactory" >  
   <constructor-arg name="clusterConfig" ref="redisClusterConfiguration"/>  
    <constructor-arg name="poolConfig" ref="redisPoolConfig"/>  
    <property name="timeout" value="${redis.timeout}" ></property>  
</bean >  
<bean id="redisTemplate" class="org.springframework.data.redis.core.RedisTemplate" >  
    <property name="connectionFactory" ref="jedisConnectionFactory" />  
    <!--如果不配置Serializer,那么存储的时候缺省使用String,如果用User类型存储,那么会提示错误User can't cast to String!!  -->  
    <property name="keySerializer" >  
        <bean class="org.springframework.data.redis.serializer.StringRedisSerializer" />  
    </property>  
    <property name="valueSerializer" >  
        <bean class="org.springframework.data.redis.serializer.JdkSerializationRedisSerializer" />  
    </property>  
    <property name="hashKeySerializer">  
        <bean class="org.springframework.data.redis.serializer.StringRedisSerializer"/>  
    </property>  
    <property name="hashValueSerializer">  
        <bean class="org.springframework.data.redis.serializer.JdkSerializationRedisSerializer"/>  
    </property>  
</bean >  

<bean id="redisHttpSessionConfiguration"
      class="org.springframework.session.data.redis.config.annotation.web.http.RedisHttpSessionConfiguration">
    <property name="maxInactiveIntervalInSeconds" value="600"/>
    <property name="redisNamespace" value="zero" />
</bean>

redis.properties 省略,自己配置即可
使用RedisDesktopManager,可以查看redis中的内容。
注意各种版本之间的搭配,要不然会报错,冲突!!!!!!!!!!!!!!!!!!!!!!!

代码采用
spring cache 的注解
@Cacheable(value = "default", key = "'xx.xx$'+#key")
public String getData(String key, String value) {
return value;
}

@CacheEvict(value = "default", key = "'xx.xx$%'")
public void clearData() {
}

@CacheEvict(value = "default", key = "'xx.xx$'+#key")
public void clearData(String key) {
}

相关文章

网友评论

      本文标题:redis集群+spring-session入门

      本文链接:https://www.haomeiwen.com/subject/zgxkrqtx.html