2

应用概述

我有一个使用 express.js 4 模块和 node.js 核心 http 模块实现的 node.js 服务器应用程序。在高层次上，应用程序接收传入的客户端 http 消息，对其他外部 API 进行各种 http 调用（使用 http 模块），最后根据上述各种外部 http API 响应的响应向客户端发送响应。

问题

我的问题是，当传入的客户端 http 请求被客户端终止时（例如，当客户端想要取消他们的请求时），我的 node.js 应用程序继续进行上述各种外部 http API 调用。在这种情况下，我似乎找不到向我的 node.js 应用程序的其余部分发出信号以终止其对外部 API 的各种传出 http 请求的方法。

当客户端终止他们的请求时，快速应用程序（即快速 http 服务器）会收到我正在监听的“关闭”事件。我的代码中的“关闭”事件监听器捕获了这个事件；但是，我似乎无法弄清楚如何向我的代码发出的“下游”或“后续”http请求发出信号以终止。

我的目标

当客户端终止对我的服务的传入请求时，如何向与单个客户端传入请求相关联的外部 API 发出所有传出 http 请求以终止？

我在下面提供了我的 node.js 应用程序的简化版本，其中包含一些内联代码注释，以帮助更清楚地说明我的问题。任何帮助或见解将不胜感激。谢谢！

附加信息

我正在使用 Apigee swagger-tools 中间件来执行我的 api 路由。

我发现了一些类似但不太直接适用于我的问题的已回答问题：

使用 Express/Node.js 和 Angular 处理取消的请求

如何检测用户取消请求

最好的，

克里斯

测试app.js

// test-app.js
"use strict";

var swaggerTools = require("swagger-tools");
var app = require("express")();

// swaggerRouter configuration
// sends incoming http messages to test-controller.js
var options = {
    controllers: './controllers'
};

// The Swagger document (require it, build it programmatically, fetch it from a URL, ...)
// describes the API specification
var apiSpec = require('./test-swagger.json');

// Initialize the Swagger middleware
swaggerTools.initializeMiddleware(apiSpec, function (middleware) {
    "use strict"

    // Interpret Swagger resources and attach metadata to request - must be first in swagger-tools middleware chain
    app.use(middleware.swaggerMetadata());

    // Validate Swagger requests/responses based on test-swagger.json API specification
    app.use(middleware.swaggerValidator());

    // Route validated requests to appropriate controller, test-controller.js
    app.use(middleware.swaggerRouter(options));
});

// Run http server on port 8080
app.listen(8080, function () {
    "use strict";
    console.log("Server running on port %d", this.address().port);
})
    .on("connection", function (socket) {
        console.log("a new connection was made by an incoming client request.");
        socket.on("close", function () {
            console.log("socket connection was closed by client");
            // somehow signal to the rest of my node.js app to terminate any
            // http requests being made to external APIs, e.g. twitter api
            socket.destroy();
        });
    })

测试控制器.js

//test-controller.js
"use strict";
var http = require("https");

// only one function currently, consequently, all incoming http requests are
// routed to this function, i.e. "compile"
module.exports = {
    compile: compile
};

function compile(req, res, next) {
    var options = {
        "method": "GET",
        "hostname": "api.twitter.com",
        "path": "/1.1/statuses/mentions_timeline.json?count=2&since_id=14927799",
        "headers": {"accept": "application/json"}
    };
    // how can i terminate this request when the http.server in test-app.js receives the "close" event?
    http.request(options)
        .on("response", function(response) {
            var apiResponse = [];
            response.on("data", function (chunk) {
                apiResponse.push(chunk);
            });
            response.on("end", function () {
                apiResponse = Buffer.concat(apiResponse).toString();
                res.status(response.statusCode).set(response.headers).send(apiResponse);
            });
        })
}
4

1 回答 1

1

在您的测试控制器的 compile 方法中，您应该能够执行以下操作：

var request = http.request(options, function (response) {
  res.writeHead(response.statusCode, response.headers)
  response.pipe(res, { end: true })
})
req.on('close', function(){
  request.abort()
})
于 2016-08-24T21:51:27.447 回答