如何在Node.js中构建类来抽象RabbitMQ和amqplib功能？

class RabbitMQClient {
  constructor(url) {
    this.url = url;
    this.connection = null;
  }
}

async connect() {
  try {
    this.connection = await amqp.connect(this.url);
    console.log('Connected to RabbitMQ');
  } catch (error) {
    console.error('Failed to connect to RabbitMQ', error);
  }
}

async publish(exchange, queue, message) {
  try {
    const channel = await this.connection.createChannel();
    await channel.assertExchange(exchange, 'direct', { durable: true });
    await channel.assertQueue(queue, { durable: true });
    await channel.bindQueue(queue, exchange, '');
    await channel.publish(exchange, '', Buffer.from(message));
    console.log('Message published');
  } catch (error) {
    console.error('Failed to publish message', error);
  }
}

async consume(queue, callback) {
  try {
    const channel = await this.connection.createChannel();
    await channel.assertQueue(queue, { durable: true });
    await channel.consume(queue, (message) => {
      callback(message.content.toString());
      channel.ack(message);
    });
    console.log('Consuming messages');
  } catch (error) {
    console.error('Failed to consume messages', error);
  }
}

const rabbitMQClient = new RabbitMQClient('amqp://localhost');
rabbitMQClient.connect()
  .then(() => {
    rabbitMQClient.publish('exchange', 'queue', 'Hello RabbitMQ');
    rabbitMQClient.consume('queue', (message) => {
      console.log('Received message:', message);
    });
  });