fix:CODE 使用自增方式

This commit is contained in:
wangchao
2023-07-03 23:08:23 +08:00
parent 41660e189b
commit f25e535c04

View File

@@ -2,7 +2,6 @@ package com.abin.mallchat.custom.user.service.impl;
import cn.hutool.core.collection.CollectionUtil; import cn.hutool.core.collection.CollectionUtil;
import cn.hutool.core.util.ObjectUtil; import cn.hutool.core.util.ObjectUtil;
import cn.hutool.core.util.RandomUtil;
import cn.hutool.json.JSONUtil; import cn.hutool.json.JSONUtil;
import com.abin.mallchat.common.common.annotation.FrequencyControl; import com.abin.mallchat.common.common.annotation.FrequencyControl;
import com.abin.mallchat.common.common.config.ThreadPoolConfig; import com.abin.mallchat.common.common.config.ThreadPoolConfig;
@@ -117,7 +116,7 @@ public class WebSocketServiceImpl implements WebSocketService {
*/ */
private Integer generateLoginCode(Channel channel) { private Integer generateLoginCode(Channel channel) {
do { do {
CODE.set(RandomUtil.randomInt(Integer.MAX_VALUE)); CODE.getAndIncrement();
} while (WAIT_LOGIN_MAP.asMap().containsKey(CODE.get()) } while (WAIT_LOGIN_MAP.asMap().containsKey(CODE.get())
|| Objects.isNull(WAIT_LOGIN_MAP.get(CODE.get(), c -> channel))); || Objects.isNull(WAIT_LOGIN_MAP.get(CODE.get(), c -> channel)));
return CODE.get(); return CODE.get();