javascript - Node 为使用 Promise.all 和 .catch() 语句的 Mongoose 请求抛出 UnhandledPromiseRejectionWarning

Question

我是 Node/Mongoose 的新手，我正在尝试正确处理脚本中的错误以将玩家添加到联盟中。在下面的代码中，.catch() 语句正确捕获了显式抛出的和非 Promise 相关的错误，但拒绝的 Promise 却没有。

例如，尝试传递无效的用户 ID 会抛出 User not found。

但是如果我通过断开数据库来测试 Promise 拒绝，我会得到以下信息:

(node:6252) UnhandledPromiseRejectionWarning: Unhandled promise rejection (rejection id: 1): MongoNetworkError: failed to connect to server [localhost:27017] on first connect [MongoNetworkError: connect ECONNREFUSED 127.0.0.1:27017]

我是否错误地使用了 Promise.all() 和 .catch()？

需要说明的是，我正在尝试找出错误没有得到处理的原因，而不是抛出错误的原因。

我的脚本:

const 
mongoose = require('mongoose'),
User = require('./models/users'),
League = require('./models/leagues'),
dbUrl = process.env.DBURL || 'mongodb://localhost/predictor';

mongoose.connect(dbUrl, { useNewUrlParser: true });

const addUserToLeague = (userId, leagueId) => {
    let foundUser = User.findById(userId);
    let foundLeague = League.findById(leagueId);

    return Promise.all([foundUser, foundLeague])
    .then(arr => {
        if(!arr[0]){
            throw 'User not found';
        }else if(!arr[1]){
            throw 'League not found';
        }
        return arr;
    })
    .then(arr => {
        arr[0].leagueMemberships.push(arr[1]);
        arr[1].users.push(arr[0]);
        return arr;
    })
    .then(updatedArr => {
        updatedArr[0].save();
        updatedArr[1].save();
        return updatedArr;
    })
    .then(updatedArr => { console.log(`User ${updatedArr[0]._id} added to league ${updatedArr[1]._id}`) })
    .catch(err => { console.log('Error:', err) });
};

addUserToLeague(process.argv[2], process.argv[3]); // Needs 2 args: User ID and League ID

Answer 1

正如 Bergi 所指出的，错误似乎来自 connect，returns a promise你根本没有处理的——包括不等待它完成。所以至少，您需要处理:

const connectionPromise = mongoose.connect(dbUrl, { useNewUrlParser: true })
    .catch(error => {
        // Handle connection error
    });

然后在 addUserToLeague 中:

const addUserToLeague = (userId, leagueId) => {
    return connectionPromise.then(connection => {
        // ...logic here
    });
};

...但是，我怀疑你是否应该在模块像这样加载时进行连接，而不是将连接传递给 addUserToLeague。

---

除此之外，Promise.all 的实际使用是可以的，但是:

1. 如果找不到项目，希望 findById 不会解决具有虚假值的 promise，这样整个第一个 then 处理程序似乎是不必要的。
2. 大概 save 返回一个 promise 。如果是这样，您不是在处理拒绝或等待解决这些问题。
3. 我会使用解构来避免 arr[0] 和 arr[1]，因为很容易忘记顺序。
4. 没有理由将带有 push 调用的 then 处理程序与执行保存操作的 then 处理程序分开。
5. addUserToLeague 应该返回 promise 链的结果，这样调用它的代码 A) 知道它何时完成，以及 B) 知道它何时失败。
6. 不应在 addUserToLeague 中处理错误；相反，在其调用者中处理它们。
7. 还有一个问题是数据是 denormalized :您将成员信息存储在用户对象和联盟对象中。也许这在文档数据库中是相对正常的(我不知道)；在 RDBMS 中，您会将信息存储在单个 位置。从addUserToLeague中的代码可以看出原因:保存用户成功但保存联盟失败怎么办？然后用户对象说它是一个联盟的成员，而联盟对象并没有说它是其中的成员。还有一个问题是，由于它存储在两个地方，即使没有出现任何问题，在短时间内，其中一个(用户或联盟)会被保存，而另一个则不会。两者都是完整性问题。如果您可以将其规范化以将此信息存储在一个地方，那就太好了。如果不能，则需要更新代码，以便保存其中一个，等待成功，保存另一个，如果失败，则尝试撤消对第一个的更改。

类似这样的事情(我不想在这里解决规范化问题，这是一个大问题):

const 
mongoose = require('mongoose'),
User = require('./models/users'),
League = require('./models/leagues'),
dbUrl = process.env.DBURL || 'mongodb://localhost/predictor';

const addUserToLeague = (connection, userId, leagueId) => {
    return Promise.all([
        User.findById(userId),
        League.findById(leagueId)
    ])
    .then(([user, league]) => {
        user.leagueMemberships.push(league);
        league.users.push(user);
        return Promise.all([user.save(), league.save()]);
    })
    .then((([user, league]) => {
        console.log(`User ${user._id} added to league ${league._id}`);
    });
};

mongoose.connect(dbUrl, { useNewUrlParser: true })
.then(connection => addUserToLeague(connection, process.argv[2], process.argv[3]) // Needs 2 args: User ID and League ID
.catch(error => {
    // Handle/report error
});

如果您使用的是任何最新版本的 Node，您可以使用 async 函数:

const 
mongoose = require('mongoose'),
User = require('./models/users'),
League = require('./models/leagues'),
dbUrl = process.env.DBURL || 'mongodb://localhost/predictor';

const addUserToLeague = async (connection, userId, leagueId) => {
    let [user, league] = await Promise.all([
        User.findById(userId),
        League.findById(leagueId)
    ]);
    user.leagueMemberships.push(league);
    league.users.push(user);
    [user, league] = await Promise.all([user.save(), league.save()]);
    console.log(`User ${user._id} added to league ${league._id}`);
};

mongoose.connect(dbUrl, { useNewUrlParser: true })
.then(connection => addUserToLeague(connection, process.argv[2], process.argv[3]) // Needs 2 args: User ID and League ID
.catch(error => {
    // Handle/report error
});