Spring Boot实现Redis存储session

创建项目

引入依赖

创建一个Spring Boot项目，引入Spring Boot DevTools、Spring Web、Thymeleaf依赖，这里是创建项目时引入，下面是创建后引入，可以创建时引入就尽量创建时引入，比较方便

项目结构

引入依赖

在pom文件中添加：

<!-- https://mvnrepository.com/artifact/redis.clients/jedis -->
<dependency>
	<groupId>redis.clients</groupId>
	<artifactId>jedis</artifactId>
	<version>3.6.2</version>
</dependency>
<!-- https://mvnrepository.com/artifact/org.springframework.session/spring-session-data-redis -->
<dependency>
	<groupId>org.springframework.session</groupId>
	<artifactId>spring-session-data-redis</artifactId>
	<version>2.5.1</version>
</dependency>
<!-- https://mvnrepository.com/artifact/io.lettuce/lettuce-core -->
<dependency>
	<groupId>io.lettuce</groupId>
	<artifactId>lettuce-core</artifactId>
	<version>6.1.2.RELEASE</version>
</dependency>

完整pom.xml

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>
    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.5.4</version>
        <relativePath/> <!-- lookup parent from repository -->
    </parent>
    <groupId>com.ledao</groupId>
    <artifactId>RedisSessionDemo</artifactId>
    <version>0.0.1-SNAPSHOT</version>
    <name>RedisSessionDemo</name>
    <description>Demo project for Spring Boot</description>
    <properties>
        <java.version>1.8</java.version>
    </properties>
    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-thymeleaf</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-devtools</artifactId>
            <scope>runtime</scope>
            <optional>true</optional>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>
        <!-- https://mvnrepository.com/artifact/redis.clients/jedis -->
        <dependency>
            <groupId>redis.clients</groupId>
            <artifactId>jedis</artifactId>
            <version>3.6.2</version>
        </dependency>
        <!-- https://mvnrepository.com/artifact/org.springframework.session/spring-session-data-redis -->
        <dependency>
            <groupId>org.springframework.session</groupId>
            <artifactId>spring-session-data-redis</artifactId>
            <version>2.5.1</version>
        </dependency>
        <!-- https://mvnrepository.com/artifact/io.lettuce/lettuce-core -->
        <dependency>
            <groupId>io.lettuce</groupId>
            <artifactId>lettuce-core</artifactId>
            <version>6.1.2.RELEASE</version>
        </dependency>
    </dependencies>

    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
            </plugin>
        </plugins>
    </build>

</project>

application.yml配置

server:
  port: 8888
  servlet:
    context-path: /
  tomcat:
    uri-encoding: utf-8

spring:
  session:
    store-type: redis #指定redis实现spring session
    timeout: PT1H # Session 过期时间， PT开头  ‘D’ – 天   ‘H’ – 小时  ‘M’ – 分钟 ‘S’ – 秒
    redis:
      flush-mode: on_save # Sessions 刷新模式  on_save http response为committed才提交 immediate 立即提交
      namespace: ledao # session 存储命名空间
  redis:
    host: 192.168.0.106 #Linux服务器IP地址
    port: 6379 #Redis端口号,一般默认为6379
    password:
    lettuce:
      pool:
        max-active: 8 # 连接池最大连接数（使用负值表示没有限制）
        max-wait: -1 # 连接池最大阻塞等待时间（使用负值表示没有限制）
        max-idle: 8 # 连接池中的最大空闲连接
        min-idle: 0 # 连接池中的最小空闲连接
      shutdown-timeout: 100  # 连接超时时间（毫秒）

启动类添加注解

添加注解@EnableRedisHttpSession

package com.ledao;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.boot.builder.SpringApplicationBuilder;
import org.springframework.boot.web.servlet.support.SpringBootServletInitializer;
import org.springframework.session.data.redis.config.annotation.web.http.EnableRedisHttpSession;

/**
 * @author LeDao
 */
@EnableRedisHttpSession
@SpringBootApplication
public class RedisSessionDemoApplication extends SpringBootServletInitializer {


    @Override
    protected SpringApplicationBuilder configure(SpringApplicationBuilder application) {
        return application.sources(RedisSessionDemoApplication.class);
    }

    public static void main(String[] args) {
        SpringApplication.run(RedisSessionDemoApplication.class, args);
    }

}

Java代码

User.java

要实现Serializable序列化，不然会Redis会报错：org.springframework.data.redis.serializer.SerializationException: Cannot serialize

package com.ledao.entity;

import java.io.Serializable;

/**
 * 用户实体类
 *
 * @author LeDao
 * @company
 * @create 2021-09-02 9:49
 */
public class User implements Serializable {

    private static final long serialVersionUID = -1;

    private Integer id;

    private String userName;

    private String password;

    public Integer getId() {
        return id;
    }

    public void setId(Integer id) {
        this.id = id;
    }

    public String getUserName() {
        return userName;
    }

    public void setUserName(String userName) {
        this.userName = userName;
    }

    public String getPassword() {
        return password;
    }

    public void setPassword(String password) {
        this.password = password;
    }

    @Override
    public String toString() {
        return "User{" +
                "id=" + id +
                ", userName='" + userName + '\'' +
                ", password='" + password + '\'' +
                '}';
    }
}

IndexController.java

package com.ledao.controller;

import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.servlet.ModelAndView;

/**
 * @author LeDao
 * @company
 * @create 2021-09-02 9:50
 */
@Controller
public class IndexController {

    @RequestMapping("/")
    public ModelAndView root() {
        ModelAndView mav = new ModelAndView();
        mav.setViewName("login");
        return mav;
    }

    @RequestMapping("/getInfo")
    public ModelAndView getInfo() {
        ModelAndView mav = new ModelAndView();
        mav.setViewName("info");
        return mav;
    }
}

UserController.java

package com.ledao.controller;

import com.ledao.entity.User;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.servlet.ModelAndView;

import javax.servlet.http.HttpSession;

/**
 * @author LeDao
 * @company
 * @create 2021-09-02 9:50
 */
@Controller
@RequestMapping("/user")
public class UserController {

    @RequestMapping("/login")
    public ModelAndView login(HttpSession session, User user) {
        ModelAndView mav = new ModelAndView();
        String password = "123";
        if (password.equals(user.getPassword())) {
            session.setAttribute("currentUser", user);
            mav.setViewName("main");
        } else {
            mav.addObject("errorInfo", "用户名或者密码错误！");
            mav.setViewName("login");
        }
        return mav;
    }
}

HTML页面

login.html

<!DOCTYPE html>
<html lang="en">
<head>
    <meta charset="UTF-8">
    <title>登录</title>
</head>
<body>
<form action="/user/login" method="post">
  用户名:
  <input type="text" name="userName">
  密码:
  <input type="text" name="password">
  <input type="submit" value="提交">
</form>
</body>
</html>

main.html

<!DOCTYPE html>
<html lang="en" xmlns:th="http://www.thymeleaf.org">
<head>
    <meta charset="UTF-8">
    <title>Title</title>
</head>
<body>
<h1>登录成功</h1>
<h2 style="color: blue">当前用户:<sapn th:text="${session.currentUser.userName}"></sapn></h2>
</body>
</html>

info.html

<!DOCTYPE html>
<html lang="en" xmlns:th="http://www.thymeleaf.org">
<head>
    <meta charset="UTF-8">
    <title>Title</title>
</head>
<body>
当前用户信息:
<span th:text="${'用户名:'+session.currentUser.userName+',密码:'+session.currentUser.password}"></span>
</body>
</html>

测试

1. 浏览器地址栏输入：http://localhost:8888/ ，进入登录页面login.html

2. 输入用户名和密码，只要密码是123就可以登录成功，然后进入主页面main.html

3. 浏览器地址栏输入：http://localhost:8888/getInfo，进入显示当前登录用户信息页面info.html

4. 在Redis可视化工具可以看到有一个用户session

5. 打开另一个浏览器，重复①②③步骤，然后Redis可视化工具可以看到多了一个用户session

PS.

GitHub地址：a6678696/RedisSessionDemo: Redis存储session例子 (github.com)