目录
SpringBoot集成Redis
1.添加 redis 依赖
或将以下配置添加到 pom.xml 中：
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-redis</artifactId>
</dependency>
2.配置 redis
#redis地址
spring.redis.host=x.x.x.x
#端口号
spring.redis.port=6379
spring.redis.password=
#DB[0-15]
spring.redis.database=0
# 可省略
spring.redis.lettuce.pool.min-idle=5
spring.redis.lettuce.pool.max-idle=10
spring.redis.lettuce.pool.max-active=8
spring.redis.lettuce.pool.max-wait=1ms
spring.redis.lettuce.shutdown-timeout=100ms
3.手动操作 redis
@RestController
public class RedisController {
@Autowired
private StringRedisTemplate stringRedisTemplate;
// 在 redis 存储数据 30s之后自动失效
@RequestMapping("/set")
public String set(String name, String value) {
stringRedisTemplate.opsForValue().set(name, value, 30, TimeUnit.SECONDS);
return "Set redis success.";
}
// 读取 redis 中的数据
@RequestMapping("/get")
public String get(String name) {
Object valObj = stringRedisTemplate.opsForValue().get(name);
if (valObj != null) {
return valObj.toString();
}
return "Null";
}
}
通过postman发送请求测试：
下面测试存入字典（Hash）类型：
// 在 redis 存储数据
@RequestMapping("/set2")
public String set2() {
stringRedisTemplate.opsForHash().put("myhash","name","ws");
return "Set redis success.";
}
// 读取 redis 中的数据
@RequestMapping("/get2")
public String get2() {
Object valObj = stringRedisTemplate.opsForHash().get("myhash", "name");
if (valObj != null) {
return valObj.toString();
}
return "Null";
}
Session持久化存储到Redis
1.添加依赖
或者在pom.xml中引入：
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
2.修改redis配置
# 设置连接的Redis数据库的索引。默认情况下，索引为0，即连接到默认的数据库。
# 如果设置多个Redis实例，可以通过此项进行区分。
spring.redis.database=0
# 设置连接的Redis服务器的主机名或IP地址
spring.redis.host=x.x.x.x
spring.redis.password=
# 设置连接的Redis服务器的端口号。在此，服务器的端口号为6379，这是Redis默认的端口号，默认的话可以省略不写。
spring.redis.port=6379
# 设置会话存储类型为Redis
spring.session.store-type=redis
# 设置服务器上所有Servlet的会话超时时间为1800秒，即30分钟。
# Spring Boot默认的会话超时时间为30分钟，但在这里，它被明确地设定为1800秒
server.servlet.session.timeout=1800
# 设置Redis的flush mode为'on_save'。flush mode决定了何时将数据写入磁盘。
# 'on_save'意味着每次数据被保存时都会立即写入磁盘，这可以保证数据的持久性，但可能会影响性能。
spring.session.redis.flush-mode=on_save
# 设置Spring Session在Redis中的命名空间为'spring:session'。
# 这是为了防止不同的应用在同一Redis实例中产生数据冲突。每个应用都可以使用不同的命名空间来保存自己的会话数据。
spring.session.redis.namespace=spring:session
3.存储和读取String类型的代码
@RestController
@RequestMapping("/user")
public class UserController {
// user session key
private static final String SESSION_KEY_USERINFO = "SESSION_KEY_USERINFO";
@RequestMapping("/set")
public String set(HttpSession session) {
session.setAttribute(SESSION_KEY_USERINFO, "ws");
return "ok";
}
@RequestMapping("/get")
public String get(HttpServletRequest request) {
HttpSession session = request.getSession(false);
Object userObj = null;
if (session != null && (userObj = session.getAttribute(SESSION_KEY_USERINFO)) != null) {
return (String) userObj;
}
return "Null";
}
}通过postman进行测试：
4.存储和读取对象类型的代码
实体类：
@Data
public class UserInfo {
private int id;
private String username;
private int age;
}controller类：
@RestController
@RequestMapping("/user")
public class UserController {
// user session key
private static final String SESSION_KEY_USERINFO = "SESSION_KEY_USERINFO";
@RequestMapping("/set")
public String set(HttpSession session) {
//...经过一系列的判断
UserInfo userInfo = new UserInfo();
userInfo.setId(1);
userInfo.setUsername("ws");
userInfo.setAge(18);
session.setAttribute(SESSION_KEY_USERINFO, userInfo);
return "ok";
}
@RequestMapping("/get")
public UserInfo get(HttpServletRequest request) {
HttpSession session = request.getSession(false);
Object userObj = null;
if (session != null && (userObj = session.getAttribute(SESSION_KEY_USERINFO)) != null) {
return (UserInfo) userObj;
}
return null;
}
}通过postman测试：发现是序列化的问题
解决方案：
让UserInfo类实现序列化接口，同时生成序列化版本号。
ps：凡是实现Serializable接口（标识接口）的类都有一个表示序列化版本标识符的静态常量:
private static final long serialVersionUID;
serialVersionUID用来表明类的不同版本间的兼容性。简言之，其目的是以序列化对象进行版本控制，有关各版本反序加化时是否兼容。
如果类没有显示定义这个静态变量，它的值是Java运行时环境根据类的内部细节自动生成的。若类的实例变量做了修改，serialVersionUID 可能发生变化。故建议，显式声明。
简单来说，Java的序列化机制是通过在运行时判断类的serialVersionUID来验证版本一致性的。在进行反序列化时，JVM会把传来的字节流中的serialVersionUID与本地相应实体类的serialVersionUID进行比较，如果相同就认为是一致的，可以进行反序列化，否则就会出现序列化版本不一致的异常。(InvalidCastException)
设置生成序列化版本号：
在类上面ALT+ENTER：
再次测试：
5.序列化细节
（1）被序列化的类的内部的所有属性，必须是可序列化的 （基本数据类型都是可序列化的）
（2）static，transient修饰的属性 不可以被序列化。
再测试下：
什么时候用static和transient？
static：类共享的时候
transient：比如说银行卡的密码，不想被持久化（序列化），写到文件中假如被别人窃取了，别人可以通过反序列化把密码读出来（破解），需要保护的东西就可以用transient来修饰
