首页 / JAVASCRIPT / 基于httpRangeRequests协议实现分片下载的功能

基于httpRangeRequests协议实现分片下载的功能

内容导读

互联网集市收集整理的这篇技术教程文章主要介绍了基于httpRangeRequests协议实现分片下载的功能，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含3915字，纯文字阅读大概需要6分钟。

内容图文

本篇文章给大家带来的内容是关于基于http Range Requests协议实现分片下载的功能，有一定的参考价值，有需要的朋友可以参考一下，希望对你有所帮助。

本文基于http Range Requests协议，实现了分片下载的功能。

使用场景包括基于浏览器的流文件片段传输、基于客户端的分片下载等。

原理

http通过Range Requests相关的header，可以与服务器进行协商，实现分部分的请求。

下面贴一下实现过程，代码可以在git查看：https://github.com/keller35/partial。

服务端代码

服务端用node实现：

const fs = require('fs');
const path = require('path');
const Koa = require('koa');

const app = new Koa();
const PATH = './resource';

app.use(async ctx => {
    const file = path.join(__dirname, `${PATH}${ctx.path}`);
    // 1、404检查
    try {
        fs.accessSync(file);
    } catch (e) {
        return ctx.response.status = 404;
    }
    const method = ctx.request.method;
    const { size } = fs.statSync(file);
    // 2、响应head请求，返回文件大小
    if ('HEAD' == method) {
        return ctx.set('Content-Length', size);
    }
    const range = ctx.headers['range'];
    // 3、通知浏览器可以进行分部分请求
    if (!range) {
        return ctx.set('Accept-Ranges', 'bytes');
    }
    const { start, end } = getRange(range);
    // 4、检查请求范围
    if (start >= size || end >= size) {
        ctx.response.status = 416;
        return ctx.set('Content-Range', `bytes */${size}`);
    }
    // 5、206分部分响应
    ctx.response.status = 206;
    ctx.set('Accept-Ranges', 'bytes');
    ctx.set('Content-Range', `bytes ${start}-${end ? end : size - 1}/${size}`);
    ctx.body = fs.createReadStream(file, { start, end });
});

app.listen(3000, () => console.log('partial content server start'));

function getRange(range) {
    var match = /bytes=([0-9]*)-([0-9]*)/.exec(range);
    const requestRange = {};
    if (match) {
        if (match[1]) requestRange.start = Number(match[1]);
        if (match[2]) requestRange.end = Number(match[2]);
    }
    return requestRange;
}

代码实现的功能逻辑大致是：

对请求的资源做检查，不存在则响应404
对于HEAD请求，返回资源大小
如果GET请求没有告知range，返回Content-Length，告知浏览器可以进行分片请求
如果请求设置了range，则检查range是否合法，不合法返回合法的rangge
一切正常，获取文件range范围部分，做流响应

代码很简单，把Range Requests协议对应实现一遍就ok了，当然这里没有完全实现协议的内容，但已经满足了这里演示的需求。

服务端代码ok了，用一个浏览器的demo来检验一下。

浏览器例子

现代浏览器基本都实现了Range Requests，这里用audio标签作为例子。

<html>
    <head>
        <title>分片流传输</title>
        <script type="text/javascript">
            function jump() {
                const player = document.getElementById('musicPlayer');
                // 从30s开始播放
                player.currentTime = 30;
            }
        </script>
    </head>
    <body>
        <audio id="musicPlayer" src="http:127.0.0.1:3000/source.mp3" controls></audio>
        <button onclick="jump()">切到30s</button>
    </body>
</html>

最终的效果是这样的：

基于httpRangeRequests协议实现分片下载的功能 - 文章图片

对比两张图，当html加载完成，浏览器自动请求资源，此时header有Range: bytes=0-，表示从第0 byte开始加载资源；当点击跳到30s处播放时，此时header变成了Range: bytes=3145728-。

同样用这个服务端代码，还可以实现一个客户端，模拟一下分包下载。

node分包下载

这个例子演示了，对一个资源，并发的实现分部分的下载，然后再合并成一个文件。

这里也是用node实现：

import request from 'request';
import path from 'path';
import fs from 'fs';

const SINGLE = 1024 * 1000;
const SOURCE = 'http://127.0.0.1:3000/source.mp3';

request({
    method: 'HEAD',
    uri: SOURCE,
}, (err, res) => {
    if (err) return console.error(err);
    const file = path.join(__dirname, './download/source.mp3');
    try {
        fs.closeSync(fs.openSync(file, 'w'));
    } catch (err) {
        return console.error(err);
    }
    const size = Number(res.headers['content-length']);
    const length = parseInt(size / SINGLE);
    for (let i=0; i<length; i++) {
        let start = i * SINGLE;
        let end = i == length ? (i + 1) * SINGLE - 1 : size - 1;
        request({
            method: 'GET',
            uri: SOURCE,
            headers: {
                'range': `bytes=${start}-${end}`
            },
        }).on('response', (resp) => {
            const range = resp.headers['content-range'];
            const match = /bytes ([0-9]*)-([0-9]*)/.exec(range);
            start = match[1];
            end = match[2];
        }).pipe(fs.createWriteStream(file, {start, end}));
    }
});

代码比较简单，就是开启多个http请求，并发的下载资源，然后根据响应的content-range，写到文件的对应位置。

以上就是基于http Range Requests协议实现分片下载的功能的详细内容，更多请关注Gxl网其它相关文章！

内容总结

以上是互联网集市为您收集整理的基于httpRangeRequests协议实现分片下载的功能全部内容，希望文章能够帮你解决基于httpRangeRequests协议实现分片下载的功能所遇到的程序开发问题。如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。

内容备注

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容，请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。

内容手机端

扫描二维码推送至手机访问。

本文链接：https://qyyshop.com/info/284393.html

来源：【匿名】

【上一篇】详解js中nightwatch的自动化测试【下一篇】javascript 怎么调用php方法

更多 ►

【基于httpRangeRequests协议实现分片下载的功能】教程文章相关的互联网学习教程文章

用js脚本Request.QueryString[""]获取url传

用js脚本Request.QueryString[""]获取url传值时注意的一点比如： var ID= ‘<%= Request.QueryString["id"]%>‘ ，原来的URL为test.aspx?id=value,此处的value中不能包含单引号“‘‘”,否则会出错，test.aspx?id=‘123‘,此时用Request.QueryString["id"] 接收时就会报错，把单引号“‘‘”‘去掉就OK了；还有就是在单独的js文件中用 ‘<%= Request.QueryString["id"]%>‘ 这种方法也取不到id的值，只能在当前页中才能取到。用...

[Javascript] AbortController to cancel the fetch request【代码】

We are able to cancel the fetch request by using AbortController with RxJS Observable.return Observable.create(observer => {// Create an AbortController to able to cancel the fetch requestconst controller = new AbortController();// we need singal to pass to the fetch requestconst signal = controller.singal;// Pass the singal in fetch options fetch(url, { singal }).then(response => {return respons...

浅析XMLHttpRequest的缓存问题_javascript技巧

在使用XMLHttpRequest中有没有遇到过，第一次使用是好的，刷新一下就不行了，清空一下缓存再刷新又好了。这是在使用XMLHttpRequest中常遇到的一个问题，在有的时候XMLHttpRequest请求的结果会缓存在同一个URL中，如果你请求之后的响应不同，就会产生一些莫名其妙的问题，当然也包括文章一开始那个呵呵。解决方法：知道了原理就简单了，也就是每次请求的URL不同，让它每次都去服务器端请求，而不是使用缓存。下面有两种自己常用的...

ajax缓存问题requestheader_javascript技巧

代码如下:var paras="ajaxFlag=getMarkerIDs"; var myAjax=new Ajax.Request( "AddInfoHandler.ashx", {method:get,parameters:paras,onComplete:showGetMarkerIDsResponse} );因为我有一个切换数据库的操作，第一次进数据库A的时候，列表加载正确，点击结点（ajax）地图显示A数据，但点击ie后退再进入数据库B的treeview，列表加载正确（加载列表不是ajax），点击结点地图显示的数据却还是A的数据（ajax），我在AddInfoHandler.as...

javascript-wx.request请求结果如何强制不使用缓存？

wx.request({url: 'wxapp.php',data: {x: '12' ,y: '34'},header: {'Content-Type': 'application/json'},success: function(res) {console.log(res.data)} })php: $x,'y'=>$y]; echo json_encode($z); 当data: {x: '12' ,y: '34'} 返回 1234 当data: {x: '123' ,y: '343'} 返回 Object {x: "123", y: "343"} 再次修改data: {x: '12' ,y: '34'} 编译，清空缓存，重启返回 1234 这是怎么一种情况？回复内容： wx.request({url: 'wxa...

javascript – 如何通过XMLHttpRequest()下载时避免缓存数据【代码】

我正在为Chrome浏览器编写扩展程序(后来希望移植到Firefox).扩展程序从我的服务器下载配置文件 – 通过XMLHttpRequest的xml文件.我发现它是一次下载文件,每次后续调用似乎只是使用文件的缓存原始版本.无论我是否更改服务器上的文件都无关紧要. 我读过你可以试试 xmlhttp.setRequestHeader(‘Pragma’,’Cache-Control：no-cache’); 所以我已经做到了这一点,但它似乎没有任何区别.我可以获得新文件的唯一方法似乎是删除浏览器缓存 ...

javascript-Request-Promise：不要承诺缓存结果【代码】

我正在使用Request-Promise(请参见下面的代码). 问题：如果我缓存了一个诺言,它会缓存结果还是每次都问一个新的诺言？例：var cachedPromise = getTokenPromise(); cachedPromise.then(function(authorizationToken1) {//... }); cachedPromise.then(function(authorizationToken2) {//... }); //QUESTION: Is right that authorizationToken1 equals authorizationToken2getTokenPromise()函数：var querystring = require('quer...

javascript-如何在jQuery中缓存$.post-request的结果？【代码】

我有一个小的jQuery脚本,可以通过查看ID来获取信息. 防止多次请求相同数据的最佳方法是什么(例如,在jQuery中进行缓存的最佳做法是什么？)？我试图使用$.post和$.ajax并将选项“ cache”设置为true,但是该请求被发送了多次. 保存收集的数据并使用集查看是否必须请求它更好吗？欢迎任何想法和建议！如果重要的话,我在服务器端使用ASP.Net MVC.解决方法:您在文档中看到的缓存选项是指浏览器的缓存. 您可以通过多种方式实现自记忆函...

微信小程序网络请求wx.request详解及实例

微信小程序网络请求wx.request详解及实例如果说小程序API里面最重要一个接口是哪一个？那么首推wx.request()。相当于在小程序内请发起一个https请求（本地调试模式下支持HTTP）。HTTP协议中共定义了八种方法或者叫“动作”来表明对Request-URI指定的资源的不同操作方式。 GET：向特定的资源发出请求。POST：向指定资源提交数据进行处理请求。数据被包含在请求体中。PUT：向指定资源位置上传其最新内容。DELETE：请求服务器删除Req...

javascript-如何使用原生的XMLHttpRequest对象提交表单?

HTML:JavaScript: var submit = document.getElementById("submit");submit.onclick = function() {var xhr = new XMLHttpRequest();xhr.onreadystatechange = function(){if(xhr.state == 4) {if((xhr.status >= 200 && xhr.status form.php代码如上, 我想要达到的效果, 是跟在form里添加了action和method属性一样, 提交后可以自动跳转到form.pp.但是这样提交并没有反应, 搜了一下, 全是关于jquery的. 还是不知道用ajax提交表单是...

javascript-post上传完返回format:requestContent-Typeisn'tmultipart/form-data

post上传MP3完返回错误文本是这个{"error":"invalid multipart format: request Content-Type isn't multipart/form-data"} 这是哪里的错误好像说的是说：内容类型不是multipart/form-data”的意思回复内容：post上传MP3完返回错误文本是这个{"error":"invalid multipart format: request Content-Type isnt multipart/form-data"} 这是哪里的错误好像说的是说：内容类型不是multipart/form-data”的意思你在包头没有写入c...

django使用request获取浏览器发送的参数

获取数据(四种方式)1. url: 需要正则去匹配url(r^index/(num)/$, view.index)匹配到的参数会自动传入对应的视图函数也可以给匹配到的参数起名字?P<num>url(r^index/(?P<num1>\d*)(?P<num2>\w*)$,)使用url传参的时候,要么都使用位置参数,要么都使用给参数起名字的方式也可以通过request.path获取到url然后获取相应的参数.如访问127.0.0.1:8000/index/则request.path = /index/2. ?号后面的键值对(又叫查询字符串): 如 index/?num=55...

requests库的基本使用

1. response.content和response.text的区别response.content是编码后的byte类型（“str”数据类型），response.text是unicode类型。这两种方法的使用要视情况而定。注意：unicode -> str 是编码过程（encode()）; str -> unicode 是解码过程（decode()）。示例如下：# --coding:utf-8-- # import requests response = requests.get("https://baidu.com/") print response.url print type(response.content) with open("C:\\Users\\...