hy/aslan-server
2
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

用户在线时长锁为58秒

Browse Source
This commit is contained in:
tianfeng 2025-12-25 20:01:29 +08:00
parent ffbef39f05
commit 3089fabac0
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
rc-service/rc-service-other/other-infrastructure/src/main/java/com/red/circle/other/infra/common/user/OnlineStatusCommon.java
View File

@ -69,7 +69,8 @@ public class OnlineStatusCommon {
} }
private void onlineStatusMessage(OnlineStatusUploadCmd cmd) { private void onlineStatusMessage(OnlineStatusUploadCmd cmd) {
if (redisService.setIfAbsent("OLU:" + cmd.getUserId(), 1, TimeUnit.MINUTES)) { //客户端每60秒发送一次, 冗余网络延迟等问题 设置为50秒
if (redisService.setIfAbsent("OLU:" + cmd.getUserId(), 50, TimeUnit.SECONDS)) {
userMqMessageService.onlineStatus(new UserOnlineStatusEvent() userMqMessageService.onlineStatus(new UserOnlineStatusEvent()
.setUserId(cmd.getUserId()) .setUserId(cmd.getUserId())
.setSysOrigin(SysOriginPlatformEnum.valueOf(cmd.getSysOrigin())) .setSysOrigin(SysOriginPlatformEnum.valueOf(cmd.getSysOrigin()))