parallel_websocket_server 0.1.0

python multiprocessing websocket server

parallel_websocket_server

run websocket server in parallel (using multiprocessing)

Installation

pip install parallel_websocket_server

How to use

import json
import random
from parallel_websocket_server import ParallelWebSocketServer


if __name__ == "__main__":
    receive_queue = mp.Queue()
    send_queue = mp.Queue()

    server = ParallelWebSocketServer(receive_queue, send_queue)

    while True:
        if not receive_queue.empty():
            received_message = receive_queue.get_nowait()
            print(received_message)

        ran = random.random()
        if ran < 0.00001:
            send_queue.put(json.dumps({"hoge": 1}))