소스 검색

设置webSoucket的id

Administrator 4 년 전
부모
커밋
c202366739

+ 2 - 0
src/main/java/com/goafanti/core/websocket/SystemWebSocketHandler.java

@@ -4,6 +4,7 @@ import java.io.IOException;
 import java.util.Map;
 import java.util.Map;
 import java.util.concurrent.ConcurrentHashMap;
 import java.util.concurrent.ConcurrentHashMap;
 
 
+import org.apache.shiro.SecurityUtils;
 import org.springframework.stereotype.Service;
 import org.springframework.stereotype.Service;
 import org.springframework.web.socket.CloseStatus;
 import org.springframework.web.socket.CloseStatus;
 import org.springframework.web.socket.TextMessage;
 import org.springframework.web.socket.TextMessage;
@@ -12,6 +13,7 @@ import org.springframework.web.socket.WebSocketMessage;
 import org.springframework.web.socket.WebSocketSession;
 import org.springframework.web.socket.WebSocketSession;
 
 
 import com.goafanti.common.utils.LoggerUtils;
 import com.goafanti.common.utils.LoggerUtils;
+import com.goafanti.core.shiro.token.TokenManager;
 
 
 @Service
 @Service
 public class SystemWebSocketHandler implements WebSocketHandler {
 public class SystemWebSocketHandler implements WebSocketHandler {

+ 1 - 3
src/main/java/com/goafanti/core/websocket/WebSocketConfig.java

@@ -20,9 +20,7 @@ public class WebSocketConfig extends WebMvcConfigurerAdapter implements WebSocke
 
 
 	@Override
 	@Override
 	public void registerWebSocketHandlers(WebSocketHandlerRegistry registry) {
 	public void registerWebSocketHandlers(WebSocketHandlerRegistry registry) {
-		registry.addHandler(systemWebSocketHandler, "/webSocketServer")
-		.addInterceptors(new WebSocketHandshakeInterceptor())
-				.setAllowedOrigins("*");
+		registry.addHandler(systemWebSocketHandler, "/webSocketServer").addInterceptors(new WebSocketHandshakeInterceptor()).setAllowedOrigins("*");
 //		registry.addHandler(systemWebSocketHandler, "/sockjs/webSocketServer").setAllowedOrigins("*")
 //		registry.addHandler(systemWebSocketHandler, "/sockjs/webSocketServer").setAllowedOrigins("*")
 //				.addInterceptors(new WebSocketHandshakeInterceptor()).withSockJS();
 //				.addInterceptors(new WebSocketHandshakeInterceptor()).withSockJS();
 	}
 	}

+ 2 - 2
src/main/resources/spring/spring-websocket.xml

@@ -17,9 +17,9 @@
         <!--指定 webSocket 地址-->
         <!--指定 webSocket 地址-->
         <websocket:mapping path="/webSocketServer" handler="systemWebSocketHandler"/>
         <websocket:mapping path="/webSocketServer" handler="systemWebSocketHandler"/>
         <!-- 过滤器 -->
         <!-- 过滤器 -->
-        <!-- <websocket:handshake-interceptors>
+         <websocket:handshake-interceptors>
         	<bean class="com.goafanti.core.websocket.WebSocketHandshakeInterceptor"/>
         	<bean class="com.goafanti.core.websocket.WebSocketHandshakeInterceptor"/>
-        </websocket:handshake-interceptors> --> 
+        </websocket:handshake-interceptors>  
     </websocket:handlers>
     </websocket:handlers>
  
  
 </beans>
 </beans>