Qconn

Akka下分片集群的实现

讲师: 

Akka 2.3.0开始,提供了cluster sharding和persistence功能,这意味着有状态的Actors现在可以由Akka来自动管理分片集群,并在节点或者actor当掉时恢复状态并几乎立即可用。那么Akka的这些功能是怎么实现的呢?本次分享将以我们在豌豆荚实验室实现的有状态长连接集群spray-socketio为例介绍这些功能,并给出了一个将Transport/State/Business合理分层且实现了实时流式消息接入的架构。

豌豆荚平台服务架构师
微博: @邓草原

出生于1967年,现任豌豆荚平台服务架构师。邓草原曾在2000年前后任某互联网公司CTO,后移居加拿大温哥华,作为自由职业者长年从事开源软件的开发。2008年后回到北京,在加入豌豆荚之前曾任职方正证券金融工程部,担任首席专家,开发并行、分布式实时金融计算和交易平台。邓草原在并行分布式实时计算领域有丰富的经验,为AIOTrade开源金融交易平台的开发者。他还是Erlang、Scala等语言的爱好者和推广者,也是这两种语言在NetBeans上IDE的开发者,为NetBeans梦之队成员。目前正与豌豆荚的同事一起开发基于Akka和Spray的WebSocket和Socket.IO的开源实现,并尝试在移动互联领域实现大规模的实时流式计算。