如何从RabbitMQ message - nodejs发出http请求

const amqp = require('amqplib');

async function sendMessageToRabbitMQ(message) {
  const connection = await amqp.connect('amqp://localhost'); // 连接到RabbitMQ服务器
  const channel = await connection.createChannel(); // 创建通道

  const queueName = 'myQueue'; // 消息队列名称
  await channel.assertQueue(queueName); // 确保消息队列存在

  channel.sendToQueue(queueName, Buffer.from(message)); // 发送消息到队列

  console.log('Message sent to RabbitMQ');
  await channel.close(); // 关闭通道
  await connection.close(); // 关闭连接
}

sendMessageToRabbitMQ('Hello RabbitMQ');

const amqp = require('amqplib');
const axios = require('axios');

async function consumeMessageFromRabbitMQ() {
  const connection = await amqp.connect('amqp://localhost'); // 连接到RabbitMQ服务器
  const channel = await connection.createChannel(); // 创建通道

  const queueName = 'myQueue'; // 消息队列名称
  await channel.assertQueue(queueName); // 确保消息队列存在

  channel.consume(queueName, async (message) => {
    const content = message.content.toString(); // 获取消息内容
    console.log('Received message from RabbitMQ:', content);

    // 发送HTTP请求
    try {
      await axios.post('http://example.com/api', { message: content });
      console.log('HTTP request sent successfully');
    } catch (error) {
      console.error('Failed to send HTTP request:', error);
    }

    channel.ack(message); // 确认消息已被处理
  });

  console.log('Waiting for messages from RabbitMQ');
}

consumeMessageFromRabbitMQ();