Sistem arxitekturasında kanalın rolu nədir və o necə çoxsaylı abunəçilər və ya istehlakçılar ilə qarşılıqlı əlaqədədir?

Sistem arxitekturasında kanal (Channel), müxtəlif komponentlər arasında (istehsalçılar və iste'molçular) vasitəçi və ya məlumatlar şinası kimi fəaliyyət göstərir. Onun əsas vəzifəsi məlumatların və ya hadisələrin bir yerdən digər yerə asinxron və təhlükəsiz ötürülməsini təmin etməkdir, göndərən və alan arasında birbaşa əlaqə tələb olunmur.

Bir neçə abunəçi və ya iste'molçu ilə qarşılıqlı əlaqə üçün, kanal aşağıdakı modellərdən birinə əsaslana bilər:

• "Bir-bir" (One-to-One) modeli: Hər göndərilən mesaj yalnız bir iste'molçu tərəfindən qəbul edilir. Bu, növbələr (Queues) üçün xarakterikdir.

• "Bir-çox" (One-to-Many) modeli: Hər göndərilən mesaj bütün abunə olan iste'molçülərə çatdırılır. Bu, "Yayımçı-Abunəçi" (Publish-Subscribe) və ya hadisə otobüsləri (Event Buses) üçün xarakterikdir.

"Bir-çox" modelində, kanal adətən abunəçilərin siyahısını saxlayır və yeni mesaj alındıqda, onu qeydiyyatdan keçmiş bütün iste'molçülərə yayır.

Android inkişafında kanalın nümunələri:

• LiveData: Asinxron məlumat ötürməsini və abunəçilərə (Observer) bildiriş verməyi təmin edir. "Bir-çox" modeli ilə işləyir.

  // ViewModel-də LiveData istifadə nümunəsi
  private val _data = MutableLiveData<String>()
  val data: LiveData<String> = _data // müşahidə olunan LiveData
  
  fun sendData(value: String) {
      _data.value = value // məlumat göndərilməsi
  }
  

• Flow (Kotlin Coroutines): Asinxron məlumat axınlarını yaratmağa imkan verir. "Bir-bir" (soyuq Flow) və ya "Bir-çox" (SharedFlow / StateFlow isti) modelində işləyə bilər.

  // Soyuq Flow nümunəsi
  fun countUp(): Flow<Int> = flow {
      for (i in 1..5) {
          delay(100)
          emit(i) // məlumat göndərilməsi
      }
  }
  
  // SharedFlow (isti Flow) nümunəsi
  private val _sharedFlow = MutableSharedFlow<String>()
  val sharedFlow: SharedFlow<String> = _sharedFlow
  
  suspend fun sendEvent(event: String) {
      _sharedFlow.emit(event) // məlumat göndərilməsi
  }
  

• EventBus kitabxanaları: GreenRobot EventBus və ya RxJava kimi. "Yayımçı-Abunəçi" modelini həyata keçirirlər.

Kanal vasitəsilə çoxsaylı iste'molçü ilə qarşılıqlı əlaqə adətən abunəlik (consumer kanalında qeydiyyatdan keçmə) və abunəliyin ləğvi (consumer mesajları qəbul etməyi dayandırır) mexanizmlərini əhatə edir. Kanal mesajların çatdırılmasını idarə edir, paralelliyi və potensial sinxronizasiya problemlərini həll edir, bu da paylanmış və ya çox ipli sistemlərin inkişafını sadələşdirir.