StatefulSet 简介 在Kubernetes中,Pod的管理对象RC、Deployment、DaemonSet和Job都是面向无状态的服务。但现实中有很多服务是有状态的,特别是一些复杂的中间件集群,例如MySQL集群、MongoDB集群、Akka集群、ZooKeeper集群等。 以上集群有几 ...
分类:
Web程序 时间:
2019-10-05 12:10:03
阅读次数:
107
在 Actor 模型中所有的 Actor 之间有且只有一种通信模式,那就是 tell 的方式,也就是 fire and forget 的方式。但是在实际的开发过程中工程师们逐渐总结出了一些常用的通信模式。本文以 akka typed(2.6.0 M8) 框架为例,介绍存在于 actor 模型中最基本 ...
分类:
其他好文 时间:
2019-10-04 16:36:28
阅读次数:
59
可扩展的实时事务处理 我们相信编写并发、容错、可扩展的应用相当的困难。盖因大多数时候我们一直在使用错误的工具和错误的抽象等级。AKKA就是为了改变这一切的。我们利用角色模型提升了抽象等级,并且提供了一个用来构建可扩展的、弹性的以及响应式应用的更好的平台——更多信息请见Reactive Manifes ...
分类:
编程语言 时间:
2019-09-19 13:47:34
阅读次数:
88
原文:http://doc.akka.io/docs/akka/2.3.6/general/terminology.html 译者:吴京润 本章我们试图建立一个通用的术语列表,用来定义有关并发和分布式系统的坚实的基础,而这也是akka的目标。请注意,在这些术语当中许多并没有一致的定义。我们简单的寻求 ...
分类:
编程语言 时间:
2019-09-19 12:30:27
阅读次数:
73
Actor 类定义 Actor 类需要继承AbstractActor类 实现createReceive方法,绑定各类actor收到不同类型消息对应处理不同业务逻辑 默认提供了ReceiveBuilder类辅助创建 Receive 对actorOf的调用返回ActorRef的实例。这是 Actor 实 ...
分类:
其他好文 时间:
2019-09-12 13:48:53
阅读次数:
90
起因 得到ActorRef就可以给actor发送消息,但无法接收多回复,也不知道actor是否停止 Inbox收件箱出现就是解决这两个问题 示例 ...
分类:
其他好文 时间:
2019-09-12 13:45:48
阅读次数:
111
前言......... Actor模型作为Akka中最核心的概念,所以Actor在Akka中的组织结构是至关重要,本文主要介绍Akka中Actor系统。 1.Actor系统 Actor作为一种封装状态和行为的对象,总是需要一个系统去统一的组织和管理它们,在Akka中即为ActorSystem,其实这 ...
分类:
其他好文 时间:
2019-09-06 16:07:35
阅读次数:
86
背景介绍 在项目中使用了akk stream的source.queue功能,如下: 但是,如果在使用reqSourceQueue.second().runForeach方法来对流中的元素进行处理时,如果处理代码出现错误,也不抛异常,并且整个流中断了,继续往queue中offer元素也不起作用了。查看 ...
分类:
其他好文 时间:
2019-09-06 12:46:40
阅读次数:
91
Scala编程实战 1. 课程目标 1.1. 目标:使用Akka实现一个简易版的spark通信框架 2. 项目概述 2.1. 需求 Hivesql > select count(*) from user >整个表只有1条数据 Map 0% reduce 0% Map 10% reduce 0% Ma ...
分类:
其他好文 时间:
2019-08-22 00:59:40
阅读次数:
82
要看这一节。。。 10. Scala Actor并发编程 10.1. 课程目标 10.1.1. 目标一:熟悉Scala Actor并发编程 10.1.2. 目标二:为学习Akka做准备 注:Scala Actor是scala 2.10.x版本及以前版本的Actor。 Scala在2.11.x版本中将 ...
分类:
其他好文 时间:
2019-08-19 00:18:18
阅读次数:
153