如果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;
            }
        }