我正在尝试使用akka-http中的json对象流。( akka http版本"10.0.9"，akka-http-play-json版本1.10.1)could not find implicitFoo case类(我为其提供了json协议)：
could not find implici
浏览 6提问于2018-01-19得票数 0
我试图解组请求有效负载作为字符串，但由于某些原因它失败了。但也许这在akka-http中是不同的？我尝试导入有stringUnmarshaller的akka.http.scaladsl.unmarshalling.PredefinedFromEntityUnmarshallers，但是没有帮助。中也有一个字符串解组程序，但这也没有帮助
我如何解封(和马歇尔)为<e
浏览 1提问于2015-06-15得票数 13
回答已采纳
当我试图对响应进行两次解组时，我遇到了这个错误，这是因为我需要将响应作为case类，并且我还需要它作为json-string，因为对于对象，我在第一个流中使用它，在另一个第二个流中使用json-string，所以这就是为什么我需要这两个类。<init>(StreamOfStreams.scala:804) 代码： Http().singleRequest(HttpRequest( method = GET ,uri = s
浏览 18提问于2021-04-07得票数 1
我有一个使用akka流进行数据处理的akka-http应用程序。因此，使用Source[Result, _]完成请求以免费获得跨HTTP边界的背压是有意义的。版本：
complete { Created -> source.sing
浏览 2提问于2017-07-06得票数 1
回答已采纳
2回答
我使用的是akka流，我有一段图形需要有条件地跳过，因为流不能处理某些值。具体来说，我有一个接收字符串并发出http请求的流，但是当字符串为空时，服务器无法处理这种情况。但我只需要返回一个空字符串。有没有办法做到这一点，而不必通过http请求，知道它将失败？我基本上有这个：
val source = Source("1
浏览 1提问于2015-11-20得票数 15
回答已采纳
我在java项目中使用akka框架来处理HTTP服务，这就是为什么我使用javaDSL来处理akka流。所以，下面是我的故事。我创建了http缓存池(在我的参与者中)：val source = Source.single(HttpRe
浏览 12提问于2016-09-09得票数 2
1回答
如果我错过了一些简单的东西，我很抱歉，但我正在尝试通过Circe使用Akka HTTP (使用akka-http-json Circe模块)。我试图在混合了ErrorAccumulatingCirceSupport特征的ScalaTest中检索GET调用的结果。调用成功完成，但我无法解组响应...这是一个非常简单的测试，但我不确定如何将结果解组为域对象列表，例如： Get("&#x
浏览 9提问于2019-02-07得票数 2
回答已采纳
我在我的项目中使用了akka-http和reactivemongo，并使用了akka-http-spray json编组/解组case类。下面是它们的依赖关系："com.typesafe.akka" %% "
浏览 6提问于2018-08-29得票数 2
1回答
考虑到TCP提供本机流控制，我正在研究为什么某些系统实现应用程序级的背压。仅仅是为了从网络和TCP协议中抽象出异步通信的思想吗？其他更确切的问题是：
反应性流是否通过简单地让TCP处理它来实现TCP之上的应用层背压？
浏览 1提问于2018-03-27得票数 4
1回答
我试图从JSON中获取ints [1,2,3,...]的列表，但是我看到转换到泛型类型的方法不起作用，而喷雾文档只是显示了对特定对象的解组。有什么想法，如何使它工作/什么谷歌得到我的答案？API端点：import akka.http.scaladsl.Http
importakka.
浏览 5提问于2016-02-13得票数 0
回答已采纳
我有一个Akka流源，它通过流并发布HTTP请求： .via(Http().outgoingConnection(host))假设toRequest方法将字符串映射到HttpRequest，而toMessage方法将HttpResponse映射到下游处理所需的消息类。是否可以从HttpRequest中获得原始的HttpResponse？如果没有，是
浏览 1提问于2018-05-14得票数 2
回答已采纳
我有很多的网址，我想得到使用Akka HTTP，并使用流。我该怎么做呢？我已经搜索过了，但什么也没有找到，也找不到一种方法来处理文档本身中的esceptions。编辑:在摆弄了一下之后，我</
浏览 8提问于2020-05-07得票数 0
回答已采纳
我有一个用例，在Akka流的n流之后，我必须获取其中一个流的结果，并向HTTP提出请求。HTTP请求之前的最后一个akka流类型是一个字符串：现在，应该指定HTTP请求，我考虑了如下内容：
val stream2: Flow[String,F
浏览 3提问于2016-06-06得票数 3
回答已采纳
在探索Akka流时，我还遇到了Apache哪个流处理引擎。Akka流实现反应流并支持背压。
那么，如果我要在两者之间做出决定，我应该选择哪一个呢？它们有何不同之处，相似之处何在？
浏览 3提问于2020-04-23得票数 4
回答已采纳
在中：“目前没有提供公共API来解析(或呈现给)字符串或字节数组”。如何使用私有API将网络流解析为HttpRequest对象？
我的字节流将只包含http请求，而不包含响应。我是从pcap获得这个字节流的，而不是从一个活跃的http客户端获得的。
浏览 4提问于2016-01-27得票数 3
我将使用Scala和Akka Actors开发新的HTTP/REST服务。喷雾项目将独立于Akka-HTTP项目增长，还是这两个项目将合并成一个Akka-HTTTP？
如果我开始用喷雾剂发展，这会产生什么影响？我还读到剧本将整合AKKA
浏览 7提问于2015-03-24得票数 39
回答已采纳
我正在开发一个API客户端，其中我需要根据请求对JSON有效负载进行编码，并从响应中解码JSON主体。我已经阅读了几个库中的源代码，从我所看到的情况来看，我基本上有两种编码和解码JSON字符串的可能性。使用传递整个响应字符串if err == nil && data !json.Unmarshal(dat
浏览 73提问于2014-01-18得票数 256
回答已采纳
1回答
基本上，给出了一个字节流，我希望能够解析来自它的HTTP请求，可能会操纵某个东西并将其呈现为一个字节字符串。无论是请求还是答复。理想的情况下，严格和块状的要求。在主体中，在输入流、java流、反应性流或类似的东西上工作的操纵Http代理(客户机和服务器)。就像这样：
stream of bytes <-> HttpLib <-> customCode <-> HttpLib <-> stream of b
浏览 1提问于2016-06-24得票数 0
回答已采纳
我正在构建一个应用程序，在该应用程序中，我接受用户的请求，调用REST以获取一些数据，然后基于该响应进行另一个HTTP调用，等等。基本上，我正在处理一个数据树，树中的每个节点都要求我递归地调用这个API，如下所示： / \ / \ \我使用Akka HTTP与Akka流一起构建应用程序，所以
浏览 2提问于2021-07-06得票数 0
回答已采纳
1回答
我有一个示例下载代码，如果没有压缩文件，它可以正常工作，因为我知道文件的长度，当我提供的时候，我认为当流播放时，不一定要把整个文件放在内存中，而且它可以工作。), Some("application/zip"))).withHeaders("Content-Disposition" -> s"attachment; filename=backup")我不知道上述情况下的流如何处理磁盘读取之间的速度差异但是，
浏览 3提问于2017-09-12得票数 2
云服务器
ICP备案
云直播
对象存储
实时音视频
腾讯云开发者
