一篇文章带你使用SpringBoot基于WebSocket的在线群聊实现

      org.webjars
      sockjs-client
      1.1.2
    
    
      org.webjars
      jquery
      3.4.1
    
    
      org.webjars
      stomp-websocket
      2.3.3
    
    
      org.webjars
      webjars-locator-core
    

@Configuration
//开启使用STOMP协议来传输基于代理的消息，Broker就是代理的意思
@EnableWebSocketMessageBroker
public class WebSocketConfig implements WebSocketMessageBrokerConfigurer {
  /**
   * 配置消息代理
   * @param registry
   */
  @Override
  public void configureMessageBroker(MessageBrokerRegistry registry) {
    //定义消息代理的前缀
    registry.enableSimpleBroker("/topic");
    //配置一个或者多个前缀，过滤出需要代理方法处理的消息
    registry.setApplicationDestinationPrefixes("/app");
  }

  /**
   * 注册STOMP协议的节点，并指定映射的URL
   * @param registry
   */
  @Override
  public void registerStompEndpoints(StompEndpointRegistry registry) {
    //注册STOMP协议节点，同时指定使用 SockJS 协议
    registry.addEndpoint("/chat").withSockJS();
  }
}

public class Message {
  private String name;
  private String content;

  public String getName() {
    return name;
  }

  public void setName(String name) {
    this.name = name;
  }

  public String getContent() {
    return content;
  }

  public void setContent(String content) {
    this.cOntent= content;
  }
}

@Controller
public class GreetingController {
  /**
   * 这个方法用来处理浏览器发送来的消息，对其进行处理
   * @param message
   * @return
   */
  //@MessageMapping 类似 @RequestMapping
  @MessageMapping("/hello")
  //处理完之后对其进行转发到 SendTo 中的路径
  @SendTo("/topic/greetings")
  public Message greeting(Message message) {
    return message;
  }
}

@Controller
public class GreetingController {
  @Autowired
  SimpMessagingTemplate simpMessagingTemplate;
  @MessageMapping("/hello")
  public void greeting(Message message) {
    simpMessagingTemplate.convertAndSend("/topic/greetings", message);
  }
}

  
  
  
  
  




  

    
请输入用户名
    

  
  

    

    

  


  

    

      
请输入聊天内容
      

      

    
  
  
群聊进行中...