本地安装教程 Setup: Download and Start Flink Start a Local Flink Cluster Read the Code Run the Example Next Steps 本地安装教程 Get a Flink example program up and running in a few simp...

事件总线 日志记录 调度程序 持续时间 断路器 Java 8 兼容性 Akka 扩展

Local Setup Tutorial Setup: Download and Start Flink Start a Local Flink Cluster Read the Code Run the Example Next Steps Local Setup Tutorial Get a Flink example program ...

容错示例 容错示例完整源代码" level="5"> 容错示例完整源代码 容错示例 以上图示了正常的消息流。 正常流程： 步骤 描述 1 过程Listener 启动工作。 2 Worker 通过定期向自己发送Do 消息来计划工作 3, 4, 5 接收到Do 时Worker 通知CounterServic...

消息传递可靠性 一般规则 讨论：“至多一次”是什么意思？ 讨论：为什么不保证传递？ 讨论：消息排序 通信故障 在 JVM（本地）消息发送的规则 小心你对这部分的操作！ 本地消息发送的可靠性 本地消息发送顺序 本地顺序与网络顺序有什么关系？ 高级抽象 消息模式 事件源 带明确确认的邮箱 死信 应该用死信做什么？ 如何收到死信？ ...

FAQ Riker的目标是什么？ Actor如何与Future相比？ Actor如何与线程比较？ Riker可以在多个主机上运行吗？ 多个ActorSystem实例可以在同一个应用程序中运行吗？ Riker是否使用不安全的代码？ 有没有基准？ FAQ Riker的目标是什么？ Riker的主要目标是成为一个框架，使并发，弹性软件开发...

Vert.x Reactive Streams 中英文对照表 使用 Vert.x Reactive Streams Reactive Read Stream Reactive Write Stream Vert.x Reactive Streams 原文档 组件源码 中英文对照表 publisher(n.)：发布者 subscr...

调度器 缺省派发器 查找一个派发器 为Actor指定派发器 派发器的类型 更多 dispatcher 配置的例子 调度器 Akka MessageDispatcher 是维持 Akka Actor “运作”的部分, 可以说它是整个机器的引擎。所有的MessageDispatcher 实现也同时也是一个ExecutionContext ，这意...

集群中的分布式发布订阅 依赖 简介 发布 主题组 发送 DistributedPubSub 扩展 传递保证 集群中的分布式发布订阅 依赖 为了使用分布式发布订阅（Distributed Publish Subscribe ），你需要将以下依赖添加到你的项目中： <!-- Maven --> <dependency> ...

Futures 简介 执行上下文 在Actor中 用于 Actor 直接使用 函数式 Future Future 是 Monad For Comprehensions 组合 Futures 回调 定义次序 辅助方法 异常 After Futures 注：本节未经校验，如有问题欢迎提issue 简介 在 Akka...