docker容器与容器之间通信_多进程间通信

docker容器与容器之间通信_多进程间通信1、Spark组件之间使用RPC机制进行通信。RPC的客户端在本地编写并调用业务接口,接口在本地通过RPC框架的动态代理机制生成一个对应的实现类,在这个实现类中完成soket通信、远程调用等功能的逻辑

Spark组件间通信

1、Spark组件之间使用RPC机制进行通信。RPC的客户端在本地编写并调用业务接口,接口在本地通过RPC框架的动态代理机制生成一个对应的实现类,在这个实现类中完成soket通信、远程调用等功能的逻辑包装,而在RPC的服务端既编写业务接口也编写了具体的业务实现类,通过RPC框架以接口的方式暴露出来,供客户端远程调用。
Spark2.x之前使用的是Akka作为底层框架来实现Actor模型的,Spark2.x之后用Netty替换了Akka作为底层框架,来实现Actor模型(Akka底层用的也是Netty)。

BIO:客户端调用后一直等待服务端的执行返回,客户端才能继续执行自生在调用点位后面的逻辑,造成客户端逻辑的阻塞。
NIO:客户端调用后,继续执行调用点位后的本地逻辑,通过事件监听等机制获得服务端的返回,客户端无阻塞,但是客户端需要付出额为的精力去实时监听服务端的执行是否完毕。
AIO:客户端调用后,继续执行调用点位后的本地逻辑,服务端主动将结果发送到共享的地方,客户端灵活取用,客户端无阻塞也无额外开销,(服务端通常使用call-back等机制实现对客户端的通知、Feature来约定共享数据区)但是目前Linux不支持AIO,Windows支持。
*
2、Actor模型:每一个通信端点都拥有一对
inbox-outbox**,任何信息的接收都通过inbox,同样任何信息的发送都必须通过outbox,多条信息就在box中排序处理。

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

(0)
上一篇 2023-01-29
下一篇 2023-01-30

相关推荐

  • 列存储索引_索引存储和散列存储

    列存储索引_索引存储和散列存储作者:李红建 责编:宇亭 在第一期研发分享中,我们解释了,为什么Tinamu作为一款列式存储引擎在初期不支持 Delete 功能的原因,然后对一些友商列式存储引擎的 Delete 方案进行了一些调研和

    2023-06-19
    155
  • 如何确认 Python 安装成功

    如何确认 Python 安装成功a href=”https://beian.miit.gov.cn/”苏ICP备号-1/a Copyright www.python100.com .Some Rights Reserved.

    2024-09-23
    3
  • 如何查看PyCharm版本

    如何查看PyCharm版本作为一名Python工程师,我们经常使用PyCharm这款IDE进行代码开发,而不同的PyCharm版本具有不同的功能和特性,因此了解自己使用的PyCharm版本是非常重要的。本文将介绍如何查看当前 PyCharm 的版本号,帮助读者更好地掌握自己的工具。

    2024-08-16
    31
  • 自动备份任务设置_小米任务界面横排着设置

    自动备份任务设置_小米任务界面横排着设置本文主要利用SQL Server 2008 R2自带的”维护计划”创建一个自动备份数据的任务。 首先,启动 Sql Management studio,确保”SQL Server 代理”处于启动状态…

    2023-02-11
    148
  • 使用Python进行数据爬取

    使用Python进行数据爬取在当今的信息时代,数据分析和数据处理都已经成为日常生活和工作中不可或缺的一部分。而在获取数据的流程中,数据爬取无疑是其中最为重要和必要的一环。使用Python进行数据爬取在近些年也变得越来越流行和便捷,成为了许多数据分析师和数据科学家必备的技能之一。

    2024-07-08
    46
  • 合肥哪里可以开运输费发票-合肥_新闻网「建议收藏」

    合肥哪里可以开运输费发票-合肥_新闻网「建议收藏」合肥哪里可以开运输费发票【電薇同步;1.3.7 – 1.0.9.5 – 5.9.1.9.】李生、诚、信、合、作,保、真、售、后、保、障、长、期、有、效。adb的全称为Android Debug Br…

    2023-02-02
    151
  • 触发器insert

    触发器insertUSE [stalentzx]GO/****** Object: Trigger [dbo].[GZ_HISTORY_INSERT] Script Date: 2019/12/24 13:11:40

    2022-12-28
    148
  • 应用Python的for循环实现高效数据处理

    应用Python的for循环实现高效数据处理a href=”https://beian.miit.gov.cn/”苏ICP备2023018380号-1/a Copyright www.python100.com .Some Rights Reserved.

    2024-01-28
    127

发表回复

您的电子邮箱地址不会被公开。 必填项已用*标注