javascript 回调在不可能的调用中被调用两次

Question

我构建了一个 TS，MongoDB 客户端包装器。由于某种原因，当我调用获取连接的函数时，它的回调被调用了两次。

共有 2 次调用 get() 函数，1 次在导出之前，如您所见，另一个来自 mocha 测试。

总的来说，我对 TS 和 JS 很陌生，但这似乎有点不对劲。

    import {Db, MongoClient} from "mongodb";
    import {MongoConfig} from '../config/config'
    class DbClient {
        private cachedDb : Db = null;
        private async connectToDatabase() {
            console.log('=> connect to database');
            let connectionString : string = "mongodb://" + MongoConfig.host + ":" + MongoConfig.port;
            return MongoClient.connect(connectionString)
                .then(db => {
                    console.log('=> connected to database');
                    this.cachedDb = db.db(MongoConfig.database);
                    return this.cachedDb;
                });
        }
        public async get() {
            if (this.cachedDb) {
                console.log('=> using cached database instance');
                return Promise.resolve(this.cachedDb);
            }else{
                return this.connectToDatabase();
            }
        }
    }
    let client = new DbClient();
    client.get();
    export = client;

控制台输出在哪里：

=> connect to database
=> connected to database
=> connected to database

这是行为不端的任何特定原因？

Answer 1

共有 2 次调用 get() 函数，1 次在导出之前，如您所见，另一个来自 mocha 测试。

我怀疑输出有一个额外的=> connect to database。正如我在 cmets 中所说：有一个“竞争条件”，在设置 this.cachedDb 之前可以多次调用 get()，这将导致创建 Db 的多个连接/实例。

例如：

const a = client.get();
const b = client.get();

// then
a.then(resultA => {
    b.then(resultB => {
        console.log(resultA !== resultB); // true
    });
});

解决方案

可以通过将承诺存储为缓存值来解决问题（另外，正如 Randy 指出的那样，不需要在方法上使用 async 关键字，因为在任何方法中都没有等待值，因此您可以只需返回承诺）：

import {Db, MongoClient} from "mongodb";
import {MongoConfig} from '../config/config'

class DbClient {
    private cachedGet: Promise<Db> | undefined;

    private connectToDatabase() {
        console.log('=> connect to database');
        const connectionString = `mongodb://${MongoConfig.host}:${MongoConfig.port}`;
        return MongoClient.connect(connectionString);
    }

    get() {
        if (!this.cachedGet) {
            this.cachedGet = this.connectToDatabase();

            // clear the cached promise on failure so that if a caller
            // calls this again, it will try to reconnect
            this.cachedGet.catch(() => {
                this.cachedGet = undefined;
            });
        }

        return this.cachedGet;
    }
}

let client = new DbClient();
client.get();
export = client;

注意：我不确定使用 MongoDB 的最佳方式（我从未使用过），但我怀疑连接的寿命不应该长到像这样被缓存（或者应该只缓存短时间然后断开连接）。不过，您需要对此进行调查。