{ "info": { "author": "ousttrue", "author_email": "ousttrue@gmail.com", "bugtrack_url": null, "classifiers": [ "License :: OSI Approved :: Apache Software License", "Programming Language :: Python :: 3" ], "description": "tornado-msgpack\n===============\n\nYet another MessagePack RPC for Python\n\nhistory\n-------\n* 20130827 0.4 add logging\n\nsamples\n-------\n\ndemo\n++++\n::\n\n #!/usr/bin/env python\n\n port=28080\n\n import tornado_msgpack\n dispatcher=tornado_msgpack.Dispatcher()\n def add(a, b):\n return a+b\n dispatcher.add_handler(\"add\", add)\n\n with tornado_msgpack.ServerLoop(\"\", port, dispatcher.on_message):\n with tornado_msgpack.ClientLoop(\"localhost\", port) as client:\n print(client.call_sync(\"add\", 3, 4))\n\nserver\n++++++\n::\n\n #!/usr/bin/env python\n\n import tornado_msgpack\n import tornado\n\n port=18080\n\n # dispatcher\n dispatcher=tornado_msgpack.Dispatcher()\n def add(a, b):\n return a+b\n dispatcher.add_handler(\"add\", add)\n\n # server\n server_loop=tornado.ioloop.IOLoop()\n server=tornado_msgpack.Server(server_loop, dispatcher.on_message)\n server.listen(port)\n\n import signal\n def handler(signum, frame):\n server_loop.stop()\n signal.signal(signal.SIGINT, handler)\n\n try:\n # blocking...\n server_loop.start()\n except ex as KeyboardInterrupt:\n pass\n \nclient\n++++++\n::\n\n #!/usr/bin/env python\n import tornado_msgpack\n import tornado\n import threading\n\n host=\"127.0.0.1\"\n port=18080\n\n client_loop=tornado.ioloop.IOLoop()\n client_thread=threading.Thread(target=lambda : client_loop.start())\n\n # connecion status\n def on_status(session):\n print(\"status changed: \"+session.status)\n client=tornado_msgpack.Client(client_loop, on_status)\n\n client.session.connect(host, port)\n try:\n client_thread.start()\n\n # sync\n result=client.call_sync(\"add\", 3, 4)\n\n # async\n future=client.call_async(\"add\", 5, 6)\n future.join() # wait server respone\n msgpack_rpc=future.message\n result=msgpack_rpc[3]\n\n # async_with_callback\n def on_receive(msgpack_rpc):\n print(msgpack_rpc)\n future=client.call_async_with_callback(on_receive, \"add\", 5, 6)\n future.join() # wait server respone\n\n finally:\n client_loop.stop()\n client_thread.join()", "description_content_type": null, "docs_url": null, "download_url": "UNKNOWN", "downloads": { "last_day": -1, "last_month": -1, "last_week": -1 }, "home_page": "UNKNOWN", "keywords": null, "license": "Apache Software License", "maintainer": null, "maintainer_email": null, "name": "tornado_msgpack", "package_url": "https://pypi.org/project/tornado_msgpack/", "platform": "UNKNOWN", "project_url": "https://pypi.org/project/tornado_msgpack/", "project_urls": { "Download": "UNKNOWN", "Homepage": "UNKNOWN" }, "release_url": "https://pypi.org/project/tornado_msgpack/0.4/", "requires_dist": null, "requires_python": null, "summary": "ore ore MessagePack RPC", "version": "0.4" }, "last_serial": 850156, "releases": { "0.1": [ { "comment_text": "", "digests": { "md5": "1934fbebcd1d17efd59c3c0ac432d32d", "sha256": "4dd906cec819224a9a1362a2bc32745a92f0e8563610b9606af68673ac1c9f78" }, "downloads": -1, "filename": "tornado_msgpack-0.1.zip", "has_sig": false, "md5_digest": "1934fbebcd1d17efd59c3c0ac432d32d", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 6344, "upload_time": "2013-06-19T02:40:16", "url": "https://files.pythonhosted.org/packages/bd/8f/5c26c68d5b47313b6180f643850b1147eac6588525986d112b3705877868/tornado_msgpack-0.1.zip" } ], "0.2": [ { "comment_text": "", "digests": { "md5": "bf841b92a54399418eeee7c61117ce82", "sha256": "ca02a655ea4ccc23d11632a56b652c4e9be8f02e54c84093015d456647d7c84a" }, "downloads": -1, "filename": "tornado_msgpack-0.2.tar.gz", "has_sig": false, "md5_digest": "bf841b92a54399418eeee7c61117ce82", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 3454, "upload_time": "2013-08-27T08:33:21", "url": "https://files.pythonhosted.org/packages/89/80/cfbeef35e807d83e7912e9051a48767e2bdff003d8a681a74680e7793f15/tornado_msgpack-0.2.tar.gz" } ], "0.3": [ { "comment_text": "", "digests": { "md5": "4337fb47980bc6e282bbb48dba482520", "sha256": "888c1f5ab795f69ddce1f721e398705ff24a62da6b42e2a8fe1759df76c074aa" }, "downloads": -1, "filename": "tornado_msgpack-0.3.tar.gz", "has_sig": false, "md5_digest": "4337fb47980bc6e282bbb48dba482520", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 3510, "upload_time": "2013-08-27T08:46:04", "url": "https://files.pythonhosted.org/packages/e0/bc/7b17e59991c71f855fc3ebeb66624ef094cb9d86fcf0f93c647ec210a9be/tornado_msgpack-0.3.tar.gz" } ], "0.4": [ { "comment_text": "", "digests": { "md5": "35fc1a5929638a0d1fcb8aabdf058f45", "sha256": "a8158e3f10f895e7b98ca8bf665825f330aa65a66a34a05ac0aed9a7b9bb5577" }, "downloads": -1, "filename": "tornado_msgpack-0.4.tar.gz", "has_sig": false, "md5_digest": "35fc1a5929638a0d1fcb8aabdf058f45", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 3772, "upload_time": "2013-08-27T10:25:16", "url": "https://files.pythonhosted.org/packages/ac/bf/c22ba3cd4a33926ace1739c3ae58eadcc9b3ae3915194290fdae9eb3793d/tornado_msgpack-0.4.tar.gz" } ] }, "urls": [ { "comment_text": "", "digests": { "md5": "35fc1a5929638a0d1fcb8aabdf058f45", "sha256": "a8158e3f10f895e7b98ca8bf665825f330aa65a66a34a05ac0aed9a7b9bb5577" }, "downloads": -1, "filename": "tornado_msgpack-0.4.tar.gz", "has_sig": false, "md5_digest": "35fc1a5929638a0d1fcb8aabdf058f45", "packagetype": "sdist", "python_version": "source", "requires_python": null, "size": 3772, "upload_time": "2013-08-27T10:25:16", "url": "https://files.pythonhosted.org/packages/ac/bf/c22ba3cd4a33926ace1739c3ae58eadcc9b3ae3915194290fdae9eb3793d/tornado_msgpack-0.4.tar.gz" } ] }