Câu hỏi System Design: Thiết kế hệ thống thông báo – trả lời sao cho điểm cao

Bạn vừa vào buổi phỏng vấn và người phỏng vấn ném ra câu: "Design a notification system that can send email, push and SMS to millions of users". Đó là một trong những câu hỏi system design “điển hình” mà mọi công ty công nghệ dùng để kiểm tra khả năng tư duy kiến trúc, cân nhắc trade‑off và ứng dụng các pattern phổ biến. Dưới đây là cách bạn có thể trả lời sao cho điểm cao, kèm ví dụ thực tế bằng Java Spring Boot và Go.

1. Đặt lại phạm vi (Clarify requirements)#

Functional: gửi 3 loại kênh (email, push, SMS), hỗ trợ đa ngôn ngữ, cho phép người dùng tùy chọn kênh, và lưu lịch sử thông báo.
Non‑functional:
- Throughput: ít nhất 10 000 notify/s, “burst” lên 100 000/s trong các chiến dịch marketing.
- Latency: p99 < 200 ms cho push, < 500 ms cho email/SMS.
- Reliability: độ mất dữ liệu < 0.001 %, retry được thực hiện ít nhất 3 lần.
- Scalability: có thể mở rộng ngang (horizontal) khi người dùng tăng.
Boundary: không cần xây dựng dịch vụ gửi email/SMS thực, chỉ cần mô tả cách tích hợp với nhà cung cấp (SMTP, Twilio, Firebase).

1. Đặt lại phạm vi (Clarify requirements)#

Functional: gửi 3 loại kênh (email, push, SMS), hỗ trợ đa ngôn ngữ, cho phép người dùng tùy chọn kênh, và lưu lịch sử thông báo.
Non‑functional:
- Throughput: ít nhất 10 000 notify/s, “burst” lên 100 000/s trong các chiến dịch marketing.
- Latency: p99 < 200 ms cho push, < 500 ms cho email/SMS.
- Reliability: độ mất dữ liệu < 0.001 %, retry được thực hiện ít nhất 3 lần.
- Scalability: có thể mở rộng ngang (horizontal) khi người dùng tăng.
Boundary: không cần xây dựng dịch vụ gửi email/SMS thực, chỉ cần mô tả cách tích hợp với nhà cung cấp (SMTP, Twilio, Firebase).

Pattern	Ứng dụng trong thiết kế
Pub‑Sub	Kafka topic `notification_events` phân phối tới 3 consumer group (email, push, sms).
Rate Limiter	Redis leaky‑bucket để ngăn spam gửi SMS quá mức.
Circuit Breaker	Hystrix (Java) / resilience4j để ngắt kết nối khi nhà cung cấp SMS/Email lỗi.
Retry with Exponential Backoff	Đảm bảo ít nhất 3 lần retry trước khi đánh dấu FAILED.
Transactional Outbox	Đảm bảo atomicity giữa DB và message queue, tránh mất tin khi transaction commit thất bại.

Yếu tố	Giải pháp	Trade‑off
Throughput	Partition Kafka theo `user_id` để cân bằng load.	Cần quản lý offset và rebalance.
Latency	Sử dụng in‑memory cache (Redis) để lưu thông tin người dùng, giảm DB hit.	Cache invalidation.
Reliability	Replication Kafka (3‑way), PostgreSQL HA, Redis Sentinel.	Tăng chi phí hạ tầng.
Cost	Khi traffic thấp, dùng cold‑start lambda‑like workers thay vì luôn chạy.	Độ trễ cold start.

Pattern	Where it fits
Pub‑Sub	Kafka topic `notification_events` fan‑outs to three consumer groups (email, push, sms).
Rate Limiter	Redis leaky‑bucket to protect SMS providers from spikes.
Circuit Breaker	Resilience4j/Hystrix to short‑circuit external providers when they become unhealthy.
Retry with Exponential Backoff	Guarantees at least three attempts before marking a notification as `FAILED`.
Transactional Outbox	Guarantees atomicity between DB write and queue publish, eliminating lost messages.

Concern	Solution	Trade‑off
Throughput	Partition Kafka by `user_id` to spread load across brokers.	Requires careful offset management and rebalance handling.
Latency	Use Redis to cache user‑channel preferences, avoiding DB round‑trip per message.	Cache invalidation complexity.
Reliability	Replicated Kafka (3‑way), PostgreSQL HA, Redis Sentinel.	Higher infrastructure cost.
Cost	During low traffic, switch to on‑demand workers (e.g., AWS Lambda) instead of always‑on pool.	Cold‑start latency.

Câu hỏi System Design: Thiết kế hệ thống thông báo – trả lời sao cho điểm caoSystem Design Interview: Design a Notification System – How to Score High

1. Đặt lại phạm vi (Clarify requirements)#

Câu hỏi System Design: Thiết kế hệ thống thông báo – trả lời sao cho điểm caoSystem Design Interview: Design a Notification System – How to Score High

1. Đặt lại phạm vi (Clarify requirements)#

2. Kiến trúc cấp cao (High‑level architecture)#

3. Các pattern quan trọng#

4. Mô hình dữ liệu (Data model)#

5. Ví dụ Java (Spring Boot 3, Java 21)#

6. Ví dụ Go (worker)#

7. Mở rộng & Trade‑offs#

8. Những câu trả lời “điểm cao” trong interview#

Tóm tắt#

1. Clarify the scope#

2. High‑level architecture#

3. Core patterns you should mention#

4. Data model#

5. Java implementation (Spring Boot 3, Java 21)#

6. Go worker (high‑concurrency processing)#

7. Scaling and trade‑offs#

8. Scoring a high‑quality interview answer#

Key takeaways#

Thảo luậnDiscussion

1. Đặt lại phạm vi (Clarify requirements)#

1. Đặt lại phạm vi (Clarify requirements)#

2. Kiến trúc cấp cao (High‑level architecture)#

3. Các pattern quan trọng#

4. Mô hình dữ liệu (Data model)#

5. Ví dụ Java (Spring Boot 3, Java 21)#

6. Ví dụ Go (worker)#

7. Mở rộng & Trade‑offs#

8. Những câu trả lời “điểm cao” trong interview#

Tóm tắt#

1. Clarify the scope#

2. High‑level architecture#

3. Core patterns you should mention#

4. Data model#

5. Java implementation (Spring Boot 3, Java 21)#

6. Go worker (high‑concurrency processing)#

7. Scaling and trade‑offs#

8. Scoring a high‑quality interview answer#

Key takeaways#

Bài học liên quanRelated lessons

Publish-Subscribe

Thảo luậnDiscussion

5. Ví dụ Java (Spring Boot 3, Java 21)#

5. Java implementation (Spring Boot 3, Java 21)#