spray相关内容

执行上下文和调度程序-最佳实践,有用的配置和文档

Scala执行上下文和调度程序-列出和比较:为什么? 关于什么/如何/什么是执行Scala中的期货的最佳执行上下文还有很多问题,以及如何配置调度程序.仍然我无法找到包含优缺点和配置示例的更长列表. 我能找到的最好的方法是在Akka文档中: http://doc.akka.io/docs/akka/snapshot/scala/dispatchers.html 和Play文档 https ..
发布时间:2021-04-23 20:35:43 其他开发

如何告诉特定的喷涂客户请求遵循所有重定向?

我的应用程序中有一个特定的管道,该管道必须遵循所有域和协议中的所有重定向(例如,为了理智起见,最多可以进行50次重定向)(例如,它可以遵循 http://somewhere.com 到 https://somewhere.else.com ),但仅适用于GET请求.我的应用程序中没有其他管道可以执行此操作. 这是现在的样子: val pipeline = sendReceive ~> ..
发布时间:2020-07-25 19:15:42 其他开发

使用Spray Client进行多个请求时的akka​​超时

在akka 2.3.6中使用喷雾1.3.2. (akka仅用于喷雾). 我需要读取巨大的文件,并为每一行发出一个http请求. 我用迭代器逐行读取文件,并为每个项目提出请求. 它在某些行中成功运行,但有时会因以下原因而失败: akka.pattern.AskTimeoutException: Ask timed out on [Actor[akka://default/user/IO-HTT ..
发布时间:2020-07-25 19:15:34 其他开发

用Spray-json处理默认值的好方法是什么

在某些情况下,对于案例类,默认值比可选参数有意义: case class Car(numberOfWheels:Int = 4, color:String) case class Car(numbeOfWheels:Option[Int], color:String) //silly 在第一种情况下,我希望能够轻松地将以下json转换为实例: {"color":"red"} ..
发布时间:2020-07-08 20:17:27 其他开发

用Spray-json解析一个简单的数组

我正在尝试(但失败)弄清了Spray-json如何将json提要转换为对象.如果我有一个简单的键->值json提要,那么它似乎可以正常运行,但是我想要读取的数据在这样的列表中: [{ "name": "John", "age": "30" }, { "name": "Tom", "age": "25" }] 我的代码如下: package jsont ..
发布时间:2020-07-08 20:17:13 其他开发

spray-json和列表编组

我正在使用spray-json将自定义对象的列表封送为JSON.我有以下案例类及其JsonProtocol. case class ElementResponse(name: String, symbol: String, code: String, pkwiu: String, remarks: String, priceNetto: BigDecimal, priceBrutto: Bi ..
发布时间:2020-07-08 20:17:04 其他开发

解析隐式时,Scala如何使用显式类型?

我有以下代码,该代码使用spray-json通过parseJson方法将某些JSON反序列化为case类. 取决于隐式JsonFormat [MyCaseClass]的定义位置(嵌入式或从同伴对象导入)以及定义时是否提供显式类型,代码可能无法编译. 我不明白为什么从同伴对象导入隐式对象时要求它在定义时必须具有显式类型,但是如果我将其内联,则不是这种情况吗? 有趣的是,在所有情况下 ..
发布时间:2020-06-26 18:41:22 其他开发

如何在Scala中找到隐式的来源?

简短问题: 有没有办法让scala编译器告诉我在程序中给定点使用的某个隐式声明在哪里? 如果没有,是否可以手动遵循一种算法来发现自己声明了隐式变量的位置? 常见问题: 我正在遵循简单的喷雾器教程. 在下面的代码段中(pathEnd { post { entity(as[Question]) { question => completeWithLocationHeade ..
发布时间:2020-06-26 18:40:11 其他开发

如何在测试规范中修复参数ta缺少的隐式值:TildeArrow

我正在使用Spray开发一个简单的测试规范,但无法正确编译,也不知道我做错了什么。我的scala版本是2.9.3,喷涂版本1.0.1(更新这两个都不是合适的选择)。这是我的测试规范的代码: import org.specs2.mutable.Specification import spray.testkit.Specs2RouteTest 导入spray.http._ 导入akk ..
发布时间:2020-06-11 01:03:59 其他开发

线程[default-akka.actor.default-dispatcher-5]关闭ActorSystem导致未捕获的致命错误

在我的应用程序中,我正在从cassandra中检索数据,并使用akka spray提供其余的api。当我通过IDE运行时,它工作正常。但是,当我在计算机上本地执行 Spark Submit 时,出现如下所示的错误 [错误] [04/05/2016 10:43:38.687] [default-akka.actor.default-dispatcher-5] [ActorSystem(默认)] ..
发布时间:2020-06-03 18:50:28 其他开发

喷涂路线不匹配

我已经尝试了很多事情,但是无论我在测试中做了什么(只是发送一个PUT请求以“创建用户”),日志都不会输入任何pathPrefix,而只是结束了而无法匹配任何内容。 有人可以提供见解吗?以下是我编写的课程以及简单的测试(甚至还没有检查任何内容) 我知道总体而言,这很初级,我没有做很棒,但这只是我共同努力的一点,我觉得我可以对路由做一些快速测试 包系统 import akka. ..
发布时间:2020-06-03 18:49:58 其他开发

将Dispatcher与Spray HttpService一起使用

我的应用程序具有使用SprayCan的API。在应用程序中,任何阻塞代码都为每个特定资源都有一个单独的调度程序。 是否也需要通过使用自己的Dispatcher配置API服务来保护API服务免受应用程序的阻止? 使用Router进行API服务来处理更大容量的请求也是一种惯例吗? 类MyService使用HttpService扩展Actor {...} val service ..
发布时间:2020-06-03 18:48:57 其他开发

在喷涂路由中异步执行一些逻辑

这是我的简单路由应用程序: object Main通过SimpleRoutingApp {隐含 来扩展应用程序val system = ActorSystem(“ my-system”) startServer(interface =“ 0.0.0.0”,port = System.getenv(“ PORT”)。toInt){ 导入格式。UsageJsonFormat._ ..
发布时间:2020-06-03 18:48:45 其他开发