我理解的RPC

时间:2021-12-27 01:40:15
这两天在学习公司一牛人写的RPC框架,一直都对RPC的概念很模糊,现在稍微清晰了些。
 
rpc定义:RPC(Remote Procedure Call Protocol)——远程过程调用协议,它是一种通过网络从远程计算机程序上请求服务,而不需要了解底层网络技术的协议。RPC协议假定某些传输协议的存在,如TCP或UDP,为通信程序之间携带信息数据。在OSI网络通信模型中,RPC跨越了传输层和应用层。RPC使得开发包括网络分布式多程序在内的应用程序更加容易。
 
我理解的是在应用中要想对集群中所有的机器状况有了解,就要有一台机器知道集群中的所有机器的情况,这台就是server了,其他的都是agent。agent要知道谁是server,包括ip和端口,server要事先主动暴露ip、端口还有注册的服务。这样agent主动周期发送心跳并携带本机的相关参数到server,server接收请求并处理,返回相应数据。当然中间需要一致的协议,目前我们使用的是msgpack。
 
以下是阅读代码时的记录,类名及相关参数是基于源码的。
server端:
class RPCServer实例化时启动一个http server应该是监控server 处理情况的(下面处理过程中更新的handleStatus)
RPCServer启动前要注册服务,类名或者是moudle.class,这个也就是client端调用时的service和method,可以注册多个。注册的服务是放到RPCServer实例的serviceMap字典中,key是service名称,value是service实例。
然后RPCServer启动,通过eventlet.server监听某个端口及绑定处理客户端链接的方法---handle
 
handle的处理:
1.更新handleStatus活动连接数
2.实例化一个eventlet.GreenPool池
3.循环:
     从暴露的端口中读取client的数据,更新handleStatus接收字节数,反序列化并从greenpool中取一个协程处理,直到端口中没有数据为止
     协程处理是采用线程安全的方式,调用相应的处理方式---从RPCServer启动前注册服务的字典serviceMap中找,找到
     就调用方法处理message,并序列化返回的结果给client,更新handleStatus返回字节数。
4.最后更新handleStatus活动连接数 减1
 
handleStatus主要为http server提供RPCServer的处理状态的
 
agent(client)端:
client是要知道server的地址及监听端口,还有注册的服务的,client启动时实例化一个Session实例(用来保存发送到server的信息,实际应该是监控请求发送是否完成),每发送一次请求到server都会在client端的这个实例的_request_table(一个字典)中设置本次请求的msg_id,值为Future,Future是用来监控返回是否成功的【self.session.set(msgid, request.future)】
然后序列化(msgpack)请求信息 包括请求id,service,method等,放到一个client维护的队列中,这个队列是client启动时就实例化的,同时还启动了三个协程
pool.spawn_n(self.read_greenlet)
pool.spawn_n(self.write_greenlet)
pool.spawn_n(self.heartbeat_greenlet)
read_greenlet:监听server端的响应(死循环)
write_greenlet:从队列获取请求并发送到server(死循环)
heartbeat_greenlet:心跳
 
---完

我理解的RPC的更多相关文章

  1. 理解REST和RPC

    REST 越来越多的人开始意识到,网站即软件,而且是一种新型的软件. 网站开发,完全可以采用软件开发的模式.但是传统上,软件和网络是两个不同的领域,很少有交集:软件开发主要针对单机环境,网络则主要研究 ...

  2. RPC 使用中的一些注意点

    最近线上碰到一点小问题,分析其原因发现是出在对 RPC 使用上的一些细节掌握不够清晰导致.很多时候我们做业务开发会把 RPC 当作黑盒机制来使用,但若不对黑盒的工作原理有个基本掌握,也容易犯一些误用的 ...

  3. RPC 的概念模型与实现解析

    今天分布式应用.云计算.微服务大行其道,作为其技术基石之一的 RPC 你了解多少?一篇 RPC 的技术总结文章,数了下 5k+ 字,略长,可能也不适合休闲的碎片化时间阅读,可以先收藏抽空再细读:) 全 ...

  4. RPC原理详解

    RPC 功能目标 RPC 的主要功能目标是让构建分布式计算(应用)更容易,在提供强大的远程调用能力时不损失本地调用的语义简洁性. 为实现该目标,RPC 框架需提供一种透明调用机制让使用者不必显式的区分 ...

  5. RPC介绍

    转载http://blog.csdn.net/mindfloating/article/details/39474123/ 近几年的项目中,服务化和微服务化渐渐成为中大型分布式系统架构的主流方式,而 ...

  6. 深入浅出 RPC - 浅出篇+深入篇

    摘自: http://blog.csdn.net/mindfloating/article/details/39473807 近几年的项目中,服务化和微服务化渐渐成为中大型分布式系统架构的主流方式,而 ...

  7. 深入浅出 RPC - 深入篇

    <深入篇>我们主要围绕 RPC 的功能目标和实现考量去展开,一个基本的 RPC 框架应该提供什么功能,满足什么要求以及如何去实现它? RPC 功能目标 RPC 的主要功能目标是让构建分布式 ...

  8. RPC 的概念模型与实现解析(转)

    今天分布式应用.云计算.微服务大行其道,作为其技术基石之一的 RPC 你了解多少?一篇 RPC 的技术总结文章,数了下 5k+ 字,略长,可能也不适合休闲的碎片化时间阅读,可以先收藏抽空再细读:) 全 ...

  9. 浅析RPC概念框架

    本文原封不动的来至于csdn MindWind,原文请见 RPC:RPC 的全称是 Remote Procedure Call 是一种进程间通信方式.它允许程序调用另一个地址空间(通常是共享网络的另一 ...

随机推荐

  1. &ast;&ast;&ast;mysql中经度纬度字段用什么存储&lpar;关于mysql的float和decimal区别&rpar;

    float,decimal精确度比较   float,double容易产生误差,对精确度要求比较高时,建议使用decimal来存,decimal在mysql内存是以字符串存储的, 用于定义货币要求精确 ...

  2. 数据结构——foodfill 八连块问题

    Description Due to recent rains, water has pooled in various places in Farmer John's field, which is ...

  3. MFC中小笔记&lpar;二&rpar;

    6.有三个API函数可以运行可执行文件WinExec.ShellExecute和CreateProcess.  关于这三者的概述总结,有好几篇,自己选择. 1.CreateProcess因为使用复杂, ...

  4. input file禁用手机本地文件选择,只允许拍照上传图片

    <input type="file" accept="image/*" capture="camera"> 会有个问题,上传的图 ...

  5. 传输SO10 &lpar;SO10 Transport&rpar;

    传输SO10 (SO10 Transport) 方法一.   手工添加到请求里面,格式为: R3TR TEXT text object, name, ID, language   方法二.使用程序:R ...

  6. 雷林鹏分享:XML 验证

    XML 验证 拥有正确语法的 XML 被称为"形式良好"的 XML. 通过 DTD 验证的XML是"合法"的 XML. 形式良好的 XML 文档 "形 ...

  7. Access、SQLServer、Oracle常见SQL语句应用区别

    Access.SQLServer.Oracle常见SQL语句应用区别 关劲松 PMP 如果要兼容Access.SQL Server.Oracle三个数据库版本:我们在编写SQL语句的过程中,尽量使用一 ...

  8. JavaScript--DOM元素尺寸和位置&lpar;22&rpar;

    一 获取元素的CSS大小 1.通过style内联获取元素的大小 var box = document.getElementById('box'); // 获得元素; box.style.width; ...

  9. LINUX内核分析第三周学习总结——构造一个简单的Linux系统MenuOS

    LINUX内核分析第三周学习总结——构造一个简单的Linux系统MenuOS 张忻(原创作品转载请注明出处) <Linux内核分析>MOOC课程http://mooc.study.163. ...

  10. 生成器python

    一.列表生成式 需求:看列表[0, 1, 2, 3, 4, 5, 6, 7, 8, 9],我要求你把列表里的每个值加1,你怎么实现?你可能会想到2种方式 >>> a [0, 1, 2 ...