利用Socket完成http请求,手动组装头信息,灵活性更高。
自己做个记录,方便下次拿来使用。
注意问题:
1.HTTP请求报文包含请求行、请求头部、空行、请求包体4个部分组成。
2.模拟请求头部时Accept-Encoding不要使用压缩,否则响应结果会出现乱码。
3.请求头部结束使用回车换行符结束。
private void text() throws IOException {
Socket socket = new Socket("115.159.78.xxx", 8080);
StringBuffer sb = new StringBuffer("GET http://115.159.78.xxx:8080/noticecontroller/info HTTP/1.1\r\n");
// 以下为请求头
sb.append("Host: 115.159.78.xxx\r\n");
sb.append("User-Agent: Mozilla/5.0 (Windows NT 6.1; WOW64; rv:53.0) Gecko/20100101 Firefox/53.0\r\n");
sb.append("Accept: text/html,application/xhtml+xml,application/xml;q=0.9,*/*;q=0.8\r\n");
sb.append("Accept-Language: zh-CN,zh;q=0.8,en-US;q=0.5,en;q=0.3");
// 注意这里不要使用压缩 否则返回乱码
sb.append("Accept-Encoding: \r\n");
sb.append("Range: bytes=2-10\r\n");
sb.append("Connection: keep-alive\r\n");
sb.append("Content-Length: 100\r\n");
sb.append("Upgrade-Insecure-Requests: 1\r\n");
// 注意这里要换行结束请求头
sb.append("\r\n");
System.out.println(sb.toString());
OutputStream os = socket.getOutputStream();
os.write(sb.toString().getBytes());
InputStream is = socket.getInputStream();
ByteArrayOutputStream baos = new ByteArrayOutputStream();
byte[] bytes = new byte[1024];
int len = -1;
while ((len = is.read(bytes)) != -1) {
baos.write(bytes, 0, len);
}
System.out.println(new String(baos.toByteArray()));
socket.close();
}
ok,现在我们来实现断连续传。
首先介绍一下HTTP Range 头域的使用:
Range头域可以请求实体的一个或者多个子范围。例如,
表示头500个字节:bytes=0-499
表示第二个500字节:bytes=500-999
表示最后500个字节:bytes=-500
表示500字节以后的范围:bytes=500-
第一个和最后一个字节:bytes=0-0,-1
同时指定几个范围:bytes=500-600,601-999
我们先准备一个由于中断下载仅下载1000字节的文件,假设我们已经准备好了。接下来看代码,注释很详细,我就不解释了。(为了方便,这里没使用socket,如若使用socket,同理,加上Range头域就ok了)
//Kotlin
/**
* java 断点续传.
*/
@Test fun text() {
val url = URL("http://gdown.baidu.com/data/wisegame/2336735c7e89381c/weixin_1120.apk")
val httpUrlContent = url.openConnection()
httpUrlContent.doInput = true
httpUrlContent.doOutput = true
//设置头信息Range, 从第1000位字节开始拉取,包括1000
httpUrlContent.setRequestProperty("Range", "bytes=1000-")
httpUrlContent.connect()
var length = httpUrlContent.contentLength
val inputStream = httpUrlContent.getInputStream() ?: return
val byteArray = ByteArrayOutputStream()
byteArray.write(inputStream.readBytes(length))
save(byteArray.toByteArray())
}
fun save(b: ByteArray) {
//打开xxx.apk文件输出流
var file = File("xxx.apk")
val byteArrays = ByteArrayOutputStream()
//如果xxx.apk已存在,将原有字节拉取出来,与新拉去的字节进行拼接
if (file.exists()) {
var input = file.inputStream()
var bytess = ByteArray(1)
while ((input.read(bytess)) > -1) {
var lens = bytess.size
byteArrays.write(bytess, 0, lens)
}
}
byteArrays.write(b)
val output = FileOutputStream(file)
//字节输出
output.write(byteArrays.toByteArray())
output.flush()
output.close()
}
结束。
笔者能力有限,不足之处欢迎指出。
网友评论