架构

实现Nginx负载均衡、Session共享、Redis集群(一)

2018-07-25  本文已影响134人  小超2020

前期项目基于Spring 3.1,现在要实现Nginx负载均衡、Session共享、Redis集群(Redis-Sentinel哨兵模式)

实现Session共享

  1. 添加项目依赖
   <dependency>
        <groupId>org.springframework.session</groupId>
        <artifactId>spring-session-data-redis</artifactId>
        <version>1.2.1.RELEASE</version>
    </dependency>

以上依赖相当于引用了如下依赖

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

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

    <dependency>
        <groupId>redis.clients</groupId>
        <artifactId>jedis</artifactId>
        <version>2.9.0</version>
    </dependency>

    <dependency>
        <groupId>org.apache.commons</groupId>
        <artifactId>commons-pool2</artifactId>
        <version>2.4.2</version>
    </dependency>
  1. spring-session.xml配置
    <bean id="redisHttpSessionConfiguration"
             class="org.springframework.session.data.redis.config.annotation.web.http.RedisHttpSessionConfiguration">
            <property name="cookieSerializer" ref="cookieSerializer"/>
            <property name="maxInactiveIntervalInSeconds" value="1800"/>
    </bean>
    <bean id="cookieSerializer"   class="org.springframework.session.web.http.DefaultCookieSerializer">
            <property name="cookieName" value="SESSION"/>
    </bean>
    <bean id="jedisPoolConfig" class="redis.clients.jedis.JedisPoolConfig">
            <property name="maxIdle" value="10"/>
            <property name="maxTotal" value="40"/>
    </bean>
    <bean id="jedisConnectionFactory" class="org.springframework.data.redis.connection.jedis.JedisConnectionFactory">
            <property name="hostName" value="10.45.10.72"/>
            <property name="port" value="6379"/>
            <property name="password" value="specialpassword"/>
            <property name="poolConfig" ref="jedisPoolConfig"/>
            <property name="usePool" value="true"/>
            <property name="database" value="2"/>
     </bean>
  • 单节点Redis
  <bean 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}" />
  </bean>
  • 集群redis
  <bean id="sentinelConfig" class="org.springframework.data.redis.connection.RedisSentinelConfiguration">
      <constructor-arg name="master" value="${redis.master}" />
      <constructor-arg name="sentinelHostAndPorts">
          <set>
              <value>127.0.0.1:2679</value><!--配置redis哨兵-->
              <value>127.0.0.1:2678</value>
          </set>
      </constructor-arg>
  </bean>

  <bean class="org.springframework.data.redis.connection.jedis.JedisConnectionFactory">
      <constructor-arg ref="sentinelConfig" />
      <property name="password" value="${redis.password}"/>
  </bean>
  1. 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>
 </filter-mapping>

这里配置的时候要注意,一般要把springSessionRepositoryFilter配置为web.xml中所有filter中的第一位,因为只有配置在最前面,才能使得请求第一个经过该filter,从而后续处理中的所有request使用的session都是经过spring包装的redis session。
Spring redis处理的方式其实是将原始的HttpServletRequest通过HttpServletRequestWrapper类重写getSession()方法实现的,并且在filter中它以偷天换日的方式将原始的HttpRequestServlet用该类替换了。

  • Spring中还有一种获取HttpServletRequest 的方式,即自动注入:
@Autowired
private HttpServletRequest request;
/*
*通过这种方式拿到的request,你会发现直接通过request.getSession()拿到的并不是你想要的redis session而是原始的session。可以通过如下方式获取。
*(机智的spring已经帮你把他的引用放在原始request的attribute中了) 的方式取得你想要的redis session。
*因为这里自动注入的其实只是一个spring封装过的HttpServletRequest的代理类,他传的值和controller中获取的是不一样的。
*/
HttpSession session = (HttpSession)request.getAttribute("javax.servlet.http.HttpServletRequestWrapper");
  • Spring session只是共享session的一种方式,还有一种比较常见的方式是通过tomcat的session管理来处理共享session。Spring session的好处在于它并不依赖于tomcat容器,与tomcat很好的解耦了,包括他的配置都更加的方便,并且tomcat不管是版本7还是8都可以使用同一套方式。不过我相信最适合项目的方式就是最好的方式。

[参考文章列表]
https://www.jianshu.com/p/3d5e83205a7a
https://my.oschina.net/firstbing/blog/1559728

上一篇 下一篇

猜你喜欢

热点阅读