Java Websocket开发实践：解决常见错误与性能优化

@OnOpen
public void onOpen(Session session) {
    // 设置心跳定时任务
    Timer timer = new Timer();
    timer.scheduleAtFixedRate(new TimerTask() {
        @Override
        public void run() {
            session.getAsyncRemote().sendText("Ping");
        }
    }, 0, 5000);
}

@OnMessage
public void onMessage(String message, Session session) {
    if ("Ping".equals(message)) {
        // 如果收到心跳包，回复一个Pong包
        session.getAsyncRemote().sendText("Pong");
    } else {
        // 处理其他业务逻辑
    }
}

@OnMessage
public void onMessage(String message, Session session) {
    ByteBuffer byteBuffer = ByteBuffer.allocate(1024);  // 设置缓冲区大小为1KB
    if (byteBuffer.remaining() < message.length()) {
        // 缓冲区不足，进行处理
        // ...
    } else {
        byteBuffer.put(message.getBytes());
    }
    
    // 处理其他业务逻辑
}

@OnMessage
public void onMessage(String message, Session session) {
    executorService.submit(new Task(session, message));
}

private class Task implements Runnable {
    private Session session;
    private String message;
    
    public Task(Session session, String message) {
        this.session = session;
        this.message = message;
    }
    
    @Override
    public void run() {
        // 处理业务逻辑
    }
}

@OnMessage
public void onMessage(String message, Session session) {
    byte[] compressedData = compress(message);  // 使用gzip算法压缩数据
    session.getAsyncRemote().sendBinary(ByteBuffer.wrap(compressedData));
}

private byte[] compress(String data) {
    try {
        ByteArrayOutputStream baos = new ByteArrayOutputStream();
        GZIPOutputStream gzipOutputStream = new GZIPOutputStream(baos);
        gzipOutputStream.write(data.getBytes("UTF-8"));
        gzipOutputStream.close();
        return baos.toByteArray();
    } catch (IOException e) {
        e.printStackTrace();
        return null;
    }
}