以下来自文档(akka): 交货保证 流裁判将正常的演员消息传递用于他们的体育比赛,因此提供了相同水平的基本交付保证。流引用确实通过需求重新传递和顺序故障检测在某种程度上扩展了语义。换一种说法: messages are sent over actor remoting which relies on TCP (classic remoting or Artery TCP) or Aeron UDP for basic redelivery mechanisms messages are guaranteed to…

2019年6月17日 0条评论 29点热度 阅读全文

我有一个要求客户调用通过akka http创建的post REST端点。一旦请求进入post方法,我就需要将post对象传递给流(由源,多个流和接收器组成),并从接收器获取响应,以便可以将响应返回给客户端。 我浏览了一些文章,并看了下面的代码,但担心我不想为每个请求实现流。我只想实现一个流,并继续将元素传递到该流。 以下是我所看到的高层次: val route: Route = path("dummy path") { p => get { (extract(_.request) & extractM…

2019年5月6日 0条评论 28点热度 阅读全文

这是类(class): import akka.Done; import akka.NotUsed; import akka.actor.ActorSystem; import akka.http.javadsl.ConnectHttp; import akka.http.javadsl.Http; import akka.http.javadsl.model.ContentTypes; import akka.http.javadsl.model.HttpEntities; import akka.http.ja…

2019年4月18日 0条评论 33点热度 阅读全文