Java实现WebSocket服务

后端代码：

@Component
@ServerEndpoint(value = "/websocket")
public class EndpointWebSocket extends Endpoint {

    SparkDeskService sparkDeskService = new SparkDeskService();
    ErnieBotService ernieBotService = new ErnieBotService();
    QianWenService qianWenService = new QianWenService();

    @Override
    public void onOpen(Session session, EndpointConfig endpointConfig) {

        session.addMessageHandler(new MessageHandler.Whole<String>() {
            @Override
            public void onMessage(String message) {
                // 处理前端发送的消息
                System.out.println("消息内容" + message)
                session.getBasicRemote().sendText("发送消息");
            }
        });
    }

    @Override
    public void onError(Session session, Throwable throwable) {
        throwable.printStackTrace();
    }

前端代码：

const socket = new WebSocket('ws://localhost:5051/websocket');
socket.onopen = function() {
  console.log('WebSocket connection opened');
  socket.send('发送的信息');
};

socket.onmessage = function(event) {
	// 服务器端推送的消息
  console.log(event.data);
};

socket.onclose = function() {
  console.log('WebSocket connection closed');
};