如何为从ByteString创建的HttpRequest/HttpEntity设置块大小
从ByteString创建的HttpRequest/HttpEntity可以通过设置块大小来控制数据传输的分块大小。块大小是指将数据分割成多个块进行传输的大小。
在设置块大小之前，首先需要了解HttpRequest和HttpEntity的概念。
HttpRequest是一个HTTP请求的表示，它包含了请求的方法、URL、头部信息和请求体等内容。HttpEntity是一个HTTP实体的表示，它包含了实体的内容和相关的元数据。
要为从ByteString创建的HttpRequest/HttpEntity设置块大小，可以按照以下步骤进行操作：
- 首先，将ByteString转换为适当的数据类型，以便能够创建HttpRequest/HttpEntity对象。具体的转换方式取决于所使用的编程语言和框架。
- 创建HttpRequest对象，并设置请求的方法、URL和头部信息等。
- 创建HttpEntity对象，并将转换后的ByteString设置为实体的内容。
- 设置块大小。块大小可以根据实际需求进行设置，一般建议根据网络环境和数据量大小来选择合适的块大小。较小的块大小可以提高传输效率，但会增加传输的开销；较大的块大小可以减少传输的开销，但可能会影响传输的效率。
- 将设置好的HttpEntity对象设置为HttpRequest的请求体。
以下是一些可能的腾讯云相关产品和产品介绍链接地址，供参考：
- 腾讯云对象存储（COS）：提供高可靠、低成本的对象存储服务，适用于存储和处理任意类型的文件和数据。产品介绍链接：https://cloud.tencent.com/product/cos
- 腾讯云CDN：提供全球加速、高可用的内容分发网络服务，可加速静态和动态内容的传输。产品介绍链接：https://cloud.tencent.com/product/cdn
请注意，以上链接仅供参考，具体的产品选择应根据实际需求和情况进行评估和决策。
相关·内容
如果我想用akka-http上传一个文件，我可以使用这样的方法，我可以控制块的大小： private def createUploadRequest(streamName: String, uri: Uri, path: Path): Future[(HttpRequest, Path)] = {
val bodyPart = FormData.BodyPart.fromPath("data", ContentTypes.`application/octet-stream`, path, chunkSize)
val body = FormData
浏览 20提问于2019-01-16得票数 0
回答已采纳
1回答
在akka-http中，HttpRequest和HttpResponse大多是不可变的对象，除了它们的HttpEntity主体(有一个Source)。
向另一个参与者(尤其是远程参与者)发送请求、响应或单独实体是否安全，或者是否需要一些预防措施？
浏览 1提问于2016-12-22得票数 1
我有以下问题。我正在查询服务器中的一些数据，并将其作为HttpEntity.Chunked返回。响应字符串看起来如下所示，最多10.000.000行如下所示：
[{"name":"param1","value":122343,"time":45435345},
{"name":"param2","value":243,"time":4325435},
......]
现在，我希望将传入的数据输入到和ArrayString中，其中每个字符串都是响应的一行，因为稍后应该将
浏览 5提问于2016-03-14得票数 1
回答已采纳
1回答
Akka允许将Source[ChunkStreamPart, Any]传递给HttpEntity.Chunked，这样就可以通过背压处理将ByteString流推入单个HTTP请求中：
val data: Source[ByteString, Future[ImportantInformation]]
val chunkedEntity = HttpEntity.Chunked(
ContentTypes.`application/octet-stream`,
data.map(ChunkStreamPart(_)))
val request = HttpRequest(Ht
浏览 0提问于2018-02-11得票数 0
1回答
基于所描述的技术，我编写了一个基本的微服务，以提供使用akka-http的连续流ByteStrings。相关的scala代码是：
import akka.actor.ActorSystem
import akka.stream.ActorMaterializer
import akka.stream.scaladsl.{Source, Flow}
import akka.http.scaladsl.Http
import akka.http.scaladsl.model.HttpEntity
import akka.http.scaladsl.model.HttpMethods._
impor
浏览 0提问于2015-10-26得票数 0
我的用例是将当前http请求的一些头文件复制到我正在发出的新请求中。然而，它不起作用，你能让我知道是什么问题或任何替代方案。
private def apiPostRequest(path:String, host: HostStoreInfo, byteString:ByteString , prevRequest:HttpRequest):Future[HttpResponse] = {
val request = HttpRequest(HttpMethods.POST,s"http://${host.host}:${host.port}$path",Nil,
浏览 4提问于2021-05-04得票数 0
1回答
我有这个职位申请，有两个问题。
1.具有headers值。文档说它接受一个Seq[HttpHeader]，而我传递一个扩展HttpHeader的Seq[RawHeader]，但是它说它是类型错配。为什么？
2.我传递我想要发布的数据，但是HttpEntity.Default()接收一个Source[Bytestring]。如何将data转换为Source[Bytestring]
def post(data: String): Unit = {
val headers = Seq(RawHeader("X-Access-Token", "access token&
浏览 2提问于2017-04-05得票数 2
回答已采纳
1回答
我是非常新的akka-http，我想流一个csv与任意数量的行。
例如，我想返回：
a,1
b,2
c,3
使用以下代码
implicit val actorSystem = ActorSystem("system")
implicit val actorMaterializer = ActorMaterializer()
val map = new mutable.HashMap[String, Int]()
map.put("a", 1)
map.put("b", 2)
map.put("c", 3)
val `text/c
浏览 2提问于2016-10-27得票数 1
3回答
akka-http分组响应连接
、、、、
我使用akka-http向http服务发出请求，该服务发送回分块的响应。相关的代码是这样的：
val httpRequest: HttpRequest = //build the request
val request = Http().singleRequest(httpRequest)
request.flatMap { response =>
response.entity.dataBytes.runForeach { chunk =>
println("-----")
println(chunk.utf8String)
浏览 3提问于2015-10-22得票数 5
回答已采纳
1回答
我正在为一个实验项目开发akka-http(akka-http- experimental _2.11 - 0.4)。我以前也没有做过喷雾的工作。
我想流式传输一个mp4视频(大小可以改变)到浏览器。但是我不知道如何为HttpResponse创建HttpEntity (HttpEntity.Chunked ?)。我尝试过像这样的麻烦事，这不是一种正确的做法，但在Firefox中，这种方法只适用于单个请求。
def output = Source.fromFile("C:\\Users\\karthik\\Downloads\\big_buck_bunny.mp4")(scal
浏览 7提问于2014-08-21得票数 6
我有一个Akka-http 2服务器来处理HTTP请求。
在任一端点上，我将转换为case类A或B：
case class caseClassA(data: String, eventID: String)
case class caseClassB(data: String, otherData: JsObject)
我有一个像这样的路由对象：
val routes = {
logRequestResult("akka-http-microservice") {
pathPrefix("some_endpoint"
浏览 5提问于2016-01-22得票数 0
回答已采纳
在我的一个中，我问到如何使用Akka表示表单数据请求？根据答案，我创建了一个工作示例，但是遇到了一个“可伸缩性”问题--当表单数据请求的数量很高时，我需要处理文件系统中的许多文件。
我很好奇，是否可以在表单数据请求中将ByteString作为文件有效负载发送？
case class FBSingleChunkUpload(accessToken: String,
sessionId: String,
from: Long,
to: Long,
file: ByteString) //this property is rece
浏览 0提问于2018-05-08得票数 1
回答已采纳
1回答
如何从未知长度的Akka-HTTP响应流中读取long？ 示例： val futureResponse = Http(system).singleRequest(
HttpRequest(
HttpMethods.POST,
"url",
entity = HttpEntity(ContentTypes.`application/json`, "somequery".getBytes())
).withHead
浏览 9提问于2019-01-16得票数 0
1回答
在我的一个项目中，我有一个akka演员向我的google服务器发送帖子请求。参与者将获取一个in列表，并应根据列表中的请求发出尽可能多的请求。我在runForeach(println(_))中打印了来自服务器的响应，但是对于整个ids列表，我只得到一个打印输出。这一切为什么要发生？
class FCMActor(val key: String) extends Actor{
import fcm.FCMActor._
import akka.pattern.pipe
import context.dispatcher
private implicit def system:
浏览 0提问于2016-12-30得票数 5
回答已采纳
1回答
我试图将流源缓存到磁盘，同时也将其作为HttpResponse发送出去，也就是说，我有一个Source[ByteString,_]，我想将它交给HttpEntity，但我也希望将相同的数据运行到FileIO.toPath接收器中。
|-> FileIO.toPath
Source[ByteString,_] ->|
|-> HttpEntity(contentType, Source[ByteString,_]
Broadcast似乎是我应该用于扇出的东西，但从描述中看，它会写入两个接
浏览 0提问于2018-11-22得票数 1
回答已采纳
我从Kafka使用者那里接收一个作为Bytestring的文件；我想用这个Bytestring作为一个实体HttpEntity.Default来构造一个akka-http请求。HttpEntity.Default需要SourceBytestring，作为它的参数之一。
什么是连接两者的最佳方式？
浏览 1提问于2016-09-29得票数 2
回答已采纳
1回答
我有一张大地图，我想回到前面去。最初，我将映射转换为jackson json节点，并使用play提供的返回ok()方法将映射返回给用户。
原始代码：
public Result returnResponse() {
ObjectMapper mapper = new ObjectMapper();
Map<String, Object> returnMap = populateMapWithData();
JsonNode response = mapper.valueToTree(returnMap);
return ok(response);
}
浏览 12提问于2022-05-17得票数 2
最近，在我的项目中运行基准之后，我发现直接构建严格字节串的速度比涉及构建器的要快一个数量级。
例如，编码器实现，它使用构建器：
encoder :: Int64 -> Data.ByteString.ByteString
encoder =
Data.ByteString.Lazy.toStrict .
Data.ByteString.Builder.toLazyByteString .
Data.ByteString.Builder.int64BE
执行情况比直接构造字节串的要差10倍，并且有几种进一步优化的可能性：
encoder :: Int64 -> Data.
浏览 3提问于2015-10-18得票数 12
回答已采纳
1回答
请考虑我有一个包含字段的自定义代理类，
private final String serverName;
private final int port;
private final String username;
private final String password;
我想在下面的现有代码中使用这个代理，但我不知道如何添加该代理。下面的代码不支持代理。
public CustomClassForResponse createRequest(CreateCustomRequest request) {
HttpPost httpRequest = new HttpPost
浏览 7提问于2022-03-02得票数 0
回答已采纳
创建一个从数据源获取指令(步骤)的类，并自动执行少量HC ( Apache客户端)操作。
希望能够执行HTTP、get和直接调用(比如向web服务器发送JSON或XML/ soap消息)。
对于何时使用BasicHttpEntityEnclosingRequest和BasicHttpReques感到困惑，附件是什么？现在，我有步骤输入上下文，提供param值、URL、方法等，当我想提交时--这是我正在做的事情：
HttpPost httpost = null;//todo correct method
//HttpEntity resp = this.httpc
浏览 2提问于2013-08-24得票数 1
回答已采纳
1回答
我正在测试akka-http，平均响应大小在156‘m左右。如果我按顺序运行测试，我可以在客户端获得响应，这也是用akka-http实现的。
但是，如果我在端点上运行并发请求(8个请求)，我只能得到前三个请求的响应。
在本地进行测试。
这是服务器代码；
val text = Source.fromInputStream(getClass.getResourceAsStream("/data/data.txt")).mkString
val route =
path("build") {
get {
complete {
浏览 1提问于2017-03-27得票数 0
回答已采纳
我有一个Actor，它使用以下命令发送HTTP POST请求httpRequest => http.singleRequest(httpRequest).pipeTo(self)合而为一case BidRequest 消息。参与者在另一个对象中接收回httpResponse case HttpResponse消息。在这一秒case HttpResponse消息我想要更改一个变量，第一个变量是 消息将被发回。因为消息是异步处理的，所以当我编辑第二条消息上的变量时，第一条消息已经用旧状态发回了变量。 我想我需要使用akka.pattern.ask以某种方式不让消息到达另一个case
浏览 65提问于2021-02-21得票数 0
回答已采纳
我创建了一个路由来流式传输JSON中的case类列表。但如果我使用ByteString，则打印case类而不是JSON def streamRoute: Route = pathEndOrSingleSlash {
val byteString = new LocalFileParser(config).importFromFiles.map(phoneNumber => ByteString(phoneNumber.toString + "\n"))
complete(HttpEntity(ContentTypes.`applicati
浏览 17提问于2019-03-31得票数 0
1回答
我正在尝试使用以下代码从Akka创建一个singleRequest： val request = HttpRequest(
method = HttpMethods.GET,
uri = "url"
)
val responseFuture: Future[HttpResponse] = Http().singleRequest(request)
val entityFuture: Future[HttpEntity.Strict] = responseFuture.flatMap(response => response.entity.toStrict(2.s
浏览 16提问于2020-10-23得票数 2
1回答
因此，在我用一些Haskell将tweet数据分解成n-gram之后，我遇到了一个空间泄漏问题。当我分析时，GC使用了大约60-70%的进程，并且有大量的内存部分专门用于拖动。希望一些Haskell专家能够在我出错的时候给出建议。
{-# LANGUAGE OverloadedStrings, BangPatterns #-}
import Data.Maybe
import qualified Data.ByteString.Char8 as B
import qualified Data.HashMap.Strict as H
import Text.Regex.Posix
import
浏览 0提问于2011-10-22得票数 9
回答已采纳
ByteString套接字编程有一个奇怪的问题。我已经将问题最小化为以下简短的脚本：
-- ByteString.hs
{-# LANGUAGE OverloadedStrings #-}
import Network.Socket hiding (send, sendTo, recv, recvFrom)
import Network.Socket.ByteString
import Network.BSD
import System.IO
import qualified Data.ByteString as BS
import qualified Data.ByteString.Char
浏览 3提问于2017-01-28得票数 1
回答已采纳
我正在尝试修改这个，以处理长度已知的Lazy ByteString (这样就不会强制在内存中读取它的全部内容--它是通过预先发送长度的网络实现的)。似乎我必须在Lazy ByteString上定义一个Lazy ByteString函数才能将它转换为。由于GivesPopper的定义方式复杂，我不知道如何为Lazy ByteString编写它。将欣赏如何编写它的指针。是为从文件中读取而编写的：
let file ="test"
-- streams large file content, without buffering more than 10k in memory
let
浏览 8提问于2016-06-03得票数 1
回答已采纳
嗨，我正在尝试存储客户端对一个文件的请求响应。我很容易为HttpRequest做到这一点。
但是，当我试图为HttpResponse编写编码器解码器时，我无法理解如何为scala中的HttpResponse实体编写它。
以下是HTTP请求编码器解码器的代码
val demo=HttpRequest(
method= HttpMethods.GET,
uri="myUri",
headers=generateHeaders(Map.empty),
entity="{\"customerReferenceIds\":[{\"customerI
浏览 6提问于2022-11-14得票数 0
回答已采纳
1回答
我正试图在我的Akka Http Server上创建一个端点，它使用外部服务告诉用户它是IP地址(我知道这可以更容易地执行，但这是一个挑战)。
没有在最上层使用流的代码如下：
implicit val system = ActorSystem()
implicit val materializer = ActorMaterializer()
val requestHandler: HttpRequest => Future[HttpResponse] = {
case HttpRequest(GET, Uri.Path("/"), _, _, _) =>
浏览 0提问于2015-12-13得票数 3
回答已采纳
1回答
我试图上传大文件在谷歌驱动器执行可恢复上传。
这是代码流
步骤1:使用驱动器服务在Google上创建文件，并使用put请求启动可恢复的上载会话
String fileID = _DriveService.Files.Insert(googleFileBody).Execute().Id;
//Initiating resumable upload session
String UploadUrl = null;
String _putUrl = "https://www.googleapis.com/upload/drive/v2/file
浏览 9提问于2017-05-11得票数 1
下面是我在Haskell想做的事：
接受ByteString格式的消息(不管是懒惰还是严格)
用RSA公钥加密消息
base64对加密消息进行编码
我使用的在内部处理惰性ByteStrings。然而，库只使用严格的ByteStrings。我的应用程序使用惰性ByteStrings将消息发送到网络套接字。
因此，看起来我必须在懒惰和严格的ByteStrings之间进行转换。我要做的是：
encrypt :: CryptoRandomGen t => t -> RSA.PublicKey -> L.ByteString -> L.ByteString
e
浏览 4提问于2012-04-14得票数 3
回答已采纳
我调用一个API来获得一个zip文件响应。API的响应是正确的，但是我无法从响应中获得字节数组，因为在获得ByteString时应该完成的未来永远不会完成：
val authorization = akka.http.javadsl.model.headers.Authorization.basic("xxxxx", "xxxxxx")
val query = Map("fed" -> "xxxx", "trd" -> "yyy", "id" ->
浏览 18提问于2017-09-08得票数 0
回答已采纳
我当前的代码有签名：
def putObject(key: String, contentType: ContentType, data: Source[ByteString,_]): Future[HttpReponse]
(它简单地委托给akka-http客户端)
我希望签名是
def putObject(key: String, contentType: ContentType): Sink[ByteString, Future[HttpReponse]]
如何创建一个接收器，该接收器消耗所有ByteStrings作为单个HttpRequest的主体，而不缓冲内存中的所有字节？
浏览 0提问于2017-07-11得票数 1
5回答
我有一个函数，它接受一个列表，我希望返回的列表(懒惰应该转移到输出的类型)。
import qualified Data.ByteString as B
import qualified Data.ByteString.Lazy as L
csVals :: L.ByteString -> [B.ByteString]
我想这样做的原因有很多，需要严格的ByteStrings，我可以保证在上面的csVals的输出中输出的严格ByteStrings非常小。
在没有ByteString**s [chunking]() them的情况下，我该如何对ByteString**s进行“严格限制”？*
浏览 54提问于2011-10-19得票数 23
回答已采纳
我用GitHub：做了一个示例项目
我想要的似乎很简单:读取一个URL，将内容提供为String的逐行流。现在，我在整个日中一直在努力处理这个问题(以及阅读文档)，因此决定公开这个示例并寻求帮助。
我和斯卡拉相处得很好。我知道Akka，上一次我使用Akka-streams可能是在2.4之前。现在我迷路了。
问题：
在这些上，我想返回一个Source[String,Any]，而不是一个Future (注意:这些行不编译)。
问题可能是Http().singleRequest(...)将流程具体化了，我不想这样。如何在没有实际阅读网页的情况下，直接注入阅读网页的“配方”？
def sourceA
浏览 0提问于2016-05-24得票数 2
几周前，我问了一个关于使用SOAP API而不是REST API读取Salesforce数据的问题(参见Trying to use Apache Gobblin to read Salesforce data using SOAP API(s) instead of REST API )，但不幸的是没有人回答这个问题，所以我正在尝试直接实现这个解决方案(有一点帮助)。 使用REST API，读入表定义的现有代码(通过调用REST API)如下所示： // the URL starts with the Salesforce REST API endpoint, and ends with &
浏览 28提问于2020-08-29得票数 1
回答已采纳
在使用Akka HttpRequest并将请求传递给参与者时，我无法识别响应。参与者将处理将接收到的每条消息，但它不知道用于获取此响应的请求。是否有任何方法来识别与响应匹配的每个请求？
注意:我没有服务器再次重新发送请求体的任何部分。
提前感谢
MySelf.scala
import akka.actor.{ Actor, ActorLogging }
import akka.http.scaladsl.Http
import akka.http.scaladsl.model._
import akka.stream.{ ActorMaterializer, ActorMaterializer
浏览 1提问于2018-05-27得票数 1
回答已采纳
2回答
问题
我正在尝试用Haskell和Pipes库实现一个简单的web服务器。我现在知道循环或菱形拓扑在管道中是不可能的，但我认为我想要的是。我想要的拓扑如下：
-GET--> handleGET >-> packRequest >-> socketWriteD
|
socketReadS >-> parseRequest >-routeRequest
|
浏览 3提问于2013-04-25得票数 10
回答已采纳
我对akka没有太多的背景，但是HttpEntity处理字符串的方式发生了变化吗？
我目前正在使用akka-HTTP1.0，但我希望升级到2.0，并开始使用Source.queue功能。我正在遵循中概述的步骤，这些步骤来自类似的堆栈溢出问题。我已经能够实现从博客帖子的一切。但是，更新到2.0似乎破坏了我为HttpEntity所做的工作。目前，我在Akka-HTTP1.0中的HttpRequest中有以下声明：
entity = HttpEntity(MediaTypes.`application/xml`, xml)
其中xml是使用XStream创建的字符串。当我转到2.0时，我会收到来
浏览 4提问于2016-02-10得票数 1
回答已采纳
1回答
如何检查我的SpringBootApplication中的RestTemplate是否正确出现错误？我设法创建了一个ResponseErrorHandler，但不确定如何处理代码中的错误。因此，如果发生错误，我希望打印一条错误消息，否则，如果一切正常，则处理响应。我该怎么做呢？
ErrorHandler：
public class MyErrorHandler implements ResponseErrorHandler {
private boolean error;
@Override
public void handleError(ClientHttpRespo
浏览 0提问于2017-05-20得票数 0
我正在尝试创建一个示例akka流，该流接受CSV文件，将其更改为XML (使用已经存在的具有toXml函数的对象)，然后将其发布到端点。我创建的代码如下所示：
val poolClientFlow =
Http().cachedHostConnectionPool[Thing]("localhost",5000)
val file = new File("./example.csv")
val uploadPipeline =
FileIO.fromFile(file)
.via(Framing.delimiter(ByteString(&#
浏览 1提问于2017-05-18得票数 1
回答已采纳
鉴于这些数据：
data A1 = A1 | A2 | A3
我如何为它创建一个实例？
instance ToJSON A1 where
toJSON = ???
instance FromJSON A1 where
parseJSON = ???
如果它是一个构造函数，我就能够做到这一点，但是我不知道如何使用不接受任何参数的多个构造函数。
UPDATE:对于每个构造函数，我都有以下错误：
my-app/src/Lib.hs:54:32:
No instance for (ToJSON a1) arising from a use of ‘.=’
The type v
浏览 0提问于2016-03-24得票数 2
回答已采纳
2回答
我正在尝试从iOS查询。
如何为“%term%”这样的城市的SQL创建NSPredicate？
提前谢谢
浏览 1提问于2014-05-10得票数 2
回答已采纳
我之前写了一些代码，它使用OverloadedStrings从十六进制编码的字符串文字创建ByteString，它使用提供的函数对其进行解码。这很好用，但似乎我并没有像我想象的那样理解它。
让我完全迷惑的是这一点。为什么
{-# LANGUAGE OverloadedStrings #-}
import Data.ByteString.Base16 ()
import qualified Data.ByteString as B
plaintext = "The message" :: B.ByteString
main = print plaintext
编译并运行正常
浏览 0提问于2013-02-03得票数 24
回答已采纳
我使用Source.queue对HttpRequests进行排队，并在客户端限制它，以便从远程服务器下载文件。我知道Source.queue不是线程安全的，我们需要使用MergeHub来使它成为线程安全。下面是使用Source.queue和cachedHostConnectionPool的代码片段。
import java.io.File
import akka.actor.Actor
import akka.event.Logging
import akka.http.scaladsl.Http
import akka.http.scaladsl.client.RequestBuildin
浏览 0提问于2017-09-22得票数 3
我刚刚开始使用scala，并且正在尝试编写小项目。我编写了使用graphql请求的服务器。现在，我对jwt令牌有一个问题，因为用于验证的方法返回Directive1ByteString而不是ByteString。我能以某种方式检索它吗？验证后，我需要来自该jwt令牌的索赔数据 下面是我正在苦苦挣扎的代码： val directive: Directive1[ByteString] = jwt.jwtAuthenticate(Unmarshaller._fromStringUnmarshallerFromByteStringUnmarshaller)
val claim: String = ?
浏览 15提问于2021-02-09得票数 0
回答已采纳
我的代码如下。
import org.apache.commons.codec.binary.Hex
import akka.actor.ActorSystem
import akka.http.scaladsl.Http
import akka.http.scaladsl.model.headers.RawHeader
import akka.http.scaladsl.model._
import akka.stream.ActorMaterializer
import akka.util.ByteString
import javax.crypto.spec.SecretKeySpec
浏览 10提问于2017-08-19得票数 0
回答已采纳
1回答
我正在尝试上传一个大约7 GB的文件到谷歌云存储。我使用HttpRequest类上传。我选择了“简历”上传。我还将读取超时设置为20000000。
如果我上传较小的文件，如果工作良好。对于更大的文件，如6GB。它返回：
Exception in thread "main" com.google.api.client.http.HttpResponseException: 400 Bad Request
Request is too large.
at com.google.api.client.http.HttpRequest.execute(HttpRequest.j
浏览 5提问于2013-09-12得票数 3
0回答
我不确定我是否走在正确的道路上。因为我没有从HTTP请求中获得任何数据。我需要将这段java代码转换成force.com顶点，这样我才能使用web服务。
public static HttpEntity getRequestEntity()
{
JSONArray jsonArr = new JSONArray();
HttpEntity entity = null;
JSONObject jsonElement = new JSONObject();
JSONObject jsonObj = new JSONObject();
JSONObject jsonObj1 =
浏览 21提问于2016-07-07得票数 1
回答已采纳
1回答
假设我让这个函数执行一个get请求：
import Network.HTTP.Conduit
import qualified Data.ByteString.Char8 as C8
get :: String -> [(C8.ByteString, C8.ByteString)] -> IO (Response LC8.ByteString)
get url par = do
request <- parseUrl url
res <- withManager $ httpLbs $ createReq request
return res
whe
浏览 4提问于2014-07-20得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
实时音视频活动推荐
腾讯云开发者
