如何处理Node.js上的RabbitMQ连接以在Jest上使用？

Question

我有一个下面的代码片段来连接RabbitMQ，它的工作正常，但在测试用例中，我收到异步操作错误。我尝试使用this.start();和this.start().then

var amqplib = require('amqplib');
const { amqp: { uri: amqpURI } } = require('../config');

class Broker {
    constructor(url) {
        this.queue = 'user';
        this.url = url;
        //this.start(); Old
        this.start().then(function (conn) {
            console.log(conn);
        });
    }
    start() {
        return amqplib.connect(this.url).then((conn) => {
            conn.on("close", () => {
                this.conn = null;
                return this.retryConnection();
            });
            return conn;
        }).catch((error) => {
        });
    }

    .....

}

注意：当我评论this.start();时，错误消失

错误：

测试运行完成后，Jest没有退出一秒钟。

这通常意味着您的测试中没有停止异步操作。考虑使用--detectOpenHandles运行Jest来解决此问题。

Answer 1

我写了一个代码，在连接关闭时重新连接RabbitMQ。所以，当我关闭Jest.js上的连接时，它试图再次重新连接RabbitMQ。

现在，由于on close，我正在重新连接RabbitMQ error。

conn.on("close", (err) => {
    if (err) {
        this.conn = null;
        return this.retryConnection();
    }
});