1个回答
test
2024-06-24
在Electron应用中使用 amqplib 库来连接到RabbitMQ服务器并进行通信
const amqp = require('amqplib');
// 连接信息
const rabbitMQConfig = {
hostname: 'your-rabbitmq-hostname',
port: 5672,
username: 'your-username',
password: 'your-password',
};
// 连接到RabbitMQ服务器
amqp.connect(`amqp://${rabbitMQConfig.hostname}:${rabbitMQConfig.port}`, {
username: rabbitMQConfig.username,
password: rabbitMQConfig.password,
}).then((connection) => {
// 创建通道
return connection.createChannel();
}).then((channel) => {
// 声明队列
const queueName = 'your-queue-name';
return channel.assertQueue(queueName).then(() => {
// 发送消息
const message = 'Hello, RabbitMQ!';
channel.sendToQueue(queueName, Buffer.from(message));
console.log(`[x] Sent '${message}'`);
});
}).catch((error) => {
console.error('Error:', error);
});
回复
适合作为回答的
- 经过验证的有效解决办法
- 自己的经验指引,对解决问题有帮助
- 遵循 Markdown 语法排版,代码语义正确
不该作为回答的
- 询问内容细节或回复楼层
- 与题目无关的内容
- “赞”“顶”“同问”“看手册”“解决了没”等毫无意义的内容