问题标签 [scala-dispatch]
For questions regarding programming in ECMAScript (JavaScript/JS) and its various dialects/implementations (excluding ActionScript). Note JavaScript is NOT the same as Java! Please include all relevant tags on your question; e.g., [node.js], [jquery], [json], [reactjs], [angular], [ember.js], [vue.js], [typescript], [svelte], etc.
scala - 调度和库依赖
嗨,我作为最后的手段来到这里,但我束手无策。我正在尝试学习调度,以便可以在 scala 中完成我的下一个 Web 项目,但我什至无法通过教程。这就是我想要做的。
在 sbt 控制台中,前 3 行正常工作,但我在最后一个错误值 >>> 不是 com.ning.http.client.RequestBuilder@6eb7546d 的成员。老实说,谷歌搜索这个错误并不那么有洞察力。尝试将其放入 .scala 文件并运行它时,它在 import dispatch._ 行上出错。老实说,我不知道我在这里做错了什么,现在会为了一些帮助而杀人。这不可能像看起来那么难。我还安装了 sbt 并按照调度主页上的这些说明进行操作:
我还有一个 build.sbt 文件夹,其中包含以下内容
scala - net.databinder.dispatch 因保持活动连接过多而失败
我使用 net.databinder.dispatch 来调用 Web 服务器:
客户定义:
并且服务器定义:
如果我连续多次调用网络服务器(但不是并行),我会收到错误消息:
关闭连接的其他 Web 服务器不会发生此错误。
这里有什么问题?网络服务器?客户端?
net.databinder.dispatch 是否真的使用了 keep-alive 功能(所以,重用同一个套接字),还是每次都创建一个新的?如何修改前面的示例以告诉 net.databinder.dispatch 使用 keep-alive 功能?
我正在使用的版本:
scala - 在 Scala Dispatch 中解码流式 GZIP 响应?
从 API 接收 Gzipped 响应,但 Dispatch 0.9.5 似乎没有任何方法来解码响应。有任何想法吗?
这是我当前的实现,println
唯一打印出字节的字符串表示形式。
试图看看实现我自己的处理程序,但不知道从哪里开始。这是相关文件Lines
:https ://github.com/dispatch/reboot/blob/master/core/src/main/scala/as/stream/lines.scala
谢谢!
java - 在Scala中解压缩async-http-client gzipped HttpResponseBodyPart?
因为 Scala Dispatch 0.9.5 似乎没有用于解压缩 GZIP 流的默认处理程序,所以我试图修改它的as.stream.Lines
处理程序来处理传入数据。由于同一个项目也在使用 Spray.io,我试图GzipDecompressor
在HttpResponseBodyPart
字节上使用它,但它引发了异常。见下文:
上面的方法修改了以下内容(第 23 行):https://github.com/dispatch/reboot/blob/master/core/src/main/scala/stream/strings.scala#L23
它抛出一个异常!java.util.zip.ZipException: Not in GZIP format
对于那些想知道 GzipDecompressor 是什么样子的人,这里是:https ://github.com/spray/spray/blob/master/spray-httpx/src/main/scala/spray/httpx/encoding/Gzip.scala
我知道它确实是一个 Gzipped 流。任何解决方法?谢谢!
更新
玩弄以下内容:
该课程GZIPDecompressMachine
来自这里:https ://gist.github.com/841435/09921c8dcbb6b2ad01a3161589ed4fe68f256fbc
它抛出了一个异常:java.io.EOFException: Unexpected end of ZLIB input stream
这里有什么想法吗?
scala - 如何替换 Dispatch 中的默认线程池?
如何替换 Dispatch 中的默认线程池?我在这里看到了实例化 CachedThreadPool 的https://github.com/dispatch/dispatch/blob/master/futures/src/main/scala/Futures.scala 。我想改用 FixedThreadPool 。
scala - 使用 Dispatch Databinder 0.10 处理 xml 时设置字符集
我正在使用 Scalatra 应用程序包装上游 API,并使用 Dispatch 发出异步请求。但是,我在将上游 XML 转换为xml.Elems
使用 Dispatch 的内置 XML 处理支持时遇到了麻烦。
我正在尝试做一些与 Dispatch 文档中的内容非常相似的事情,即检索上游 XML 并进行一些重新处理。有问题的函数看起来像:
这导致:
上游 API 没有发回字符集,在检索它时,Dispatch 在 XML 开始之前用字节顺序标记显示它:<?xml version="1.0" encoding="utf-8"?>
。
我可以看到早期版本的 Dispatch 通过以下方式解决了这个问题:
但是我目前看不到使用 Dispatch 0.10 进行这项工作的方法。有没有人有任何关于在这个响应上设置字符集的提示,所以我可以解析返回的内容?
scala - 导入有效,但不导入包中的所有内容?
我正在尝试将调度与具有 OAuth 身份验证的第 3 方网站一起使用,但我无法从调度中导入内容。消费者 api它显然在库中,但由于某种原因找不到。我正在使用 sbt 来构建项目,这是依赖项:
下面是运行 repl(sbt, console-quick) 给出的结果。尝试编译项目以类似的值未找到错误结束。导入没有失败,但消费者不可用。来自调度的其他东西,如 Http 都可以使用。
似乎其他人也有这个问题,但没有答案.. https://groups.google.com/forum/?fromgroups=#!topic/liftweb/NI3nZJjsrjo
我发现关闭的东西是包装中的 SomeConsumer dispatch.oauth
,但这不是我要找的。在这里你可以看到包中的 Consumer 和 Token,但是
没有帮助。
scala - 如何使用 Scala 调度来获取在 301 重定向中返回的 URL?
我正在使用 Scala调度HTTP 库,版本 0.10.1。我向返回 HTTP 301 永久重定向的 URL 发出请求。例如,http://wikipedia.com返回一个 301 重定向到http://www.wikipedia.org/。如何使用 dispatch 获取重定向的 URL?
按照教程,这就是我所做的。
这会引发“意外响应状态:301”异常。大概我需要查询r
重定向 URL 的值,或者可能在其定义中指定一些参数OK
,但我无法从文档中弄清楚该做什么。