Express.js请求失败后如何重启中间件栈重新处理请求？

方案一：抽离业务逻辑，直接复用 #

把路由里的核心请求逻辑抽成独立函数，错误处理时更新端口后直接调用这个函数，不用重新走整个中间件栈，这是最直接高效的方式，还能避免循环问题。

修改后的代码示例：

function getInternalPort() {
    // 从文件读取内部应用当前端口的逻辑
}

let port = getInternalPort()

// 抽离核心业务逻辑
async function fetchInternalData(req) {
    return await functionThatUsesPort()
}

app.get('...a route...', async (req, res, next) => {
    try {
        const result = await fetchInternalData(req)
        res.json(result)
    } catch (error) {
        // 把请求对象带上，方便后续重试
        error.req = req
        next(error)
    }
})

const errorHandler = async (error, request, response, next) => {
    if (error.code == 'ECONNREFUSED') {
        // 限制重试次数，防止死循环
        const retryCount = request.retryCount || 0
        if (retryCount >= 2) {
            return response.status(503).json({ message: '内部服务暂时不可用' })
        }

        // 更新端口
        port = getInternalPort()
        // 标记重试次数
        request.retryCount = retryCount + 1

        try {
            // 直接调用业务逻辑函数
            const result = await fetchInternalData(request)
            response.json(result)
        } catch (retryError) {
            // 重试失败继续抛错
            next(retryError)
        }
    } else {
        response.json(null)
        console.log(error)
    }
}

app.use(errorHandler)

方案二：从头触发整个中间件栈 #

如果必须完整走一遍所有中间件（比如有前置中间件需要重新执行），可以用Express内置的app.handle()方法，它会从中间件栈的最开始处理请求。同样要加重试次数限制，避免无限循环。

修改后的代码示例：

function getInternalPort() {
    // 从文件读取内部应用当前端口的逻辑
}

let port = getInternalPort()

app.get('...a route...', async (req, res) => {
    try {
        const result = await functionThatUsesPort()
        res.json(result)
    } catch (error) {
        next(error)
    }
})

const errorHandler = (error, request, response, next) => {
    if (error.code == 'ECONNREFUSED') {
        const retryCount = request.retryCount || 0
        if (retryCount >= 2) {
            return response.status(503).json({ message: '内部服务暂时不可用' })
        }

        // 更新端口
        port = getInternalPort()
        request.retryCount = retryCount + 1

        // 清除之前的响应状态，避免头已发送的错误
        response.clearCookie()
        response.setHeader('Content-Type', 'application/json')
        // 从头触发整个中间件栈
        app.handle(request, response)
    } else {
        response.json(null)
        console.log(error)
    }
}

app.use(errorHandler)

注意事项 #

• 一定要加重试次数限制，否则如果内部应用一直无法连接，会陷入无限循环，耗尽服务器资源。
• 方案二中用app.handle()时，要确保响应还没有被发送（比如之前没有调用res.send或res.json），否则会抛出"Cannot set headers after they are sent to the client"错误。
• 如果有多个路由或者复杂的中间件逻辑，方案一的抽离业务逻辑方式更可控，也更容易维护。

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