openstack中的rpc远程调用的方法

今天通过本文给大家分享openstack中的rpc远程调用的方法,本文给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友参考下吧

openstack中的rpc远程调用的方法,恰卡网带你了解更多相关信息。

众所周知,OpenStack的通信方式有两种,一种是基于HTTP协议的RESTFul API方式,另一种则是RPC调用。两种通信方式的应用场景有所不同,在OpenStack中,前者主要用于各组件之间的通信(如nova与glance的通信),而后者则用于同一组件中各个不同模块之间的通信(如nova组件中nova-compute与nova-scheduler的通信)。

nova中rpc调用非常多,用pycharm点点点跟函数的时候遇到rpc就会点不下去了,不解决直接就看不下去了那种多法

什么是 RPC

openstack中的rpc远程调用的方法

看不明白这个图对于看nova代码,其实不是很重要,直接忽略以后再看也可以,当务之急是解决一下看openstack代码遇到rpc就跟丢了的问题

RPC、消息队列、RESTful

这三个其实不是一个层面的东西,本质上不应该放在一起比,但是因为都用来通信,比较容易混淆就还是解释一下

  • RESTful:主要用于各组件之间的通信(比如nova与glance的通信),或者说用于组件对外提供调用接口
  • RPC:则用于同一组件中各个不同模块之间的通信(比如nova组件中nova-compute与-nova-scheduler的通信)
  • 消息队列:用于解耦组件,也是组件间通信用的,而且会有一个队列用来暂存消息

在nova中的典型rpc

nova/nova/nova/conductor/tasks/live_migrate.py

class LiveMigrationTask(base.TaskBase):    def __init__(self, context, instance, destination,                 block_migration, disk_over_commit, migration, compute_rpcapi,                 servicegroup_api, scheduler_client):        super(LiveMigrationTask, self).__init__(context, instance)    ...     def _execute(self):        self._check_instance_is_active()        self._check_host_is_up(self.source)        if not self.destination:            self.destination = self._find_destination()            self.migration.dest_compute = self.destination            self.migration.save()        else:            self._check_requested_destination()        # TODO(johngarbutt) need to move complexity out of compute manager        # TODO(johngarbutt) disk_over_commit?        #调用 ComputeAPI 类中的 live_migration() RPC接口        return self.compute_rpcapi.live_migration(self.context,                host=self.source,                instance=self.instance,                dest=self.destination,                block_migration=self.block_migration,                migration=self.migration,                migrate_data=self.migrate_data)

conductorcompute_rpcapi.live_migration的方式远程调用computelive_migration,过程就是, conductorRPC的方式发出一个请求到Queue再被nova-compute接收

nova/nova/nova/compute/rpcapi.py

class ComputeAPI(object):    # 这是一个RPC远程调用的方法    def live_migration(self, ctxt, instance, dest, block_migration, host,                       migration, migrate_data=None):        args = {\'migration\': migration}        version = \'4.2\'        if not self.client.can_send_version(version):            version = \'4.0\'        # 获取目标 compute 主机(DEST HOST)的RPC client,即被调用的服务进程的HostIP        cctxt = self.client.prepare(server=host, version=version)        # 通过目标主机对象的 RPC cliient 来调用远程过程方法 cast() ,以此来实现远程调用        cctxt.cast(ctxt, \'live_migration\', instance=instance,                   dest=dest, block_migration=block_migration,                   migrate_data=migrate_data, **args)        # cast()异步远程调用,不会阻塞别的进程,适合于需要长时间进行的执行过程        # cast()的第二个参数是RPC client调用的函数名,case()后面的参数会继续作为参数传入该调用函数        # cast()函数内的live_migration()函数是 manager.live_migration() 视具体实现迁移功能的函数,在manager.py内实现。

调用的时候是从nova/nova/conductor/tasks/live_migrate.pynova/nova/compute/rpcapi.py,但是实际上是compute服务首先得在rpcapi.py提供出接口函数,然后使用者通过
– 1. import导入的方式去使用rpc调用
– 2. 类实例化传参的方式去引入

热迁移这里用的就是类实例化传参

tip: call()表示同步调用 和 cast()表示异步调用

openstack中的rpc远程调用的方法

根据在rpc.py或者rpcapi.py中的cast()的第二个参数,去该服务下的manager.py中找和这个参数同名的函数(这个就是rpc最终想要调用的函数),我们这里是compute_rpcapi,所以要去找compute下的mannager.py

为什么要去找mannager,是因为nova.compute.manager 会一直监听 Queue ,当Queue中存在相关的 RPC 请求时,就去完成这个请求

nova/nova/nova/compute/manager.py

@wrap_exception()    @wrap_instance_event(prefix=\'compute\')    @wrap_instance_fault    def live_migration(self, context, dest, instance, block_migration,                       migration, migrate_data):        \"\"\"执行实时迁移。        :param context: security context        :param dest: destination host        :param instance: a nova.objects.instance.Instance object        :param block_migration: if true, prepare for block migration        :param migration: an nova.objects.Migration object        :param migrate_data: implementation specific params        \"\"\"        self._set_migration_status(migration, \'queued\')        def dispatch_live_migration(*args, **kwargs):            with self._live_migration_semaphore:                # 调用_do_live_migration执行迁移                self._do_live_migration(*args, **kwargs)        # NOTE(danms): We spawn here to return the RPC worker thread back to        # the pool. Since what follows could take a really long time, we don\'t        # want to tie up RPC workers.        utils.spawn_n(dispatch_live_migration,                      context, dest, instance,                      block_migration, migration,                      migrate_data)

当然实际干活的还不是manager.pydef live_migration,而是live_migration函数去调用_do_live_migration,但是之后的就是热迁移的流程,在之前的文档里写了就不展开了,反正rpc的体现就只到这里

冷迁移中还有很多例子,不一一列举了,有兴趣可以去看冷迁移源码分析这篇博客

看完例子会发现,既然原生的代码既然已经写了rpc调用,那么对应的服务肯定已经提供了rpc接口,所以实际上看到compute_rpcapi,可以不去compute下的rpc文件中找了,直接去compute下的manager看具体实现(不止compute,其他服务也一样),当然,如果需要雪确定是同步还是异步调用那还是不要偷这一步的懒。

总结

完整的rpc应该具有

  • 组件A提供出rpc调用接口(rpc.py或者rpcapi.py文件)
  • 组件B引入组件A的rpc (import或者类实例化传参)
  • 组件B调用组件A的rpc(以rpc方式发送一个请求到消息队列)
  • 组件A处理请求(组件A监听到发给自己的rpc请求会通过manager处理请求)

如果只是看代码,那么去对应的manager下面找实现就可以了,但是如果自己要加就还是的明白从哪里提供的、怎样导入,何种途径接收,这样想在代码里添加自己的rpc调用才心里有数

参考文献:

https://zhuanlan.zhihu.com/p/36427583
https://blog.csdn.net/Jmilk/article/details/52655645
https://www.cnblogs.com/wongbingming/p/11086773.html
https://blog.csdn.net/qq_33909098/article/details/118578133

到此这篇关于openstack中的rpc远程调用的文章就介绍到这了,更多相关openstack rpc调用内容请搜索趣讯吧以前的文章或继续浏览下面的相关文章希望大家以后多多支持趣讯吧!

版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌抄袭侵权/违法违规的内容,请发送邮件至 55@qq.com 举报,一经查实,本站将立刻删除。转转请注明出处:https://www.szhjjp.com/n/2121.html

(0)
nan
上一篇 2021-07-10
下一篇 2021-07-10

相关推荐

  • 属虎白羊座和属猴天蝎座在一起好不好 爱情指数分析

    人生至少有一次为了某个人而舍身忘我,不求朝朝暮暮,不求白头偕老,不求曾经拥有,甚至不求你爱我,只求在最美的年纪,与你同行一段。爱情的美好不是没有遗憾,而是遗憾却始终美好。当火象星座的白羊座遇上水象星座的天

    知识 2023-06-09
    0
  • 「最靠谱的网络兼职」有什么网络兼职靠谱的

    最靠谱的网络兼职,比较好的网络兼职内容导航:兼职工作软件哪个最靠谱有靠谱的网络兼职吗有什么网络兼职靠谱的推荐几个正规比较可信的网络兼职一、兼职工作软件哪个最靠谱摘要兼职app:兼职猫、兼客兼职、兼职卫士、斗米兼职、口袋兼职1、兼职猫:兼职猫的界面比较清爽,客服态度也不错,再加上其自身的多重审核功能,在上面发布招聘的企业都是经过实名认证的,所以其可靠度相对是比较高的。而且平台还推出了兼职保险服务,让

    2022-04-20
    0
  • 什么是创业(什么样的人适合创业)

    什么是创业?什么样的人适合创业,久久派带你了解相关信息。今天我们来聊聊什么是创业?以及什么样的人适合创业?一、什么是创业?创业有广义和狭义之分。狭义的说创业就是创建一个新企业。一些学者,也对创业给出了一个定义:创业就是不拘泥于当前资源条件的限制下对机会的追逐,将不同的资源组合以利用和开发机会并创造价值的过程。从这个定义里面,我们就可以看到两个重要的关键词,一个

    2021-11-17
    0
  • 与史郎中钦听黄鹤楼上吹笛赏析(与史郎中钦听黄鹤楼上吹笛翻译)

    与史郎中钦听黄鹤楼上吹笛(唐)李白一为迁客去长沙,西望长安不见家。黄鹤楼中吹玉笛,江城五月落梅花。译文一旦遭受贬谪,就像是贾谊到了长沙,整日向西望去,看不到长安,更见不到故乡的家了。一日我与史郎中在黄鹤楼上听人吹笛“梅花落”曲调,

    2021-11-03
    0
  • 恭喜,我们终于都解脱了全文免费阅读热推小说-多人求封士宁关思月恭喜,我们终于都解脱了小说哪里能看

    关思月傻眼了,“阳阳?”小家伙头也不回,房门“砰”的一声被关上。关思月欲哭无泪。都是小叛徒。总不能为了躲封士宁闺女也不要了,关思月硬着头皮,慢吞吞地打开房门,一抬头,就对上某人似笑非笑的脸。

    网络资讯 2023-05-14
    0
  • 食管癌饮食吃什么好 食管癌饮食可以吃的食物

    食管癌可以吃甲鱼、胡萝卜、薏仁等。甲鱼可以滋阴养血、补虚抗癌,适合很多癌症病人食用。胡萝卜富含维生素A、B2、B5、蔗糖、葡萄糖、淀粉、钙、铁、磷等微量元素,是抵抗癌症的理想食品。薏仁具有抗肿瘤、利尿、消肿、抗炎、降血糖、增强肌体免疫力的作用,尤其是能抑制癌细胞繁殖。食管癌饮食可以吃的食物1、小米粥小米粥是一种很有营养的食

    知识 2023-06-15
    0

发表回复

登录后才能评论