zoukankan      html  css  js  c++  java
  • Java开发笔记(一百一十三)HttpClient实现下载与上传

    前面介绍了通过HttpClient实现HTTP接口的GET方式调用和POST方式调用,那么文件下载与文件上传又该如何操作呢?其实在HttpClient看来,文件下载属于特殊的GET调用,只不过应答报文由字符串形式变成了文件形式;同样文件上传属于特殊的POST调用,只不过请求报文也由字符串形式变成了文件形式。那么文件下载与普通的GET调用相比,在代码上的区别仅仅是发送请求send方法的第二个参数,之前演示普通GET调用的时候,send方法第二个输入参数为BodyHandlers.ofString(),具体调用代码如下所示:

    			// 客户端传递请求信息,且返回字符串形式的应答报文
    			HttpResponse<String> response = client.send(request, BodyHandlers.ofString());
    

    上面代码里的BodyHandlers名叫报文体处理器,它会将服务端返回的应答数据转换为指定形式,比如调用ofString方法表示自动把应答数据转成字符串。除了字符串,BodyHandlers还支持把应答数据转为其它格式,它支持的转换格式及其设置方法说明如下:
    ofString:把应答数据转换为字符串。
    ofByteArray:把应答数据转换为字节数组。
    ofFile:把应答数据转换为文件(Path类型)。
    ofInputStream:把应答数据转换为输入流。
    ofLines:把应答数据转换为分行的字符串流(Stream<String>类型)。
    就文件下载而言,无疑使用ofFile方法最合适,因为该方法可将应答数据保存到本地文件,省去了繁琐的I/O操作。于是对普通的GET调用代码稍加改造,就变成了以下的文件下载代码:

    	// 从指定url下载文件到本地(同步方式)
    	private static void testSyncDownload(String path, String downloadUrl) {
    		// 从下载地址中获取文件名
    		String fileName = downloadUrl.substring(downloadUrl.lastIndexOf("/"));
    		// 创建默认的HTTP客户端对象
    		HttpClient client = HttpClient.newHttpClient();
    		// 创建默认的HTTP请求对象(默认GET调用)
    		HttpRequest request = HttpRequest.newBuilder(URI.create(downloadUrl)).build();
    		try {
    			// 客户端传递请求信息,且返回文件形式的应答报文
    			HttpResponse<Path> response = client.send(request, 
    					BodyHandlers.ofFile(Paths.get(path + fileName)));
    			// 获取应答的所有头部属性
    			HttpHeaders headers = response.headers();
    			// 打印HTTP下载的应答内容长度、内容类型、编码方式
    			System.out.println( String.format("应答内容长度=%s, 内容类型=%s, 编码方式=%s", 
    					headers.firstValue("Content-Length").orElse(null),
    					headers.firstValue("Content-Type").orElse(null),
    					headers.firstValue("Content-Encoding").orElse(null)) );
    			// 打印HTTP下载的应答状态码和应答报文
    			System.out.println( String.format("应答状态码=%d, 文件路径=%s", 
    					response.statusCode(), response.body().toString()) );
    		} catch (Exception e) {
    			e.printStackTrace();
    		}
    	}
    

    然后在外部调用以上的testSyncDownload方法,准备下载某张网络图片,图片下载的调用代码如下:

    		testSyncDownload("D:/", "https://img-blog.csdnimg.cn/2018112123554364.png");
    

    运行以上的图片下载代码,观察到以下的下载日志,可见不费吹灰之力便得到下载好的图片文件。

    应答内容长度=123109, 内容类型=image/png, 编码方式=null
    应答状态码=200, 文件路径=D:2018112123554364.png
    

    由于网络文件可能很大,下载过程也较耗时,因此文件下载操作往往需要另起线程处理。倘若采取传统的HttpURLConnection+Thread组合,对初学者而言宛如天书,敲起键盘不由得战战兢兢。如今有了HttpClient,它本身支持异步方式的调用,所谓异步指的就是开分线程处理,主要事务在主线程中运行,耗时任务在分线程中运行,两条任务线交错并行,步伐相异故而称之为“异步”。相对应的,倘若主要事务与耗时任务都在主线程当中运行,则必然存在先后次序关系,如此方能保持一致的步调,故而此时可称作“同步”。

    HttpClient客户端的send方法默认采取同步方式,一直等到HTTP调用结束才能继续执行后面的代码,它还有另一个异步的请求方法名叫sendAsync,调用该方法后返回的是进行中任务对象CompletableFuture。这个进行中任务CompletableFuture,类似于多线程里面的未来任务FutureTask,它们都表示一个正在运行的异步任务,调用cancel方法可以中途取消该任务,调用isDone方法可以判断该任务是否已经执行完毕,而调用get方法可以获取该任务的执行结果。通过CompletableFuture的协助,HttpClient得以从容实现在分线程中运行的异步文件传输,需要开发者完成的编码工作仅仅是把原来的send方法改成sendAsync方法,就像以下代码示范的那样:

    			// 异步方式调用。sendAsync返回值类型为CompletableFuture<HttpResponse<T>>
    			CompletableFuture<Path> result = client
    					// 客户端发送异步请求,且返回文件形式的应答报文
    					.sendAsync(request, BodyHandlers.ofFile(Paths.get(path + fileName)))
    					// 把CompletableFuture<HttpResponse<T>>类型映射为CompletableFuture<Path>类型
    					.thenApply(HttpResponse::body);
    			// 打印下载完的本地文件路径
    			System.out.println("下载完的本地文件路径="+result.get().toString());
    

    运行更改后的文件下载代码,观察到如下正常输出的下载日志:

    下载完的本地文件路径=D:2018112123554364.png
    

    使用HttpClient实现文件的上传功能则略微复杂,缘于Java官方尚未提供分段数据的转换工具,因此还得借助于Apache的HttpEntity实体类。这样一来又要引入第三方的两个jar包,分别是httpcore-***.jar和httpmime-***.jar,它俩个本来就是Apache推出的HttpClient开发包。说起来真是令人哭笑不得,Java自己搞了一套HttpClient,结果功能不够完备,到头来又得捡回Apache的衣裳来狗尾续貂。这个问题只好留待Java的后续版本予以改进了,不管怎样,当前的HttpClient稍加修补也能满足文件上传的要求,下面是实现文件上传的完整代码例子:

    	// 把本地文件上传给指定url(同步方式)
    	private static void testSyncUpload(String filename, String uploadUrl) {
    		// 创建默认的HTTP客户端对象
    		HttpClient client = HttpClient.newHttpClient();
    		// 官方的HttpClient并没有提供类似WebClient那种现成的BodyInserters.fromMultipartData方法,因此这里需要自己转换
    		// Apache推出的HttpClient的下载页面是 http://hc.apache.org/downloads.cgi
    		// 根据指定文件创建二进制形式的文件体对象
    		FileBody fileBody = new FileBody(new File(filename), ContentType.DEFAULT_BINARY);
    		String boundary = "WUm4580jbtwfJhNp7zi1djFEO3wNNm"; // 边界字符串
    		// 创建用于网络传输的HTTP实体对象
    		HttpEntity entity = MultipartEntityBuilder.create() // 分段实体
    				.addPart("file", fileBody) // 添加文件体
    				.setBoundary(boundary) // 设置边界字符串
    				.build();
    		// 创建字节数组输出流
    		try (ByteArrayOutputStream baos = new ByteArrayOutputStream()) {
    			entity.writeTo(baos); // 把HTTP实体对象写入字节数组输出流
    			// 创建一个自定义的HTTP请求对象
    			HttpRequest request = HttpRequest.newBuilder(URI.create(uploadUrl)) // 待上传的url地址
    					// 设置头部参数,要求分段传输,并且各段之间以边界字符串隔开
    					.header("Content-Type", "multipart/form-data; boundary=" + boundary)
    					// 调用方式为POST,且请求报文为字节数组
    					.POST(BodyPublishers.ofByteArray(baos.toByteArray())).build();
    			// 客户端传递请求信息,且返回字符串形式的应答报文
    			HttpResponse<String> response = client.send(request, BodyHandlers.ofString());
    			// 打印HTTP上传的应答状态码和应答报文
    			System.out.println( String.format("应答状态码=%d, 应答报文=%s", 
    					response.statusCode(), response.body()) );
    		} catch (Exception e) {
    			e.printStackTrace();
    		}
    	}
    

    接着由外部调用上面的testSyncUpload方法,这里访问的是本机的上传服务,具体代码如下所示:

    		testSyncUpload("E:/bliss.jpg", "http://localhost:8080/NetServer/uploadServlet");
    

    运行上面的文件上传代码,从以下的上传日志可知成功完成了上传操作。

    应答状态码=200, 应答报文=文件上传成功,文件大小为1912K
    

    与文件下载一样,HttpClient的文件上传也支持异步方式,仍然是把请求的send方法改为sendAsync方法即可,修改后的代码片段如下所示:

    			// 异步方式调用。sendAsync返回值类型为CompletableFuture<HttpResponse<T>>
    			CompletableFuture<String> result = client
    					// 客户端发送异步请求,且返回字符串形式的应答报文
    					.sendAsync(request, BodyHandlers.ofString())
    					// 把CompletableFuture<HttpResponse<T>>类型映射为CompletableFuture<Path>类型
    					.thenApply(HttpResponse::body);
    			// 打印上传完的应答报文内容
    			System.out.println("文件上传的应答报文="+result.get());
    

    运行更改后的文件上传代码,观察到如下正常输出的上传日志:

    文件上传的应答报文=文件上传成功,文件大小为1912K
    

      

    更多Java技术文章参见《Java开发笔记(序)章节目录

  • 相关阅读:
    运行VCK190的A72的Linux
    【分享】MPSoC UBoot下SD/eMMC卡的验证
    【分享】在MPSoC上运行基于eglfs_kms的QT应用程序
    大数据运维(67)pytorch安装及基本使用(win10+CPU+Python3.6)
    大数据运维(66)PyTorch GPU环境配置及安装
    Java多线程学习-AQS
    Java多线程学习:(wait,notify)--(await,signal)--(park,unpark)
    LeetCode52. N皇后 II
    LeetCode51. N 皇后
    LeetCode417. 太平洋大西洋水流问题
  • 原文地址:https://www.cnblogs.com/pinlantu/p/11047139.html
Copyright © 2011-2022 走看看