Stella981 Stella981
2年前
Akka实战:构建REST风格的微服务
使用AkkaHttp构建REST风格的微服务,服务API应尽量遵循REST语义,数据使用JSON格式交互。在有错误发生时应返回:{"errcode":409,"errmsg":"aaisinvalid,theIDisexpectedtobebb"}类似的JSON错误消息。代码:https://github.com/ya
Stella981 Stella981
2年前
Spark RPC通讯机制
Spark1.6推出了RPCEnv,RPCEndpoint,RPCEndpointRef为核心的新型架构下的RPC通信方式。早期版本当中,有netty和Akka两种实现方式。但是从最新的2.11代码来看,Akka已经找不到了。关于netty的更多知识,可以查看之前的文章。RpcEndpoint和RpcEndpointRef有一个管理者:RpcEnv。
Stella981 Stella981
2年前
Scala编程实战
项目概述需求目前大多数的分布式架构底层通信都是通过RPC实现的,RPC框架非常多,比如前我们学过的Hadoop项目的RPC通信框架,但是Hadoop在设计之初就是为了运行长达数小时的批量而设计的,在某些极端的情况下,任务提交的延迟很高,所以Hadoop的RPC显得有些笨重。Spark的RPC是通过Akka类库实现的,Akka用
Wesley13 Wesley13
2年前
AKKA事件机制
AKKAEventBus事件机制就用于当前运行环境,与集群环境不同,详细见AKKA集群中的发布与订阅DistributedPublishSubscribeinCluster(https://www.oschina.net/action/GoToLink?urlhttps%3A%2F%2Fwww.cnblo
Stella981 Stella981
2年前
Akka系列之Logging
在akka中如何使用logakka中显示日志不需要第三方jar,直接使用akka的Logging即可,Logging默认是输出到STDOUT,当然你也可以使用第三方插件如SLF4J来记录日志,Logging使用的异步方式以此来达到最小的性能损耗.代码中使用Loggingimportakka.actor.;
Stella981 Stella981
2年前
Akka Stop Kill PoisonPill 区别
AkkaStopKillPoisonPill区别(https://www.oschina.net/action/GoToLink?urlhttps%3A%2F%2Fwww.cnblogs.com%2Fyunfeiqi%2Fp%2F7052843.html)
Stella981 Stella981
2年前
Akka源码分析
  akka中的EventBus其实是不常用,也最容易被忽略的一个组件。  但如果你深入Cluster的实现就会发现,这个东西其实还挺有用的,而且它是ActorSystem系统中所有事件消息的一个横切面,通过它你可以订阅特定类型的消息,然后做出相应的动作。那读者可能会问了,这个订阅消息也很简单的啊,我自己实现不就好了。嗯,其实你这个想法是对的,akka所
Stella981 Stella981
2年前
Scala的一些产品及其链接
Kafkahttp://kafka.apache.org/(https://www.oschina.net/action/GoToLink?urlhttp%3A%2F%2Fkafka.apache.org%2F)Akkahttp://akka.io/(https://www.oschina.net/action/GoToLink?url
Stella981 Stella981
2年前
Akka
在实际应用中,集群环境里共用一些数据是不可避免的。我的意思是有些数据可以在任何节点进行共享同步读写,困难的是如何解决更改冲突问题。本来可以通过分布式数据库来实现这样的功能,但使用和维护成本又过高,不值得。分布式数据类型distributeddata(ddata)正是为解决这样的困局而设计的。akka提供了一组CRDT(ConflictFreeReplic