博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
tornado+jsonrpc
阅读量:5944 次
发布时间:2019-06-19

本文共 2192 字,大约阅读时间需要 7 分钟。

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

 

tornado中jsonrpc的使用

import jsonimport tornado.httpserverimport tornado.ioloopimport tornado.webfrom jsonrpcserver.aio import methods#第一个方法@methods.addasync def ping(context, **kwargs):    return kwargs#第二个方法@methods.addasync def ping_one(context, **kwargs):    return kwargsclass 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 timefrom jsonrpcclient import HTTPClientreq = 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)

 

 服务端响应如下:

 

客户端响应如下:

 

 

json-rpc是一种非常轻量级的跨语言远程调用协议,实现及使用简单。方便语言扩展客户端的实现。

使用场景:

调用另一个服务的某个方法,相对于接口调用,在代码整洁及解耦方面有优势。并且可以使用批量请求(在所有请求完成后,在一并返回)

并且如果是 频繁请求另一个服务的某种功能,使用rpc比http较为轻量级,并且结合socket使用,达到一个连接中多个请求,减少系统开销

 

相关网址:https://www.zybuluo.com/phper/note/76641

                  https://blog.csdn.net/red_heel/article/details/78911252

                  https://www.cnblogs.com/chunguang/p/5724782.html

转载于:https://www.cnblogs.com/rgcLOVEyaya/p/RGC_LOVE_YAYA_692days_820.html

你可能感兴趣的文章
禁止浏览器缓存js
查看>>
【Redis】安装PHP的redis驱动(二)
查看>>
java中string和int互相转化
查看>>
什么是序列化,为什么要序列化
查看>>
Java保留小数点后有效数字
查看>>
新学期的合作
查看>>
C++中一些类和数据结构的大小的总结
查看>>
mysql开启binlog
查看>>
ctrl + z fg bg
查看>>
工作流引擎Oozie(一):workflow
查看>>
struct框架
查看>>
Deep Learning(深度学习)相关网站
查看>>
设置Eclipse编码方式
查看>>
分布式系统唯一ID生成方案汇总【转】
查看>>
Cross-compilation using Clang
查看>>
营销系统--手动补偿
查看>>
图标字体设计
查看>>
【转】Principles of training multi-layer neural network using backpropagation
查看>>
并查集hdu1232
查看>>
改动Androidproject的名称(非Eclipse重命名)
查看>>