tornado-msgpack

Yet another MessagePack RPC for Python

history

20130827 0.4 add logging

samples

demo

#!/usr/bin/env python

port=28080

import tornado_msgpack
dispatcher=tornado_msgpack.Dispatcher()
def add(a, b):
    return a+b
dispatcher.add_handler("add", add)

with tornado_msgpack.ServerLoop("", port, dispatcher.on_message):
    with tornado_msgpack.ClientLoop("localhost", port) as client:
        print(client.call_sync("add", 3, 4))

server

#!/usr/bin/env python

import tornado_msgpack
import tornado

port=18080

# dispatcher
dispatcher=tornado_msgpack.Dispatcher()
def add(a, b):
    return a+b
dispatcher.add_handler("add", add)

# server
server_loop=tornado.ioloop.IOLoop()
server=tornado_msgpack.Server(server_loop, dispatcher.on_message)
server.listen(port)

import signal
def handler(signum, frame):
    server_loop.stop()
signal.signal(signal.SIGINT, handler)

try:
    # blocking...
    server_loop.start()
except ex as KeyboardInterrupt:
    pass

client

#!/usr/bin/env python
import tornado_msgpack
import tornado
import threading

host="127.0.0.1"
port=18080

client_loop=tornado.ioloop.IOLoop()
client_thread=threading.Thread(target=lambda : client_loop.start())

# connecion status
def on_status(session):
    print("status changed: "+session.status)
client=tornado_msgpack.Client(client_loop, on_status)

client.session.connect(host, port)
try:
    client_thread.start()

    # sync
    result=client.call_sync("add", 3, 4)

    # async
    future=client.call_async("add", 5, 6)
    future.join() # wait server respone
    msgpack_rpc=future.message
    result=msgpack_rpc[3]

    # async_with_callback
    def on_receive(msgpack_rpc):
        print(msgpack_rpc)
    future=client.call_async_with_callback(on_receive, "add", 5, 6)
    future.join() # wait server respone

finally:
    client_loop.stop()
    client_thread.join()

Metadata

Release files for tornado_msgpack 0.4

For a detailed explanation of source distributions (sdists) and built distributions (wheels), please see the package formats documentation.

Source distribution (sdist)

Source distribution for tornado_msgpack 0.4
File	Size	Uploaded	Provenance
tornado_msgpack-0.4.tar.gz	3.8 kB	Aug 27, 2013	Without provenance	Details

Release files / tornado_msgpack-0.4.tar.gz

Download URL	tornado_msgpack-0.4.tar.gz
Size	3.8 kB
Tags	Source
SHA-256 checksum How to use checksums	`a8158e3f10f895e7b98ca8bf665825f330aa65a66a34a05ac0aed9a7b9bb5577`
BLAKE2b-256 checksum How to use checksums	`acbfc22ba3cd4a33926ace1739c3ae58eadcc9b3ae3915194290fdae9eb3793d`
Upload date	Aug 27, 2013
Uploaded using Trusted Publishing? What is trusted publishing?	No

Security for tornado_msgpack 0.4

Report project as malware

Provenance

Provenance describes where a file came from. On PyPI, provenance is shared via attestations, which provide a verifiable record of the build or publishing details. View details, limitations and caveats.

No provenance found

None of the files in this release were uploaded with provenance metadata.

A note on package security

PyPI is a repository for distributing packages, not a service for auditing them. While third-party security researchers and our staff do their best to detect and remove malicious packages, PyPI cannot guarantee the quality, security or suitability of any given package.