axios怎么请求数据(axios 中如何取消请求_从不会使用到精通原理_番茄出品)
start
最近频繁遇到一个问题 ,axios 是如何取消请求的? 这篇文章将从新手小白的视角出发 ,从 axios 取消逻辑的基础使用 ,到原理分析 ,带你彻底了解并掌握 axios 中取消请求的“秘密 ” 。 编写时间:2023/02/24-23/14 编写作者:lazy_tomato1. 官方信息
1.1 源码地址
github-axios 点击跳转
1.2 axios 目前 npm 默认版本为 1.3.3
我去年阅读 axios 源码的时候 ,默认版本还是 0.28.x ,今年变成了 1.x.x 了 ,这个需要注意下 。
我对 axios 版本号比较在意的原因是 ,看到过这句话:
axios 的实现原理非常简单 。 但是 axios 的精髓在于它已经迭代了40个版本 ,但是大版本号使用为0. npm 的 version 规则是首个版本号变化表示 api 不向下兼容 。 而 axios 增加了这么多功能 。却始终保持没有 api 明显变化 。 这里 axios 内部使用了多种设计模式和架构模式 。 (适配器 ,桥接 ,代理 ,抽象工厂,微内核设计 。)axios 整体源码不过千行 ,可模仿和学习的地方还是有很多的 ,互勉 。
1.3 axios 中取消请求的api
由上述的截图可得,目前最新的 axios 的取消请求api ,推荐使用 AbortController 。旧版本的 CancelToken 在 v0.22.0 后弃用 。
本文主要讲解 CancelToken , 有关 AbortController 的说明后续博客再做补充 。
1.3.1 CancelToken官方示例
const CancelToken = axios.CancelToken; const source = CancelToken.source(); axios.get(/user/12345, { cancelToken: source.token }).catch(function (thrown) { if (axios.isCancel(thrown)) { console.log(Request canceled, thrown.message); } else { // handle error } }); axios.post(/user/12345, { name: new name }, { cancelToken: source.token }) // cancel the request (the message parameter is optional) source.cancel(Operation canceled by the user.); 1.3.2 AbortController const controller = new AbortController(); axios.get(/foo/bar, { signal: controller.signal }).then(function(response) { //... }); // cancel the request controller.abort()2. CancelToken 使用案例
官方文档中的演示案例不太直观 ,我们搭建一个服务 ,本地调试一下。
2.1安装依赖
npm init -y npm i axios@0.22.0 express body-parser # 注意 ,需要手动指定 axios 的版本 ,默认安装的axios是1.3.x版本的 。2.2 后端服务代码 main.js
const express = require(express) const bodyParser = require(body-parser) const app = express() const router = express.Router() // 跨域请求处理 app.all(*, (req, res, next) => { res.header(Access-Control-Allow-Origin, *) res.header(Access-Control-Allow-Headers, X-Requested-With) res.header( Access-Control-Allow-Headers, Content-Type, Content-Length, Authorization, Accept, X-Requested-With, X_Requested_With ) res.header(Access-Control-Allow-Methods, PUT, POST, GET, DELETE, OPTIONS) //允许接收的请求头上加上一个Authorization ,这样我们才能够将数据发送过去 res.header(X-Powered-By, 3.2.1) // OPTIONS类型的请求 复杂请求的预请求 if (req.method == OPTIONS) { res.send(200) } else { /*让options请求快速返回*/ next() } }) // 挂载处理post请求的插件 app.use(bodyParser.urlencoded({ extended: false })) app.use(bodyParser.json()) router.get(/, (req, res) => { res.send(Hello World) }) // 五秒后返回 router.get(/tomato, (req, res) => { setTimeout(() => { res.send({ text: 我是lazy_tomato, }) }, 5000) }) router.post(/lazy, (req, res) => { console.log(req.body) setTimeout(() => { res.send({ name: req.body.name + tomato, }) }, 5000) }) // 挂载路由 app.use(router) // 监听5000端口 启动服务 app.listen(5000, () => { console.log(Server is running 5000) })2.3 启动本地服务
node ./main.js2.4 前端代码 index.html
<!DOCTYPE html> <html lang="en"> <head> <meta charset="UTF-8"> <title>lazy_tomato出品</title> </head> <body> <h1 id="sendGet">发送get请求</h1> <h1 id="sendPost">发送post请求</h1> <h1 id="cancel">取消请求</h1> <script src="./node_modules/axios/dist/axios.min.js"></script> <script> var sendGet = document.getElementById(sendGet) var sendPost = document.getElementById(sendPost) var cancel = document.getElementById(cancel) const CancelToken = axios.CancelToken; const source = CancelToken.source(); sendPost.addEventListener(click, () => { console.log(开始发送请求post请求) axios.post(http://localhost:5000/lazy, { name: 我是 lazy- }, { cancelToken: source.token }).then(res => { console.log(res) }).catch(err => { if (axios.isCancel(err)) { console.log(请求取消, err); } else { console.log(其他错误, err) } }); }, true) sendGet.addEventListener(click, () => { console.log(开始发送get请求) axios.get(http://localhost:5000/tomato, { cancelToken: source.token }).then(res => { console.log(res) }).catch(err => { if (axios.isCancel(err)) { console.log(请求取消, err); } else { console.log(其他错误, err) } }); }, true) cancel.addEventListener(click, () => { console.log(开始终止请求) source.cancel(手动调用 source.cancel方法 ,手动取消请求); }, true) </script> </body> </html>2.5 效果展示
2.5.1 取消get请求 2.5.2 取消post请求 2.5.3 取消后再次发起请求2.6 CancelToken 使用总结
const CancelToken = axios.CancelToken; const source = CancelToken.source(); axios.get(/user/12345, { cancelToken: source.token }).catch(function (thrown) { if (axios.isCancel(thrown)) { console.log(Request canceled, thrown.message); } else { // handle error } }); axios.post(/user/12345, { name: new name }, { cancelToken: source.token }) // cancel the request (the message parameter is optional) source.cancel(Operation canceled by the user.);对照官方的使用示例 ,总结一下:
不管是 get 请求还是 post 请求 ,都是在调用接口的时候 ,传入一个 cancelToken 属性 。 当我们想要取消该接口调用的时候 ,调用 source的 cancel 方法即可。 重复调用 ,接口会直接取消 。3. 对应源码
如果对源码不感兴趣,可直接跳跃到 4 ,查看结论即可 。
3.1 CancelToken.source()
对照我们的使用案例 ,核心逻辑就是 CancelToken.source() 。源代码如下:
CancelToken.source() 返回值其实就是一个对象,它包含 token ,cancel 两个属性 。
/** * Returns an object that contains a new `CancelToken` and a function that, when called, * cancels the `CancelToken`. * 返回一个对象 ,其中包含一个新的 CancelToken 和一个函数 ,当调用时 , * 取消 CancelToken */ CancelToken.source = function source() { var cancel // 在 new CancelToken的时候 ,传入一个函数 executor;将这个函数接收到的参数存储到 cancel 中 var token = new CancelToken(function executor(c) { cancel = c }) // source 其实就是一个对象 return { token: token, cancel: cancel, } }token 是构造函数 CancelToken 的实例(具体包含那些信息 ,可以查看 CancelToken 构造函数);
cancel 是在 new CancelToken 过程中 ,传入的 executor 函数接收到的形参;
阅读到这里 ,主要逻辑就在函数 CancelToken 。
3.2 CancelToken 整体概览
整体代码截图:
3.3 source 中的 cancel 属性存储的是什么?
查看 CancelToken 中的 executor 函数接收了什么参数?
CancelToken 源码
executor(function cancel(message) { if (token.reason) { // Cancellation has already been requested return } token.reason = new Cancel(message) resolvePromise(token.reason) })所以 cancel 可以理解为
function cancel(message) { if (token.reason) { return } token.reason = new Cancel(message) resolvePromise(token.reason) }调用逻辑
source.cancel(Operation canceled by the user.); // 等同于 function cancel(Operation canceled by the user.) { if (token.reason) { return } token.reason = new Cancel(Operation canceled by the user.) resolvePromise(token.reason) }3.4 Cancel
上方 new Cancel(Operation canceled by the user.) 对应源码
// 一个普通的函数 ,包含一个 message 属性 function Cancel(message) { this.message = message; } // 所以它返回的就是一个包含错误信息的对象 { message: Operation canceled by the user. }3.5 CancelToken 原型上的方法
/** * Throws a `Cancel` if cancellation has been requested. * 如果已请求取消 ,则抛出 Cancel 。 (我的理解:如果实例上存在 reason ,报错) */ CancelToken.prototype.throwIfRequested = function throwIfRequested() { if (this.reason) { throw this.reason } } /** * Subscribe to the cancel signal * 订阅取消标识 */ CancelToken.prototype.subscribe = function subscribe(listener) { // 存在错误 ,直接执行listener if (this.reason) { listener(this.reason) return } // 将 listener 以数组的形式存储在当前实例的 _listeners 上 if (this._listeners) { this._listeners.push(listener) } else { this._listeners = [listener] } } /** * Unsubscribe from the cancel signal * 取消订阅取消标识 */ CancelToken.prototype.unsubscribe = function unsubscribe(listener) { if (!this._listeners) { return } var index = this._listeners.indexOf(listener) if (index !== -1) { this._listeners.splice(index, 1) } }这一小节,查看了 CancelToken 原型上的方法:
throwIfRequested:如果存在取消属性 ,抛出错误 。 subscribe:存储传入的参数 listener; unsubscribe:删除传入的参数 listener;3.6 CancelToken 完整代码分享
CancelToken 全局逻辑梳理
function CancelToken(executor) { // 1.如果传入的参数不是函数 ,直接报错 。 if (typeof executor !== function) { throw new TypeError(executor must be a function.) } // 2.定义一个变量 var resolvePromise // 3.在实例上添加一个 promise 属性,等于一个 Promise对象 this.promise = new Promise(function promiseExecutor(resolve) { // 4. 将 Promise 中的 resolve 函数暴露出去,存储到 resolvePromise 。 resolvePromise = resolve }) // 5. token 为当前 CancelToken 实例对象 var token = this // 6. this.promise 成功后 ,批量调用 token._listeners 每一项 。 this.promise.then(function (cancel) { if (!token._listeners) return var i var l = token._listeners.length for (i = 0; i < l; i++) { token._listeners[i](cancel) } token._listeners = null }) // 7. 更换 promise 的 then 方法 this.promise.then = function (onfulfilled) { var _resolve var promise = new Promise(function (resolve) { token.subscribe(resolve) _resolve = resolve }).then(onfulfilled) promise.cancel = function reject() { token.unsubscribe(_resolve) } return promise } // 8. 处理 executor 的形参 executor(function cancel(message) { if (token.reason) { return } token.reason = new Cancel(message) resolvePromise(token.reason) }) }难点说明:
第 3 ,4 步:this.promise 上存储一个 Promise 对象 ,该 Promise 对象的状态将由外部的 resolvePromise 控制 。 第 5 步:当前实例对象的 token 属性 ,等于当前实例对象 。 第 6 ,7 步:这两部略微比较复杂。详细说明一下 。第 6 步定义的是 this.promise 成功之后触发的方法 。
function (cancel) { if (!token._listeners) return var i var l = token._listeners.length for (i = 0; i < l; i++) { token._listeners[i](cancel) } token._listeners = null }第 7 步定义的是 this.promise 成功时触发的方法。
function (onfulfilled) { var _resolve var promise = new Promise(function (resolve) { token.subscribe(resolve) _resolve = resolve }).then(onfulfilled) promise.cancel = function reject() { token.unsubscribe(_resolve) } return promise }第 6 步和第 7 步 ,如果顺序颠倒 ,执行结果完全不同 。
源码的执行逻辑:第 6 步 ,先注册一个微任务 ,到队列 。然后第 7 步更改当前 Promsie 对象的 then 方法 。
resolvePromise 的时候 ,仅会执行第 6 步 ,但是会判断 then 方法返回的是否是 Promsie 对象 ,是 Promsie 对象则执行第 6 步,不是则跳过 。
3.7 请求 xhr.js
目前的 axios 支持 XMLHttpRequest 和 http 两种方式发送请求 。
本文重点看一下 XMLHttpRequest.
var request = new XMLHttpRequest() if (config.cancelToken || config.signal) { onCanceled = function (cancel) { if (req.aborted) return req.abort() reject(!cancel || (cancel && cancel.type) ? new Cancel(canceled) : cancel) } config.cancelToken && config.cancelToken.subscribe(onCanceled) if (config.signal) { config.signal.aborted ? onCanceled() : config.signal.addEventListener(abort, onCanceled) } }每发送一次请求 ,都会创建一个 XMLHttpRequest 的实例 。如果存在 cancelToken ,主动触发 config.cancelToken.subscribe(onCanceled) 方法 。存储取消的方法 onCanceled 到 CancelToken 的实例上 。
CancelToken 的实例,存储 onCanceled ,这里利用的闭包的特性 。
3.8 onCanceled
function onCanceled(cancel) { // 不存在 request 直接 return if (!request) { return } // 调用 取消的方法 。 request.abort() reject(cancel) // Clean up request request = null }取消请求 ,落实到具体实现 ,其实就是:request.abort() ,也就是 XMLHttpRequest.abort()
MDN官方文档-XMLHttpRequest.abort()
3.9 取消一次请求 ,后续请求全部自动取消?
function throwIfCancellationRequested(config) { if (config.cancelToken) { config.cancelToken.throwIfRequested(); } if (config.signal && config.signal.aborted) { throw new Cancel(canceled); } } CancelToken.prototype.throwIfRequested = function throwIfRequested() { if (this.reason) { throw this.reason; } };每次发起请求之前 ,在处理配置的时候就会触发校验函数: throwIfCancellationRequested
如果传入的参数存在 cancelToken ,而且 cancelToken 实例上有 reason 则直接报错 。
4. 总结
分两个讲解:
4.1 使用
使用的方式 ,就是在发送请求的时候 ,传入一个 cancelToken: CancelToken.source().token 令牌即可 。
需要取消请求的时候 ,手动触发 CancelToken.source().cancel
4.2 原理
CancelToken.source() 会返回一个对象 source;
source 对象上有两个属性分别为: token ,cancel;
{ "source.token":"存储 CancelToken 的实例对象 A", "source.cancel":"存储可以改变 A.promise 状态的函数" }A上还存储着 ,取消当前请求的方法 b;
A.promise 状态改变,就会调用方法 b;
当我们想主动取消请求的时候 ,调用 source.cancel =》改变 A.promise 状态 =》调用方法 b;
**核心逻辑:**利用工厂函数 ,创建对象。利用闭包的特性,在对象中存储取消请求的方法 ,共外部调用 。
5. 思考
这几天 ,一直在研究 axios 的取消逻辑代码;截止今天 ,终于学习并编写完毕了相关文档 。
总结一下我自己有那些收获?
5.1 大的方向上:
了解了 axios 取消请求的用法; 了解了 axios 取消请求 ,两个版本的不同实现方式;5.2 具体的提升:
源码中 ,将一个 Promise 对象的状态 ,交由外部变量控制 ,这种思路可以模仿; 相对于我们平时的面向过程编程 ,包括我查看 Vue 源码中某些功能的实现 ,都是基于一个 构造函数 实现的 ,常使用"工厂模式" ,来批量初始化一些有相同共性的对象 ,是极其方便的。或许在我后续的编程中,会逐步学习尝试使用这种方式 。 在一个 CancelToken 源码中 ,批量通知取消请求的逻辑 ,值得我多加揣摩 。一个实例属性,存储多个订阅的对象 ,当取消请求时 ,批量通知 。(有点类似 发布订阅的思想)end
axios相关博客
使用axios传递参数 ,为什么new Date() 会变成 2022-08-10T11:33:56.849Z 最新版axios@1.3.x取消请求-AbortController-初体验-番茄出品创心域SEO版权声明:以上内容作者已申请原创保护,未经允许不得转载,侵权必究!授权事宜、对本内容有异议或投诉,敬请联系网站管理员,我们将尽快回复您,谢谢合作!