java websocket封装

### 关于Java WebSocket封装的方法和库

#### 使用`Java-WebSocket`库进行封装

为了简化使用Java语言和WebSocket技术建立客户端与服务端长连接的操作，可以采用`Java-WebSocket`这一开源框架[^2]。下面是一个简单的例子来展示如何创建一个WebSocket服务器：

import org.java_websocket.WebSocket;
import org.java_websocket.handshake.ClientHandshake;
import org.java_websocket.server.WebSocketServer;

import java.net.InetSocketAddress;
import java.util.Collections;
import java.util.HashSet;
import java.util.Set;

public class SimpleWebSocketServer extends WebSocketServer {
    private static Set<WebSocket> connections = Collections.synchronizedSet(new HashSet<>());

    public SimpleWebSocketServer(InetSocketAddress address) {
        super(address);
    }

    @Override
    public void onOpen(WebSocket conn, ClientHandshake handshake) {
        connections.add(conn);
        System.out.println("New connection from " + conn.getRemoteSocketAddress());
    }

    @Override
    public void onClose(WebSocket conn, int code, String reason, boolean remote) {
        connections.remove(conn);
        System.out.println("Closed connection to " + conn.getRemoteSocketAddress());
    }

    @Override
    public void onMessage(WebSocket conn, String message) {
        System.out.println("Received message from " + conn.getRemoteSocketAddress() + ": " + message);

        // Echo the received message back to all connected clients.
        synchronized (connections) {
            for (WebSocket client : connections) {
                if (client != conn) { // Do not echo message sender itself
                    client.send(message);
                }
            }
        }
    }

    @Override
    public void onError(WebSocket conn, Exception ex) {
        System.err.println("An error occurred:");
        ex.printStackTrace();
    }

    @Override
    public void onStart() {
        System.out.println("Server started!");
    }
}

这段代码定义了一个继承自`org.java_websocket.server.WebSocketServer`类的新类`SimpleWebSocketServer`，实现了基本的消息接收、发送以及错误处理逻辑。

对于Android应用中的具体实现，则可以通过如下方式启动线程并实例化WebSocket对象来进行通信操作[^1]：

// 假设MyWebSocketService已经包含了必要的WebSocket配置和服务方法
webSocketThread = new MyWebSocketService.WebSocketThread();
webSocketThread.start();

以上展示了利用特定的`Java-WebSocket`库完成WebSocket功能的一种途径，在实际开发过程中可根据需求调整相应参数设置以满足不同场景下的网络交互要求。