pip install websocket
python
import asyncio
import websockets
python
async def handle_message(websocket, path):
async for message in websocket:
await broadcast(message)
async def broadcast(message):
for client in clients:
await client.send(message)
python
clients = set()
async def main():
server = await websockets.server.serve(handle_message, "localhost", 8000)
await server.wait_closed()
asyncio.run(main())
python
import websocket
def on_message(ws, message):
print(f"Received message: {message}")
def on_open(ws):
ws.send("Hello, server!")
def on_close(ws):
print("Connection closed")
websocket.enableTrace(True)
ws = websocket.WebSocketApp("ws://localhost:8000/",
on_message=on_message,
on_open=on_open,
on_close=on_close)
ws.run_forever()
