update 聊天室更新用户头像

nb-auth/src/main/java/com/nb/auth/sa/SaConfig.java

@@ -27,7 +27,6 @@ import java.util.regex.Pattern;
 @AllArgsConstructor
 public class SaConfig {
     private final SaTokenDaoRedisJackson saTokenDaoRedisJackson;
-    private final DefaultSaTokenListener defaultSaTokenListener;
     @PostConstruct
     public void init(){
         SaStrategy.me.hasElement=(list,element)->{

nb-auth/src/main/java/com/nb/auth/sa/DefaultSaTokenListener.java → nb-service/web-service/src/main/java/com/nb/web/service/bus/listener/DefaultSaTokenListener.java

@@ -1,4 +1,4 @@
-package com.nb.auth.sa;
+package com.nb.web.service.bus.listener;
 
 import cn.dev33.satoken.config.SaTokenConfig;
 import cn.dev33.satoken.listener.SaTokenListener;
@@ -11,6 +11,9 @@ import com.nb.common.queue.delay.message.DelayMessageProperties;
 import lombok.AllArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.stereotype.Component;
+import org.tio.core.Tio;
+import org.tio.websocket.starter.TioWebSocketServerBootstrap;
+
 import java.util.concurrent.TimeUnit;
 
 /**
@@ -26,6 +29,7 @@ import java.util.concurrent.TimeUnit;
 public class DefaultSaTokenListener implements SaTokenListener {
     private final DelayMessageManager delayMessageManager;
     private final SaTokenConfig saTokenConfig;
+    private final TioWebSocketServerBootstrap bootstrap;
 
 
     @Override
@@ -37,12 +41,12 @@ public class DefaultSaTokenListener implements SaTokenListener {
 
     @Override
     public void doLogout(String loginType, Object loginId, String tokenValue) {
-
+        Tio.closeToken(bootstrap.getServerTioConfig(),tokenValue,"退出登录");
     }
 
     @Override
     public void doKickout(String loginType, Object loginId, String tokenValue) {
-
+        Tio.closeToken(bootstrap.getServerTioConfig(),tokenValue,"被踢下线");
     }
 
     @Override