Socket.D

sd:tcp://19.10.2.3:9812/path?u=noear&t=1234
sd:udp://19.10.2.3:9812/path?u=noear&t=1234
sd:ws://19.10.2.3:1023/path?u=noear&t=1234

//udp only <2k
[len:int][flag:int][sid:str(<64)][\n][event:str(<512)][\n][metaString:str(<4k)][\n][data:byte(<16m)]

//The reply acceptor registration in the channel is removed after the reply is completed

pip install socketD

python setup.py build
python setup.py install

cd \python\socketd
pip install .

async def application():
    # 服务端
    server: Server = SocketD.create_server(ServerConfig("ws").set_port(9999))
    server_session: WebSocketServer = await server.config(idGenerator).listen(
        SimpleListenerTest()).start()
    
    # 客户端
    client_session: Session = await SocketD.create_client("ws://127.0.0.1:9999") \
        .config(idGenerator).open()

    start_time = time.monotonic()
    for _ in range(100):
        await client_session.send("demo", StringEntity("test.png"))
        await client_session.send_and_request("demo", StringEntity("test.png"), 100)
        await client_session.send_and_subscribe("demo", StringEntity("test.png"), send_and_subscribe_test, 100)
    end_time = time.monotonic()
    logger.info(f"Coroutine send took {(end_time - start_time) * 1000.0} monotonic to complete.")
    await client_session.close()
    server_session.close()
    await server.stop()

asyncio.run(application())

pip install uvloop

import uvloop
asyncio.set_event_loop_policy(uvloop.EventLoopPolicy())