1.概述

本博客是视频的笔记，这个是讲解 flink 1.12 源码的，入门非常的好。

尚硅谷2021最新Flink内核源码解析课程（从入门到精通）

2.介绍

Flink内部节点之间的通信是用Akka，比如JobManager和TaskManager之间的通信。而operator之间的数据传输是利用Netty。

Flink通过Akka进行的分布式通信的实现，在0.9版中采用。使用Akka，所有远程过程调用现在都实现为异步消息。这主要影响组件JobManager，TaskManager 和JobClient。

将来，甚至有可能将更多的组件转换为参与者，从而允许它们发送和处理异步消息。RPC框架是Flink任务运行的基础，Flink整个RPC框架基于Akka实现，并对Akka中的ActorSys

【Flink】FLink 通讯组件 Akka与Actor 模型相关推荐

【Akka】Actor模型探索
Akka是什么 Akka就是为了改变编写高容错性和强可扩展性的并发程序而生的.通过使用Actor模型我们提升了抽象级别,为构建正确的可扩展并发应用提供了一个更好的平台.在容错性方面我们采取了" ...
Akka入门（二）Akka的Actor模型如何满足现代分布式系统需求
Actor模型允许开发者: 在不诉诸锁定的情况下实施封装. 使用协作实体的模型对信号做出反应,改变状态,并相互发送信号以推动整个应用程序向前发展. 不要担心与我们的世界观不匹配的执行机制. (一) 消 ...
spark 如何用netty实现akka的actor模型
Spark的中,通过netty实现了类似akka的actor机制. 在spark中,一个EndPointData就类似一个akka中的actor. private class EndpointData ...
scala之Akka的Actor模型（上）
原文地址:http://my.oschina.net/jingxing05/blog/287213 明确并行和并发看两张图并行parallelism 并发concurrency 关键点在于多个任 ...
Akka之actor模型
一定义Actor import akka.actor.{Props, ActorSystem, Actor} import akka.actor.Actor.Receive import akka. ...
Scala Akka的Actor模型
Actor模型与Akka
Actor模型与Akka 一. Actor模型 Actor模型概念一个概念模型,用于处理并发计算 Actor模型内部的状态由自己的行为维护,外部线程不能直接调用对象的行为,必须通过消息才能激发行为, ...
95-848-020-源码-AKKA-Akka与Actor 模型
1.概述 Akka是一个用来开发支持并发.容错.扩展性的应用程序框架.它是actor model的实现,因此跟Erlang的并发模型很像.在actor模型的上下文中,所有的活动实体都被认为是互不依赖的 ...
actor 模型原理（二）
现在开始研究一下akka的actor模型是怎么实现的: 老外写了一个程序说明actor的工作机制,下图就是学生给老师发邮件的具体示意图,那么1-6一共6个步骤 1.学生创建actor system , ...

【Flink】FLink 通讯组件 Akka与Actor 模型

1.概述

2.介绍

【Flink】FLink 通讯组件 Akka与Actor 模型相关推荐

最新文章

热门文章