在nodejs中的AMQPLIB连接上配置套接字超时

Question

如果RabbitMQ实例如果找到错误，则大约需要120秒才能超时，然后尝试错误，

这是我用于连接的代码：

         async function connectAmqp() {
            try {
                // Create amqp connection and is there any error then exit with error.
                cluster = await amqp.connect(`amqp://127.0.0.1:5672`,{
                    timeout:2000
                });
                return cluster;
            } catch (error) {
                throw error;
            }
        }

Answer 1

假设您正在使用amqplib。

第二个参数为timeout值。

它在此

const amqp = require('amqplib');

const connection = await amqp.connect('amqp://localhost', {
  timeout: 2000,
});