public class JasyptUtil {
    // 盐：随机输入即可
    private static final String SALT = "SALT_CODE";

    // 加密
    private static void encrypt() {
        StandardPBEStringEncryptor encryptor = new StandardPBEStringEncryptor();
        encryptor.setPassword(SALT);
        System.out.println("username: " + encryptor.encrypt("root"));
        System.out.println("password: " + encryptor.encrypt("123456"));
    }

    // 解密
    private static void decrypt() {
        StandardPBEStringEncryptor encryptor = new StandardPBEStringEncryptor();
        encryptor.setPassword(SALT);
        System.out.println("username: " + encryptor.decrypt("w1tz6At82gnb4n6BZmgkaQ=="));
        System.out.println("password: " + encryptor.decrypt("UjPD7C8JowwL7vLL80iSdA=="));
    }

    // 根据你输入的盐值计算出来加密的结果
    public static void main(String[] args) {
        // w1tz6At82gnb4n6BZmgkaQ==
        // UjPD7C8JowwL7vLL80iSdA==
        encrypt();

        // root
        // 123456
        decrypt();
    }
}

@Service
public class NikkeCDKeyService extends ServiceImpl<NikkeCdkeyMapper, NikkeCdkey> {

    @Resource
    private NikkeCdkeyMapper nikkeCdkeyMapper;

    // 爬取 cdkey 信息
    @SneakyThrows
    @Transactional(rollbackFor = Exception.class)
    public Result<Object> getCdKeyInfoByCSS() {
        String url = "https://gamewith.jp/nikke/article/show/371014";
        String userAgent = "Mozilla/5.0 (Macintosh; Intel Mac OS X 10_15_7) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/111.0.0.0 Safari/537.36";
        Document doc = Jsoup.connect(url)
                .userAgent(userAgent)
                .get();
        // 按日期分类出来的 cdkey 表格, 一个日期内可能有多个 cdkey
        // 主要是用来获取日期天数
        Elements codeTableElements = doc.select("#article-body > div.code"); // size:12
        // 总 h3 标签数对应的元素集合
        Elements h3Elements = doc.select("#article-body > h3");
        List<NikkeCdkey> nikkeCdkeyList = new ArrayList<>();
        for (int j = 0, codeTableElementsSize = codeTableElements.size(); j < codeTableElementsSize; j++) {
            Element element = codeTableElements.get(j);
            // 实际发布 cdkey 日期的 h3 标签
            String title = h3Elements.get(j).text();
            Elements cdkeyElements = element.select("table > tbody > tr > td:nth-child(1)");
            Elements rewardElements = element.select("table > tbody > tr > td:nth-child(2)");
            // cdkeyElements 与 rewardElements 是一一对应的, 用哪个 size 都一样
            for (int i = 0; i < cdkeyElements.size(); i++) {
                NikkeCdkey nikkeCdkey = new NikkeCdkey();
                String cdkey = cdkeyElements.get(i).text();
                String reward = rewardElements.get(i).text();
                nikkeCdkey.setTitle(title);
                nikkeCdkey.setCdkey(cdkey);
                nikkeCdkey.setReward(reward);
                nikkeCdkeyList.add(nikkeCdkey);
            }
        }
        int i = nikkeCdkeyMapper.saveOrUpdateByCdkey(nikkeCdkeyList);
        return Result.ok("集合大小: " + i);
    }

    // 展示 cdkey 信息
    public Result<Object> showCDKey() {
        List<NikkeCdkey> nikkeCdkeyList = nikkeCdkeyMapper.selectList(null);
        return Result.ok(nikkeCdkeyList);
    }

}

@Component
public class FeignInterceptor implements RequestInterceptor {
    @Override
    public void apply(RequestTemplate requestTemplate) {
        //  微服务远程通过feign互相调用时，获取相关信息
        ServletRequestAttributes attributes = (ServletRequestAttributes) RequestContextHolder.getRequestAttributes();
        HttpServletRequest request = attributes.getRequest();
        //  再设置 header 数据
        requestTemplate.header("userTempId", request.getHeader("userTempId"));
        requestTemplate.header("userId", request.getHeader("userId"));
    }
}

    @Test
    public void testRateLimiterParallel() throws Exception {

        Stopwatch started = Stopwatch.createStarted();
        ExecutorService executorService = Executors.newFixedThreadPool(140);
        RateLimiter rateLimiter = RateLimiter.create(140);//创建限流器 每秒只能通过140个请求
        ArrayList<CompletableFuture> objects = Lists.newArrayList();
        IntStream.range(0, 200).forEach(item -> {
            rateLimiter.acquire();
            System.out.println("等待："+rateLimiter.acquire());
            System.out.println("等待结束"+item);
            //多线程模拟请求
            CompletableFuture<Void> cFeature = CompletableFuture.runAsync(() -> {
                try {
                    TimeUnit.MILLISECONDS.sleep(200);
                    System.out.println("输出" + item + ": 当前秒数：" + LocalDateTime.now().getSecond());
                } catch (Exception e) {
                    e.printStackTrace();
                }
            }, executorService);
            objects.add(cFeature);
        });
        CompletableFuture.allOf(objects.toArray(new CompletableFuture[objects.size()])).join();
        System.out.println("执行完毕");
        started.stop();
        long elapsed = started.elapsed(TimeUnit.MILLISECONDS);
        System.out.println("耗时：" + elapsed);

    }