Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- import asyncio
- import websockets
- import logging
- import json
- import uuid
- users = {}
- logger = logging.getLogger('websockets.server')
- logger.setLevel(logging.DEBUG)
- logger.addHandler(logging.StreamHandler())
- async def connect(websocket, path):
- logging.debug("connection at path: {}", path)
- if (path != "/connect"):
- return
- id = uuid.uuid1()
- users[id] = websocket
- try:
- async for message in websocket:
- logging.debug("message: {}", message)
- clients = [w for i, w in users.items() if i != id]
- await asyncio.wait([client.send(message) for client in clients])
- finally:
- del users[id]
- server = websockets.serve(connect, "192.168.31.182", 8080)
- asyncio.get_event_loop().run_until_complete(server)
- asyncio.get_event_loop().run_forever()
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement