in src/frontend/src/main/java/com/alibabacloud/hipstershop/web/AuthTestController.java [30:64]
public RedirectView begin(RedirectAttributes redirectAttributes) {
if (AUTH_BEGIN.get()) {
redirectAttributes.addFlashAttribute("message", "已开启");
redirectAttributes.addFlashAttribute("alertClass", "alert-success");
return new RedirectView("/auth/result");
}
AUTH_ENABLE.set(true);
// 模拟 viewCart() 接口调用
String uri = "http://127.0.0.1:" + port + "/cart";
EXECUTOR_SERVICE.submit((Runnable) () -> {
AccessCountUtil.uriAccess(uri, DUBBO_AUTH_LOCK, DUBBO_AUTH_RESULT_QUEUE);
});
// 模拟各个product的服务调用
for (int i = 0; i < PRODUCT_NUM; i++) {
String uri2 = "http://127.0.0.1:" + port + "/product/" + products[i];
int finalI = i;
EXECUTOR_SERVICE.submit((Runnable) () -> {
AccessCountUtil.uriAccess(uri2, PRODUCT_LOCK[finalI], SPRING_CLOUD_AUTH_RESULT_QUEUE[finalI]);
});
}
AUTH_BEGIN.set(true);
try {
TimeUnit.MILLISECONDS.sleep(500);
} catch (Exception ignore) {
}
redirectAttributes.addFlashAttribute("message", "开启成功,点击按钮可查最新结果");
redirectAttributes.addFlashAttribute("alertClass", "alert-success");
return new RedirectView("/auth/result");
}