websocket-server-sender.py

websocket-server-sender.py

import asyncio
import websockets
import time
import json

async def sender(websocket, path):
    print("Client connected on path:", path)
    while True:
        time.sleep(5)
        m = json.dumps({'hello': 'world'})
        print("sending message:", m)
        await websocket.send(m)

start_server = websockets.serve(sender, "localhost", 8765)

asyncio.get_event_loop().run_until_complete(start_server)
asyncio.get_event_loop().run_forever()

# To run, first run: pip3 install websockets

# On the client, brew install websocat and run
# websocat ws://localhost:8765/hello/world