基于Spark Framework WebSocket，如何通过IP手动创建Jetty会话？

既然Spark Framework底层依赖Jetty实现WebSocket，要手动发起P2P连接，我们得直接调用Jetty的原生WebSocket客户端API——Spark的上层封装没法直接做这件事。下面是具体步骤和代码示例：

1. 添加Jetty WebSocket客户端依赖 #

如果用Maven，在pom.xml里加上：

<dependency>
    <groupId>org.eclipse.jetty.websocket</groupId>
    <artifactId>jetty-websocket-client</artifactId>
    <version>你的Jetty版本（要和Spark依赖的Jetty版本一致）</version>
</dependency>

注意：一定要匹配Spark内置的Jetty版本，避免依赖冲突。可以查Spark的pom或者依赖树确认版本号。

2. 定义Jetty WebSocket客户端端点 #

创建一个类继承WebSocketAdapter，处理连接、消息接收等事件：

import org.eclipse.jetty.websocket.api.Session;
import org.eclipse.jetty.websocket.api.WebSocketAdapter;

public class PeerWebSocketClient extends WebSocketAdapter {
    @Override
    public void onWebSocketConnect(Session session) {
        super.onWebSocketConnect(session);
        System.out.println("成功连接到对等方: " + session.getRemoteAddress());
        // 连接成功后可以发送初始消息
        try {
            session.getRemote().sendString("Hello from peer client!");
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

    @Override
    public void onWebSocketText(String message) {
        super.onWebSocketText(message);
        System.out.println("收到对等方消息: " + message);
    }

    @Override
    public void onWebSocketError(Throwable cause) {
        super.onWebSocketError(cause);
        cause.printStackTrace();
    }
}

3. 手动发起连接到对等方IP #

在你的代码里，创建Jetty客户端实例，指定目标IP、端口和Spark的WebSocket路径：

import org.eclipse.jetty.websocket.client.ClientUpgradeRequest;
import org.eclipse.jetty.websocket.client.WebSocketClient;

import java.net.URI;

public class PeerConnectionInitiator {
    public static void main(String[] args) throws Exception {
        // 对等方的IP和端口，比如192.168.1.100:4567，路径要和Spark服务器端的WebSocket路径一致
        String peerUri = "ws://192.168.1.100:4567/p2p-websocket";
        
        WebSocketClient client = new WebSocketClient();
        try {
            client.start();
            // 创建客户端端点实例
            PeerWebSocketClient clientEndpoint = new PeerWebSocketClient();
            // 发起连接请求
            ClientUpgradeRequest request = new ClientUpgradeRequest();
            client.connect(clientEndpoint, new URI(peerUri), request);
            
            // 保持客户端运行（实际项目里可以用线程阻塞或者其他方式）
            Thread.sleep(Long.MAX_VALUE);
        } finally {
            client.stop();
        }
    }
}

4. 确保Spark服务器端能接受连接 #

你的Spark WebSocket服务器端代码要正常监听，比如：

import static spark.Spark.*;

public class SparkP2PServer {
    public static void main(String[] args) {
        port(4567);
        webSocket("/p2p-websocket", PeerWebSocketServer.class);
        init();
    }
}

// 服务器端WebSocket端点
import spark.websockets.WebSocket;
import spark.websockets.WebSocketHandler;

public class PeerWebSocketServer implements WebSocketHandler {
    @Override
    public void handle(WebSocket webSocket) {
        webSocket.onMessage(message -> {
            System.out.println("收到客户端消息: " + message);
            webSocket.send("收到你的消息啦！");
        });
        webSocket.onClose((code, reason) -> {
            System.out.println("连接关闭: " + reason);
        });
    }
}

关键注意事项 #

• 版本一致性：Jetty客户端版本必须和Spark依赖的Jetty版本完全匹配，否则会出现类加载异常。
• 网络可达性：确保对等方的IP是公网可达的（或者在同一局域网内），并且端口没有被防火墙/路由器拦截。如果是公网P2P，可能还需要处理NAT穿透（比如STUN/TURN），但这超出了手动创建会话的范围。
• 会话管理：如果需要维护多个对等连接，要自己管理客户端会话实例，避免资源泄漏。

内容的提问来源于stack exchange，提问作者Jakub A.