位置: 编程技术 - 正文

python如何通过protobuf实现rpc(python如何通过键找对应值)

编辑:rootadmin

推荐整理分享python如何通过protobuf实现rpc(python如何通过键找对应值),希望有所帮助,仅作参考,欢迎阅读内容。

文章相关热门搜索词:python如何通过类创建对象,python如何通过键值找所在字典的数据,python如何通过类创建对象,python如何通过下标获取元素,python如何通过值找键,python如何通过类创建对象,python如何通过值找键,python如何通过类创建对象,内容如对您有帮助,希望把文章链接给更多的朋友!

由于项目组现在用的rpc是基于google protobuf rpc协议实现的,所以花了点时间了解下protobuf rpc。rpc对于做分布式系统的人来说肯定不陌生,对于rpc不了解的童鞋可以自行google,这里只是做个简单的介绍。rpc的主要功能是让分布式系统的实现更为简单,为提供强大的远程调用而不损失本地调用语义的简洁性。为了实现这个目标,rpc框架需要提供一种透明调用机制让使用者不必显示区分本地调用还是远程调用。rpc架构涉及的组件如下:

客户方像调用本地方法一样去调用远程接口方法,RPC 框架提供接口的代理实现,实际的调用将委托给代理RpcProxy 。代理封装调用信息并将调用转交给RpcInvoker 去实际执行。在客户端的RpcInvoker 通过连接器RpcConnector 去维持与服务端的通道RpcChannel,并使用RpcProtocol 执行协议编码(encode)并将编码后的请求消息通过通道发送给服务方。RPC 服务端接收器 RpcAcceptor 接收客户端的调用请求,同样使用RpcProtocol 执行协议解码(decode)。解码后的调用信息传递给RpcProcessor 去控制处理调用过程,最后再委托调用给RpcInvoker 去实际执行并返回调用结果。

protobuf rpc在上面组件中主要扮演RpcProtocol的角色,使得我们省去了协议的设计,并且protobuf协议在编码和空间效率都是上非常高效的,这也是很多公司采用protobuf作为数据序列化和通信协议的原因。同时protobuf rpc定义了一个抽象的rpc框架,如下图所示:

RpcServiceStub和RpcService类是protobuf编译器根据proto定义生成的类,RpcService定义了服务端暴露给客户端的函数接口,具体实现需要用户自己继承这个类来实现。RpcServiceStub定义了服务端暴露函数的描述,并将客户端对RpcServiceStub中函数的调用统一转换到调用RpcChannel中的CallMethod方法,CallMethod通过RpcServiceStub传过来的函数描述符和函数参数对该次rpc调用进行encode,最终通过RpcConnecor发送给服务方。对方以客户端相反的过程最终调用RpcSerivice中定义的函数。事实上,protobuf rpc的框架只是RpcChannel中定义了空的CallMethod,所以具体怎样进行encode和调用RpcConnector都要自己实现。RpcConnector在protobuf中没有定义,所以这个完成由用户自己实现,它的作用就是收发rpc消息包。在服务端,RpcChannel通过调用RpcService中的CallMethod来具体调用RpcService中暴露给客户端的函数。

python如何通过protobuf实现rpc(python如何通过键找对应值)

介绍了这么多,对于怎么样用protobuf rpc来实现一个rpc肯定还是一头雾水吧,下面就用protobuf rpc来实现一个简单的python版rpc demo吧。

下面直接给出demo描述PRC的proto文件,至于proto文件的编写规则可以参考protobuf官网。

common.proto文件:

game_service.proto文件:

common.proto文件描述了RPC中收发的消息;game_service.proto描述了服务器导出的connect_server函数,该函数接受RequestMessage对象作为参数,并返回RequestMessage对象。在使用PRC协议时,必须加上option py_generic_services = true;可选项,要不然编译器不会生成包含connect_server函数的GameService描述。

使用编译器protoc编译proto文件,具体命令为:protoc.exe --python_out=. game_service.proto编译后生成的文件为game_service_pb2.py,该文件主要是实现了GameService和GameService_Stub类。GameService_Stub类用于客户端调用者来调用GameService的服务。前面已经说了,在客户端,RpcChannel只实现了一个空的CallMethod,所以需要继承RpcChannel重新这个函数来encode消息和发送消息。在服务端RpcChannel需要调用CallMethod来调用Service中的函数。具体实现如下:

最后就是继承GameService,并实现connect_server函数了。

至于用于网络收发消息的RpcConnector,可以使用python的asyncore库实现,具体实现在这就不讨论了。

从上面的实现来看,protobuf rpc的实现主要包括编写proto文件并编译生成对应的service_pb2文件,继承RpcChannel并实现CallMethod和调用Service的CallMethod,继承Service来实现暴露给客户端的函数。

标签: python如何通过键找对应值

本文链接地址:https://www.jiuchutong.com/biancheng/383386.html 转载请保留说明!

上一篇:使用Python保存网页上的图片或者保存页面为截图(python3.5怎么保存)

下一篇:Django Admin实现上传图片校验功能(django admin form)

  • 税盘服务费抵扣增值税
  • 税控盘的维护费
  • 增值税发票没了能补开吗
  • 单位购牙膏牙刷卫生纸怎么做账
  • 应发工资和实发工资计算公式excel
  • 福利费进项税转出的会计分录
  • 银行承兑汇票怎么填写
  • 仓储货架工厂仓库货架
  • 事业单位为职工代扣代缴个人所得税
  • 生产企业商贸企业
  • 营改增之后对企业的影响
  • 工程开发票备注栏必需要写吗?
  • 同一地级行政区范围内举例
  • 小微 小型微利
  • 以前年度损益调整怎么用
  • 资金筹集业务核算实训心得体会
  • 对外捐赠视同销售分录
  • 工程哪些材料可以做
  • 取得高新技术企业
  • 知识产权?
  • 什么是差额征税劳务费
  • 笔记本如何进行截图
  • 任务管理器无法完成操作拒绝访问
  • 单位话费谁负责交
  • 苹果发布macOS13.6
  • PHP:Memcached::replaceByKey()的用法_Memcached类
  • 股票分红怎么扣税
  • win10电脑c盘满了怎么转移到d盘
  • 1050ti 4g显卡
  • 企业所得税税金及附加包括
  • 在树洞中休息的英语
  • 其他债权投资如何进行投资收益的确认的核算?
  • 职工伙食费会计科目
  • axios.defaults.baseURL的三种配置方法
  • 后端三件套
  • 因果推断的常用标准
  • php使用什么开发工具
  • e命令怎么用
  • 小微企业所得税优惠政策2023
  • 关于公司预支工资制度
  • 附表一般写在哪
  • python __call__
  • 织梦上传图片大小设置
  • 一般纳税人年收入500万交多少税
  • 番茄开发票属于蔬菜吗?
  • 分期收款发出商品是什么意思
  • 当月发票是否需要当月支付
  • 印花税缴纳怎么做账
  • 车辆按揭贷款需要什么
  • 收到专利权投资的票据
  • 取得工程款发票计入什么会计科目里
  • 员工办理健康证费用由谁支付
  • 企业清算的顺序
  • where条件加判断
  • win8.1 multiple edition
  • 应用程序发生异常如何解决
  • 开源操作系统总结
  • popblock.exe
  • linux磁盘管理fdisk
  • windows7粘滞键怎么关
  • winxp系统怎么设置默认账户登入
  • u盘怎么安装win7镜像文件
  • OpwareSE2.exe - OpwareSE2是什么进程 有什么用
  • 如何使用ssh
  • node运行js文件
  • Android游戏开发入门
  • linux 常用命令大全及其详解
  • 实现 java
  • vue移动端图片预览
  • javascript学习指南
  • JavaScript中的方法名不区分大小写
  • 深入探讨英文
  • javascript面向过程
  • jquery1
  • android使用红杏代理更新sdk
  • 河南省低保查询官网
  • 外购已税小汽车用于连续生产小汽车为啥可以抵扣
  • 四川税务2021
  • 大企业如何做好工作
  • 公司小规模怎么纳税
  • 免责声明:网站部分图片文字素材来源于网络,如有侵权,请及时告知,我们会第一时间删除,谢谢! 邮箱:opceo@qq.com

    鄂ICP备2023003026号

    网站地图: 企业信息 工商信息 财税知识 网络常识 编程技术

    友情链接: 武汉网站建设