spray相关内容
Scala执行上下文和调度程序-列出和比较:为什么? 关于什么/如何/什么是执行Scala中的期货的最佳执行上下文还有很多问题,以及如何配置调度程序.仍然我无法找到包含优缺点和配置示例的更长列表. 我能找到的最好的方法是在Akka文档中: http://doc.akka.io/docs/akka/snapshot/scala/dispatchers.html 和Play文档 https
..
我正在测试REST API,代码如下: 设置内容,使用PUSH调用填充数据库 测试API a 测试API b ... 该代码当前位于一个相当大的FlatSpec中: class RestAPITest extends FlatSpec with Matchers with ScalatestRouteTest with SprayJsonSupport 我想删
..
我的应用程序中有一个特定的管道,该管道必须遵循所有域和协议中的所有重定向(例如,为了理智起见,最多可以进行50次重定向)(例如,它可以遵循 http://somewhere.com 到 https://somewhere.else.com ),但仅适用于GET请求.我的应用程序中没有其他管道可以执行此操作. 这是现在的样子: val pipeline = sendReceive ~>
..
在akka 2.3.6中使用喷雾1.3.2. (akka仅用于喷雾). 我需要读取巨大的文件,并为每一行发出一个http请求. 我用迭代器逐行读取文件,并为每个项目提出请求. 它在某些行中成功运行,但有时会因以下原因而失败: akka.pattern.AskTimeoutException: Ask timed out on [Actor[akka://default/user/IO-HTT
..
在某些情况下,对于案例类,默认值比可选参数有意义: case class Car(numberOfWheels:Int = 4, color:String) case class Car(numbeOfWheels:Option[Int], color:String) //silly 在第一种情况下,我希望能够轻松地将以下json转换为实例: {"color":"red"}
..
我正在编写一个RESTful接口,我想编组和解组JSON,以准备Ember Data. 问题在于Ember Data想要实体名称,而我尝试使用的两个库Spray-json和json4s似乎并不容易做到这一点. 所需的 Ember数据格式 { "coursePhoto": { "photoId": 1 } } 当前默认格式: {"photoId":15} 这
..
我正在尝试(但失败)弄清了Spray-json如何将json提要转换为对象.如果我有一个简单的键->值json提要,那么它似乎可以正常运行,但是我想要读取的数据在这样的列表中: [{ "name": "John", "age": "30" }, { "name": "Tom", "age": "25" }] 我的代码如下: package jsont
..
我正在使用spray-json将自定义对象的列表封送为JSON.我有以下案例类及其JsonProtocol. case class ElementResponse(name: String, symbol: String, code: String, pkwiu: String, remarks: String, priceNetto: BigDecimal, priceBrutto: Bi
..
我正在使用 val akkaV = "2.2.3" val sprayV = "1.2.0" Seq( "io.spray" % "spray-can" % sprayV, "io.spray" % "spray-routing" % sprayV, "io.spray" %% "spray-json
..
我有以下代码,该代码使用spray-json通过parseJson方法将某些JSON反序列化为case类. 取决于隐式JsonFormat [MyCaseClass]的定义位置(嵌入式或从同伴对象导入)以及定义时是否提供显式类型,代码可能无法编译. 我不明白为什么从同伴对象导入隐式对象时要求它在定义时必须具有显式类型,但是如果我将其内联,则不是这种情况吗? 有趣的是,在所有情况下
..
简短问题: 有没有办法让scala编译器告诉我在程序中给定点使用的某个隐式声明在哪里? 如果没有,是否可以手动遵循一种算法来发现自己声明了隐式变量的位置? 常见问题: 我正在遵循简单的喷雾器教程. 在下面的代码段中(pathEnd { post { entity(as[Question]) { question => completeWithLocationHeade
..
我正在使用Spray开发一个简单的测试规范,但无法正确编译,也不知道我做错了什么。我的scala版本是2.9.3,喷涂版本1.0.1(更新这两个都不是合适的选择)。这是我的测试规范的代码: import org.specs2.mutable.Specification import spray.testkit.Specs2RouteTest 导入spray.http._ 导入akk
..
如何以编程方式执行拒绝处理程序的 Route 并得到结果 HttpEntity ? 例如,假设我有 RequestContext 对象和 Rejection 对象在其上执行 RejectionHandler.default 并获得 HttpEntity 。 这是我要执行的操作的示例: 隐式def myRejectionHandler = RejectionHandler.ne
..
在我的应用程序中,我正在从cassandra中检索数据,并使用akka spray提供其余的api。当我通过IDE运行时,它工作正常。但是,当我在计算机上本地执行 Spark Submit 时,出现如下所示的错误 [错误] [04/05/2016 10:43:38.687] [default-akka.actor.default-dispatcher-5] [ActorSystem(默认)]
..
我已经尝试了很多事情,但是无论我在测试中做了什么(只是发送一个PUT请求以“创建用户”),日志都不会输入任何pathPrefix,而只是结束了而无法匹配任何内容。 有人可以提供见解吗?以下是我编写的课程以及简单的测试(甚至还没有检查任何内容) 我知道总体而言,这很初级,我没有做很棒,但这只是我共同努力的一点,我觉得我可以对路由做一些快速测试 包系统 import akka.
..
我的应用程序具有使用SprayCan的API。在应用程序中,任何阻塞代码都为每个特定资源都有一个单独的调度程序。 是否也需要通过使用自己的Dispatcher配置API服务来保护API服务免受应用程序的阻止? 使用Router进行API服务来处理更大容量的请求也是一种惯例吗? 类MyService使用HttpService扩展Actor {...} val service
..
这是我的简单路由应用程序: object Main通过SimpleRoutingApp {隐含 来扩展应用程序val system = ActorSystem(“ my-system”) startServer(interface =“ 0.0.0.0”,port = System.getenv(“ PORT”)。toInt){ 导入格式。UsageJsonFormat._
..
我有一项服务: trait MyService扩展了HttpService { def getDao(implicit dao :SomeDAO)= dao def someRoute = path(“ foo”){ get { complete(getDao getSomething) } } } 然后,我有一个演员: 类MyActor用A
..
在检查Spray API的吞吐量时。 场景:同时存在25个用户 操作系统:免费BSD 内存:2GB 内核数:2 在大约13个并发用户处,我遇到以下错误。 [ERROR] [06/29/2015 05: 01:56.407] [default-akka.actor.default-dispatcher-2] [ActorSystem(default)]线程[de
..
我正在使用Scala 2.11.2,Akka 2.3.6和Spray 1.3.2。 我遇到了的问题授权指令。这是代码中有趣的部分: val authenticatorActor = context.actorOf(Props [AuthenticatorActor]) 隐式val timeout = Timeout(5 seconds) cookie(“ userName”){
..