目录
一、示例代码1
二、示例代码2
一、示例代码1
import java.io.*;
import java.net.HttpURLConnection;
import java.net.URL;public class Test {/*** 下载图片*/public void getNetImg() {InputStream inStream = null;FileOutputStream fOutStream =null;try {// URL 统一资源定位符URL url = new URL("https://t7.baidu.com/it/u=825057118,3516313570&fm=193&f=GIF");// 建立HttpURLConnection连接对象HttpURLConnection connection = (HttpURLConnection) url.openConnection();// 设定 请求方式connection.setRequestMethod("GET");// 连接服务器connection.connect();// 判断请求响应是否成功,响应的状态码。200 响应成功、404 或 500等if(connection.getResponseCode()==200){System.out.println("connection.getResponseCode()返回的状态码:"+connection.getResponseCode());// 从输入流中读取inStream = connection.getInputStream();// 文件输出流fOutStream = new FileOutputStream(new File("E:\\天空之城.jpg")); //new File("myImg.jpg")默认存储在项目根目录// 定义缓存字节数组,存放图片byte[] bs = new byte[1024];int len = 0;while((len = inStream.read(bs))!=-1){ //inStream.read(bs);返回的是数组的长度。最多一次读出bs.length个字节,读到文件末尾返回-1fOutStream.write(bs, 0, len); //写入到文件输出流中fOutStream.flush(); // 强制持久化到存储设备,然后清空缓存}} else {System.out.println("响应失败!状态码:"+connection.getResponseCode());}} catch (IOException e) {e.printStackTrace();}finally {if(inStream!=null){try {inStream.close(); // 关闭输入流} catch (IOException e) {e.printStackTrace();}}if(fOutStream!=null){try {fOutStream.close(); // 关闭输出流} catch (IOException e) {e.printStackTrace();}}}}}
下载后存储的主要代码:
// 从输入流中读取 inStream = connection.getInputStream(); // 文件输出流 fOutStream = new FileOutputStream(new File("E:\\天空之城.jpg")); 注:new File("E:\\天空之城.jpg")指定下载后文件的保存位置。new File("myImg.jpg")默认存储在项目根目录// 定义缓存字节数组,存放图片 byte[] bs = new byte[1024]; int len = 0;//inStream.read(bs);返回的是数组的长度。最多一次读出bs.length个字节,读到文件末尾返回-1 while((len = inStream.read(bs))!=-1){ fOutStream.write(bs, 0, len); //写入到文件输出流中fOutStream.flush(); // 强制持久化到存储设备,然后清空缓存 }
二、示例代码2
import org.apache.commons.codec.binary.Base64;
import org.springframework.util.FileCopyUtils;import java.io.*;
import java.net.HttpURLConnection;
import java.net.URL;
import java.util.HashMap;
import java.util.Map;public class Test {public Map<String, String> getWFile() throws Exception {// 定义mapMap<String, String> map = new HashMap<String, String>();URL url = new URL("https://gd-hbimg.huaban.com/02e9bd22213105052e000fa3dfde5b69a98ae3521e224-q1KQCC_fw1200webp");HttpURLConnection conn = (HttpURLConnection) url.openConnection();conn.setRequestMethod("GET");conn.setConnectTimeout(1000*5);//5秒,连接超时时间conn.setReadTimeout(1000*20);//20秒,读取超时时间conn.setRequestProperty("Content-Type", "application/octet-stream");conn.setDoOutput(true);conn.setDoInput(true);//conn.setRequestProperty("Connection", "Keep-Alive"); // 设置为HTTP长连接conn.connect();System.out.println("connection.getResponseCode()返回的状态码:"+conn.getResponseCode());InputStream inputStream = conn.getInputStream(); //输入流,从中读取ByteArrayOutputStream swapStream = new ByteArrayOutputStream(); //字节输出流byte[] buff = new byte[100]; //定义缓存字节数组int rc = 0;while ((rc = inputStream.read(buff, 0, 100)) > 0) {swapStream.write(buff, 0, rc); //写入字节输出流swapStream.flush(); // 强制持久化到存储设备,然后清空缓存}byte[] data = swapStream.toByteArray(); //toByteArray(),ByteArrayOutputStream对象 转字节数组map.put("inputStream", Base64.encodeBase64String(data)); //对字节数组编码为Base64字符串(String)return map;}public static void main(String[] args) {try{Test test=new Test();// 调用方法getWFile()下载文件Map<String, String> map = test.getWFile();byte[] bytes = Base64.decodeBase64(map.get("inputStream")); // 将Base64字符串解码 为byte[]数组ByteArrayInputStream bs = new ByteArrayInputStream(bytes); // 创建转换为ByteArrayInputStream字节数组输入流对象FileOutputStream out = new FileOutputStream(new File("E:\\天空之城2.jpg")); //创建文件输出流,(目标文件)//FileCopyUtils.copy(bs, out)是用于文件复制的方法,其中bs代表源文件的字节数据,而out代表目标文件的位置。// 这个方法的主要用途包括简化文件复制操作,避免编写繁琐的文件读写代码,提供高效的文件复制方法,提高文件传输的效率,并支持多种数据源和目标源的复制操作,// 如从输入流到输出流、从文件到文件等。此方法用到内存,注意JVM内存溢出问题(文件太大时)。FileCopyUtils.copy(bs, out);}catch (Exception e){e.printStackTrace();}}}
示例代码2中主要增加了:
conn.setConnectTimeout(1000*5);//5秒,连接超时时间 conn.setReadTimeout(1000*20);//20秒,读取超时时间 注:两个超时设置防止网络异常或服务端异常时,导致客户端长时间连接或读取不释放,而影响客户端应用的正常运行。main方法中使用了FileCopyUtils.copy(bs, out)是用于文件复制的方法,其中bs代表源文件的字节数据,而out代表目标文件的位置。这个方法的主要用途包括简化文件复制操作,避免编写繁琐的文件读写代码,提供高效的文件复制方法,提高文件传输的效率,并支持多种数据源和目标源的复制操作, 如从输入流到输出流、从文件到文件等。此方法用到内存,注意JVM内存溢出问题(文件太大时)。
说说conn.setRequestProperty("Connection", "Keep-Alive")设置:
HTTP的Keep-Alive即:保持Http长连接,底层通过保持TCP连接一段时间来达到长连接的目的。这段时间可以重复发送HTTP请求(request/response)。解决HTTP请求量大的情况。
HTTP 1.0 中默认是关闭的,需要在http头加入"Connection: Keep-Alive",才能启用Keep-Alive;
HTTP 1.1 中默认启用Keep-Alive,如果加入"Connection: close ",才关闭。
一般而言客户端只设置是否启用Keep-Alive,而保持连接的控制取决于服务端(如保持连接的时长、最大连接数量等)。tomcat、weblogic等各自设置属性有不同。现在的浏览器、java8往后都是默认开启的Keep-Alive。