若依集成WebSocket

导入包：

    <dependency><groupId>io.reactivex.rxjava3</groupId><artifactId>rxjava</artifactId><version>3.1.8</version></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-websocket</artifactId></dependency>

1. security放开websocket的连接
2. 设置拦截器，拦截用户信息

@Component
@EnableWebSocketMessageBroker
@Order(Ordered.HIGHEST_PRECEDENCE+99)
public class wsConfig implements WebSocketMessageBrokerConfigurer {@AutowiredISysUserService sysUserService;private static long HEART_BEAT = 10000;@Overridepublic void registerStompEndpoints(StompEndpointRegistry registry) {registry.addEndpoint("/ws").setAllowedOrigins("*");
//                .setAllowedOriginPatterns("*")//                .withSockJS();}@Overridepublic void configureMessageBroker(MessageBrokerRegistry registry) {ThreadPoolTaskScheduler te = new ThreadPoolTaskScheduler();te.setPoolSize(1);te.setThreadNamePrefix("wss-heartbeat-thread");te.initialize();registry.enableSimpleBroker("/topic","/queue")
//                .setHeartbeatValue().setHeartbeatValue(new long[]{HEART_BEAT,HEART_BEAT}).setTaskScheduler(te);}@Overridepublic void configureClientInboundChannel(ChannelRegistration registration) {ChannelInterceptor interceptor = new ChannelInterceptor(){@Overridepublic Message<?> preSend(Message<?> message, MessageChannel channel) {StompHeaderAccessor accessor = MessageHeaderAccessor.getAccessor(message, StompHeaderAccessor.class);if(accessor == null || accessor.getCommand() == null){return null;}if (StompCommand.CONNECT.equals(accessor.getCommand())){// 处理连接的请求String token = accessor.getFirstNativeHeader("Authorization");SysUser user = sysUserService.selectUserById(1L);LoginUser loginUser = new LoginUser();BeanUtils.copyProperties(user,loginUser);UsernamePasswordAuthenticationToken principal = new UsernamePasswordAuthenticationToken(loginUser, null, Collections.EMPTY_LIST);//                    UserContextHolder.set(user);accessor.setUser(principal);}else{// 其他的请求，token只用设置一次
//                    SysUser user = sysUserService.selectUserById(1L);
//                    UserContextHolder.set(user);System.out.println("other请求");Authentication authentication = (Authentication) accessor.getUser();LoginUser loginUser = (LoginUser) authentication.getPrincipal();System.out.println("loginUser111 = " + loginUser);}return message;}};registration.interceptors(interceptor);}
}

3. 请求获取用户信息

   @MessageMapping("/send")public void sendMessage(Message<?> message, com.cj.project.ws.model.Message messageBody){System.out.println("message = " + message);StompHeaderAccessor accessor = MessageHeaderAccessor.getAccessor(message, StompHeaderAccessor.class);Principal principal = accessor.getUser();Authentication authentication = (Authentication) principal;Object user = authentication.getPrincipal();System.out.println("user = " + user);System.out.println(user instanceof LoginUser);if (user instanceof LoginUser){LoginUser loginUser = (LoginUser) user;System.out.println("loginUser = " + loginUser);}Object payload = message.getPayload();System.out.println("payload = " + payload);System.out.println("payload = " + new String((byte[]) payload));System.out.println("messageBody = " + messageBody);String messageBodyTo = messageBody.getTo();System.out.println("messageBodyTo = " + messageBodyTo);this.pushMessage();}

心跳推送，send到/heartbeat

引用：https://juejin.cn/post/7345310754470821922
引用：https://blog.csdn.net/print_helloword/article/details/142816204
https://blog.csdn.net/2301_80817413/article/details/139561814
https://blog.csdn.net/qq_45032714/article/details/112261976