Unix Domain Socket support

Unix domain socket support is now available for msgpack-rpc. Sample examples below.

UDS examples

Server

import msgpackrpc.udsaddress
from msgpackrpc.transport import uds
class SumServer(object):
    def sum(self, x, y):
        return x + y

# Use builder as uds. default builder is tcp which creates tcp sockets
server = msgpackrpc.Server(SumServer(), builder=uds)
# Use UDSAddress instead of msgpackrpc.Address
server.listen(msgpackrpc.udsaddress.UDSAddress('/tmp/exrpc'))
server.start()

Client

import msgpackrpc.udsaddress
from msgpackrpc.transport import uds

#Use UDSAddress instead of default Address object
client = msgpackrpc.Client(msgpackrpc.udsaddress.UDSAddress("/tmp/exrpc"), builder=uds)
result = client.call('sum', 1, 2)  # = > 
print "Sum of 1 and 2 : %d" % result

Go through the below sections for general usage of Message Pack RPC Library

MessagePack RPC for Python

MessagePack RPC implementation based on Tornado.

Installation

% python setup.py install

or

% easy_install msgpack-rpc-python

Dependent modules

• msgpack-python (>= 0.3)
• tornado (>= 3)

Example

Server

import msgpackrpc

class SumServer(object):
    def sum(self, x, y):
        return x + y

server = msgpackrpc.Server(SumServer())
server.listen(msgpackrpc.Address("localhost", 18800))
server.start()

Client

import msgpackrpc

client = msgpackrpc.Client(msgpackrpc.Address("localhost", 18800))
result = client.call('sum', 1, 2)  # = > 3

Run test

In test directory:

% PYTHONPATH=../ python test_msgpackrpc.py

Run with timeout test(Timeout test takes about 5 seconds)

% PYTHONPATH=../ python test_msgpackrpc.py --timeout-test

Performance

OS: Mac OS X ver 10.8.3
CPU: Intel Core i7 2.7 GHz
Memory: 16 GB 1600 MHz DDR3

	call(QPS)	async(QPS)	notify(QPS)
2.7.3	5903	6040	24877
3.3.0	5493	5812	23634
PyPy 1.9.0 with GCC 4.2.1	5519	9729	46406

Test code are available in example directory(bench_client.py and bench_server.py).

TODO

• Add advanced return to Server.
• UDP, UNIX Domain support
• Utilities (MultiFuture, SessionPool)

Copyright

Author	Masahiro Nakagawa
Copyright	Copyright (c) 2011- Masahiro Nakagawa
License	Apache License, Version 2.0