提交 ba402f80 编写于 作者: zhehao.chen's avatar zhehao.chen

fix--压测key缓存删除

上级 05e43d62
流水线 #52019 已失败 于阶段
......@@ -2,6 +2,7 @@ package com.pica.cloud.account.account.server.controller;
import com.pica.cloud.account.account.server.service.TokenService;
import com.pica.cloud.foundation.entity.PicaResponse;
import com.pica.cloud.foundation.service.starter.interceptor.EnabledLoginValidate;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import org.springframework.beans.factory.annotation.Autowired;
......@@ -50,10 +51,11 @@ public class TokenController extends AccountBaseController {
return PicaResponse.toResponse();
}
@EnabledLoginValidate
@ApiIgnore
@GetMapping(value = "/token/remove/examTest")
public PicaResponse removeTokenOfExamTest(@RequestParam("beginValue") Integer beginValue, @RequestParam("endValue") Integer endValue) {
tokenService.removeTokenOfExamTest(beginValue, endValue);
public PicaResponse removeTokenOfExamTest(@RequestParam("beginValue") Integer beginValue, @RequestParam("endValue") Integer endValue, @RequestParam("examId") Integer examId) {
tokenService.removeTokenOfExamTest(beginValue, endValue, examId);
return PicaResponse.toResponse();
}
}
......@@ -16,5 +16,5 @@ public interface TokenService {
/** 删除token */
void removeToken(Long timestamp);
void removeTokenOfExamTest(Integer beginValue, Integer endValue);
void removeTokenOfExamTest(Integer beginValue, Integer endValue, Integer examId);
}
......@@ -135,18 +135,15 @@ public class TokenServiceImpl implements TokenService {
@Async
@Override
public void removeTokenOfExamTest(Integer beginValue, Integer endValue) {
public void removeTokenOfExamTest(Integer beginValue, Integer endValue, Integer examId) {
Integer num = 0;
if (beginValue < 200000000) {
return;
}
if (endValue < beginValue) {
return;
}
StringBuilder builder = new StringBuilder("removeTokenOfExamTest,");
for (int i = beginValue; i < endValue; i++) {
String key1 = String.format("exam.100006.user.%d.using", i);
String key1 = String.format("exam.%d.user.%d.using", examId, i);
String str = redisClient.get(key1);
if (!StringUtils.isEmpty(str)) {
num++;
......@@ -158,7 +155,7 @@ public class TokenServiceImpl implements TokenService {
}
if (num > 0 && (num % 100 == 0 || (i + 1) == endValue)) {
logger.info(builder.toString());
logger.info("removeTokenOfExamTesting:" + i + "," + builder.toString());
builder = new StringBuilder("removeTokenOfExamTest,");
try {
Thread.sleep(1);
......
Markdown 格式
0% or
您添加了 0 到此讨论。请谨慎行事。
先完成此消息的编辑!
想要评论请 注册