Giới thiệu
Cách các microservices giao tiếp với nhau quyết định coupling, reliability, và performance của toàn hệ thống. Bài này phân tích các communication patterns và hướng dẫn chọn đúng pattern cho từng use case.
1. Synchronous Communication
1.1 Request-Reply Pattern
┌──────────┐ HTTP/gRPC ┌──────────┐
│ Order │ ──────────────►│ Product │
│ Service │◄────────────── │ Service │
└──────────┘ Response └──────────┘
Order Service gọi Product Service để validate product trước khi tạo order.
Phải đợi response → coupling tạm thời (temporal coupling).
Ưu điểm:
- Đơn giản, dễ hiểu, dễ debug
- Response ngay lập tức
- Error handling rõ ràng (HTTP status codes)
Nhược điểm:
- Temporal coupling: caller blocked đến khi nhận response
- Cascade failure: nếu Product Service down → Order Service cũng fail
- Latency tăng với mỗi hop trong call chain
1.2 Giảm thiểu rủi ro Sync
- Circuit Breaker: ngắt mạch khi downstream service fail
- Timeout: đặt timeout hợp lý (không quá dài)
- Retry with backoff: retry với exponential backoff
- Fallback: trả về cached data hoặc default response
- Bulkhead: isolate connection pools cho từng downstream
2. Asynchronous Communication
2.1 Message Queue Pattern
┌──────────┐ Enqueue ┌──────────┐ Dequeue ┌──────────┐
│ Order │ ──────────────►│ Queue │──────────────►│ Email │
│ Service │ │(RabbitMQ)│ │ Service │
└──────────┘ └──────────┘ └──────────┘
Fire-and-forget: Order Service gửi message, không đợi.
Email Service xử lý khi sẵn sàng (rate riêng).
Queue đảm bảo message không mất.
Use cases:
- Task distribution (send email, resize image)
- Work queues (process video, generate report)
- Load leveling (absorb traffic spikes)
2.2 Event Streaming / Pub-Sub Pattern
┌──────────┐ ┌──────────────┐
│ Order │──publish──────►│ Kafka │
│ Service │ OrderPlaced │ Topic: │
└──────────┘ │ orders │
└──┬───┬───┬───┘
│ │ │
┌──────────┘ │ └──────────┐
▼ ▼ ▼
┌──────────┐ ┌──────────┐ ┌──────────┐
│ Payment │ │Inventory │ │ Email │
│ Service │ │ Service │ │ Service │
└──────────┘ └──────────┘ └──────────┘
1 event → N consumers. Services không biết nhau → loose coupling.
Events được lưu trữ → có thể replay (event sourcing).
Use cases:
- Domain events (OrderPlaced, PaymentConfirmed)
- Data replication across services
- Event sourcing & audit trail
- Real-time analytics
2.3 Event Notification vs Event-Carried State Transfer
| Pattern | Event chứa gì | Consumer cần gì |
|---|---|---|
| Event Notification | Chỉ ID: {orderId: "123"} | Query lại source service |
| Event-Carried State | Full data: {orderId, items, total, ...} | Không cần query lại |
Khuyến nghị: Event-Carried State Transfer giúp giảm coupling (consumer không cần gọi lại source).
3. So sánh Message Brokers
| Feature | RabbitMQ | Apache Kafka | NATS |
|---|---|---|---|
| Model | Message Queue | Event Stream/Log | Pub/Sub + JetStream |
| Ordering | Per queue | Per partition | Per subject |
| Retention | Consumed → deleted | Configurable (days/forever) | JetStream: configurable |
| Throughput | ~50K msg/s | ~1M msg/s | ~10M msg/s |
| Replay | Không | Có (offset-based) | JetStream: Có |
| Consumer groups | Có | Có | JetStream: Có |
| Complexity | Trung bình | Cao (ZooKeeper/KRaft) | Thấp |
| Best for | Task queues, RPC | Event streaming, sourcing | Cloud-native, lightweight |
3.1 Khi nào dùng cái gì?
RabbitMQ: Task queues (send email, process image)
Request-Reply pattern (RPC over messages)
Complex routing (exchanges, bindings)
Kafka: Domain events (OrderPlaced, PaymentConfirmed)
Event sourcing & CQRS
Data pipeline & streaming analytics
Audit trail (event log)
NATS: Lightweight microservices communication
Real-time messaging (chat, notifications)
Cloud-native, Kubernetes-native
Request-Reply + Pub/Sub combined
4. Hybrid Approach (Production Pattern)
Trong thực tế, hầu hết hệ thống dùng kết hợp cả hai:
┌─────────────────────────────────────────────────┐
│ E-Commerce Communication │
├─────────────────────────────────────────────────┤
│ SYNCHRONOUS (REST/gRPC): │
│ • GET product details (query, cần response ngay)│
│ • Validate payment (command, cần kết quả) │
│ • Search products (query, real-time) │
├─────────────────────────────────────────────────┤
│ ASYNCHRONOUS (Kafka Events): │
│ • OrderPlaced → trigger Payment, Inventory │
│ • PaymentConfirmed → trigger Shipping │
│ • UserRegistered → trigger Welcome Email │
│ • ProductUpdated → update Search Index │
└─────────────────────────────────────────────────┘
Tóm tắt
| Pattern | Khi nào dùng | Tradeoff |
|---|---|---|
| Sync (REST/gRPC) | Cần response ngay, query data | Tight coupling, cascade failure |
| Async Queue | Task distribution, load leveling | Eventual consistency |
| Async Events | Domain events, data sync | Complexity, debugging khó |
| Hybrid | Production recommendation | Cần quản lý cả hai |
Bài tiếp theo: Bài 7: Database per Service & Polyglot Persistence