news 2026/5/6 23:25:54

Jedis线程不安全问题

作者头像

张小明

前端开发工程师

1.2k 24
文章封面图
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);}}
版权声明: 本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若内容造成侵权/违法违规/事实不符,请联系邮箱:809451989@qq.com进行投诉反馈,一经查实,立即删除!
网站建设 2026/5/4 12:10:58

数据中心如何赢得社区信任的九大策略

美国各地社区对AI规模数据中心的快速扩张日益警惕。在拥挤的公开听证会上&#xff0c;居民质疑不断上涨的水电费和本地基础设施的压力&#xff0c;越来越多的项目面临延迟或被拒。2025年12月&#xff0c;亚利桑那州钱德勒市就发生了一起典型事件&#xff0c;尽管前美国参议员进…

作者头像 李华
网站建设 2026/5/2 13:37:02

5年测试被裁,恶补3个月上岸阿里25K,面试差点被问哭···

我的个人背景非常简单&#xff0c;也可以说丝毫没有亮点。 学历普通&#xff0c;计算机专业二本毕业&#xff0c;毕业后出来就一直在一家小公司&#xff0c;岁月如梭细&#xff0c;算了下至今从事软件测试已经5年了&#xff0c;也点点点了五年&#xff0c;每天都是重复的工作&…

作者头像 李华
网站建设 2026/4/25 10:38:44

《Foundation 均衡器》

《Foundation 均衡器》 引言 在现代社会,均衡器作为一种常见的音频处理工具,被广泛应用于各种音频制作与播放场景中。本文将深入探讨Foundation均衡器的工作原理、功能特点以及在音频制作中的应用,帮助读者更好地理解和使用这一重要的音频处理工具。 均衡器概述 均衡器(…

作者头像 李华
网站建设 2026/5/1 16:11:10

JMeter启动时常见的错误

很多小伙伴在学工具这一块时&#xff0c;安装也是很吃力的一个问题&#xff0c;之前记得有说过怎么安装jmeter这个工具。那么你要启动jmeter的时候&#xff0c;一些粉丝就会碰到如下几个问题。 1.解压下载好的jmeter安装&#xff0c;Windows 平台&#xff0c;双击 jmeter/bin …

作者头像 李华
网站建设 2026/5/4 17:03:29

Flutter for OpenHarmony 实战:网络监控登录系统完整开发指南

Flutter for OpenHarmony 实战&#xff1a;网络监控登录系统完整开发指南 文章目录Flutter for OpenHarmony 实战&#xff1a;网络监控登录系统完整开发指南摘要一、项目背景与功能概述1.1 网络监控应用场景1.2 应用功能规划1.3 界面设计要求二、数据模型设计2.1 客户端状态类2…

作者头像 李华