Catsxp Forum

代码： 全选

import asyncio
import websockets

async def handler(websocket):
    print("Client connected")
    try:
        async for message in websocket:
            print("Received:", message)
            await websocket.send(f"Echo: {message}")
    except websockets.ConnectionClosed:
        print("Client disconnected")

async def main():
    async with websockets.serve(handler, "0.0.0.0", 4455):
        print("WebSocket server running on ws://localhost:4455")
        await asyncio.Future()  # run forever

asyncio.run(main())

代码： 全选

import asyncio

async def debug_server(reader, writer):
    peer = writer.get_extra_info("peername")
    print("Connection from:", peer)

    data = await reader.read(1024)
    print("RAW BYTES:", data)
    if data:
        print(data.decode(errors="replace"))
    else:
        print("No data received")

    writer.close()
    await writer.wait_closed()

async def main():
    server = await asyncio.start_server(debug_server, "0.0.0.0", 4455)
    print("Listening on 4455")
    async with server:
        await server.serve_forever()

asyncio.run(main())

代码： 全选

598: URL_REQUEST
ws://localhost:4455/
Start Time: 2026-01-30 17:56:37.589

t=3004 [st=  0] +REQUEST_ALIVE  [dt=314]
                 --> priority = "LOWEST"
                 --> traffic_annotation = 17188928
                 --> url = "ws://localhost:4455/"
t=3004 [st=  0]    NETWORK_DELEGATE_BEFORE_URL_REQUEST  [dt=1]
t=3005 [st=  1]    TRANSPORT_SECURITY_STATE_SHOULD_UPGRADE_TO_SSL
                   --> get_sts_state_result = false
                   --> host = "localhost"
                   --> host_found_in_hsts_bypass_list = false
                   --> should_upgrade_to_ssl = false
t=3005 [st=  1]   +URL_REQUEST_START_JOB  [dt=313]
                   --> initiator = "http://www.websocket-test.com"
                   --> load_flags = 18 (BYPASS_CACHE | DISABLE_CACHE)
                   --> method = "GET"
                   --> network_isolation_key = "http://websocket-test.com http://websocket-test.com"
                   --> request_type = "other"
                   --> site_for_cookies = "SiteForCookies: {site=http://websocket-test.com; schemefully_same=true}"
                   --> url = "ws://localhost:4455/"
t=3005 [st=  1]      FIRST_PARTY_SETS_METADATA  [dt=0]
                     --> cache_filter = "none"
                     --> frame_entry = "none"
                     --> top_frame_primary = "none"
t=3005 [st=  1]      COMPUTED_PRIVACY_MODE
                     --> privacy_mode = "disabled"
t=3005 [st=  1]      NETWORK_DELEGATE_BEFORE_START_TRANSACTION  [dt=0]
t=3005 [st=  1]      HTTP_CACHE_GET_BACKEND  [dt=0]
t=3005 [st=  1]     +HTTP_STREAM_REQUEST  [dt=312]
t=3005 [st=  1]        HTTP_STREAM_JOB_CONTROLLER_BOUND
                       --> source_dependency = 599 (HTTP_STREAM_JOB_CONTROLLER)
t=3317 [st=313]        HTTP_STREAM_REQUEST_BOUND_TO_JOB
                       --> source_dependency = 600 (HTTP_STREAM_JOB)
t=3317 [st=313]     -HTTP_STREAM_REQUEST
t=3317 [st=313]      URL_REQUEST_DELEGATE_CONNECTED  [dt=1]
                     --> net_error = -385 (ERR_BLOCKED_BY_LOCAL_NETWORK_ACCESS_CHECKS)
t=3318 [st=314]   -URL_REQUEST_START_JOB
                   --> net_error = -385 (ERR_BLOCKED_BY_LOCAL_NETWORK_ACCESS_CHECKS)
t=3318 [st=314]    URL_REQUEST_DELEGATE_RESPONSE_STARTED  [dt=0]
t=3318 [st=314] -REQUEST_ALIVE
                 --> net_error = -385 (ERR_BLOCKED_BY_LOCAL_NETWORK_ACCESS_CHECKS)