proto.lib

Request-Reply qua Messaging

RPC bất đồng bộ qua broker dùng correlation id và reply-to queue để khớp phản hồi với yêu cầu gốc.

MessagingTrung bình2026-07-02
Request-Reply qua Messaging

Tags

#request-reply#correlation-id#async-rpc

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

End-to-End Delivery Receipt (biên nhận xuyên nhiều hop)

Ack từ broker không phải là ack từ người nhận cuối: một request đi qua nhiều hop bất đồng bộ cần một correlation id và một RECEIPT cuối cùng (delivered/failed/expired) báo lại cho service khởi xướng, để nó biết chắc 'việc đó có thực sự xảy ra không' mà không phải đoán từ timeout.

#delivery-receipt#correlation-id#async#saga
MessagingNâng cao

Ack và Timeout cho lệnh điều khiển thiết bị IoT

Server gửi lệnh xuống thiết bị kèm correlation id và thời hạn (expiry); thiết bị ack việc nhận lệnh rồi sau đó báo kết quả thực thi, cho phép server phân biệt ba trạng thái không delivered, delivered nhưng chưa có kết quả, và completed — vì việc retry chỉ an toàn ở trạng thái đầu tiên.

#iot#command-ack#correlation-id#expiry
MessagingNâng cao

Sink stream (Kafka) xuống Lakehouse: file cột + commit metadata

Sink connector đọc liên tục từ Kafka, gom bản ghi theo cửa sổ thời gian thành file cột (Parquet), rồi commit một snapshot metadata mới cho bảng lakehouse; exactly-once đạt được bằng cách gắn việc commit offset Kafka với chính việc commit snapshot đó, không tách rời.

#kafka#sink-connector#lakehouse#table-format