JS AbortController：服务端如何监听请求取消信号？

答案是可以。当客户端调用abortController.abort()时，浏览器会主动关闭当前HTTP连接（HTTP/1.1发送FIN包，HTTP/2发送RST_STREAM帧），服务端可以通过监听连接中断或请求终止的事件来捕获这个行为，进而执行回滚操作。

下面是不同服务端技术栈的具体实现方式：

Node.js（Express/Koa 为例） #

在Node.js的Web框架中，请求对象（req）会在客户端断开连接时触发close事件，同时如果正在处理请求体或流式响应，还可能抛出ECONNRESET错误。你可以利用这些来触发回滚逻辑：

// Express 示例
app.post('/your-endpoint', async (req, res) => {
  let hasCompleted = false;

  // 监听客户端断开事件
  req.on('close', async () => {
    if (!hasCompleted) {
      // 执行你的回滚逻辑
      await rollbackRelatedChanges();
    }
  });

  try {
    // 处理请求，比如修改数据库等操作
    await handleBusinessLogic(req.body);
    
    // 响应成功，标记为已完成
    res.status(200).json({ status: 'success' });
    hasCompleted = true;
  } catch (err) {
    // 捕获客户端断开导致的连接重置错误
    if (err.code === 'ECONNRESET') {
      await rollbackRelatedChanges();
    } else {
      // 处理其他业务错误
      res.status(500).json({ error: err.message });
      hasCompleted = true;
    }
  }
});

注意：close事件会在请求正常结束或异常断开时都触发，所以必须用hasCompleted这类标记来避免重复执行回滚。

Python（Flask/Django 为例） #

• Flask：可以通过request.environ中的werkzeug.request_disconnected判断，或者利用request_tearing_down信号在请求结束时检查连接状态：

  from flask import Flask, request
  from flask.signals import request_tearing_down
  
  app = Flask(__name__)
  
  def handle_rollback(sender, **extra):
      if request.environ.get('werkzeug.request_disconnected'):
          # 执行回滚逻辑
          rollback_changes()
  
  request_tearing_down.connect(handle_rollback, app)
  
  @app.post('/your-endpoint')
  def handle_request():
      try:
          # 处理业务逻辑
          process_data(request.get_json())
          return {'status': 'success'}, 200
      except BrokenPipeError:
          # 捕获客户端断开导致的管道破裂错误
          rollback_changes()
          return '', 499
  

• Django：可以在视图中捕获BrokenPipeError，或者通过中间件监听请求的关闭状态：

  from django.http import JsonResponse
  
  def your_view(request):
      try:
          # 处理业务逻辑
          process_data(request.body)
          return JsonResponse({'status': 'success'})
      except BrokenPipeError:
          rollback_changes()
          return JsonResponse({}, status=499)
  

关键注意事项 #

• 网络延迟可能导致服务端无法立即收到断开通知，所以回滚逻辑最好设计成幂等的，即使多次执行也不会破坏数据一致性。
• 对于短请求，可能服务端已经完成处理并发送响应，此时客户端取消不会触发回滚，所以要确保回滚只在业务操作未完成时执行。
• 部分反向代理或负载均衡器可能会保持连接，需要确保这些组件不会屏蔽客户端的断开信号。

内容的提问来源于stack exchange，提问作者Josh