proto.lib

RabbitMQ Ack/Nack & Redelivery

Consumer xác nhận xử lý thành công bằng basic.ack, hoặc báo lỗi bằng basic.nack để broker requeue message cho lần giao tiếp theo.

MessagingCơ bản2026-07-07
RabbitMQ Ack/Nack & Redelivery

Tags

#rabbitmq#ack#nack#requeue#at-least-once

Tài liệu tham khảo

Mở rộng

Animation gốc là một file HTML tự chứa, có thể nhúng lại ở bất kỳ trang nào khác. Mở file gốc

Liên quan

MessagingTrung bình

RabbitMQ/AMQP: Exchange, binding và định tuyến message

Mô hình AMQP 0-9-1: producer publish tới exchange, exchange khớp routing key với binding để đưa message vào queue, consumer ack để xoá — kèm requeue/DLX và các kiểu direct/topic/fanout.

#amqp#rabbitmq#exchange#queue
MessagingTrung bình

Sink Connector ghi idempotent bằng upsert

Một sink kết nối stream vào database phải tránh trùng lặp khi redelivery: nó tính khoá xác định cho mỗi record và ghi bằng upsert (hoặc insert kèm unique constraint), đồng thời lưu version/offset của record để một retry cũ hơn không thể ghi đè bản mới hơn.

#sink-connector#idempotency#upsert#at-least-once
MessagingTrung bình

RabbitMQ Single Active Consumer: một tiêu thụ, dự phòng nóng

Nhiều consumer cùng đăng ký vào một hàng đợi nhưng chỉ MỘT được broker cho phép nhận message tại một thời điểm; khi consumer đang active ngắt kết nối, broker tự động thăng cấp consumer kế tiếp — giữ thứ tự chặt trong hàng đợi và failover nhanh mà không có split-brain của việc hai consumer cùng xử lý.

#rabbitmq#single-active-consumer#ordering#failover