SpringBoot利用Redis管理分布式Session

https://www.jianshu.com/p/fe9a6c3bda4e

1、添加pom配置

<dependencies>
    <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-data-redis</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.session</groupId>
            <artifactId>spring-session-data-redis</artifactId>
        </dependency>
</dependencies>

2、添加yml參數

spring:
  redis:
    cluster:
      nodes: X.X.X.X:6379
    password: XXXXXXXXXXXXXXX
    pool:
      max-active: 8
      max-idle: 8
      max-wait: -1
      min-idle: 0
    timeout: 5000
  session:
    redis:
      namespace: XXXXXXXXXXXXXX

3、添加Redis配置類

@Configuration
@EnableRedisHttpSession(maxInactiveIntervalInSeconds = 3600)
public class RedisSessionConfig {

    private static final Logger logger = LoggerFactory.getLogger(RedisSessionConfig.class);

    @Value("${spring.redis.cluster.nodes}")
    private String cluster;

    @Value("${spring.redis.password}")
    private String password;

    public RedisSessionConfig() {
        //redisSession配置類
    }

    @Bean
    public static ConfigureRedisAction configureRedisAction() {
        logger.info("redisconfig配置生效");
        return ConfigureRedisAction.NO_OP;
    }

    @Bean
    public JedisConnectionFactory connectionFactory() {
        JedisConnectionFactory jedisConnectionFactory = new JedisConnectionFactory(redisClusterConfiguration(), jedisPoolConfig());
        jedisConnectionFactory.setPassword(password);
        jedisConnectionFactory.setUsePool(true);
        jedisConnectionFactory.setTimeout(1800);
        return jedisConnectionFactory;
    }

    /**
     * redis集群配置
     * 配置redis集群的結點及其它一些屬性
     *
     * @return
     */
    private RedisClusterConfiguration redisClusterConfiguration() {
        RedisClusterConfiguration redisClusterConfig = new RedisClusterConfiguration();

        redisClusterConfig.setClusterNodes(getClusterNodes());

        redisClusterConfig.setMaxRedirects(3);
        return redisClusterConfig;

    }

    /**
     * JedisPoolConfig 配置
     * <p/>
     * 配置JedisPoolConfig的各項屬性
     *
     * @return
     */
    private JedisPoolConfig jedisPoolConfig() {
        JedisPoolConfig jedisPoolConfig = new JedisPoolConfig();
        //連接耗盡時是否阻塞, false報異常,ture阻塞直到超時, 默認true
        jedisPoolConfig.setBlockWhenExhausted(true);

        //是否啟用pool的jmx管理功能, 默認true
        jedisPoolConfig.setJmxEnabled(true);

        //jedis調用returnObject方法時，是否進行有效檢查
        jedisPoolConfig.setTestOnReturn(true);

        //是否啟用后進先出, 默認true
        jedisPoolConfig.setLifo(true);

        //最大空閑連接數, 默認8個
        jedisPoolConfig.setMaxIdle(8);

        //最大連接數, 默認8個
        jedisPoolConfig.setMaxTotal(8);

        //獲取連接時的最大等待毫秒數(如果設置為阻塞時BlockWhenExhausted),如果超時就拋異常, 小於零:阻塞不確定的時間,  默認-1
        jedisPoolConfig.setMaxWaitMillis(-1);

        //逐出連接的最小空閑時間 默認1800000毫秒(30分鍾)
        jedisPoolConfig.setMinEvictableIdleTimeMillis(3600000);

        //最小空閑連接數, 默認0
        jedisPoolConfig.setMinIdle(0);

        //每次逐出檢查時 逐出的最大數目 如果為負數就是 : 1/abs(n), 默認3
        jedisPoolConfig.setNumTestsPerEvictionRun(3);

        //對象空閑多久后逐出, 當空閑時間>該值 且 空閑連接>最大空閑數 時直接逐出,不再根據MinEvictableIdleTimeMillis判斷  (默認逐出策略)
        jedisPoolConfig.setSoftMinEvictableIdleTimeMillis(3600000);

        //在獲取連接的時候檢查有效性, 默認false
        jedisPoolConfig.setTestOnBorrow(false);

        //在空閑時檢查有效性, 默認false
        jedisPoolConfig.setTestWhileIdle(false);

        //逐出掃描的時間間隔(毫秒) 如果為負數,則不運行逐出線程, 默認-1
        jedisPoolConfig.setTimeBetweenEvictionRunsMillis(-1);
        return jedisPoolConfig;
    }

    /**
     * redis集群節點IP和端口的添加
     * <p/>
     * 節點：RedisNode redisNode = new RedisNode("127.0.0.1",6379);
     *
     * @return redis集群配置
     */
    private Set<RedisNode> getClusterNodes() {
        // 添加redis集群的節點
        logger.info("讀取到的redis集群配置為:{}", cluster);
        if (!StringUtils.isBlank(cluster)) {
            Set<RedisNode> clusterNodes = new HashSet<>();
            List<String> nodes = Arrays.asList(cluster.split(","));
            for (String node : nodes) {
                List<String> domainAndPort = Arrays.asList(node.split(":"));
                String domain = domainAndPort.get(0);
                int port = Integer.parseInt(domainAndPort.get(1));
                clusterNodes.add(new RedisNode(domain, port));
            }
            return clusterNodes;
        } else {
            logger.error("redis集群配置為空！");
            return null;
        }
    }
}

4、添加session

request.getSession().setAttribute("user", result);

5、獲取session

Object user = request.getSession().getAttribute("user");