Chào mừng trở lại với bản tin Tech Radar. Trong kiến trúc Microservices hiện đại, việc duy trì một hệ thống có khả năng giao tiếp linh hoạt cả ra bên ngoài (HTTP) và nội bộ (gRPC) là một yêu cầu thiết yếu. Đồng thời, Quản lý Trạng thái (State Management) trong môi trường phân tán đòi hỏi những giải pháp chặt chẽ để ngăn chặn xung đột dữ liệu.

Hôm nay, chúng ta sẽ mổ xẻ cách kết hợp framework Kratos rất được đánh giá cao của Go với Dapr v1.15 để giải quyết toàn diện bài toán này.

1. Kratos Dual-Protocol: Chạy song song HTTP & gRPC

Answer-first: Framework Kratos tích hợp với Dapr v1.15 State Management thông qua sidecar pattern, cho phép HTTP và gRPC server chạy song song. Để tránh xung đột trạng thái khi chạy đa giao thức, hệ thống sử dụng Dapr ETags thông qua SaveStateWithETag cho Optimistic Concurrency Control (OCC), và sử dụng Middleware để đồng bộ Metadata.

Thiết kế Protocol-First với Protobuf

Kratos sử dụng Protobuf làm “single source of truth”. Từ một file .proto duy nhất, Kratos tự động tạo code cho cả gRPC và HTTP RESTful APIs. Điều này giải phóng lập trình viên khỏi việc viết logic định tuyến thủ công cho từng loại giao thức.

Tầng Transport Hợp Nhất (Giải quyết DRY cho Middleware)

Sự thông minh trong kiến trúc của Kratos nằm ở tầng Transport được trừu tượng hóa. Thay vì cấu hình Middleware (như Logging, Authentication, Tracing) riêng biệt cho HTTP và gRPC, bạn chỉ cần viết nó một lần. Tầng Transport hợp nhất áp dụng các Middleware này đồng đều trên cả hai server, loại bỏ hoàn toàn việc lặp code (DRY).

2. Dapr v1.15 State Management: Kiến trúc Cắm Rút & ETags

Answer-first: Dapr v1.15 quản lý trạng thái thông qua kiến trúc có thể cắm rút (pluggable), trừu tượng hóa cơ sở dữ liệu bên dưới (Redis, PostgreSQL). Cụ thể, Dapr cung cấp cơ chế Kiểm soát Đồng thời Lạc quan (OCC) sử dụng ETags để ngăn chặn hoàn toàn việc mất cập nhật (lost updates) trong môi trường phân tán.

Sức mạnh của Dapr Sidecar

Dapr chạy dưới dạng sidecar hoàn toàn cách ly khỏi logic ứng dụng. Khi Kratos cần lưu trạng thái, nó không quan tâm cơ sở dữ liệu bên dưới là MongoDB hay Redis. Kratos chỉ đơn giản gọi API Dapr qua HTTP hoặc gRPC tới localhost.

Optimistic Concurrency Control (OCC) với ETags

Trong mô hình Dual-Protocol của Kratos, một HTTP request và một gRPC request có thể cố gắng sửa đổi một bản ghi cùng lúc. Để giải quyết, Dapr đính kèm một ETag vào mỗi bản ghi trạng thái. Khi Kratos cập nhật dữ liệu, nó phải gửi ETag hiện tại kèm theo request. Dapr sẽ từ chối giao dịch nếu ETag không khớp (nghĩa là dữ liệu đã bị sửa đổi bởi một tiến trình khác).

3. Tích hợp Kratos và Dapr: Giải quyết Xung đột Trạng thái & Metadata

Answer-first: Để tích hợp hoàn hảo, lập trình viên sử dụng Dapr Go SDK gọi hàm SaveStateWithETag, kết hợp với Kratos Middleware để truyền context.Context một cách mượt mà. Điều này đảm bảo tất cả các tracking IDs và ETags được giữ nguyên khi di chuyển giữa các tầng HTTP/gRPC và Dapr Sidecar.

Đoạn code: SaveStateWithETag dùng Dapr Go SDK

Khi lưu dữ liệu, bắt buộc phải lấy ETag trước, xử lý logic và lưu lại cùng với ETag cụ thể đó.

item, err := client.GetState(ctx, storeName, key, nil)
// ... logic tăng bộ đếm ...
err = client.SaveStateWithETag(ctx, storeName, key, data, item.Etag, nil)

Lưu ý Cực Kỳ Quan Trọng về Truyền Metadata

Kratos dịch thông tin từ HTTP headers và gRPC metadata thành context.Context. Để Dapr Sidecar nhận diện được các tracing hoặc auth token này, bạn bắt buộc phải truyền ctx này vào mọi hàm gọi Dapr SDK. Bỏ qua context sẽ làm gãy luồng Distributed Tracing.

4. Q&A: Điểm nghẽn Thực tế (FAQ)

Answer-first: Việc tích hợp Kratos và Dapr mang lại sự linh hoạt nhưng đòi hỏi tối ưu cấu hình mạng cục bộ, quản lý vòng đời ứng dụng (graceful shutdown) và xây dựng chiến lược retry hợp lý để giảm thiểu độ trễ overhead.

Dapr Sidecar có làm tăng độ trễ gRPC của Kratos không?
Có, nhưng rất nhỏ (khoảng ~2.1ms ở p99). Để tối ưu cho hệ thống tải cao, bạn nên cấu hình Kratos giao tiếp với sidecar qua một kênh gRPC (app-channel) và bật tính năng keep-alive để tái sử dụng kết nối.
Làm cách nào để test Kratos và Dapr ở local bằng Docker Compose?
Bí quyết là cấu hình container Dapr sidecar dùng chung interface mạng với container Kratos qua khai báo network_mode: "service:kratos-app". Điều này mô phỏng chính xác mô hình mạng của một Pod trên Kubernetes.
Cấu hình Graceful Shutdown cho Kratos và Dapr như thế nào?
Việc tắt ứng dụng cần sự phối hợp chặt chẽ. Hãy đảm bảo tham số terminationGracePeriodSeconds trên Kubernetes lớn hơn giá trị annotation dapr.io/graceful-shutdown-seconds của Dapr để tránh sidecar bị kill trước khi Kratos xử lý xong request cuối cùng.
Dapr State Management có hỗ trợ Truy vấn/Lọc Dữ liệu không?
Có, Dapr cung cấp API /query (hiện đang ở bản alpha). Nó hỗ trợ các toán tử EQ, IN, AND, OR trên dữ liệu JSON. Tuy nhiên, tính năng này chủ yếu tương thích với các cơ sở dữ liệu hỗ trợ truy vấn JSON phức tạp, như MongoDB hoặc PostgreSQL.
Làm thế nào để tự động retry khi update State gặp lỗi 409 Conflict?
Thay vì viết các vòng lặp exponential backoff cồng kềnh thủ công bên trong Kratos, bạn nên tận dụng tính năng Resiliency của Dapr. Khai báo các chính sách retry trực tiếp trong file resiliency.yaml, và Dapr sẽ tự động xử lý khi một ETag gặp lỗi 409 Conflict.

Đọc các bài viết sắp tới của chúng tôi về Kratos Framework, Microservices với Dapr, và Chuỗi bài System Design trên blog để tiếp tục theo dõi các mẫu microservices thực chiến.

🤝 Kết nối với tôi

Bạn đang gặp phải những thách thức tương tự về kiến trúc hệ thống, mở rộng quy mô (scaling) hay dịch chuyển (migration)? Hãy kết nối với tôi trên LinkedIn, theo dõi GitHub của tôi, hoặc gửi một email để trao đổi nhé.