Strangler Pattern으로 레거시 API 안전하게 이관하기

@Component class MigrationRouter( private val featureFlagClient: FeatureFlagClient, ) { fun resolveTarget( endpoint: String, userId: Long, ): MigrationTarget { if (!featureFlagClient.isEnabled("migration.$endpoint.enabled")) { return MigrationTarget.LEGACY } val cohort = featureFlagClient.getCohort(userId) if (cohort == Cohort.INTERNAL || cohort == Cohort.BETA) { return MigrationTarget.NEW } // 사용자 단위 고정 분기: 같은 사용자는 항상 같은 시스템으로 val bucket = Math.floorMod(userId.hashCode(), 100) val rolloutPercentage = featureFlagClient.getInt("migration.$endpoint.percentage") return if (bucket < rolloutPercentage) { MigrationTarget.NEW } else { MigrationTarget.LEGACY } } }

요청 → Facade → 레거시 호출 ──────────→ 응답 (사용자) └→ (비동기) 신규 호출 → 비교 → 메트릭 / diff 적재

@Component class OrderFacade( private val migrationRouter: MigrationRouter, private val legacyOrderClient: LegacyOrderClient, private val newOrderClient: NewOrderClient, private val shadowComparator: ShadowComparator, ) { fun getOrder( request: OrderRequest, userId: Long, ): OrderResponse { val target = migrationRouter.resolveTarget( endpoint = "orders", userId = userId, ) if (target == MigrationTarget.NEW) { return newOrderClient.getOrder(request) } val legacyResponse = legacyOrderClient.getOrder(request) if (migrationRouter.isShadowEnabled("orders")) { // 반환값을 쓰지 않는다. 비교하고 버린다 shadowComparator.compareAsync( request = request, legacyResponse = legacyResponse, traceId = MDC.get("traceId"), ) } return legacyResponse } }

@Component class ShadowComparator( private val newApiClient: NewApiClient, private val diffRecorder: DiffRecorder, private val meterRegistry: MeterRegistry, ) { @Async("shadowExecutor") fun compareAsync( request: OrderRequest, legacyResponse: OrderResponse, traceId: String, ) { runCatching { // 신규 호출도 이 안에서. 그래야 지연이 사용자 요청에 물리지 않는다 val newResponse = newApiClient.getOrder(request) if (signatureOf(legacyResponse) == signatureOf(newResponse)) { // 일치: 카운터만 올리고 페이로드는 버린다 meterRegistry.counter("shadow.compare", "result", "match").increment() } else { meterRegistry.counter("shadow.compare", "result", "mismatch").increment() // 불일치: 원본을 통째로 남겨야 나중에 원인을 볼 수 있다 diffRecorder.record( traceId = traceId, endpoint = "/orders", legacyResponse = legacyResponse, newResponse = newResponse, ) } }.onFailure { e -> // Shadow 실패는 절대 사용자 요청에 전파하지 않는다 log.warn("shadow comparison failed. traceId={}", traceId, e) } } // 타임스탬프, 요청 ID 등 매 요청 달라지는 필드는 제외하고 해싱 private fun signatureOf(response: OrderResponse): String { return response.copy( requestId = null, respondedAt = null, ).let { objectMapper.writeValueAsString(it) } .let { DigestUtils.sha256Hex(it) } } }

// 레거시 응답의 기괴한 스키마를 신규 도메인 모델로 번역 @Component class LegacyOrderAdapter( private val legacyClient: LegacyOrderClient, ) : OrderOutputPort { override fun findById(orderId: OrderId): Order? { val legacyDto = legacyClient.getOrderInfo(orderId.value) ?: return null return Order( id = OrderId(legacyDto.ORD_NO), status = mapStatus(legacyDto.STAT_CD), // "01", "02" → enum amount = Money(legacyDto.AMT_WON), // 원 단위 Long → 값 객체 ) } private fun mapStatus(code: String): OrderStatus { return when (code) { "01" -> OrderStatus.PENDING "02" -> OrderStatus.PAID "09" -> OrderStatus.CANCELED else -> throw IllegalLegacyStatusException("unknown legacy status code: $code") } } }