Circuit Breaker là gì?

• CLOSED: Trạng thái bình thường, cho phép mọi yêu cầu.
• OPEN: Trạng thái ngắt mạch, từ chối mọi yêu cầu (Trạng thái hết hạn sau một khoảng TTL).
• HALF_OPEN: Cho phép một phần yêu cầu → Đang trong quá trình thử nghiệm phục hồi.

CLOSED ──(Lỗi liên tục)──▶ OPEN ──(Hết TTL)──▶ HALF_OPEN ──(Thành công)──▶ CLOSED
                                                 └────(Thất bại)────┘

Triển khai dựa trên Redis

Thuật toán cơ bản

1. Nếu số lần thất bại vượt ngưỡng, chuyển sang trạng thái OPEN và thiết lập TTL.
2. Khi TTL hết hạn và key trạng thái biến mất, hệ thống sẽ coi là đang ở trạng thái HALF_OPEN.
3. Cho phép một số yêu cầu trong trạng thái HALF_OPEN, nếu tích lũy đủ số lần thành công → Quay lại trạng thái CLOSED.
4. Nếu thất bại lần nữa trong trạng thái HALF_OPEN → Chuyển ngay lập tức về OPEN.

Triển khai tích hợp Kotlin Coroutine + Redisson

suspend fun <T> execute(key: String, supplier: suspend () -> T): T {
    if (!isCallPermitted(key)) throw CircuitOpenException("Mạch đang ở trạng thái OPEN")

    return try {
        val result = supplier()
        onSuccess(key)
        result
    } catch (ex: Exception) {
        if (classifier.shouldTrip(ex)) {
            onFailure(key)
        }
        throw ex
    }
}

Chiến lược phân loại ngoại lệ: Ngăn chặn xâm nhập Domain

interface ExceptionClassifier {
    fun shouldTrip(ex: Throwable): Boolean
}

class DefaultExceptionClassifier : ExceptionClassifier {
    override fun shouldTrip(ex: Throwable): Boolean = when (ex) {
        is ClientErrorException -> false // Lỗi phía client: Không ngắt mạch
        is TimeoutException, is UpstreamServerException -> true // Lỗi hệ thống: Ngắt mạch
        else -> true
    }
}

Lưu ý khi triển khai

• Việc chuyển sang trạng thái HALF_OPEN có thể coi là việc hết hạn TTL của trạng thái OPEN hoặc quản lý một cách tường minh.
• onSuccess chỉ tham gia vào việc chuyển đổi trạng thái khi đang ở HALF_OPEN (bỏ qua khi đang ở CLOSED).
• onFailure chỉ xử lý các ngoại lệ thuộc đối tượng ngắt mạch (loại trừ lỗi phía client).
• Đảm bảo tính an toàn đa luồng (thread-safe) trong Coroutine bằng cách sử dụng các API bất đồng bộ của Redisson kết hợp với await().

Kết luận