Server

中文英文

服务器通过 WebsocketServer 连接多个 YDoc。

以下是使用 websockets 库的代码示例：

import asyncio
from websockets import serve
from ypy_websocket import WebsocketServer

async def server():
    async with (
        WebsocketServer() as websocket_server,
        serve(websocket_server.serve, "localhost", 1234),
    ):
        await asyncio.Future()  # 永久运行

asyncio.run(server())

Ypy-websocket 还可以与 ASGI 服务器一起使用。以下是使用 Uvicorn 的代码示例：

# main.py
import asyncio
import uvicorn
from ypy_websocket import ASGIServer, WebsocketServer

websocket_server = WebsocketServer()
app = ASGIServer(websocket_server)

async def main():
    config = uvicorn.Config("main:app", port=5000, log_level="info")
    server = uvicorn.Server(config)
    async with websocket_server:
        task = asyncio.create_task(server.serve())
        while not server.started:
            await asyncio.sleep(0)

        await asyncio.Future()  # 永久运行

asyncio.run(main())

A server connects multiple YDoc through a WebsocketServer.

Here is a code example using the websockets library:

import asyncio
from websockets import serve
from ypy_websocket import WebsocketServer

async def server():
    async with (
        WebsocketServer() as websocket_server,
        serve(websocket_server.serve, "localhost", 1234),
    ):
        await asyncio.Future()  # run forever

asyncio.run(server())

Ypy-websocket can also be used with an ASGI server. Here is a code example using Uvicorn:

# main.py
import asyncio
import uvicorn
from ypy_websocket import ASGIServer, WebsocketServer

websocket_server = WebsocketServer()
app = ASGIServer(websocket_server)

async def main():
    config = uvicorn.Config("main:app", port=5000, log_level="info")
    server = uvicorn.Server(config)
    async with websocket_server:
        task = asyncio.create_task(server.serve())
        while not server.started:
            await asyncio.sleep(0)

        await asyncio.Future()  # run forever

asyncio.run(main())