如何在Java中实现WebSocket高效处理数据帧：完整指南与实战案例

import javax.websocket.*;
import javax.websocket.server.ServerEndpoint;
import java.io.IOException;
import java.nio.ByteBuffer;

@ServerEndpoint("/websocket")
public class WebSocketServer {

    @OnOpen
    public void onOpen(Session session) {
        System.out.println("Client connected: " + session.getId());
    }

    @OnMessage
    public void onMessage(String message, Session session) {
        System.out.println("Received message from client " + session.getId() + ": " + message);
        // 处理接收到的数据帧
        processDataFrame(message);
    }

    @OnClose
    public void onClose(Session session) {
        System.out.println("Client disconnected: " + session.getId());
    }

    @OnError
    public void onError(Session session, Throwable throwable) {
        System.out.println("Error occurred for client " + session.getId() + ": " + throwable.getMessage());
    }

    private void processDataFrame(String message) {
        // 将接收到的消息转换为字节数组
        byte[] payload = message.getBytes();

        // 创建一个ByteBuffer来表示WebSocket数据帧
        ByteBuffer buffer = ByteBuffer.allocate(payload.length + 2);
        buffer.putShort((short) payload.length); // 设置数据帧的长度
        buffer.put(payload); // 添加数据帧的有效载荷

        // 发送处理后的数据帧回客户端
        session.getAsyncRemote().sendBinary(buffer);
    }
}