如何为从ByteString创建的HttpRequest/HttpEntity设置块大小 - 腾讯云开发者社区

文章/答案/技术大牛

发布

Akka（38）： Http：Entityof ByteString-数据传输基础

在Akka-http中对应的是HttpRequest和HttpResponse。这两个类型都具备HttpEntity类型来装载需要交换的数据。首先，无论如何数据在线上的表现形式肯定是一串bytes。...很明显，HttpEntity可以分两大类，一种是Strict类型的，它的data是ByteString。...但是，其中的application/octet-stream类型代表数据必须是Source[ByteString,Any]。我们下面就通过客户端的例子来理解HttpEntity。...) .andThen{case _ => sys.terminate()} 从显示的结果可以得出runService函数中的entity.dataBytes.map(_.utf8String)已经把...来装载这个Source然后通过HttpRequest传给客户端的： path("random") { get { complete( HttpEntity

1.3K9 0

Akka（41）： Http：DBTable-rows streaming - 数据库表行交换

因为文件内容是以一堆bytes来表示的，而http消息的数据部分也是byte类型的，所以我们可以直接用Source[ByteString,_]来读取文件然后放进HttpEntity中。...,NotUsed]然后放入HttpResponse的HttpEntity里。...那么反向交换即从客户端上传一段表行的话就需要把一个Source[T,_]转换成Source[ByteString,_]然后放进HttpRequest的HttpEntity里。...服务端收到数据后又要进行反向的转换即把Request.Entity.dataBytes从Source[ByteString,_]转回Source[T,_]。...如果我们的目的是简单提供一个Source[ByteString,_]，我们是否可以直接调用Spray-Json的函数来进行ROW->Son->ByteString转换呢？

1.7K7 0

您找到你想要的搜索结果了吗？

是的

没有找到

Akka（34）： Http：Unmarshalling，from Json

按具体流程来说就是先把Json转换成可传输格式数据如：MessageEntity,HttpRequest,HttpReponse等，然后再转换成程序高级结构数据如classXX实例。...从Unmarshaller的构建函数apply可以估计它的作用应该与函数A=>Future[B]很相似。...A代表网上可传输类型如MessageEntity、HttpRequest，B代表某种程序高级数据类型。因为A到B的转换是non-blocking的，所以可以立即返回Future类型结果。...注意：这一步只包括了从网上可传输类型到程序类型转换这一过程，不包括具体实现时的Json转换。...("Hello")).to[String] val futHello = Unmarshal(HttpRequest(method = HttpMethods.GET, entity = HttpEntity

9977 0

Akka（40）： Http：Marshalling reviewed - 传输数据序列化重温

上篇我们讨论了Akka-http的文件交换。由于文件内容编码和传输线上数据表达型式皆为bytes，所以可以直接把文件内容存进HttpEntity中进行传递。...那么对于在内存里自定义的高级数据类型则应该需要首先进行byte转换后才能放入HttpEntity中了。高级数据类型与byte之间的相互转换就是marshalling和unmarshalling过程了。...这是一个类型别称，实际上就是Marshaller[T,MessageEntity]： type ToEntityMarshaller[T] = Marshaller[T, MessageEntity] 从源代码上看这些...Marshaller的隐式实例都提供了转换函数 T=>HttpEntity。..., ByteString(p.toString)) } 这个Marshaller代表的转换过程是：Person -> Person.String -> ByteString。

1.5K8 0

Akka（28）： Http：About Akka-Http

从更高应用层次来分析：系统集成实质上是两个系统之间通过Http协议实现数据交换。...举个例子：Request和Response两种类型的消息定义如下： /** * The immutable model HTTP request model. */ final class HttpRequest...`HTTP/1.1`) = new HttpRequest(method, uri, headers, entity, protocol) def unapply(any: HttpRequest...(GET, uri = "/index") // construct simple POST request containing entity val data = ByteString("abc"...，Header也都用HttpEntity，HttpHeader类型进行了对应。

1.4K7 0

Akka（33）： Http：Marshalling，to Json

Akka-http网上交换数据转换代表把一个高级结构类型T的实例转换成简单的目标类型如MessageEntity，它代表http消息中的数据部分（entity-body），最后产生Json进行交换。...Akka-http的Json解决方案是典型的type-class模式：是一种可以即兴创建功能的类型继承模式（add-hoc polymorphism）。...Marshaller[A,B]的别名： type FromEntityUnmarshaller[T] = Unmarshaller[HttpEntity, T] type ToEntityMarshaller...[T] = Marshaller[T, MessageEntity] 既然Akka-http的Json实现方式是type-class模式的，那么我们就试试其它Json库的功能实现方式，如：Json4s。...to[ByteString] // val reqFuture = Marshal(400).to[HttpRequest] // val resp = reqFuture.flatMap

2.3K10 0

Java调用外部REST请求的几种方式

2、默认使用JDK 的HttpURLConnection进行通信，但是可以通过RestTemplate.setRequestFactory 切换到不同的HTTP源：如Apache HttpComponents...，如：SimpleClientHttpRequestFactory 创建请求 public ClientHttpRequest createRequest(URI uri, HttpMethod httpMethod...(); } // form 表单格式的入参，并设置超时时间 public static String get(String urlString, Map paramMap...(); } 2.2 post 请求这些请求最终调用的都是 HttpRequest 的 execute() 方法。...post(urlString, paramMap, HttpGlobalConfig.timeout); } // form 表单格式的入参，并设置超时时间 public static String

1.2K3 1

【Android 应用开发】Android 平台 HTTP网速测试案例 API 分析

-- 下载文件 : 对每一条连接,宽带接入速率测试平台持续从内存直接发送 64kByte 大小的内容。...-- 平均速率 : 从收到第 1 个 HTTP[GET]请求开始计时,宽带接入速率测试平台及客户端软件每隔 1s 统计已经发送的文件大小,计算数据平均传送速率,并在网页上或客户端中实时更新。...HttpEntity 接口接口介绍 : HttpEntity 可以随着 HTTP 消息发送和接收, 在一些请求和响应中可以找到 HttpEntity, 这是可选的; HttpEntity 分类...: -- 数据流 : 内容是从数据流中获取的, 或者是在内存中生成的, 通常, 这类实体是从连接中获取的, 并且不可重复; -- 独立的 : 内容从内存中获取, 或者从连接或其它实体中获取的,...创建 AndroidHttpClient : 使用 AndroidHttpClient 的 newInstance(str)方法, 创建该实例, 创建实例的时候, 传入的字符串是包名 + 版本号, 自己组织

1.3K1 0

工具篇：apache-httpClient 和 jdk11-HttpClient的使用

支持多线程操作基于阻塞的 I/0 实现，也就是说使用 HttpClient 的线程会被阻塞头部信息设置 HttpPost httpPost = new HttpPost("https://api.mch.weixin.qq.com...是对《请求或者响应》对象的封装，具体实现类有 BasicHttpEntity，InputStreamEntity：操作对象是数据流 BufferedHttpEntity：带缓冲区的 HttpEntity...，其他HttpEntity的包装类，将内容存入一缓存区可以重复读 FileEntity：文件对应的Entity FileEntity entity = new FileEntity(new File(...创建一个 HttpClient public static Builder newBuilder() public static HttpClient newHttpClient() // HttpClient.newBuilder...封装的函数处理 get 请求 HttpRequest request = HttpRequest.newBuilder(URI.create("http://localhost:8080/content

2.4K1 0

【Android】HttpURLConnection接口

其对象主要通过URL的openConnection方法获得。创建方法如下代码所示： URL url = new URL("http://www.51cto.com/index.jsp?.../x-www-form-urlencoded"); // 连接，从postUrl.openConnection()至此的配置必须要在connect之前完成，...; } } 使用POST方法进行参数传递时，需要使用NameValuePair来保存要传递的参数。，另外，还需要设置所使用的字符集。...par", "HttpClient_android_Post")); //设置字符集 HttpEntity httpentity = new UrlEncodedFormEntity...(params, "gb2312"); //请求httpRequest httpRequest.setEntity(httpentity);

9255 0

Haskell HTTP请求：如何解读响应状态

以下是一个使用Either类型处理HTTP请求可能发生的错误的例子：haskell复制-- 使用Either类型处理HTTP请求httpRequest :: String -> IO (Either String...(Response ByteString))httpRequest url = do manager 设置代理信息...：端口号应该是一个整数，而不是字符串 , proxyUser = "16QMSOML" , proxyPass = "280651" }-- 使用tlsManagerSettings创建带有代理的...httpClient :: String -> IO ()httpClient url = do manager 的设置

7251 0

Android网络编程之Http通信

其对象主要通过URL的openConnection方法获得。创建方法如下代码所示： 1.URL url = new URL("http://www.51cto.com/index.jsp?...//得到读取的内容(流) 4.InputStreamReader in = new InputStreamReader(urlConn.getInputStream()); 5. // 为输出创建...; 19. } 20. } 使用POST方法进行参数传递时，需要使用NameValuePair来保存要传递的参数。，另外，还需要设置所使用的字符集。...//设置字符集 10. HttpEntity httpentity = new UrlEncodedFormEntity(params, "gb2312"); 11....//请求httpRequest 12. httpRequest.setEntity(httpentity); 13. //取得默认的HttpClient 14.

6473 0

restapi（4）- rest-mongo : MongoDB数据库前端的httpserver

然后get返回的结果集又没有什么灵活的控制方法如返回数量、字段、排序等。...客户端从后台下载时就需要把bytes转换成UTF8字符就可以恢复文件内容了。首先，我们先从Model开始，在scala里用case class来表示。...因为到现在我还没有想到办法在一个httprequest里把多个字段和图片一次性发出来，必须分两个request才能完成一个Document的上传。...id = doc.getString("id"), photo = mgoGetBlobOrNone(doc, "photo") ) } } 从另一个角度来讲...我希望对任何Model的Route只需要指定M即可，如： implicit val personDao = new MongoRepo[Person]("testdb","person", Some

2.2K2 0

聊聊RestTemplate对HttpClient的适配

createHttpUriRequest，设置RequestConfig，针对bufferRequestBody的场景HttpComponentsClientHttpRequest，否则创建HttpComponentsStreamingClientHttpRequest...= (HttpEntityEnclosingRequest) this.httpRequest;HttpEntity requestEntity = new ByteArrayEntity(bufferedOutput...;HttpEntity requestEntity = new StreamingHttpEntity(getHeaders(), this.body);entityEnclosingRequest.setEntity...AbstractClientHttpRequest，实现了StreamingHttpOutputMessage接口，其getBodyInternal抛出UnsupportedOperationException，其executeInternal方法创建的是...spring-web的ClientHttpRequest，将response通过HttpComponentsClientHttpResponse适配为spring-web的ClientHttpResponse

4631 0

聊聊RestTemplate对HttpClient的适配

createHttpUriRequest，设置RequestConfig，针对bufferRequestBody的场景HttpComponentsClientHttpRequest，否则创建HttpComponentsStreamingClientHttpRequest...entityEnclosingRequest = (HttpEntityEnclosingRequest) this.httpRequest; HttpEntity requestEntity...AbstractClientHttpRequest，实现了StreamingHttpOutputMessage接口，其getBodyInternal抛出UnsupportedOperationException，其executeInternal方法创建的是...} } return this.headers; } @Override public InputStream getBody() throws IOException { HttpEntity...spring-web的ClientHttpRequest，将response通过HttpComponentsClientHttpResponse适配为spring-web的ClientHttpResponse

6692 0

Akka-CQRS（11）- akka-http for http-web-service: Marshalling-数据序列化

在POS控制平台例子里不会涉及到POST操作，应该全部是GET类型的，如： http://192.168.11.189:2588/pos/logon?...下一步研究一下如何构建返回的HttpResponse：httpresponse是从server端传送到client端的。...这个过程包括把HttpResponse Entity里的数据从某种类型转换成通讯用的二进制数据流、到了客户端再转换成目标类型。...akka-http的数据转换机制Marshaller/Unmarshaller是通过类型转换的隐式实例来实现的，akka-http提供了多个标准类型数据转换的隐式实例，如StringMarshaller...所以，自定义类型的数据转换主要包括类型->jsonstring->bytestring->jsonstring->类型。

8786 0

restapi（6）- do it the functional way, 重温函数式编程

本来作者的目的很简单：前端通过httprequest提交了一张图片及产品编号pid、系统读取MongoDB查找相同pid的数量count，然后将图片和描述包括count写入数据库并在reponse里返回...把一个简单功能的实现搞的这么复杂都是我的错，可能受OOP荼毒太深。这次希望静下心来用函数式编程模式把这段代码从新实现一次，示范一下函数式编程的代码精炼和高雅特点。...不知怎么搞的，我尽然在这段代码中间使用了Await.result。从OOP角度分析这很容易理解，下一段程序需要上一段程序的结果来继续运行。...在这里可以形象的把Monad函数组合描述为数据库操作步骤：先count、再insert，这两个步骤产生的结果还是留在Monad里的，直到所谓的世界末日，即实际运算完成后才取出，所以Monad是一种典型的程序运算流程管道...encodeResponseWith(Gzip) { complete( HttpEntity

1.1K3 0

【SpringBoot WEB 系列】RestTemplate 之自定义请求头

上一篇介绍了 RestTemplate 的基本使用姿势，在文末提出了一些扩展的高级使用姿势，本篇将主要集中在如何携带自定义的请求头，如设置 User-Agent，携带 Cookie Get 携带请求头...Post 携带请求头拦截器方式设置统一请求头的参数而已重点在于将请求头塞入 HttpEntity 输出结果 (get with selfDefine header: <200,params: {"name...拦截器方式如果我们可以确定每次发起请求时，都要设置一个自定义的 User-Agent，每次都使用上面的两种姿势就有点繁琐了，因此我们是可以通过拦截器的方式来添加通用的请求头，这样使用这个 RestTemplate...时，都会携带上请求头 // 借助拦截器的方式来实现塞统一的请求头 ClientHttpRequestInterceptor interceptor = (httpRequest, bytes, execution

1.8K2 0

设置和获取HTTP标头

GetHeader() 返回此请求中设置的任何主HTTP标头的当前值。此方法接受一个参数，即头的名称(不区分大小写)；这是一个字符串，如Host或Date SetHeader() 设置标题的值。...此方法有两个参数：标头的名称(不区分大小写)，不带冒号(：)分隔符；这是一个字符串，如Host或Date 标头值不能使用此方法设置实体标头或只读标头(Content-Length和Connection...这涉及到设置Transfer-Encoding以指示消息已分块，并使用大小为零的块来指示完成。当服务器返回大量数据并且在完全处理请求之前不知道响应的总大小时，分块编码非常有用。...要发送分块请求，请执行以下操作：创建%Net.ChunkedWriter的子类，%Net.ChunkedWriter是定义以块形式写入数据的接口的抽象流类。...在%Net.HttpRequest的实例中，创建%Net.ChunkedWriter子类的实例，并用要发送的请求数据填充它。

3.7K1 0

【SpringBoot WEB 系列】RestTemplate 之自定义请求头

，如设置 User-Agent，携带 Cookie Get 携带请求头 Post 携带请求头拦截器方式设置统一请求头的参数而已重点在于将请求头塞入 HttpEntity 输出结果 (get with selfDefine header: <200,params: {"name...拦截器方式如果我们可以确定每次发起请求时，都要设置一个自定义的 User-Agent，每次都使用上面的两种姿势就有点繁琐了，因此我们是可以通过拦截器的方式来添加通用的请求头，这样使用这个 RestTemplate...时，都会携带上请求头 // 借助拦截器的方式来实现塞统一的请求头 ClientHttpRequestInterceptor interceptor = (httpRequest, bytes, execution...一灰灰 Blog 尽信书则不如，以上内容，纯属一家之言，因个人能力有限，难免有疏漏和错误之处，如发现 bug 或者有更好的建议，欢迎批评指正，不吝感激下面一灰灰的个人博客，记录所有学习和工作中的博文，

6453 0

点击加载更多

Akka（38）： Http：Entityof ByteString-数据传输基础

Akka（41）： Http：DBTable-rows streaming - 数据库表行交换

Akka（34）： Http：Unmarshalling，from Json

Akka（40）： Http：Marshalling reviewed - 传输数据序列化重温

Akka（28）： Http：About Akka-Http

Akka（33）： Http：Marshalling，to Json

Java调用外部REST请求的几种方式

【Android 应用开发】Android 平台 HTTP网速测试案例 API 分析

工具篇：apache-httpClient 和 jdk11-HttpClient的使用

【Android】HttpURLConnection接口

Haskell HTTP请求：如何解读响应状态

Android网络编程之Http通信

restapi（4）- rest-mongo : MongoDB数据库前端的httpserver

聊聊RestTemplate对HttpClient的适配

聊聊RestTemplate对HttpClient的适配

Akka-CQRS（11）- akka-http for http-web-service: Marshalling-数据序列化

restapi（6）- do it the functional way, 重温函数式编程

【SpringBoot WEB 系列】RestTemplate 之自定义请求头

设置和获取HTTP标头

【SpringBoot WEB 系列】RestTemplate 之自定义请求头

相关资讯

热门标签

活动推荐

运营活动

社区

活动

圈层

关于

腾讯云开发者

热门产品

热门推荐

更多推荐