Как использовать RabbitMQ из Node.js?

Senior
256 просмотров
AFK Offer AI

amqplib — популярная библиотека. const conn = await connect("amqp://localhost"); const channel = await conn.createChannel(). Producer: channel.assertQueue("tasks"); channel.sendToQueue("tasks", Buffer.from(JSON.stringify(msg))). Consumer: channel.assertQueue("tasks"); channel.consume("tasks", (msg) => { process(msg); channel.ack(msg) }). ack() важен — без него при краше задача потеряется. amqplib-rpc для request-reply. amqp-connection-manager для автореконнекта.

Следующий вопрос

Как настроить monorepo TypeScript проект?