proto.lib

Ack sớm vs Ack muộn trong Task Queue

Ack ngay khi nhận task (early ack) khiến worker crash làm mất task vĩnh viễn vì broker đã xoá nó khỏi hàng đợi; ack sau khi xử lý xong (late ack) khiến crash làm task được redeliver, nên chỉ có late ack kết hợp task idempotent mới đảm bảo không mất việc.

MessagingTrung bình2026-08-20
Ack sớm vs Ack muộn trong Task Queue

Tags

#task-queue#ack#acknowledgement#prefetch#visibility-timeout#idempotency#celery

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

Heartbeat gia hạn Reservation cho Task dài

Một task chạy hợp lệ 20 phút trên hàng đợi có reservation timeout 5 phút sẽ bị broker coi là worker chết và giao lại cho worker khác nếu không có cơ chế heartbeat gia hạn; giải pháp là worker định kỳ extend lease, báo cáo tiến độ, và checkpoint để phục hồi đúng chỗ khi crash thật.

#task-queue#heartbeat#visibility-timeout#checkpoint
MessagingNâng cao

Fan-Out/Fan-In: Join qua bộ đếm chia sẻ

Một request nổ ra thành N subtask song song (ví dụ render 500 thumbnail); mỗi subtask hoàn tất độc lập rồi tăng nguyên tử một bộ đếm chia sẻ, subtask cuối cùng chạm ngưỡng sẽ kích hoạt continuation — với các điểm khó là subtask không bao giờ xong, retry làm đếm trùng, và worker không được block chờ chính con của nó.

#fan-out#fan-in#task-queue#join
MessagingNâng cao

Kafka Share Groups: hành vi hàng đợi trên log

Thay vì gán mỗi consumer một partition cố định, share group cho phép NHIỀU consumer cùng đọc một partition, ack từng record riêng lẻ — mang lại hành vi work-queue (nhiều consumer hơn partition, ack/redeliver theo record) trên cùng broker vẫn giữ log replay được, đổi lại mất thứ tự per-record.

#kafka#share-group#kip-932#queue-semantics