最近在开发中使用akka http进行请求，返回的是一个future，并且要对future进行超时设置，不知怎么设置，因此学习了下。 一、Future阻塞 首先，scala中的future不支持内置超时，要想达到这样的目的，可以使用Await进行阻塞，具体例子如下： 上面的代码将超时，报如下错误： ...
分类：
其他好文 时间：
2018-09-24 16:52:27
阅读次数：
294
熔断器，在很多技术栈中都会出现的一种技术。它是在分布式系统中提供一个稳定的阻止嵌套失败的机制。 该怎么理解呢？简单来说，在分布式环境中，如果某个计算节点出现问题，很容易出现失败的逆向传到或整个系统的雪崩。什么意思呢？比如某个服务按照顺序依次调用了其他的三个服务，分别为A/B/C。如果B服务由于某种原 ...
分类：
其他好文 时间：
2018-09-14 12:03:33
阅读次数：
229
[From] https://blog.csdn.net/linuxarmsummary/article/details/79399602 Akka in JAVA(一) AKKA简介 什么是AKKA Akka是一个由Scala编写的,能兼容Sacala和JAVA的,用于编写高可用和高伸缩性的Act ...
分类：
其他好文 时间：
2018-09-05 19:48:46
阅读次数：
169
Spark RPC是spark个模块之间通信的基础,之前采用的事akka模型,在1.6之后基于netty编写了类似于akka的通信框架. spark RPC涉及到的类图如下 RpcEnv是RPC模块中的主要的抽象类，其中定义了RPC调用涉及的主要对象和方法。RpcEnv负责注册维护RpcEndpoi ...
分类：
其他好文 时间：
2018-08-27 21:31:20
阅读次数：
168
上一篇博客我们研究了集群的分片源码，虽然akka的集群分片的初衷是用来解决actor分布的，但如果我们稍加改造就可以很轻松的开发出一个简单的分布式缓存系统，怎么做？哈哈很简单啊，实体actor的id就是key，actor的状态就是value，而且还可以无锁的改变状态。 其实akka的Distribu ...
分类：
其他好文 时间：
2018-08-22 16:46:55
阅读次数：
277
在ClusterClient源码分析中，我们知道，他是依托于“Distributed Publish Subscribe in Cluster”来实现消息的转发的，那本文就来分析一下Pub/Sub是如何实现的。 还记得之前分析Cluster源码的文章吗？其实Cluster只是把集群内各个节点的信息通 ...
分类：
其他好文 时间：
2018-08-17 17:13:29
阅读次数：
194
使用过akka的应该都知道，默认情况下，消息是按照最多一次发送的，也就是tell函数会尽量把消息发送出去，如果发送失败，不会重发。但有些业务场景，消息的发送需要满足最少一次，也就是至少要成功发送一次。akka在Persistence的基础之上提供了at-least-once传递的语法。 简单来说ak ...
分类：
其他好文 时间：
2018-08-09 12:15:53
阅读次数：
164
akka中的EventBus其实是不常用，也最容易被忽略的一个组件。 但如果你深入Cluster的实现就会发现，这个东西其实还挺有用的，而且它是ActorSystem系统中所有事件消息的一个横切面，通过它你可以订阅特定类型的消息，然后做出相应的动作。那读者可能会问了，这个订阅消息也很简单的啊，我自己 ...
分类：
其他好文 时间：
2018-08-07 12:48:54
阅读次数：
317
前面几篇博客，我们依次介绍了local和remote的一些内容，其实再分析cluster就会简单很多，后面关于cluster的源码分析，能够省略的地方，就不再贴源码而是一句话带过了，如果有不理解的地方，希望多翻翻之前的博客。 在使用cluster时，配置文件中的akka.actor.provider ...
分类：
其他好文 时间：
2018-08-02 16:57:42
阅读次数：
560
actor锚定模式是指使用actorSelection对acor进行锚定的设计模式，也可以说是一个对actor的引用技巧。在某些情况下，我们可能需要能够根据Actor的path锚定对应的实例。简单来说就是，无论actor是因为异常导致的restart还是用户主动stop，然后再重新actorOf，只 ...
分类：
其他好文 时间：
2018-07-31 19:11:03
阅读次数：
154
