Hàng đợi thông điệp, xuất bản - thuê bao và luồng sự kiện (tương đương Amazon SNS, SQS, Kinesis)

Kiến trúc vi dịch vụ của VNeID cần một 'xương sống' truyền thông điệp bất đồng bộ để các dịch vụ giao tiếp mà không phụ thuộc trực tiếp lẫn nhau: gửi thông báo, xử lý hồ sơ theo hàng đợi, phát sự kiện định danh cho nhiều bên cùng nhận, và tiếp nhận luồng sự kiện lớn (nhật ký, giao dịch) để phân tích. Đây là vai trò của các dịch vụ SNS, SQS, Kinesis.

Về nghiệp vụ: cung cấp ba năng lực dùng chung — hàng đợi thông điệp bảo đảm (thay SQS), xuất bản - thuê bao nhiều người nhận (thay SNS), và luồng sự kiện thông lượng cao cho phân tích (thay Kinesis). Về kỹ thuật: xây dựng trên Apache Kafka (luồng sự kiện, lưu trữ nhật ký giao dịch, thông lượng rất cao) kết hợp RabbitMQ hoặc NATS (hàng đợi tác vụ, xuất bản - thuê bao độ trễ thấp); triển khai cụm nhân bản đa vùng, bảo đảm phân phối ít nhất một lần và trình tự theo phân vùng; đóng gói thành dịch vụ có tự phục vụ và giám sát. Nền tảng: Kafka và RabbitMQ là chuẩn công nghiệp nguồn mở đang được chính các nền tảng lớn của Việt Nam vận hành ở quy mô hàng chục triệu người dùng.

Phương thức áp dụng: dùng làm trục sự kiện chung cho toàn bộ VNeID — xử lý hồ sơ bất đồng bộ, gửi thông báo tới công dân, đồng bộ trạng thái giữa các dịch vụ và cấp dữ liệu cho nền tảng phân tích (Giải pháp 18). Mục tiêu cụ thể: chịu được luồng sự kiện đỉnh ở quy mô 10 triệu người dùng, không mất thông điệp, và tách rời các dịch vụ để một cấu phần sự cố không kéo theo phần còn lại.