Làm thế nào để xây dựng một chiến lược xử lý lỗi (Error Handling) toàn diện trong ứng dụng Reactive Programming mà không làm gián đoạn luồng dữ liệu chính?

Question

Accepted Answer

Bản chất vấn đề
Theo quy chuẩn của Observable, khi một lỗi (Error) xảy ra, luồng dữ liệu sẽ ngay lập tức phát tín hiệu error, kích hoạt phương thức complete ngầm định và đóng toàn bộ luồng vĩnh viễn. Trong ứng dụng Enterprise, việc luồng bị chết đột ngột do một lỗi mạng nhỏ là điều không thể chấp nhận.
Các kỹ thuật xử lý lỗi chuyên sâu

catchError: Bắt lỗi và trả về một Observable thay thế hoặc một luồng rỗng, giúp luồng chính không bị đứt.
retry / retryWhen: Tự động thử lại luồng khi xảy ra lỗi (thường áp dụng cho lỗi mất kết nối mạng tạm thời).
throwError: Ném lỗi ra ngoài khi không thể phục hồi.

Ví dụ mã nguồn minh họa retry và catchError
import { of, throwError } from 'rxjs';
import { ajax } from 'rxjs/ajax';
import { catchError, retry } from 'rxjs/operators';

const apiCall$ = ajax('https://api.example.com/data').pipe(
  retry(3), // Thử lại tối đa 3 lần nếu gặp lỗi
  catchError(error => {
    console.error('Đã xảy ra lỗi nghiêm trọng sau 3 lần thử:', error);
    // Trả về một fallback observable chứa dữ liệu mặc định
    return of({ status: 'fallback', data: [] });
  })
);

apiCall$.subscribe(
  response => console.log('Nhận dữ liệu:', response),
  err => console.log('Lỗi này sẽ không bao giờ chạy đến nếu đã dùng catchError')
);
Lưu ý kinh nghiệm thực chiến

Đặt toán tử catchError bọc bên trong các Inner Observable thay vì đặt ở luồng gốc ngoài cùng, tránh việc toàn bộ luồng cấp cao bị đóng khi có lỗi ở một thành phần con.

Làm thế nào để xây dựng một chiến lược xử lý lỗi (Error Handling) toàn diện trong ứng dụng Reactive Programming mà không làm gián đoạn luồng dữ liệu chính?

Bản chất vấn đề

Làm Chủ Phỏng Vấn & Nâng Cao Trình Độ Chuyên Nghiệp

Tải Tuyển Tập 100+ Câu Hỏi Phỏng Vấn Chuyên Sâu (PDF)

Cần Mentor Phỏng Vấn Thử 1-1 & Tối Ưu CV?

Kiểm Tra CV Chuẩn ATS Miễn Phí

Câu hỏi reactive programming liên quan cùng chủ đề