异步编程中，如何优雅地处理细粒度错误？

异步编程中优雅的细粒度错误处理

在异步编程中，处理细粒度错误常常导致代码嵌套复杂，影响可读性，形成“回调地狱”。本文提供一种更优雅的错误处理方法，避免繁琐的try...catch嵌套。

我们以一个包含多个异步操作的函数为例，每个操作都可能抛出错误。传统的try...catch嵌套如下：

async function xxx() {
    try {
        const result1 = await getinfo1();
        try {
            const result2 = await getinfo2(result1);
            // ...更多嵌套
        } catch (error) {
            // 处理错误
        }
    } catch (error) {
        // 处理错误
    }
}

这种嵌套结构难以阅读和维护。为了改进，我们可以使用await-to-js等工具，将错误处理与业务逻辑分离。await-to-js返回一个数组，第一个元素是错误对象（无错误则为null），第二个元素是结果值。

魔珐星云

无需昂贵GPU，一键解锁超写实/二次元等多风格3D数字人，跨端适配千万级并发的具身智能平台。

下载

以下示例展示了如何使用await-to-js：

import to from 'await-to-js';

async function asyncTaskWithCb(cb) {
    let err, user, savedTask, notification;

    [err, user] = await to(UserModel.findById(1));
    if (!user) return cb('用户未找到');

    [err, savedTask] = await to(TaskModel.create({ userId: user.id, name: 'Demo Task' }));
    if (err) return cb('保存任务失败');

    if (user.notificationsEnabled) {
        [err] = await to(NotificationService.sendNotification(user.id, '任务创建'));
        if (err) return cb('发送通知失败');
    }

    if (savedTask.assignedUser.id !== user.id) {
        [err, notification] = await to(NotificationService.sendNotification(savedTask.assignedUser.id, '您有新任务'));
        if (err) return cb('发送通知失败');
    }

    cb(null, savedTask);
}

async function asyncFunctionWithThrow() {
  const [err, user] = await to(UserModel.findById(1));
  if (!user) throw new Error('用户未找到');
}

通过await-to-js，我们可以清晰地处理每个异步操作的错误，避免了嵌套的try...catch，提高了代码的可读性和可维护性。这是一种更优雅的细粒度错误处理方法。