Jedis线程不安全问题-深圳市維司達科技有限公司

1. 为什么 Jedis 是线程不安全的？

Jedis 实例在多线程环境下是线程不安全的。其根本原因在于 Jedis 的底层实现：

共享 Socket 连接：Jedis 内部维护了一个唯一的Socket连接和对应的输入/输出流（InputStream/OutputStream）。
请求-响应模式冲突：Jedis 发送请求和接收响应是串行的。如果多个线程共享同一个 Jedis 实例，线程 A 发送了GET key1，在读取响应前，线程 B 发送了SET key2 val2。此时线程 A 读取到的响应可能是线程 B 操作的结果，从而导致数据错乱、协议解析异常或Socket 连接关闭。

2. 解决方案：JedisPool (线程池)

为了解决线程安全问题并提高性能，官方推荐使用JedisPool。

原理：预先创建一组 Jedis 实例并存入池中。每个线程需要操作 Redis 时，从池中“借出”一个专用的实例，操作完成后再“归还”。
效果：确保在同一时刻，一个 Jedis 实例只被一个线程独占，从物理上隔离了线程竞争。

3. 代码示例

A. 依赖配置 (Maven)

在pom.xml中引入 Jedis 和连接池依赖（适配 Spring Boot 3.4.2 开发环境）：

<dependency><groupId>redis.clients</groupId><artifactId>jedis</artifactId><version>5.2.0</version></dependency><dependency><groupId>org.apache.commons</groupId><artifactId>commons-pool2</artifactId><version>2.12.0</version></dependency>

B. JedisPool 初始化配置

配置线程池的核心参数，以保证高并发下的稳定性：

publicclassJedisPoolFactory{privatestaticfinalJedisPooljedisPool;static{// 1. 配置连接池参数JedisPoolConfigconfig=newJedisPoolConfig();config.setMaxTotal(20);// 最大连接数config.setMaxIdle(10);// 最大空闲连接config.setMinIdle(2);// 最小空闲连接config.setMaxWait(Duration.ofMillis(2000));// 获取连接最大等待时间// 2. 初始化 JedisPooljedisPool=newJedisPool(config,"127.0.0.1",6379,1000,"your_password");}publicstaticJedisgetJedis(){returnjedisPool.getResource();}}

C. 正确的使用模式 (Try-with-resources)

使用try-with-resources语法可以确保 Jedis 实例在使用完毕后自动触发close()方法归还给线程池，而不是关闭 Socket：

publicvoidredisOperation(){// 从池中借出连接try(Jedisjedis=JedisPoolFactory.getJedis()){// 执行 Redis 命令jedis.set("user:name","czl");// 示例使用Stringvalue=jedis.get("user:name");System.out.println("Result: "+value);}catch(Exceptione){// 异常处理逻辑e.printStackTrace();}// 退出 try 块后，jedis 实例自动归还到线程池}

4. 在 SpringBoot 中集成 Jedis 线程池

在 Spring Boot 项目中，我们不再需要手动通过JedisPool编写工厂类，而是利用Spring Data Redis提供的自动化配置。

4.1 核心依赖配置

首先，在pom.xml中引入spring-boot-starter-data-redis。注意必须显式排除默认的 Lettuce 客户端（Spring Boot 默认使用 Lettuce），并引入 Jedis 驱动：

<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-data-redis</artifactId><exclusions><exclusion><groupId>io.lettuce</groupId><artifactId>lettuce-core</artifactId></exclusion></exclusions></dependency><dependency><groupId>redis.clients</groupId><artifactId>jedis</artifactId></dependency><dependency><groupId>org.apache.commons</groupId><artifactId>commons-pool2</artifactId></dependency>

4.2 YAML 线程池参数配置

在application.yaml中，我们需要指定客户端类型为jedis，并配置具体的连接池参数以确保多线程安全。

spring:data:redis:host:127.0.0.1port:6379client-type:jedis# 指定使用 Jedis 客户端jedis:pool:max-active:20# 连接池最大连接数（对应 maxTotal）max-idle:10# 最大空闲连接min-idle:2# 最小空闲连接max-wait:2000ms# 获取连接的最大等待时间

5. 代码实现示例

5.1 自定义序列化配置

为了配合你之前使用的JsonUtils，建议配置一个自定义的RedisTemplate。 Spring 会自动将上述 YAML 中的连接池参数注入到RedisConnectionFactory中。

@ConfigurationpublicclassRedisConfig{@BeanpublicRedisTemplate<String,Object>redisTemplate(RedisConnectionFactoryfactory){RedisTemplate<String,Object>template=newRedisTemplate<>();template.setConnectionFactory(factory);// 使用 String 序列化 Keytemplate.setKeySerializer(newStringRedisSerializer());// 使用 JSON 序列化 Valuetemplate.setValueSerializer(newGenericJackson2JsonRedisSerializer());returntemplate;}}

5.2 业务调用示例

在业务层，直接注入RedisTemplate。 Spring Data Redis 会自动从池中借还连接，你无需再关心close()或JedisPool的手动操作：

@ServicepublicclassUserService{@AutowiredprivateRedisTemplate<String,Object>redisTemplate;publicvoidsaveUser(UserDOuser){// 底层自动从 JedisPool 借出连接，执行完自动归还redisTemplate.opsForValue().set("user:"+user.getId(),user);}}