Aká je úloha kanála v architektúre systému a ako…

Kanál (Channel) v architektúre systému plní úlohu medzičlánku alebo dátovej zbernice medzi rôznymi komponentmi (výrobcami a spotrebiteľmi). Jeho hlavnou úlohou je zabezpečiť asynchrónny a bezpečný prenos dát alebo udalostí z jedného miesta na druhé, bez potreby priameho prepojenia medzi odosielateľom a príjemcom.

Pre interakciu s viacerými odberateľmi alebo spotrebiteľmi môže kanál fungovať podľa jednej z nasledujúcich modelov:

Model "Jeden ku jednému" (One-to-One): Každá správa odoslaná výrobcom je prijímaná iba jedným spotrebiteľom. Toto je typické pre fronty (Queues).
Model "Jeden ku mnohým" (One-to-Many): Každá správa odoslaná výrobcom je prijímaná všetkými prihlásenými spotrebiteľmi. Toto je typické pre vzor "Vydavateľ-odberateľ" (Publish-Subscribe) alebo udalostné autobusy (Event Buses).

V modeli "Jeden ku mnohým" kanál zvyčajne udržiava zoznam odberateľov a pri prijatí novej správy ju rozširuje všetkým registrovaným spotrebiteľom.

Príklady implementácie kanála v Android vývoji môžu byť:

LiveData: Zabezpečuje asynchrónny prenos dát a oznamovanie odberateľov (Observer). Funguje podľa modelu "Jeden ku mnohým".

// Príklad použitia LiveData v ViewModel
private val _data = MutableLiveData<String>()
val data: LiveData<String> = _data // pozorované LiveData

fun sendData(value: String) {
    _data.value = value // odoslanie dát
}

Flow (Kotlin Coroutines): Umožňuje vytvárať asynchrónne prúdy dát. Môže fungovať ako v modeli "Jeden ku jednému" (studené Flow), tak aj v modeli "Jeden ku mnohým" (horúce SharedFlow / StateFlow).

// Príklad studeného Flow
fun countUp(): Flow<Int> = flow {
    for (i in 1..5) {
        delay(100)
        emit(i) // odoslanie dát
    }
}

// Príklad SharedFlow (horúci Flow)
private val _sharedFlow = MutableSharedFlow<String>()
val sharedFlow: SharedFlow<String> = _sharedFlow

suspend fun sendEvent(event: String) {
    _sharedFlow.emit(event) // odoslanie dát
}

EventBus knižnice: ako GreenRobot EventBus alebo RxJava. Implementujú vzor "Vydavateľ-odberateľ".

Interakcia s viacerými spotrebiteľmi cez kanál zvyčajne zahŕňa mechanizmy odberu (registrovať sa v kanáli) a odhlásenia (spotrebiteľ prestáva dostávať správy). Kanál riadi doručovanie správ, spracováva paralelizmus a potenciálne problémy so synchronizáciou, čo uľahčuje vývoj distribuovaných alebo viacvláknových systémov.

Aká je úloha kanála v architektúre systému a ako interaguje s viacerými odberateľmi alebo spotrebiteľmi?