一、Flink内核解析，针对版本1.12.0，四大块：任务的提交流程，组件通信，任务的调度，内存管理。 任务的提交流程：以命令行的提交命令开始追踪类，20多个步骤，几十个类，数千行代码量，最后画一个PPT动图 组件通信：actor的模型，akka基本原理和实现,5大关键角色：代理转发，处理细节，PP ...
分类：
其他好文 时间：
2021-06-18 19:53:27
阅读次数：
0
AKKA是可用于设计跨处理器核心和网络的可伸缩、有弹性的系统的开源库。使用Scala语言编写，是基于Actor模型处理并发，提供了Java和Scala的API。下面总结如何基于SpringBoot搭建hello world项目。 第一步引入依赖， <properties> <akka.version ...
分类：
其他好文 时间：
2020-11-02 10:45:33
阅读次数：
32
Dynamic stream handling 动态流处理 Dependency To use Akka Streams, add the module to your project: val AkkaVersion = "2.6.9" libraryDependencies += "com.ty ...
分类：
其他好文 时间：
2020-10-12 20:14:08
阅读次数：
21
赠书活动火热进行中，赶快参与吧！详情请查看《聊聊Akka》今天有个朋友咨询我一个问题，截图如下：qq.pngqq.png在忙完了自己的事情后，我也简单的看了下，然后写了一个Filter来实现这位朋友说的功能，其实就是想记录请求的参数信息，下面我把涉及到的请求都打印了一遍，当然日志格式你可以自定义。输出日志的FilterpublicclassDebugRequestextendsZuulFilter
分类：
编程语言 时间：
2020-08-03 23:23:16
阅读次数：
73
Lightbend推出的微服务框架Lagom，与Akka Typed自然耦合，为实现Domain-Driven Designed Distributed Application提供了完整的解决方案。 ...
分类：
其他好文 时间：
2020-07-26 19:04:18
阅读次数：
102
在Kubernetes系统中，Pod的管理对象RC、Deployment、DaemonSet和Job都面向无状态的服务。 但现实中有很多服务是有状态的，特别是一些复杂的中间件集群，例如MySQL集群、MongoDB集群、Akka集群、ZooKeeper集群等，这些应用集群有4个共同点。 （1）每个节 ...
分类：
其他好文 时间：
2020-07-04 22:23:09
阅读次数：
58
引言 朋友看罢我之前整理的《Akka Typed 官方文档之随手记》，一人用了诗歌《长城长》作为回赠，另一人则要求推出简化版本。于是抽空整理了几张思维导图，并且用了一些不太恰当的比喻，不知此番效果如何。 Markdown语法默认不支持图片比例，所以请使用右键点击图片 → 在新标签页中打开图片可看大图 ...
分类：
其他好文 时间：
2020-07-03 00:52:41
阅读次数：
91
前面介绍了事件源（EventSource）和集群（cluster），现在到了讨论CQRS的时候了。CQRS即读写分离模式，由独立的写方程序和读方程序组成，具体原理在以前的博客里介绍过了。akka-typed应该自然支持CQRS模式，最起码本身提供了对写方编程的支持，这点从EventSourcedBe ...
分类：
其他好文 时间：
2020-06-26 10:29:47
阅读次数：
52
前面提到过，akka-typed中较重要的改变是加入了EventSourcedBehavior。也就是说增加了一种专门负责EventSource模式的actor, 最终和其它种类的actor一道可以完美实现CQRS。新的actor，我还是把它称为persistentActor，还是一种能维护和维持运 ...
分类：
数据库 时间：
2020-06-06 12:41:30
阅读次数：
65
Spark 通信架构 1、spark 一开始使用 akka 作为网络通信框架，spark 2.X 版本以后完全抛弃 akka，而使用 netty 作为新的网络通信框架。最主要原因：spark 对 akka 没有维护，需要 akka 更新，spark 的发展受到了 akka 的牵制，akka 版本之间 ...
分类：
其他好文 时间：
2020-05-29 19:20:02
阅读次数：
70
