Socket模拟Http请求实现断连续传

利用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()
    }

结束。

笔者能力有限，不足之处欢迎指出。

最后编辑于：2017.11.27 12:35:46

Socket模拟Http请求 实现断连续传

Socket模拟Http请求实现断连续传