带有递归的Promise，用于AMQPLIB重新连接方法

function connectToAMQP() {
  return new Promise((resolve, reject) => {
    // 连接到AMQPLIB的代码
    // ...

    // 当连接成功时，解析Promise
    resolve(connection);

    // 当连接断开时，使用递归重新连接
    connection.on('close', () => {
      console.log('Connection closed. Reconnecting...');
      connectToAMQP().then(resolve).catch(reject);
    });
  });
}

// 调用带有递归的Promise方法来连接AMQPLIB
connectToAMQP()
  .then((connection) => {
    console.log('Connected to AMQP');
    // 在连接成功后执行其他操作
  })
  .catch((error) => {
    console.error('Failed to connect to AMQP:', error);
  });