Node.js请求在收到响应之前丢弃

const http = require('http');

// 创建一个 HTTP 请求
const options = {
  hostname: 'example.com',
  port: 80,
  path: '/',
  method: 'GET'
};

const req = http.request(options, (res) => {
  console.log(`STATUS: ${res.statusCode}`);
  console.log(`HEADERS: ${JSON.stringify(res.headers)}`);
  
  // 监听响应数据
  res.on('data', (chunk) => {
    console.log(`BODY: ${chunk}`);
  });

  // 响应结束
  res.on('end', () => {
    console.log('No more data in response.');
  });
});

// 处理请求错误
req.on('error', (e) => {
  console.error(`Problem with request: ${e.message}`);
});

// 模拟某种条件，在 1 秒后终止请求
setTimeout(() => {
  console.log('Aborting request...');
  req.abort();
}, 1000);

// 发送请求
req.end();

const axios = require('axios');
const CancelToken = axios.CancelToken;
const source = CancelToken.source();

axios.get('http://example.com', {
  cancelToken: source.token
}).then((response) => {
  console.log(response.data);
}).catch((thrown) => {
  if (axios.isCancel(thrown)) {
    console.log('Request canceled', thrown.message);
  } else {
    console.log('Error:', thrown.message);
  }
});

// 模拟某种条件，在 1 秒后取消请求
setTimeout(() => {
  console.log('Canceling request...');
  source.cancel('Operation canceled by the user.');
}, 1000);

const fetch = require('node-fetch');
const AbortController = require('abort-controller');

const controller = new AbortController();
const signal = controller.signal;

fetch('http://example.com', { signal })
  .then((response) => response.text())
  .then((data) => {
    console.log(data);
  })
  .catch((err) => {
    if (err.name === 'AbortError') {
      console.log('Request was aborted');
    } else {
      console.log('Fetch error:', err);
    }
  });

// 模拟某种条件，在 1 秒后取消请求
setTimeout(() => {
  console.log('Aborting request...');
  controller.abort();
}, 1000);