picows 0.2.0

Fast websocket client and server for asyncio

picows is a library for building WebSocket clients and servers with a focus on performance.

Performance

picows is implemented in Cython and provides unparalleled performance compared to other popular WebSocket libraries.

The above chart shows the performance of echo clients communicating with a server through a loopback interface using popular Python libraries. boost.beast client is also included for reference. Typically, picows is ~1.5-2 times faster than aiohttp. All Python clients use uvloop. Please find the benchmark sources here.

Installation

picows requires Python 3.8 or greater and is available on PyPI. Use pip to install it:

$ pip install picows

Rationale

Popular WebSocket libraries attempt to provide high-level interfaces. They take care of timeouts, flow control, optional compression/decompression, assembling WebSocket messages from frames, as well as implementing async iteration interfaces. These features come with a significant cost even when messages are small, unfragmented (every WebSocket frame is final), and uncompressed. The async iteration interface is done using Futures, which adds extra work for the event loop and introduces delays. Furthermore, it is not always possible to check if more messages have already arrived; sometimes, only the last message matters.

API Design

The API follows low-level transport/protocol design from asyncio It passes frames instead of messages to a user handler. A message can potentially consist of multiple frame but it is up to user to choose the best strategy for merging frames. Though the most common case is when messages and frames are the same i.e. a message consists of only a single frame.

Getting started

Echo client

Connects to an echo server, sends a message and disconnect upon reply.

import asyncio
import uvloop
from picows import WSFrame, WSTransport, WSListener, ws_connect, WSMsgType

class ClientListener(WSListener):
    def on_ws_connected(self, transport: WSTransport):
        transport.send(WSMsgType.TEXT, b"Hello world")

    def on_ws_frame(self, transport: WSTransport, frame: WSFrame):
        print(f"Echo reply: {frame.get_payload_as_ascii_text()}")
        transport.disconnect()


async def main(endpoint):
  # ClientListener instance will be created after successfull accept and http upgrade.
  (_, client) = await ws_connect(endpoint, ClientListener, "client")
  await client._transport.wait_until_closed()


if __name__ == '__main__':
  asyncio.set_event_loop_policy(uvloop.EventLoopPolicy())
  asyncio.run(main("ws://127.0.0.1:9001"))

This prints:

Echo reply: Hello world

Echo server

import asyncio
import uvloop
from picows import WSFrame, WSTransport, WSListener, ws_connect, WSMsgType

class ServerClientListener(WSListener):
    def on_ws_connected(self, transport: WSTransport):
        print("New client connected")

    def on_ws_frame(self, transport: WSTransport, frame: WSFrame):
        transport.send(frame.opcode, frame.get_payload_as_bytes())
        if frame.opcode == WSMsgType.CLOSE:
            transport.disconnect()

async def main():
    url = "ws://127.0.0.1:9001"
    # ServerClientListener instance will be created for each client after accept and successfull http upgrade.
    server = await ws_create_server(url, ServerClientListener, "server")
    print(f"Server started on {url}")
    await server.serve_forever()

if __name__ == '__main__':
    asyncio.set_event_loop_policy(uvloop.EventLoopPolicy())
    asyncio.run(main())

Features

• Maximally efficient WebSocket frame parser and builder implemented in Cython

• Re-use memory as much as possible, avoid reallocations, and avoid unnecessary Python object creations

• Provide Cython .pxd for efficient integration of user Cythonized code with picows

• Ability to check if a frame is the last one in the receiving buffer

• Support both secure and unsecure protocols (ws and wss schemes)