0


axios 中如何取消请求_从不会使用到精通原理_番茄出品

start

  • 最近频繁遇到一个问题,axios 是如何取消请求的?
  • 这篇文章将从新手小白的视角出发,从 axios 取消逻辑的基础使用,到原理分析,带你彻底了解并掌握 axios 中取消请求的“秘密”。
  • 编写时间:2023/02/24-23/14
  • 编写作者:lazy_tomato

1. 官方信息

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 =newAbortController();

axios.get('/foo/bar',{signal: controller.signal
}).then(function(response){//...});// cancel the request
controller.abort()

2. CancelToken 使用案例

官方文档中的演示案例不太直观,我们搭建一个服务,本地调试一下。

2.1安装依赖

npm init -ynpm i [email protected] 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.js

2.4 前端代码 index.html

<!DOCTYPEhtml><htmllang="en"><head><metacharset="UTF-8"><title>lazy_tomato出品</title></head><body><h1id="sendGet">发送get请求</h1><h1id="sendPost">发送post请求</h1><h1id="cancel">取消请求</h1><scriptsrc="./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 属性。
  • 当我们想要取消该接口调用的时候,调用 sourcecancel 方法即可。
  • 重复调用,接口会直接取消。

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=functionsource(){var cancel
  // 在 new CancelToken的时候,传入一个函数 executor;将这个函数接收到的参数存储到 cancel 中var token =newCancelToken(functionexecutor(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(functioncancel(message){if(token.reason){// Cancellation has already been requestedreturn}
  token.reason =newCancel(message)resolvePromise(token.reason)})
所以 cancel 可以理解为
functioncancel(message){if(token.reason){return}
  token.reason =newCancel(message)resolvePromise(token.reason)}
调用逻辑
source.cancel('Operation canceled by the user.');// 等同于functioncancel('Operation canceled by the user.'){if(token.reason){return}
  token.reason =newCancel('Operation canceled by the user.')resolvePromise(token.reason)}

3.4 Cancel

上方

new Cancel('Operation canceled by the user.')

对应源码

// 一个普通的函数,包含一个 message 属性functionCancel(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=functionthrowIfRequested(){if(this.reason){throwthis.reason
  }}/**
 * Subscribe to the cancel signal
 * 订阅取消标识
 */CancelToken.prototype.subscribe=functionsubscribe(listener){// 存在错误,直接执行listenerif(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=functionunsubscribe(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

全局逻辑梳理

functionCancelToken(executor){// 1.如果传入的参数不是函数,直接报错。if(typeof executor !=='function'){thrownewTypeError('executor must be a function.')}// 2.定义一个变量var resolvePromise

  // 3.在实例上添加一个 promise 属性,等于一个 Promise对象this.promise =newPromise(functionpromiseExecutor(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)returnvar 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 =newPromise(function(resolve){
      token.subscribe(resolve)
      _resolve = resolve
    }).then(onfulfilled)

    promise.cancel=functionreject(){
      token.unsubscribe(_resolve)}return promise
  }// 8. 处理 executor 的形参executor(functioncancel(message){if(token.reason){return}

    token.reason =newCancel(message)resolvePromise(token.reason)})}

难点说明:

  • 第 3,4 步:this.promise 上存储一个 Promise 对象,该 Promise 对象的状态将由外部的 resolvePromise 控制。
  • 第 5 步:当前实例对象的 token 属性,等于当前实例对象。
  • 第 6,7 步:这两部略微比较复杂。详细说明一下。

第 6 步定义的是

this.promise

成功之后触发的方法。

function(cancel){if(!token._listeners)returnvar 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 =newPromise(function(resolve){
    token.subscribe(resolve)
    _resolve = resolve
  }).then(onfulfilled)

  promise.cancel=functionreject(){
    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 =newXMLHttpRequest()if(config.cancelToken || config.signal){onCanceled=function(cancel){if(req.aborted)return

    req.abort()reject(!cancel ||(cancel && cancel.type)?newCancel('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

functiononCanceled(cancel){// 不存在 request 直接 returnif(!request){return}// 调用 取消的方法。
  request.abort()reject(cancel)// Clean up request
  request =null}

取消请求,落实到具体实现,其实就是:

request.abort()

,也就是

XMLHttpRequest.abort()

MDN官方文档-XMLHttpRequest.abort()

在这里插入图片描述

3.9 取消一次请求,后续请求全部自动取消?

functionthrowIfCancellationRequested(config){if(config.cancelToken){
    config.cancelToken.throwIfRequested();}if(config.signal && config.signal.aborted){thrownewCancel('canceled');}}CancelToken.prototype.throwIfRequested=functionthrowIfRequested(){if(this.reason){throwthis.reason;}};

每次发起请求之前,在处理配置的时候就会触发校验函数:

throwIfCancellationRequested

如果传入的参数存在

cancelToken

,而且

cancelToken

实例上有

reason

则直接报错。

在这里插入图片描述

4. 总结

分两个讲解:

4.1 使用

使用的方式,就是在发送请求的时候,传入一个

cancelToken: CancelToken.source().token

令牌即可。

需要取消请求的时候,手动触发

CancelToken.source().cancel

4.2 原理

  1. CancelToken.source() 会返回一个对象 source
  2. source 对象上有两个属性分别为: token,cancel
{"source.token":"存储 CancelToken 的实例对象 A","source.cancel":"存储可以改变 A.promise 状态的函数"}
  1. A上还存储着,取消当前请求的方法 b;
  2. A.promise 状态改变,就会调用方法 b;
  3. 当我们想主动取消请求的时候,调用 source.cancel =》改变 A.promise 状态 =》调用方法 b;

核心逻辑:利用工厂函数,创建对象。利用闭包的特性,在对象中存储取消请求的方法,共外部调用。

5. 思考

这几天,一直在研究

axios

的取消逻辑代码;截止今天,终于学习并编写完毕了相关文档。

总结一下我自己有那些收获?

5.1 大的方向上:

  1. 了解了 axios 取消请求的用法;
  2. 了解了 axios 取消请求,两个版本的不同实现方式;

5.2 具体的提升:

  1. 源码中,将一个 Promise 对象的状态,交由外部变量控制,这种思路可以模仿;
  2. 相对于我们平时的面向过程编程,包括我查看 Vue 源码中某些功能的实现,都是基于一个 构造函数 实现的,常使用"工厂模式",来批量初始化一些有相同共性的对象,是极其方便的。或许在我后续的编程中,会逐步学习尝试使用这种方式。
  3. 在一个 CancelToken 源码中,批量通知取消请求的逻辑,值得我多加揣摩。一个实例属性,存储多个订阅的对象,当取消请求时,批量通知。(有点类似 发布订阅的思想)

end

axios相关博客

  • 使用axios传递参数,为什么new Date() 会变成 2022-08-10T11:33:56.849Z
  • 最新版axios@1.3.x取消请求-AbortController-初体验-番茄出品

本文转载自: https://blog.csdn.net/wswq2505655377/article/details/129202680
版权归原作者 upward_tomato 所有, 如有侵权,请联系我们删除。

“axios 中如何取消请求_从不会使用到精通原理_番茄出品”的评论:

还没有评论