HTTP之断点续传教程
这里主要是理解http断点续传的原理，如何通过http请求头操作，以及相应的请求和响应头的设置。
server端实现
// 断点续传
// 客户端要发一个头 Range:bytes = 0 -1
// 服务端返回一个头
// Accept-Ranges:bytes
// COntent-Ranges: 0-10/总大小
const http = require(\'http\')
const fs = require(\'fs\')
const path = require(\'path\')
const {promisify} = require(\'util\')
const stat = promisify(fs.stat) // 将方法promise化
const server = http.createServer(async (req, res) => {
let p = path.join(__dirname, \'content.txt\')
let statObj = await stat(p)
let start = 0
let end = statObj.size //可读流是包前包后
let total = end
// 读取文件大小
// 读取请求头
let range = req.headers[\'range\']
// 如果有请求头部，则进行分片读取
if (range) {
// 设置请求头，告诉浏览器支持分片下载
res.setHeader(\'Accept-Ranges\', \'bytes\')
// 拿到起始位置和结束为止
let result = range.match(/bytes=(\\d*)-(\\d*)/)
start = result[1] ? result[1] - 0 : start
end = result[2] ? result[2] - 1 : end
// 获取成功 并且文件总大小告诉客户端
res.setHeader(\'Content-Range\', `${start}-${end}/${total}`)
}
res.setHeader(\'Content-Type\', \'text/plain;charset=utf8\');
fs.createReadStream(p, {start, end}).pipe(res)
})
server.listen(3000)
// server启动成功
server.on(\'listening\', () => {
console.log(\'http启动完成\')
})
// 关闭HTTP服务器
server.on(\'close\', () => {
console.log(\'服务器关闭\')
})
// 服务器监听错误
server.on(\'error\', e => {
console.log(e)
})
模拟客户端
这里使用node模拟客户端
const http = require(\'http\')
const fs = require(\'fs\')
const path = require(\'path\')
let ws = fs.createWriteStream(path.join(__dirname, \'./download.txt\'))
let pause = false
let start = 0
let step = 10
// 请求参数
let options = {
hostname: \'localhost\',
port: 3000,
path: \'/\',
methods: \'GET\'
}
/**
* @description 下载文件
*/
function download () {
// 跟新请求头
options.headers = {
Range: `bytes=${start}-${start step}`
}
// 更新下标
start = step
// 发送请求
http.get(options, res => {
let range = res.headers[\'content-range\']
let total = range.split(\'/\')[0]
let buffers = []
res.on(\'data\', chunk => {
buffers.push(chunk)
})
// 合并文件 并写入本地磁盘
res.on(\'end\', () => {
ws.write(Buffer.concat(buffers))
console.log(\'end\', buffers.toString())
// 如果不是暂停，并且没有大于文件总长度，才会继续下载
// if (pause === false && start < total) download()
// 为了展示效果，这里做一个手动延迟
setTimeout(() => {
if (pause === false && start < total) download()
}, 5000)
})
})
}
download()
// 下载 每次获取10个 我们在控制台进行操作 输入p是暂停，其他任意键是继续
process.stdin.on(\'data\', chunk => {
chunk = chunk.toString()
if (chunk.includes(\'p\')) {
pause = true
} else {
pause = false
download()
}
})
总结
通过以上简单的代码，对断点续传，以及http请求头做了一个学习和体会，知道了Accept-Range的作用，其实很多东西都可以通过请求头和响应头来操作，只是目前太菜了 好多还只能看看….
