Message Queue Patterns

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'
    }
});

Shrnutí

Work queues pro background jobs, pub/sub pro events, DLQ pro error handling. RabbitMQ pro routing, Kafka pro streaming.