利用Java Web技术实现实时通信系统的案例分析

let socket = new WebSocket('ws://localhost:8080/chatroom');
socket.onopen = function(event) {
  console.log('Connection opened.');
};
socket.onmessage = function(event) {
  let message = JSON.parse(event.data);
  console.log('Received message: ' + message.content);
  // 将消息显示在页面上
};
socket.onclose = function(event) {
  console.log('Connection closed.');
};
socket.onerror = function(error) {
  console.error('WebSocket Error: ' + error);
};
function sendMessage(content) {
  let message = { content: content };
  socket.send(JSON.stringify(message));
}

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.EnableAutoConfiguration;
import org.springframework.context.annotation.ComponentScan;
import org.springframework.messaging.handler.annotation.MessageMapping;
import org.springframework.messaging.handler.annotation.SendTo;
import org.springframework.stereotype.Controller;
import org.springframework.web.socket.config.annotation.*;
import java.util.concurrent.CopyOnWriteArraySet;
@Controller
@EnableWebSocketMessageBroker
public class WebSocketConfig implements WebSocketMessageBrokerConfigurer {
    private final CopyOnWriteArraySet<String> clients = new CopyOnWriteArraySet<>();
    @Override
    public void registerStompEndpoints(StompEndpointRegistry registry) {
        registry.addEndpoint("/chatroom").withSockJS(); // 注册WebSocket端点
    }
    @MessageMapping("/message") // 监听客户端发送的消息
    @SendTo("/topic/messages") // 将消息发送到指定的订阅地址
    public String handleMessage(String message) {
        return message; // 这里简化了逻辑，实际中可能需要处理消息内容或格式等
    }
    
    // 注意：以上代码使用了STOMP协议和SockJS，这与纯WebSocket略有不同。为了简化示例，我们假设Spring Boot配置已经设置为使用纯WebSocket。在实际应用中，你可能需要调整配置以适应你的需求。如果你希望使用纯WebSocket而不是STOMP over WebSocket，你可能需要实现自己的`WebSocketHandler`并手动管理WebSocket会话。由于篇幅限制，这里不再展示纯WebSocket的实现细节。但核心思路是相似的：维护一个客户端会话列表，并在收到消息时广播给所有客户端。
}