如何在Cloudflare Workers返回响应后执行后续代码？

问题核心：返回Discord的DEFERRED_CHANNEL_MESSAGE_WITH_SOURCE（type 5）响应后，Cloudflare Workers会立即终止请求上下文，导致后续的sendDeferedReply异步任务无法执行。

原因 #

Cloudflare Workers的请求生命周期是返回响应即结束，所有未绑定到特定机制的异步任务会被直接终止，无法完成后续操作。

解决方案 #

使用Cloudflare Workers提供的ctx.waitUntil()方法，将需要在响应后执行的异步任务注册为后台任务，确保Worker在返回响应后继续执行该任务。

代码修改步骤 #

1. 修改fetch函数，添加上下文参数并传递给路由

export default {
    // 添加ctx（上下文）参数
    async fetch(request, env, ctx) {
        if (request.method === 'POST') {
            const signature = request.headers.get('x-signature-ed25519');
            const timestamp = request.headers.get('x-signature-timestamp');
            console.log(signature, timestamp, env.DISCORD_PUBLIC_KEY);
            const body = await request.clone().arrayBuffer();
            const isValidRequest = verifyKey(
                body,
                signature,
                timestamp,
                env.DISCORD_PUBLIC_KEY
            );
            if (!isValidRequest) {
                console.error('Invalid Request');
                return new Response('Bad request signature.', { status: 401 });
            }
        }
        // 将ctx传递给路由处理器
        return router.handle(request, env, ctx);
    },
};

2. 修改路由POST处理器，用waitUntil包裹异步任务

router.post('/', async (request, env, ctx) => {
    const message = await request.json();
    console.log(message);
    if (message.type === InteractionType.APPLICATION_COMMAND) {
        switch (message.data.name.toLowerCase()) {
            case SETUP.name.toLowerCase(): {
                // 用ctx.waitUntil注册后台任务，确保响应返回后继续执行
                ctx.waitUntil(sendDeferedReply(message, env));
                return new JsonResponse({
                    type: 5,
                });
            }
        }
    }
    // 其他交互类型的处理逻辑...
});

3. 确保sendDeferedReply是异步函数
   如果你的sendDeferedReply还不是异步函数，需要调整为返回Promise的形式，示例如下：

async function sendDeferedReply(message, env) {
    // 调用Discord API编辑延迟响应，替换为你的实际逻辑
    const apiUrl = `https://discord.com/api/v10/interactions/${message.id}/${message.token}/callback`;
    const response = await fetch(apiUrl, {
        method: 'POST',
        headers: {
            'Content-Type': 'application/json',
        },
        body: JSON.stringify({
            type: 4, // 编辑延迟响应的类型
            data: {
                content: '设置完成！' // 你的实际回复内容
            }
        })
    });

    // 添加错误处理，便于调试
    if (!response.ok) {
        console.error('延迟回复发送失败:', await response.text());
    }
}

关键说明 #

• ctx.waitUntil()接收一个Promise作为参数，Cloudflare Workers会在返回响应后，等待该Promise完成再终止Worker进程。
• 后台任务的执行时间仍受限于Workers的最大执行时长（当前为15分钟），如果任务耗时过长，仍需拆分优化。

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