Slick 中如何使用反应流来插入数据
在 Slick 的文档中，提供了使用反应流的示例仅用于读取数据作为 DatabasePublisher 的一种方式.但是，当您想根据插入率将数据库用作 Sink 和 backpreasure 时会发生什么? 我已经寻找了等效的DatabaseSubscriber，但它不存在.所以问题是，如果我有来源，请说: val 源 = 源(0 到 100) 我怎样才能用 Slick 构造一个
..
akka-stream相关内容
map 和 mapAsync 的区别
谁能解释一下 map 和 mapAsync w.r.t AKKA 流之间的区别?在文档中据说 涉及外部非流的流转换和副作用可以使用 mapAsync 或 mapAsyncUnordered 执行基于服务的服务 为什么我们不能简单地在这里映射?我假设 Flow、Source、Sink 本质上都是 Monadic，因此 map 应该可以正常工作，w.r.t w.r.t w.r.t w.r.
..
为什么 Akka 流循环不在此图中结束?
我想创建一个在下沉之前循环 n 次的图.我刚刚创建了这个满足我要求的示例，但在下沉后并没有结束，我真的不明白为什么.有人能指教我吗? 谢谢. 导入 akka.actor.ActorSystem导入 akka.stream.scaladsl._导入 akka.stream.{ActorMaterializer, UniformFanOutShape}导入 scala.concurrent.
..
Akka-Stream 实现比单线程实现慢
2015 年 10 月 30 日更新 基于 Roland Kuhn Awnser: Akka Streams 使用 Actors 之间的异步消息传递来实现流处理阶段.跨数据传递异步边界有一个你在这里看到的开销:你的计算似乎只需要大约 160ns(来自单线程测量)，而流解决方案需要每个元素大约 1µs，主要由消息传递决定. 另一个误解是说“流"意味着并行:在您的代码所有计算都在单个
..
如何在断开连接后清理 akka-http websocket 资源然后重试?
下面的代码成功建立了一个websocket连接. websockets 服务器(也是 akk-http)使用 Andrew 在此处建议的答案故意关闭连接. 下面的 SinkActor 收到一条 akka.actor.Status.Failure 类型的消息，所以我知道从服务器到客户端的消息流已经中断.> 我的问题是...我的客户端应该如何重新建立 websocket 连接?sourc
..
Akka-http 在一个流中处理来自不同连接的 HttpRequests
Akka-http 文档 说: 除了将绑定在服务器端的套接字视为Source[IncomingConnection] 和每个连接作为一个Source[HttpRequest] 和 Sink[HttpResponse] 假设我们得到了包含来自许多 Source[IncomingConnection] 的传入连接的合并源. 然后，假设我们从 Source[IncomingConnec
..
akka-http 中的连接池使用源队列实现线程安全吗?
参考下面提到的实现: http://doc.akka.io/docs/akka-http/10.0.5/scala/http/client-side/host-level.html val poolClientFlow = Http().cachedHostConnectionPool[Promise[HttpResponse]]("akka.io")val 队列 =Source.queu
..
akka-stream + akka-http 生命周期
TLDR:当我将传出 http 请求作为流的一部分时，是按请求具体化一个流(即使用短期流)还是跨请求使用单个流具体化? 详细信息:我有一个典型的服务，它接受一个 HTTP 请求，将其分散到几个 3rd 方下游服务(不受我控制)并在将结果发回之前聚合结果.我将 akka-http 用于客户端实现，并使用 Spray 作为服务器(传统，随着时间的推移将转移到 akka-http).示意图:
..
Akka Stream + Akka Http - 获取错误请求
我有以下流，效果很好: 源代码.map(x => HttpRequest(uri = x.rawRequest)).via(Http().outgoingConnection(host, port)).to(Sink.actorRef(myActor, IsDone)).跑() 还有一个简单的actor来处理流完成时的响应状态和最终消息: /*** 一个简单的actor来计算已经处理了多少行
..
如何在响应流中将消息从订阅者发送到 Web 套接字连接中的发布者
我的应用程序有一个 Akka-Websocket 接口.Web 套接字由参与者订阅者和参与者发布者组成.订阅者通过将命令发送给相应的参与者来处理命令.发布者侦听事件流并将更新信息发布回流(并最终发布到客户端).这很好用. 我的问题:订阅者如何将事件发送回流?例如确认接收到的命令的执行. public class WebSocketApp extends HttpApp {private s
..
使用 Akka 将文件从服务器流式传输到客户端
基本上我想允许用户从服务器下载 csv 文件.假设 CSV 文件已存在于服务器上.API 端点通过 GET/export 公开.如何将文件从 Akka HTTP 服务器流式传输到客户端?这是我到目前为止... 服务: def export(): Future[IOResult] = {FileIO.fromPath(Paths.get("file.csv")).to(Sink.ignore
..
Akka Flow 在通过连接池发出 http 请求时挂起
我正在使用 Akka 2.4.4 并尝试从 Apache HttpAsyncClient 迁移(未成功). 以下是我在项目中使用的代码的简化版本. 问题是，如果我向流发送超过 1-3 个请求，它就会挂起.到目前为止，经过 6 个小时的调试，我什至无法找到问题所在.我在 Decider 中没有看到异常、错误日志、事件.什么都没有:) 我尝试将 connection-timeout
..
在流中链接 Akka-http-client 请求
我想使用 akka-http-client 作为 Stream 链接 http 请求.链中的每个 http 请求都依赖于先前请求的成功/响应，并使用它来构建新的请求.如果请求不成功，Stream 应该返回不成功请求的响应. 如何在 akka-http 中构建这样的流?我应该使用哪个 akka-http 客户端级 API? 解决方案 如果您正在制作网络爬虫，请查看 这篇文章.该答案解决
..
如何使用 akka-http 对自认证服务器进行 POST 调用
我有一个 akka-streams 拓扑，我使用 akka-http 进行 POST 调用. 在向不安全的服务器(具有自签名证书)发送发布请求时出现以下错误.它是一个内部服务器，所以从安全的角度来看我很好. javax.net.ssl.SSLHandshakeException: 一般 SSLEngine 问题在 sun.security.ssl.Handshaker.checkThrow
..
如何响应actor调用的结果?
我们正在考虑使用 Akka-HTTP Java API - 使用路由 DSL. 不清楚如何使用路由功能来响应一个HttpRequest；使用无类型 Akka Actor.例如，匹配 Route 路径后，我们如何将请求传递给“处理程序"ActorRef，然后以异步方式响应 HttpResponse? Akka-User 邮件列表上发布了一个类似的问题，但没有后续解决方案 - https:
..
如何使用 akka http 发送文件作为响应?
我对 akka 世界有点陌生，所以我的知识领域有点小.我正在创建一个 https 服务器并使用 akka 流和 http 处理它，对于特定的 url，我需要将文件发送回客户端.我如何使用 akka 流并避免使用 akka 路由来实现这一点. def handleCall(request:HttpRequest):HttpResponse = {logger.info("请求是{}",reques
..
使用 Spark DStream 作为 Akka 流的源的惯用方式
我正在构建一个 REST API，它在 Spark 集群中启动一些计算，并以分块的结果流进行响应.给定有计算结果的 Spark 流，我可以使用 dstream.foreachRDD() 将数据发送出 Spark.我正在使用 akka-http 发送分块的 HTTP 响应: val requestHandler: HttpRequest =>HttpResponse = {case HttpR
..
从服务器关闭 akka-http websocket 连接
在我的场景中，客户端发送“再见"websocket 消息，我需要关闭之前在服务器端建立的连接. 来自 akka-http 文档: 通过取消来自服务器逻辑的传入连接流(例如，通过将其下游连接到 Sink.cancelled 并将其上游连接到 Source.empty)，可以关闭连接.也可以通过取消 IncomingConnection 源连接来关闭服务器的套接字. 但考虑到 Sin
..
akka-http 发送连续分块的 http 响应(流)
我有这个带有 akka-http 客户端和服务器的粗略测试示例. Server.scala: import akka.actor.ActorSystem导入 akka.stream.ActorMaterializer导入 akka.stream.scaladsl.Sink导入 akka.http.scaladsl.Http导入 akka.http.scaladsl.model.HttpMe
..
使用 Play 2.6 和 akka 流的 Websocket 代理
我正在尝试使用 Play 和 akka 流为 Websocket 连接创建一个简单的代理.流量是这样的: (客户端)请求 ->->请求(服务器)代理(客户端)响应 在遵循一些示例之后，我想出了以下代码: def socket = WebSocket.accept[String, String] { request =>val uuid = UUID.randomUUID().toStrin
..