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 для автореконнекта.
Как использовать RabbitMQ из Node.js?
Senior
256 просмотровAFK Offer AI
Как настроить monorepo TypeScript проект?