标签: akka-stream

Scala实战:使用Akka Stream优化异步代码

Scala扫盲行动 背景今天同事在开发一个消息推送功能,业务还是比较简单的: 通过地区查找这个区域内的所有组织 通过组织ID获取每个组织的所有用户 通过用户ID获得所有绑定了设备IMEI号 通过IMEI号向设备上推送消息 0 业务代码123456789101112131415implicit val system = ActorSystem()implicit val mat = Act

Akka实战:再谈断点上传

去年的文章:《Akka实战:HTTP大文件断点上传、下载,秒传》 通过示例介绍了在Akka HTTP里怎样实现断点上传功能。通过一段时间的应用,发现了些问题,这篇文章再深入介绍下。在 https://github.com/yangbajing/scala-applications/tree/master/file-upload能找到完整的源码。 Nginx代理Nginx代理时默认会在Nginx端收

Alpakka Kafka,反应式Kafka客户端

Alpakka Kafka 是一个要用于 Java 和 Scala 语言的开源的流感知和反应式集成数据线项目。它建立在 Akka Stream之上,提供了 DSL 来支持反应式和流式编程,内置回压功能。Akka Streams 是 Reactive Streams 和JDK 9+ java.util.concurrent.Flow 的兼容实现,可无缝地与其进行互操作。 要使用 Alpakka Ka