[kotlin] 코틀린(Kotlin) Flow를 활용한 실무 예제

14 Dec 2023

kotlin

코틀린에서는 비동기적인 데이터 스트림을 처리하기 위해 Flow를 사용할 수 있습니다. Flow는 비동기 작업 결과를 효율적으로 처리하는 데 도움이 됩니다. 이번에는 실무에서 Flow를 활용한 예제를 살펴보겠습니다.

1. 실무 시나리오

가정 운송 모니터링 시스템을 구축한다고 가정해보겠습니다. 실시간으로 차량 위치 및 상태를 추적하고 이를 관리자에게 제공하는 시스템을 구현해야 합니다.

2. 기능 요구사항

차량 위치 및 상태 추적: 차량의 실시간 위치 및 트랙터 상태를 지속적으로 업데이트합니다.
알림 기능: 특정 상황이 발생하면(예: 지연, 사고 등) 즉시 관리자에게 알림을 전송합니다.

3. Flow를 활용한 실시간 위치 및 상태 추적

import kotlinx.coroutines.flow.Flow
import kotlinx.coroutines.flow.flow
import kotlinx.coroutines.delay

data class VehicleLocation(val latitude: Double, val longitude: Double)
data class VehicleStatus(val speed: Int, val fuelLevel: Int)

fun trackVehicle(locationUpdateIntervalMs: Long, statusUpdateIntervalMs: Long): Flow<VehicleInfo> = flow {
    while (true) {
        val location = getCurrentLocation()
        val status = getVehicleStatus()
        emit(VehicleInfo(location, status))
        delay(locationUpdateIntervalMs)
    }
}

private suspend fun getCurrentLocation(): VehicleLocation {
    // Implement logic to retrieve current location (e.g., from GPS module)
}

private suspend fun getVehicleStatus(): VehicleStatus {
    // Implement logic to retrieve vehicle status (e.g., from sensors)
}

위 코드는 Flow를 사용하여 실시간 차량 위치 및 상태를 추적하는 기능을 구현한 예제입니다. flow 빌더를 사용하여 데이터를 지속적으로 생성하고 업데이트하도록 작성했습니다.

4. 알림 기능 구현

알림 기능을 구현하기 위해서는 Flow의 collect 함수를 사용하여 특정 조건에 해당하는 상황이 발생했을 때 관리자에게 알림을 전송하도록 작성할 수 있습니다. 이 부분은 실제 시나리오 및 알림 전송 방식에 따라 다를 수 있습니다.

이와 같이 코틀린의 Flow를 활용하여 실무에서 비동기적인 데이터 스트림을 처리하는데 유용하게 활용할 수 있습니다.

참고 문헌:

Kotlin Flow 공식 문서: https://kotlinlang.org/docs/flow.html

이상으로 코틀린 Flow를 활용한 실무 예제에 대해 살펴보았습니다.