标签导航:

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

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

在异步编程中,处理细粒度错误常常导致代码嵌套复杂,影响可读性,形成“回调地狱”。本文提供一种更优雅的错误处理方法,避免繁琐的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),第二个元素是结果值。

以下示例展示了如何使用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,提高了代码的可读性和可维护性。这是一种更优雅的细粒度错误处理方法。