要解决“amqplib@0.4.2不支持的引擎”问题,您需要升级amqplib库到0.5.4版本或更高版本,因为从0.5.0版本开始,amqplib开始支持您使用的引擎。
您可以通过以下步骤解决这个问题:
npm install amqplib@latest --save
以下是一个使用amqplib库的示例代码:
const amqp = require('amqplib');
async function connect() {
try {
const connection = await amqp.connect('amqp://localhost');
const channel = await connection.createChannel();
const queue = 'myQueue';
const message = 'Hello, RabbitMQ!';
// 发送消息到队列
channel.assertQueue(queue);
channel.sendToQueue(queue, Buffer.from(message));
console.log("消息已发送:", message);
// 关闭连接
setTimeout(() => {
connection.close();
process.exit(0);
}, 500);
} catch (error) {
console.error("连接到RabbitMQ失败:", error);
}
}
connect();
这是一个简单的连接到RabbitMQ并发送消息到队列的示例代码。您可以根据您的需求进行修改和扩展。
希望这可以帮助到您!