news 2026/7/16 9:34:22

Java 实现 Token 安全缓存:使用 ReentrantLock 和单例模式实现并发安全的 Token 管理器

作者头像

张小明

前端开发工程师

1.2k 24
文章封面图
Java 实现 Token 安全缓存:使用 ReentrantLock 和单例模式实现并发安全的 Token 管理器

在 Java 服务端开发中,Access Token 管理器必须是单例(Singleton),以确保整个应用只维护一个 Token 副本,并使用强大的可重入锁(ReentrantLock)来保证在高并发下的数据一致性。

1. Token 管理器结构:单例模式

我们使用最常用的懒汉式或饿汉式单例模式来创建AccessTokenManager类。这里以饿汉式为例,确保类加载时即完成初始化。

public class AccessTokenManager { // 状态变量 private String accessToken = null; private long expiresAt = 0L; // 精确到毫秒的过期时间戳 // 线程安全的核心:可重入锁 private final ReentrantLock lock = new ReentrantLock(); // 单例实例(饿汉式) private static final AccessTokenManager INSTANCE = new AccessTokenManager(); // 构造方法私有化 private AccessTokenManager() { // 初始化配置 } // 对外提供获取实例的静态方法 public static AccessTokenManager getInstance() { return INSTANCE; } // ... getAccessToken 方法实现 }

2. 核心方法:getAccessToken 的实现逻辑

getAccessToken方法负责检查当前 Token 的状态。其核心在于使用锁来保护 Token 刷新这一关键操作,同时允许大量并发的读操作在 Token 有效时无需等待锁。

逻辑流程:
  1. 快速检查:检查当前 Token 是否在安全阈值(例如 $10$ 分钟)内有效。如果有效,直接返回,避免锁竞争。

  2. 获取锁:如果 Token 即将过期或已过期,线程尝试获取ReentrantLock。此时,其他线程将被阻塞。

  3. 二次校验(Double Check):在获取锁后,必须再次检查 Token 状态。因为可能在线程 A 释放锁的瞬间,线程 B 立即获得了锁,但线程 A 已经完成了刷新。

  4. 执行刷新:如果二次校验仍显示 Token 无效,则线程 B 调用企业微信 API 执行刷新操作。

  5. 更新和释放:更新accessTokenexpiresAt,并在finally块中释放锁。

Java 代码关键部分:
private void refreshAccessToken() { // 实际调用企业微信 API 的代码 // 假设 API 返回 { "access_token": "new_token", "expires_in": 7200 } // 1. 调用 API 获取新 Token 和有效期 // APIResponse response = callWeComApi(); // 2. 更新状态 this.accessToken = "新获取的 Token"; // response.getAccessToken(); // 设定过期时间为当前时间 + 7200秒 - 600秒安全边际 this.expiresAt = System.currentTimeMillis() + (7200 - 600) * 1000L; } public String getAccessToken() { long currentTime = System.currentTimeMillis(); // 1. 快速检查 (无需锁) if (accessToken != null && currentTime < expiresAt) { return accessToken; } // 2. 尝试获取锁进行刷新 lock.lock(); try { // 3. 二次校验 (在锁保护下) if (accessToken != null && currentTime < expiresAt) { return accessToken; // 已被其他线程刷新,直接返回 } // 4. 执行刷新 refreshAccessToken(); return accessToken; } catch (Exception e) { // 记录日志或抛出异常 throw new RuntimeException("Access Token 刷新失败", e); } finally { // 5. 确保锁释放 lock.unlock(); } }

3. ReentrantLock 的优势

相比于使用synchronized关键字,ReentrantLock在这里的优势在于:

  • 明确的锁定和释放:必须手动调用lock()unlock(),强制要求开发者将释放锁的逻辑放置在finally块中,防止异常导致死锁。

  • 非阻塞尝试:ReentrantLock支持tryLock(),可以尝试获取锁,如果获取失败,线程可以选择做其他事情,而不是无限等待。

  • 条件变量:支持Condition,可以更精细地控制线程的等待和唤醒,虽然在这个简单的 Token 场景中用不到,但在更复杂的并发任务中非常有用。

通过这种设计,AccessTokenManager成为了一个高可用、线程安全的 Token 抽象层,为上层的所有 API 调用提供了稳定的保障。


QiWe开放平台提供了后台直登功能,登录成功后获取相关参数,快速Apifox在线测试,所有登录功能都是基于QiWe平台API自定义开发。

版权声明: 本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若内容造成侵权/违法违规/事实不符,请联系邮箱:809451989@qq.com进行投诉反馈,一经查实,立即删除!
网站建设 2026/7/14 21:56:45

温度传感器类型与比较介绍

温度传感器是将温度这一非电量转换为电量&#xff08;电压、电流、电阻&#xff09;的器件。在模拟电路中&#xff0c;我们需要对其输出信号进行调理&#xff08;放大、线性化、补偿&#xff09;&#xff0c;然后才能被ADC采集或用于控制。选择合适的传感器是设计的第一步。一、…

作者头像 李华
网站建设 2026/7/16 2:28:13

LobeChat图像生成插件接入Stable Diffusion全流程

LobeChat图像生成插件接入Stable Diffusion全流程 在AI助手逐渐从“能说话”向“能看、能画、能思考”演进的今天&#xff0c;用户对智能交互的期待早已不再局限于文字回复。设想这样一个场景&#xff1a;你正在策划一场科幻主题展览&#xff0c;只需对聊天框说一句“帮我设计一…

作者头像 李华
网站建设 2026/7/14 23:23:53

Diskinfo下载官网日志分析TensorRT异常退出原因

Diskinfo下载官网日志分析TensorRT异常退出原因 在AI推理系统部署的实战中&#xff0c;一个看似简单的“容器启动后立即退出”问题&#xff0c;往往让开发者耗费数小时排查。尤其是当使用NVIDIA官方提供的TensorRT镜像时&#xff0c;进程静默终止、无明显错误输出的情况屡见不…

作者头像 李华
网站建设 2026/7/15 23:36:58

压缩解压缩算法 BFP-8bit

整个算法设计基于ORAN协议中的BFP压缩算法&#xff1b;对于压缩处理&#xff0c;首先记录无符号最大值的最高有效位&#xff08;0~14&#xff09;&#xff0c;根据最高有效比特位确定压缩处理过程中的压缩因子&#xff1b;压缩处理过程用于完成对数据的压缩&#xff0c;输出压缩…

作者头像 李华
网站建设 2026/7/16 3:19:13

山东港口科技借助 TDengine 构建智慧港口“数据基石”

作者&#xff1a;山东港口, 张艳明 小T导读&#xff1a;在智慧港口的建设过程中&#xff0c;面对海量物联网设备产生的时序数据&#xff08;如设备状态、能耗、作业效率等&#xff09;的高效接入与实时分析需求&#xff0c;山东港口科技选择采用 TDengine TSDB 时序数据库作为…

作者头像 李华
网站建设 2026/7/16 9:29:59

如何将LobeChat与自有GPU资源结合实现低成本高并发?

如何将LobeChat与自有GPU资源结合实现低成本高并发&#xff1f; 在AI应用从“能用”迈向“好用”的今天&#xff0c;越来越多企业开始重新审视自己的技术选型&#xff1a;当一个客服机器人每天要处理上千次对话时&#xff0c;调用OpenAI这类云端API的成本是否可持续&#xff1f…

作者头像 李华