0

0

如何在 k6 中实现所有虚拟用户共享并动态刷新全局 Token

霞舞

霞舞

发布时间:2026-02-19 10:20:03

|

513人浏览过

|

来源于php中文网

原创

如何在 k6 中实现所有虚拟用户共享并动态刷新全局 Token

本文介绍在 k6 性能测试中,如何让所有 vu 共享同一份访问令牌(token),并在其过期前统一刷新,避免各 vu 独立申请导致状态不一致;核心方案是借助 redis 作为跨 vu 的共享状态中间件。

本文介绍在 k6 性能测试中,如何让所有 vu 共享同一份访问令牌(token),并在其过期前统一刷新,避免各 vu 独立申请导致状态不一致;核心方案是借助 redis 作为跨 vu 的共享状态中间件。

在 k6 中,每个虚拟用户(VU)运行在隔离的 JavaScript 运行时环境中,无法直接共享内存变量或同步状态。这意味着 setup() 中获取的 token 仅对初始化该 VU 的上下文有效,且后续无法广播更新——这也是用户遇到“1 小时后无法统一刷新 token”的根本原因。

要突破这一限制,必须引入外部协调服务。k6 官方提供的实验性模块 k6/x/redis 是目前最轻量、最契合的解决方案:它允许 VU 通过 Redis 读写共享键值,实现跨 VU 的状态同步与协调。

✅ 推荐架构:双场景协同模式

我们将测试拆分为两个逻辑独立但语义协同的场景:

AI抖音
AI抖音

AI抖音,会思考的抖音

下载
  • token-manager 场景:仅启动 1 个 VU,周期性(如每 55 分钟)调用认证接口刷新 token,并将新 token 写入 Redis(如 SET token );
  • main-test 场景:承载全部压测流量的 VUs,每次请求前从 Redis 读取最新 token(GET token),并配合本地缓存与过期检查,减少阻塞与冗余调用。

⚠️ 注意:redisClient.get() 默认会阻塞当前 VU 直到 key 存在,因此需确保 token-manager 场景先于 main-test 启动(通过 startTime 控制),或添加超时与降级逻辑。

? 示例代码(k6 script)

import { SharedArray } from 'k6/data';
import { sleep, check } from 'k6';
import redis from 'k6/x/redis';

// 初始化 Redis 客户端(需提前运行 Redis 服务,如 docker run -d -p 6379:6379 redis)
const redisClient = redis.connect('redis://localhost:6379');

// 共享配置(可提取至环境变量)
const AUTH_URL = __ENV.AUTH_URL || 'https://api.example.com/auth/token';
const API_BASE = __ENV.API_BASE || 'https://api.example.com/v1';

export const options = {
  scenarios: {
    // 场景 1:Token 管理器(单 VU,长期运行)
    'token-manager': {
      executor: 'constant-vus',
      vus: 1,
      duration: '2h',
      startTime: '0s', // 优先启动
      exec: 'manageToken',
    },
    // 场景 2:主压测流量(多 VU,并发执行)
    'main-test': {
      executor: 'ramping-vus',
      startVUs: 10,
      stages: [
        { duration: '30s', target: 50 },
        { duration: '5m', target: 50 },
        { duration: '30s', target: 10 },
      ],
      startTime: '10s', // 延迟启动,确保 token 已就绪
      exec: 'callProtectedAPI',
    },
  },
};

// 场景 1:定期刷新并写入 Redis
export function manageToken() {
  while (__ENV.TEST_DURATION && new Date() < new Date(Date.now() + 2 * 60 * 60 * 1000)) {
    try {
      const res = http.post(AUTH_URL, JSON.stringify({ grant_type: 'client_credentials' }), {
        headers: { 'Content-Type': 'application/json' },
      });

      if (check(res, { 'auth token received': (r) => r.status === 200 && r.json().access_token })) {
        const token = res.json().access_token;
        redisClient.set('token', token);
        console.log(`[TOKEN-MANAGER] Updated global token (expires in ~1h)`);
      }
    } catch (e) {
      console.error('[TOKEN-MANAGER] Failed to refresh token:', e.message);
    }

    sleep(55 * 60); // 每 55 分钟刷新一次,预留缓冲时间
  }
}

// 场景 2:业务请求,从 Redis 获取 token
export function callProtectedAPI() {
  let token;
  try {
    token = redisClient.get('token');
    if (!token) throw new Error('token not available in Redis');
  } catch (e) {
    throw new Error(`Failed to fetch token from Redis: ${e.message}`);
  }

  const res = http.get(`${API_BASE}/users`, {
    headers: { Authorization: `Bearer ${token}` },
  });

  check(res, {
    'status is 200': (r) => r.status === 200,
    'response time < 800ms': (r) => r.timings.duration < 800,
  });
}

? 关键实践建议

  • Redis 部署推荐:使用 Docker 快速启动:
    docker run -d --name k6-redis -p 6379:6379 -e REDIS_PASSWORD="" redis:alpine
  • 健壮性增强
    • 在 callProtectedAPI 中加入 token 本地缓存(如用 SharedArray 存储最近获取值 + 时间戳),减少高频 Redis 调用;
    • 对 redisClient.get() 添加 try/catch 与 fallback 重试机制(例如失败后 sleep 1s 再试,最多 3 次);
    • 认证接口应支持无状态刷新(如传 refresh_token 或支持 client_credentials 重发),避免依赖 session。
  • 可观测性:在 manageToken 中记录日志(如 console.log)并结合 k6 的 --out json=report.json 输出,便于追踪 token 更新时序。

✅ 总结

k6 原生不支持 VU 间变量共享,但通过 k6/x/redis 模块桥接外部存储,即可优雅实现全局状态同步。本方案以低耦合、高可控的方式解决了“统一 token 分发与定时刷新”这一典型企业级测试需求——无需修改被测服务,不增加客户端逻辑,且完全兼容 k6 的分布式执行模型。只要确保 Redis 可达且 token 管理逻辑幂等,即可稳定支撑数小时乃至跨天的长稳测试任务。

本站声明:本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系admin@php.cn

热门AI工具

更多
DeepSeek
DeepSeek

幻方量化公司旗下的开源大模型平台

豆包大模型
豆包大模型

字节跳动自主研发的一系列大型语言模型

通义千问
通义千问

阿里巴巴推出的全能AI助手

腾讯元宝
腾讯元宝

腾讯混元平台推出的AI助手

文心一言
文心一言

文心一言是百度开发的AI聊天机器人,通过对话可以生成各种形式的内容。

讯飞写作
讯飞写作

基于讯飞星火大模型的AI写作工具,可以快速生成新闻稿件、品宣文案、工作总结、心得体会等各种文文稿

即梦AI
即梦AI

一站式AI创作平台,免费AI图片和视频生成。

ChatGPT
ChatGPT

最最强大的AI聊天机器人程序,ChatGPT不单是聊天机器人,还能进行撰写邮件、视频脚本、文案、翻译、代码等任务。

相关专题

更多
什么是分布式
什么是分布式

分布式是一种计算和数据处理的方式,将计算任务或数据分散到多个计算机或节点中进行处理。本专题为大家提供分布式相关的文章、下载、课程内容,供大家免费下载体验。

394

2023.08.11

分布式和微服务的区别
分布式和微服务的区别

分布式和微服务的区别在定义和概念、设计思想、粒度和复杂性、服务边界和自治性、技术栈和部署方式等。本专题为大家提供分布式和微服务相关的文章、下载、课程内容,供大家免费下载体验。

246

2023.10.07

什么是中间件
什么是中间件

中间件是一种软件组件,充当不兼容组件之间的桥梁,提供额外服务,例如集成异构系统、提供常用服务、提高应用程序性能,以及简化应用程序开发。想了解更多中间件的相关内容,可以阅读本专题下面的文章。

180

2024.05.11

Golang 中间件开发与微服务架构
Golang 中间件开发与微服务架构

本专题系统讲解 Golang 在微服务架构中的中间件开发,包括日志处理、限流与熔断、认证与授权、服务监控、API 网关设计等常见中间件功能的实现。通过实战项目,帮助开发者理解如何使用 Go 编写高效、可扩展的中间件组件,并在微服务环境中进行灵活部署与管理。

224

2025.12.18

json数据格式
json数据格式

JSON是一种轻量级的数据交换格式。本专题为大家带来json数据格式相关文章,帮助大家解决问题。

442

2023.08.07

json是什么
json是什么

JSON是一种轻量级的数据交换格式,具有简洁、易读、跨平台和语言的特点,JSON数据是通过键值对的方式进行组织,其中键是字符串,值可以是字符串、数值、布尔值、数组、对象或者null,在Web开发、数据交换和配置文件等方面得到广泛应用。本专题为大家提供json相关的文章、下载、课程内容,供大家免费下载体验。

544

2023.08.23

jquery怎么操作json
jquery怎么操作json

操作的方法有:1、“$.parseJSON(jsonString)”2、“$.getJSON(url, data, success)”;3、“$.each(obj, callback)”;4、“$.ajax()”。更多jquery怎么操作json的详细内容,可以访问本专题下面的文章。

322

2023.10.13

go语言处理json数据方法
go语言处理json数据方法

本专题整合了go语言中处理json数据方法,阅读专题下面的文章了解更多详细内容。

81

2025.09.10

pixiv网页版官网登录与阅读指南_pixiv官网直达入口与在线访问方法
pixiv网页版官网登录与阅读指南_pixiv官网直达入口与在线访问方法

本专题系统整理pixiv网页版官网入口及登录访问方式,涵盖官网登录页面直达路径、在线阅读入口及快速进入方法说明,帮助用户高效找到pixiv官方网站,实现便捷、安全的网页端浏览与账号登录体验。

561

2026.02.13

热门下载

更多
网站特效
/
网站源码
/
网站素材
/
前端模板

精品课程

更多
相关推荐
/
热门推荐
/
最新课程
关于我们 免责申明 举报中心 意见反馈 讲师合作 广告合作 最新更新
php中文网:公益在线php培训,帮助PHP学习者快速成长!
关注服务号 技术交流群
PHP中文网订阅号
每天精选资源文章推送

Copyright 2014-2026 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号