腾讯云开发者社区-腾讯云

开发者社区

文档建议反馈控制台

最新优惠活动

文章/答案/技术大牛

发布

函数式编程语言及工具

专栏作者

283

文章

264545

阅读量

67

订阅数

ScalaPB（5）：用akka-stream实现reactive-gRPC

scala react rpc

在前面几篇讨论里我们介绍了scala-gRPC的基本功能和使用方法，我们基本确定了选择gRPC作为一种有效的内部系统集成工具，主要因为下面gRPC支持的几种服务模式： 1、Unary-Call：独立的一对client-request/server-response，是我们常用的http交互模式 2、Server-Streaming：client发出一个request后从server端接收一串多个response 3、Client-Streaming：client向server发送一串多个reques

2018-05-28

1.2K0

SDP（7）：Cassandra- Cassandra-Engine：Streaming

数据库 react scala

akka在alpakka工具包里提供了对cassandra数据库的streaming功能。简单来讲就是用一个CQL-statement读取cassandra数据并产生akka-stream的Source。这是一个支持reactive-stream协议的流： object CassandraSource { /** * Scala API: creates a [[CassandraSourceStage]] from a given statement. */ def apply(

2018-03-16

3.3K0

Akka（35）： Http：Server side streaming

scala http react 编程算法

该文介绍了如何使用Akka HTTP和Slick在Scala中实现基于HTTP的流式数据传输。通过使用Akka HTTP和Slick，可以方便地处理HTTP请求和响应，以及从数据库中获取数据并将其传输到客户端。该文还介绍了如何使用Akka流式处理技术来实现HTTP服务，并处理响应数据。

2018-01-05

7850

Akka（20）： Stream：异步运算，压力缓冲-Async, batching backpressure and buffering

akka-stream原则上是一种推式（push-model）的数据流。push-model和pull-model的区别在于它们解决问题倾向性：push模式面向高效的数据流下游（fast-dow

2018-01-05

8260

FunDA（7）－ Reactive Streams to fs2 Pull Streams

react api scala

Reactive-Stream不只是简单的push-model-stream, 它还带有“拖式”（pull-model）性质。这是因为在Iteratee模式里虽然理论上由Enumerator负

2018-01-05

6780

FunDA（9）－ Stream Source：reactive data streams

react api 数据库 sql

上篇我们讨论了静态数据源（Static Source, snapshot）。这种方式只能在预知数据规模有限的情况下使用，对于超大型的数据库表也可以说是不安全的资源使用方式。Slick3.x已经

2018-01-05

6190

FunDA（6）－ Reactive Streams：Play with Iteratees、Enumerator and Enumeratees

在上一节我们介绍了Iteratee。它的功能是消耗从一些数据源推送过来的数据元素，不同的数据消耗方式代表了不同功能的Iteratee。所谓的数据源就是我们这节要讨论的Enumerator。En

2018-01-05

6300

没有更多了

社区活动

腾讯技术创作狂欢月

“码”上创作 21 天，分 10000 元奖品池！

Python精品学习库

代码在线跑，知识轻松学

博客搬家 | 分享价值百万资源包

自行/邀约他人一键搬运博客，速成社区影响力并领取好礼

技术创作特训营·精选知识专栏

往期视频·千货材料·成员作品最新动态