返利公众号 JSSDK 安全签名：JS-SDK ticket 缓存雪崩与容灾切换方案-程序员充电站

返利公众号 JSSDK 安全签名：JS-SDK ticket 缓存雪崩与容灾切换方案

大家好，我是微赚淘客系统3.0 的研发者省赚客！

在返利公众号 H5 页面中，需调用微信 JS-SDK 实现“分享领券”、“复制口令”等功能。其核心依赖jsapi_ticket签名机制，该票据有效期 7200 秒，且微信接口调用频次受限（10000 次/天）。若多节点同时缓存失效，将引发缓存雪崩，导致大量请求穿透至微信接口，触发限流甚至签名失败。我们通过本地缓存 + Redis 分布式锁 + 多级降级策略构建高可用签名服务。

一、标准签名流程与风险点

后端调用微信/cgi-bin/ticket/getticket?type=jsapi获取jsapi_ticket；
缓存票据（通常 Redis）；
前端请求/sign?url=xxx，后端用ticket + noncestr + timestamp + url生成 SHA1 签名；
前端注入配置，调用 JS-SDK。

风险：

所有实例在t=7200s同时失效 → 集中请求微信 → 限流；
Redis 故障 → 无法获取票据 → 全站 JS 功能瘫痪。

二、双层缓存 + 提前刷新机制

packagejuwatech.cn.wx.jssdk;@ServicepublicclassJsSdkTicketService{privatestaticfinalStringTICKET_CACHE_KEY="wx:jsapi_ticket";privatestaticfinallongEXPIRE_SECONDS=7200;privatestaticfinallongREFRESH_WINDOW=600;// 提前10分钟刷新privatefinalLoadingCache<String,String>localCache=Caffeine.newBuilder().expireAfterWrite(EXPIRE_SECONDS-REFRESH_WINDOW,TimeUnit.SECONDS).build(key->fetchTicketFromRemote());publicStringgetValidTicket(){// 1. 优先读本地缓存（避免 Redis 网络开销）Stringticket=localCache.getIfPresent("jsapi");if(ticket!=null){returnticket;}// 2. 本地未命中，尝试从 Redis 获取ticket=(String)redisTemplate.opsForValue().get(TICKET_CACHE_KEY);if(ticket!=null){localCache.put("jsapi",ticket);returnticket;}// 3. 双缓存均失效，抢分布式锁returnrefreshTicketWithLock();}privateStringrefreshTicketWithLock(){StringlockKey="lock:wx:jsapi_ticket";StringlockValue=UUID.randomUUID().toString();try{// 尝试获取 Redis 分布式锁（3秒自动释放）Booleanlocked=redisTemplate.opsForValue().setIfAbsent(lockKey,lockValue,Duration.ofSeconds(3));if(Boolean.TRUE.equals(locked)){// 成功获得锁，调用微信接口StringnewTicket=fetchTicketFromWxApi();// 同时写入 Redis 和本地缓存redisTemplate.opsForValue().set(TICKET_CACHE_KEY,newTicket,Duration.ofSeconds(EXPIRE_SECONDS-100));localCache.put("jsapi",newTicket);returnnewTicket;}else{// 未获得锁，短暂等待后重试本地缓存（避免惊群）Thread.sleep(50);returnlocalCache.getIfPresent("jsapi")?:(String)redisTemplate.opsForValue().get(TICKET_CACHE_KEY);}}catch(Exceptione){log.error("Failed to refresh jsapi_ticket",e);// 降级：尝试使用即将过期的旧票据（见下文）returndegradeToExpiredTicket();}finally{// 释放锁（Lua 脚本保证原子性）releaseDistributedLock(lockKey,lockValue);}}}

三、Redis 分布式锁释放（Lua 脚本）

privatevoidreleaseDistributedLock(StringlockKey,StringlockValue){Stringscript="if redis.call('get', KEYS[1]) == ARGV[1] then return redis.call('del', KEYS[1]) else return 0 end";redisTemplate.execute(newDefaultRedisScript<>(script,Long.class),Collections.singletonList(lockKey),lockValue);}

四、容灾降级：使用临近过期票据

即使微信接口不可用，只要票据未完全过期（如剩余 5 分钟），仍可继续使用：

privateStringdegradeToExpiredTicket(){// 从 Redis 中强制读取（忽略 TTL）Objectticket=redisTemplate.execute((RedisCallback<String>)connection->{byte[]keyBytes=redisTemplate.getKeySerializer().serialize(TICKET_CACHE_KEY);return(String)redisTemplate.getValueSerializer().deserialize(connection.get(keyBytes));});if(ticket!=null){log.warn("Using expired jsapi_ticket in degrade mode");returnticket;}thrownewRuntimeException("No valid or expired ticket available");}

五、签名接口实现

@GetMapping("/jssdk/sign")@ResponseBodypublicMap<String,Object>sign(@RequestParamStringurl){Stringticket=jsSdkTicketService.getValidTicket();StringnonceStr=RandomStringUtils.randomAlphanumeric(16);longtimestamp=System.currentTimeMillis()/1000;Stringsignature=DigestUtils.sha1Hex("jsapi_ticket="+ticket+"&noncestr="+nonceStr+"&timestamp="+timestamp+"&url="+url);Map<String,Object>result=newHashMap<>();result.put("appId","your_wechat_appid");result.put("timestamp",timestamp);result.put("nonceStr",nonceStr);result.put("signature",signature);returnresult;}