Architecture Intermediate
Message Queue Patterns¶
Message QueueRabbitMQAsync 3 min read
Návrhové vzory pro message queues. Work queues, dead letter queues a příklady s RabbitMQ.
Work Queue¶
// Producer
ch.assertQueue('email-queue', { durable: true });
ch.sendToQueue('email-queue', Buffer.from(JSON.stringify({
to: '[email protected]', subject: 'Potvrzení'
})), { persistent: true });
// Consumer
ch.prefetch(1);
ch.consume('email-queue', async (msg) => {
await sendEmail(JSON.parse(msg.content.toString()));
ch.ack(msg);
});
Dead Letter Queue¶
Zprávy po N neúspěšných pokusech se přesouvají do DLQ pro analýzu.
ch.assertQueue('orders', {
durable: true,
arguments: {
'x-dead-letter-exchange': 'dlx',
'x-dead-letter-routing-key': 'dead-orders'
}
});
Summary¶
Work queues pro background jobs, pub/sub pro events, DLQ pro error handling. RabbitMQ pro routing, Kafka pro streaming.
Need Help with Implementation?¶
Our team has experience designing and implementing modern architectures. We’re happy to help.