使用AkkaHttp构建REST风格的微服务，服务API应尽量遵循REST语义，数据使用JSON格式交互。在有错误发生时应返回：{"errcode":409,"errmsg":"aaisinvalid，theIDisexpectedtobebb"}类似的JSON错误消息。代码：https://github.com/ya

Spark1.6推出了RPCEnv，RPCEndpoint，RPCEndpointRef为核心的新型架构下的RPC通信方式。早期版本当中，有netty和Akka两种实现方式。但是从最新的2.11代码来看，Akka已经找不到了。关于netty的更多知识，可以查看之前的文章。RpcEndpoint和RpcEndpointRef有一个管理者：RpcEnv。

项目概述需求目前大多数的分布式架构底层通信都是通过RPC实现的，RPC框架非常多，比如前我们学过的Hadoop项目的RPC通信框架，但是Hadoop在设计之初就是为了运行长达数小时的批量而设计的，在某些极端的情况下，任务提交的延迟很高，所以Hadoop的RPC显得有些笨重。Spark的RPC是通过Akka类库实现的，Akka用

AKKAEventBus事件机制就用于当前运行环境，与集群环境不同，详细见AKKA集群中的发布与订阅DistributedPublishSubscribeinCluster(https://www.oschina.net/action/GoToLink?urlhttps%3A%2F%2Fwww.cnblo

在akka中如何使用logakka中显示日志不需要第三方jar,直接使用akka的Logging即可,Logging默认是输出到STDOUT,当然你也可以使用第三方插件如SLF4J来记录日志,Logging使用的异步方式以此来达到最小的性能损耗.代码中使用Loggingimportakka.actor.;

AkkaStopKillPoisonPill区别(https://www.oschina.net/action/GoToLink?urlhttps%3A%2F%2Fwww.cnblogs.com%2Fyunfeiqi%2Fp%2F7052843.html)

　　akka中的EventBus其实是不常用，也最容易被忽略的一个组件。　　但如果你深入Cluster的实现就会发现，这个东西其实还挺有用的，而且它是ActorSystem系统中所有事件消息的一个横切面，通过它你可以订阅特定类型的消息，然后做出相应的动作。那读者可能会问了，这个订阅消息也很简单的啊，我自己实现不就好了。嗯，其实你这个想法是对的，akka所

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

在实际应用中，集群环境里共用一些数据是不可避免的。我的意思是有些数据可以在任何节点进行共享同步读写，困难的是如何解决更改冲突问题。本来可以通过分布式数据库来实现这样的功能，但使用和维护成本又过高，不值得。分布式数据类型distributeddata（ddata）正是为解决这样的困局而设计的。akka提供了一组CRDT（ConflictFreeReplic