Python代码中的WebSocket 502错误故障排除

0 投票
0 回答
32 浏览
提问于 2025-04-11 22:56

我正在做一个叫“Pixels”的游戏。我的目标是编程监控游戏中树木重新生成的时机。一个开发者给了我一些Java代码来实现这个功能,我尝试把它转换成Python。现在我能成功获取我的会话ID、房间ID和其他相关的服务器信息。但是,当我尝试建立WebSocket连接时,总是收到一个502错误。我不太确定这是什么原因导致的。

public void openWebSocketAndProcessMessages(String server, String roomId, String sessionId) {
    ReactorNettyWebSocketClient client = new ReactorNettyWebSocketClient();
    client.setMaxFramePayloadLength(2621440);

    URI uri = URI.create(
        String.format("wss://pixels-server.pixels.xyz/%s/%s?sessionId=%s", server, roomId,
            sessionId));
    AtomicBoolean firstMessageReceived = new AtomicBoolean(false);
    // Capture the start time of the session
    Instant sessionStart = Instant.now();

    client.execute(uri, session ->
        session.receive()
            .doOnNext(message -> {
              // Check if the first message has been received and send a confirmation message
              if (firstMessageReceived.compareAndSet(false, true)) {
                System.out.println("First message received, sending confirmation...");
                byte[] confirmationBytes = {'\n'}; // Newline character as the confirmation message
                session.send(
                        Mono.just(session.binaryMessage(factory -> factory.wrap(confirmationBytes))))
                    .subscribe();
              }

              // Convert the received WebSocketMessage to a byte array (requires proper handling based on actual message type and content)
              ByteBuffer buffer = message.getPayload().asByteBuffer();
              byte[] messageBytes = new byte[buffer.remaining()];
              buffer.get(messageBytes);

                String encodedString = new String(Base64.getDecoder().decode(Base64.getEncoder().encodeToString(messageBytes)));
}

这是我在建立WebSocket连接时遇到502错误的Python代码:

async def connect_websocket(server, roomid, sessionid):
    uri = f"wss://pixels-server.pixels.xyz/{server}/{roomid}?sessionId={sessionid}"
    print(uri)
    headers = {
        "Host": "pixels-server.pixels.xyz",
        "Connection": "Upgrade",
        "Upgrade": "websocket",
        "Origin": "https://play.pixels.xyz",
        "Sec-WebSocket-Version": "13",
        "Sec-WebSocket-Key": "lAVNhobAP9AaShcdp/BegA==",
        "Sec-WebSocket-Extensions": "permessage-deflate; client_max_window_bits",
        "User-Agent": "Mozilla/5.0 (Linux; Android 10; K) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/123.0.0.0 Mobile Safari/537.36",
        "Pragma": "no-cache",
        "Cache-Control": "no-cache",
        "Accept-Encoding": "gzip, deflate, br, zstd",
        "Accept-Language": "en-GB,en-US;q=0.9,en;q=0.8",
        "Cookie": "intercom-id-grzhbhyr=e4b3442d-7fbd-4660-b003-9796901fb523; intercom-device-id-grzhbhyr=48118693-0661-4e43-b3b9-e140ae8a692d; _ga=GA1.1.523002009.1710326782; _ga_QGP383C71B=GS1.1.1711873973.8.1.1711874126.0.0.0"
    }

    async with websockets.connect(uri, extra_headers=headers) as websocket:
        while True:
            message = await websocket.recv()
            print(f"Received message: {message}
")

我不确定在建立WebSocket连接时是否有任何特定的身份验证要求我可能遗漏了。

0 个回答

暂无回答

撰写回答