tornado+jsonrpc

Posted 2021-01-11 RGC

tags:

篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了tornado+jsonrpc相关的知识，希望对你有一定的参考价值。

rpc:远程过程调用（A服务调用B服务的一个方法或函数）

tornado中jsonrpc的使用

import json

import tornado.httpserver
import tornado.ioloop
import tornado.web
from jsonrpcserver.aio import methods

#第一个方法
@methods.add
async def ping(context, **kwargs):
    return kwargs

#第二个方法
@methods.add
async def ping_one(context, **kwargs):
    return kwargs


class RpcHandler(tornado.web.RequestHandler):
    def get(self):
        response = methods.dispatch({"jsonrpc": "2.0", "method": "ping", "id": 33, \'params\': {\'where\': 23}},
                                    context={\'name\': \'张三\'})
        if not response.is_notification:
            self.write(response)

    #通过此接口调用不同的方法
    async def post(self):
        rpc_request = self.request.body.decode()
        response = await methods.dispatch(rpc_request, context={\'key\': \'one\'})
        if not response.is_notification:
            self.write(json.dumps(response))


def make_app():
    settings = {\'debug\': True}
    return tornado.web.Application([
        (r\'/\', RpcHandler),
    ], **settings)


if __name__ == \'__main__\':
    app = make_app()
    http_server = tornado.httpserver.HTTPServer(app)
    ip = \'127.0.0.1\'
    port = 8000
    http_server.bind(8000, ip)
    http_server.start(1)
    print(\'server start! http://{}:{}\'.format(ip, port))
    tornado.ioloop.IOLoop.current().start()

客户端调用代码如下：

import time

from jsonrpcclient import HTTPClient

req = HTTPClient(\'http://127.0.0.1:8000/\')
# 请求ping方法
res = req.request(\'ping\', name=34)
print(res)
time.sleep(1)
# 请求ping_one方法
res = req.request(\'ping_one\', name=35)
print(res)
time.sleep(1)
# 批量请求两个方法
res = req.send(\'\'\'[{"jsonrpc": "2.0", "method": "ping_one", "params": {"name": 351}, "id": 21},
                   {"jsonrpc": "2.0", "method": "ping_one", "params": {"name": 352}, "id": 22}
                   ]\'\'\')
print(res)