240 发简信
IP属地:山东
  • 脚本启动akka程序

    使用shell脚本启动akka程序,参考于GearPump项目 准备工作:便于测试修改,直接运行编译出的class来启动。在根目录下创建bin目录放shell脚本,创建lib...

  • 《歌·颂》

    为什么我喜欢听粤语歌? 喜欢它六调的发音,完美融入旋律中。 喜欢它句句押韵的快感,即使发不准音也觉得乐趣无穷。 喜欢它可以有,林夕黄伟文这样的词圣能把爱情写的凄美浪漫,把生活...

  • 120
    Akka sharding示例

    这个示例来自Lightbend的 Lightbend Project Starter里的Cluster Sharding Scala。是一个简单的分片集群用做记录温度的例子:...

  • 120
    Akka分片集群的实现-邓草原

    最近在学习 邓草原用akka实现的实时流式消息处理的架构,整合一下演讲和ppt,方便自己理解。http://www.infoq.com/cn/presentations/ak...

  • Akka 2.5.12 I/O 层设计

    需求 数百万条并发连接的可伸缩性 从输入通道获取数据到目标actor的邮箱,这个过程中的最低延迟 最大的吞吐量 可选的双向 back-pressure(例如,限制本地发送者...

  • Akka 2.5.12 Using TCP

    本部分内容都需要引用: 所有的 Akka I/O API都需要通过manager访问,当使用 I/O API时,第一步就是对manager的引用。 manager是处理底层I...

  • Akka 2.5.11 I/O

    akka.io包是结合spray-io模型开发的。 I/O 为了达到极端的可伸缩性,必须有一个可以正确匹配的底层传输机制,完全由事件驱动,并且是非阻塞和异步的。该模块提供了一...

  • Akka 2.5.11 分布式发布订阅

    Distributed Publish Subscribe in Cluster 通过了解Akka集群后,我们可能会产生两个问题 如果我们要发送消息到某个actor但是我们不...

  • 120
    Akka 2.5.11 Cluster Client 集群客户端

    ClusterClient是一个集群客户端,主要用于集群外部系统与集群通信,只需要知道一个集群中的节点作为初始的联络点。就可将这个节点注册为该集群的接待员(reception...

  • 120
    Akka 2.5.11 路由 Routing

    当处理到来的消息流时,我们需要一个actor来引导消息路由到目标actor,从而提高消息的分配效率。在Akka中这个 actor就是Router。它所管理的一些目标actor...

  • 120
    Akka 2.5.11 持久化 Persistence 中文文档

    持久化 当我们在集群系统中,一台机器向另一台机器发送一段数据,负责接收的机器在接收数据前突然宕机,就会造成数据丢失无法恢复。Akka实现了对actor 持久化的方法来恢复数据...