Node.js http.Server中clientError事件处理的疑问与实现探讨

我的初始clientError事件处理器实现 #

import { getHttpStatusMessage } from '#utils/getHttpStatusMessage.util.mjs';
import type { Socket } from 'node:net';
import type { ConnectionError } from 'koa';

export function clientErrorsHandler(error: ConnectionError, socket: Socket): void {
    socket.on('error', (): void => {});

    if (error.code === 'ECONNRESET')
        return void socket.destroy(error);

    let code: string;
    switch (error.code) {
        case 'ERR_HTTP_REQUEST_TIMEOUT':
            code = '408';
            break;
        case 'HPE_HEADER_OVERFLOW':
            code = '431';
            break;
        default:
            code = '400';
            break;
    }

    if (socket.writable) {
        const status: string = getHttpStatusMessage(code);
        const response: Buffer = Buffer.from(
            `HTTP/1.1 ${code} ${status}\r\nConnection: close\r\nContent-Length: 0\r\n\r\n`
        );
        socket.write(response);
    }

    socket.destroy(error);
}

已知的Socket方法行为 #

• socket.write()：同步将数据放入内部缓冲区，实际网络传输为异步执行
• socket.end()：等待所有缓冲数据传输完成后，调度关闭socket
• socket.destroy()：立即关闭socket并丢弃未发送的缓冲数据

核心疑问 #

1. 我对write()+destroy()的交互逻辑理解是否正确？Node.js官方和Fastify的同类实现是不是无法保证错误响应能送达客户端？
2. 如果确实无法保证送达，这是优先清理异常请求资源的务实权衡，还是因为这类响应数据量极小，本地socket的写入特性让该模式在实践中足够可靠？
3. 我的替代实现改用socket.end(response)，虽然能保证数据送达，但会延迟socket销毁直到数据发送完成并优雅关闭。这种处理方式是否存在资源清理延迟、连接残留等隐患？

我的替代实现 #

import { getHttpStatusMessage } from '#utils/getHttpStatusMessage.util.mjs';
import type { Socket } from 'node:net';
import type { ConnectionError } from 'koa';

export function clientErrorsHandler(error: ConnectionError, socket: Socket): void {
    socket.on('error', (): void => {});

    if (error.code === 'ECONNRESET')
        return void socket.destroy(error);

    let code: string;
    switch (error.code) {
        case 'ERR_HTTP_REQUEST_TIMEOUT':
            code = '408';
            break;
        case 'HPE_HEADER_OVERFLOW':
            code = '431';
            break;
        default:
            code = '400';
            break;
    }

    if (socket.writable) {
        const status: string = getHttpStatusMessage(code);
        const response: Buffer = Buffer.from(
            `HTTP/1.1 ${code} ${status}\r\nConnection: close\r\nContent-Length: 0\r\n\r\n`
        );
        return void socket.end(response); // 不再在发送数据后立即销毁socket
    }

    socket.destroy(error);
}

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