提交websocket相关代码

dev_2.0.0
liu 1 year ago
parent c6c47b9507
commit 4d85b74c52

@ -27,6 +27,8 @@ import org.springframework.web.bind.annotation.*;
import java.time.LocalDateTime; import java.time.LocalDateTime;
import java.util.LinkedHashSet; import java.util.LinkedHashSet;
import java.util.List;
import java.util.Map;
import java.util.Optional; import java.util.Optional;
@Api(tags = "用户管理") @Api(tags = "用户管理")
@ -43,6 +45,7 @@ public class UserController {
private final UserResourceCheck userResourceCheck; private final UserResourceCheck userResourceCheck;
@Value("${ws.nginx-ip:}") @Value("${ws.nginx-ip:}")
private String wsIp; private String wsIp;
@Value("${ws.nginx-port:}") @Value("${ws.nginx-port:}")
@ -117,5 +120,11 @@ public class UserController {
throw new BusinessException("未获取到ws的nginx地址,请确认配置文件是否配置"); throw new BusinessException("未获取到ws的nginx地址,请确认配置文件是否配置");
} }
@ApiOperation("获取当前在线的用户")
@GetMapping("queryCurrentOnlineUser")
public Map<Object, Object> queryCurrentOnlineUser(){
return redisTemplate.opsForHash().entries(UserTokenConstant.USER_WEBSOCKET_CACHE);
}
} }

Loading…
Cancel
Save