SpringBoot2.x系列教程75--SpringBoot整合JPA、Redis实现分布式的Session共享

一.SpringBoot整合JPA、Redis实现分布式的Session共享

1. 创建web项目

我们按照之前的经验，创建一个web程序，并将之改造成Spring Boot项目，具体过程略。

2.添加依赖包

<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-data-jpa</artifactId></dependency><!-- 改造:添加sql相关的依赖--><dependency><groupId>mysql</groupId><artifactId>mysql-connector-java</artifactId></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-data-redis</artifactId></dependency><dependency><groupId>org.springframework.session</groupId><artifactId>spring-session-data-redis</artifactId></dependency><dependency><groupId>org.springframework.session</groupId><artifactId>spring-session-core</artifactId></dependency><dependency><groupId>com.alibaba</groupId><artifactId>fastjson</artifactId><version>1.2.39</version></dependency>

3.创建application.yml配置文件

server:port: 8080servlet:#设置session过期时间session:timeout: "PT10M"
spring:application:name: spring-session-jpadatasource:driver-class-name: com.mysql.cj.jdbc.Driverusername: rootpassword: sycurl: jdbc:mysql://localhost:3306/spring-security?useUnicode=true&characterEncoding=utf8&characterSetResults=utf8&useSSL=false&serverTimezone=UTCredis:host: localhostport: 6379database: 0jedis:pool:max-idle: 8min-idle: 0max-active: 8session:#设置session存储类型store-type: redisjpa:database: mysqlshow-sql: true #开发阶段,打印要执行的sql语句.hibernate:ddl-auto: update

4.创建User实体类

package com.yyg.boot.entity;import ch.qos.logback.classic.db.names.TableName;
import lombok.Data;
import lombok.ToString;
import org.hibernate.annotations.GenericGenerator;import javax.persistence.*;
import javax.validation.constraints.NotBlank;
import java.io.Serializable;/*** @Author 一一哥Sun* @Date Created in 2020/4/29* @Description Description*/
@Entity
@Table(name="user")
@Data
@ToString
public class User implements Serializable {@Id@GeneratedValue(generator = "idGenerator",strategy = GenerationType.IDENTITY)private Long id;@Column(name = "username")@NotBlank(message = "username can not be empty")private String username;@Column(name = "password")@NotBlank(message = "password can not be empty")private String password;}

5.创建UserRepository仓库类

package com.yyg.boot.repository;import com.yyg.boot.entity.User;
import org.springframework.data.jpa.repository.JpaRepository;/*** @Author 一一哥Sun* @Date Created in 2020/4/29* @Description Description*/
public interface UserRepository extends JpaRepository<User,Long> {User findByUsername(String username);User findByUsernameAndPassword(String username,String password);}

6.创建Service实现类

6.1 创建UserService接口

package com.yyg.boot.service;import com.yyg.boot.entity.User;/*** @Author 一一哥Sun* @Date Created in 2020/4/29* @Description Description*/
public interface UserService {/*** save user*/User saveUser(User user);/*** find user by account*/User findByUsername(String username);/*** user login*/User login(String username, String password);}

6.2 创建UserServiceImpl实现类

package com.yyg.boot.service.impl;import com.yyg.boot.entity.User;
import com.yyg.boot.repository.UserRepository;
import com.yyg.boot.service.UserService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;/*** @Author 一一哥Sun* @Date Created in 2020/4/29* @Description Description*/
@Service
public class UserServiceImpl implements UserService {@Autowiredprivate UserRepository userRepository;@Overridepublic User saveUser(User user) {return userRepository.save(user);}@Overridepublic User findByUsername(String username) {return userRepository.findByUsername(username);}@Overridepublic User login(String username, String password) {return userRepository.findByUsernameAndPassword(username, password);}}

7.创建UserController接口

package com.yyg.boot.web;import com.yyg.boot.entity.User;
import com.yyg.boot.service.UserService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;import javax.servlet.http.HttpSession;/*** @Author 一一哥Sun* @Date Created in 2020/4/29* @Description Description*/
@RestController
@RequestMapping("/user")
public class UserController {@Autowiredprivate UserService userService;/*** save user*/@PostMapping(value = "/save")public User save(@RequestBody User user) {return userService.saveUser(user);}/*** find user by username*/@GetMapping(value = "/find/{username}")public User findUser(@PathVariable String username) {return userService.findByUsername(username);}/*** user login*/@GetMapping(value = "/login")public User login(String username, String password, HttpSession session) {User user = userService.login(username, password);if(user!=null){session.setAttribute(session.getId(),user);}return user;}@GetMapping(value = "/logout")public String logout(HttpSession session){session.removeAttribute(session.getId());return "user logout success";}}

8.添加拦截器，判断session是否有效

package com.yyg.boot.config;import com.alibaba.fastjson.JSON;
import org.springframework.context.annotation.Configuration;
import org.springframework.session.data.redis.config.annotation.web.http.EnableRedisHttpSession;
import org.springframework.web.servlet.HandlerInterceptor;
import org.springframework.web.servlet.config.annotation.InterceptorRegistry;
import org.springframework.web.servlet.config.annotation.WebMvcConfigurer;import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import javax.servlet.http.HttpSession;
import java.io.IOException;/*** @Author 一一哥Sun* @Date Created in 2020/4/28* @Description 开启Redis Http Session*/
@Configuration
@EnableRedisHttpSession(maxInactiveIntervalInSeconds = 1800)
public class RedisHttpSessionConfiguration implements WebMvcConfigurer {/*** 添加过滤接口*/@Overridepublic void addInterceptors(InterceptorRegistry registry) {registry.addInterceptor(new SecurityInterceptor())//排除拦截.excludePathPatterns("/user/login").excludePathPatterns("/user/logout")//拦截路径.addPathPatterns("/**");}/*** 判断session是否为空,从而进行拦截放行*/@Configurationpublic class SecurityInterceptor implements HandlerInterceptor {@Overridepublic boolean preHandle(HttpServletRequest request, HttpServletResponse response, Object handler) throws IOException {HttpSession session = request.getSession();if (session.getAttribute(session.getId()) != null) {return true;}response.getWriter().write(JSON.toJSONString("please login first"));return false;}}}

9.创建入口类

package com.yyg.boot;import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;/*** @Author 一一哥Sun* @Date Created in 2020/4/28* @Description Description*/
@SpringBootApplication
public class SpringSessionJpaApplication {public static void main(String[] args){SpringApplication.run(SpringSessionJpaApplication.class,args);}}

10.完整项目结构

11.启动项目，进行测试

我们在未登录的情况下，直接根据用户名查询某个用户信息，会看到浏览器提示我们先要进行登录。

然后测试save接口，会发现也是提示先进行登录才可以。

此时我们进行登录，登录成功

然后我们再进行save或find接口的测试，会发现此时这些接口都已经可以正常访问了。

数据库中已经多了一个新的数据。

然后我们再退出登录

然后重新测试查询接口，会发现已经无法查询用户信息了，提示需要进行登录才可以。

再重新登录后，我们可以再启动8081这个新的进程，然后查询tom这个用户信息，会发现也查询到了tom的用户信息，说明我们已经实现了session的共享。

redis中也有了保存的session信息。

SpringBoot2.x系列教程75--SpringBoot整合JPA、Redis实现分布式的Session共享相关推荐

springboot整合oracle_SpringBoot2.x系列教程67--Spring Boot整合分布式事务简介
SpringBoot2.x系列教程67--Spring Boot整合分布式事务简介作者:一一哥一. 分布式事务简介 1. 什么是分布式事务百度百科对分布式事务的解释如下: 分布式事务就是指事务的 ...
springboot socket服务端_SpringBoot2.x系列教程81--SpringBoot中整合WebSockets
SpringBoot2.x系列教程81--SpringBoot中整合WebSockets 作者:一一哥一. WebSockets简介 1. 什么是WebSockets WebSocket是HTML5 ...
exchange无法收发邮件_SpringBoot2.x系列教程69--SpringBoot中整合邮件发送
SpringBoot2.x系列教程69--SpringBoot中整合邮件发送作者:一一哥注: 本文案例以QQ邮箱发送的实现为例! 一. 邮件发送概述 1. 概述在Spring框架中提供了一个Ja ...
channelfuture怎么拿到数据_SpringBoot2.x系列教程66--Spring Boot整合分布式事务之数据库事务回顾
SpringBoot2.x系列教程66--Spring Boot整合分布式事务之数据库事务回顾作者:一一哥本节主要内容一. 事务出现的原因转账是生活中常见的操作,比如从A账户转账100元到B账 ...
exchange无法收发邮件_SpringBoot2.x系列教程69--SpringBoot中整合Mail实现邮件发送
SpringBoot2.x系列教程69--SpringBoot中整合邮件发送作者:一一哥注: 本文案例以QQ邮箱发送的实现为例! 一. 邮件发送概述 1. 概述在Spring框架中提供了一个Ja ...
getprivateprofilestring读不到数据_SpringBoot2.x系列教程66--Spring Boot整合分布式事务之数据库事务回顾
SpringBoot2.x系列教程66--Spring Boot整合分布式事务之数据库事务回顾作者:一一哥本节主要内容一. 事务出现的原因转账是生活中常见的操作,比如从A账户转账100元到B账 ...
SpringBoot2.x系列教程38--整合JAX-RS之利用Jersey框架实现RESTful
SpringBoot2.x系列教程38--整合JAX-RS之利用Jersey框架实现RESTful 作者:一一哥一. JAX-RS与Jersey简介 1. JAX-RS简介在Java EE 6 中 ...
（二）SpringBoot 整合 JPA
一.JPA简介 JPA(java persistence api)并不是一个框架,而是一组规范.Hibernate.TopLink.OpenJPA都实现了JPA规范,不过Hinernate最成功).所 ...
Springboot整合JPA多数据源（Oracle+Mysql）
Springboot整合JPA多数据源 1. Maven 2. 基本配置 2.1 DataSource 3. 多数据源配置 3.1 JpaConfigOracle 3.2 JpaConfigMysql ...

SpringBoot2.x系列教程75--SpringBoot整合JPA、Redis实现分布式的Session共享

SpringBoot2.x系列教程75--SpringBoot整合JPA、Redis实现分布式的Session共享

一.SpringBoot整合JPA、Redis实现分布式的Session共享

1. 创建web项目

2.添加依赖包

3.创建application.yml配置文件

4.创建User实体类

5.创建UserRepository仓库类

6.创建Service实现类

7.创建UserController接口

8.添加拦截器，判断session是否有效

9.创建入口类

10.完整项目结构

11.启动项目，进行测试

SpringBoot2.x系列教程75--SpringBoot整合JPA、Redis实现分布式的Session共享相关推荐

最新文章

热门文章