aio-msgpack-rpc

Pure asyncio implementation of the MsgPack RPC.
Requires Python >= 3.6.
Uses streams API provided by the asyncio standard library.

Just a simple implementation of the RPC layer.

Installation

pip install aio-msgpack-rpc

Example

Server

import asyncio
import aio_msgpack_rpc


# handlers can be defined on a class
# they can either be async or plain functions
class MyServicer:
    async def sum(self, x, y):
        print(f"sum: {x}, {y}")
        return x + y

    def notification(self, msg):
        print(f"notification: {msg}")


async def main():
    try:
        server = await asyncio.start_server(aio_msgpack_rpc.Server(MyServicer()), host="localhost", port=18002)

        while True:
            await asyncio.sleep(0.1)
    finally:
        server.close()

try:
    asyncio.get_event_loop().run_until_complete(main())
except KeyboardInterrupt:
    pass

Client

import asyncio
import aio_msgpack_rpc

async def main():
    client = aio_msgpack_rpc.Client(*await asyncio.open_connection("localhost", 18002))

    # blocking rpc calls
    result = await client.call("sum", 1, 2)
    assert result == 3

    # one way notifications
    await client.notify("notification", "hello")

asyncio.get_event_loop().run_until_complete(main())

Benchmark

Some basic performance benchmarks against the official implementation on my development machine.