Event Bus और Observer Pattern Kotlin में

Kotlin में Event Bus और Observer Pattern: पूरी गाइड

आधुनिक Kotlin एप्लिकेशन (खासकर Android) डेवलपमेंट में, कंपोनेंट्स के बीच कमजोर रूप से जुड़ा (loosely coupled) इंटरैक्शन बनाना अक्सर ज़रूरी होता है। Observer Pattern और इसका व्यावहारिक रूप — Event Bus — इस समस्या का एक शानदार समाधान प्रदान करते हैं। इस लेख में, हम विस्तार से समझेंगे कि Event Bus क्या है, Observer Pattern कैसे काम करता है, और Kotlin प्रोजेक्ट्स में इन कॉन्सेप्ट्स को कैसे लागू करें।

Observer Pattern क्या है?

Observer Pattern (प्रेक्षक पैटर्न) एक बिहेवियरल डिज़ाइन पैटर्न है, जिसमें एक ऑब्जेक्ट (सब्जेक्ट) अपनी स्थिति में बदलाव के बारे में कई अन्य ऑब्जेक्ट्स (ऑब्ज़र्वर्स) को सूचित करता है। मुख्य कंपोनेंट्स:

Subject — इवेंट प्रकाशक, जो सब्सक्राइबर्स की सूची बनाए रखता है।
Observer — सब्सक्राइबर, जो सूचनाएँ प्राप्त करता है।
Event — प्रकाशक से सब्सक्राइबर्स तक भेजा जाने वाला विशिष्ट संदेश या डेटा।

Observer के रूप में Event Bus

Event Bus (इवेंट बस) एक केंद्रीकृत तंत्र है जो Observer Pattern के उपयोग को सरल बनाता है। हर सब्जेक्ट को मैन्युअल रूप से ऑब्ज़र्वर्स की सूची प्रबंधित करने के बजाय, Event Bus सब्सक्रिप्शन, अनसब्सक्रिप्शन और इवेंट डिलीवरी का सारा लॉजिक अपने हाथ में ले लेता है। यह जटिल आर्किटेक्चर वाले एप्लिकेशन में विशेष रूप से उपयोगी है, जहाँ कंपोनेंट्स को एक-दूसरे के बारे में सीधे जानने की ज़रूरत नहीं होती।

Kotlin में Event Bus के फायदे

कमजोर कपलिंग — कंपोनेंट्स बस के माध्यम से संवाद करते हैं, एक-दूसरे पर सीधी निर्भरता नहीं रखते।
टेस्टिंग आसान — इवेंट बस को आसानी से मॉक किया जा सकता है।
लचीलापन — मौजूदा कोड में बदलाव किए बिना नए सब्सक्राइबर्स जोड़ना आसान है।
असिंक्रोनस — इवेंट को अलग-अलग थ्रेड्स में प्रोसेस किया जा सकता है।

Kotlin में Event Bus की सरल इम्प्लीमेंटेशन

आइए, बिना किसी थर्ड-पार्टी लाइब्रेरी के अपना खुद का सरल Event Bus बनाएँ। इससे आंतरिक कार्यप्रणाली को समझने में मदद मिलेगी।

import kotlin.reflect.KClass

class EventBus {
    private val subscribers = mutableMapOf<KClass<*>, MutableList<(Any) -> Unit>>()

    // किसी विशिष्ट प्रकार के इवेंट की सब्सक्रिप्शन
    inline fun <reified T : Any> subscribe(crossinline onEvent: (T) -> Unit) {
        val eventType = T::class
        subscribers.getOrPut(eventType) { mutableListOf() }.add { event ->
            if (event is T) {
                onEvent(event)
            }
        }
    }

    // सभी इवेंट से अनसब्सक्राइब (डेमो के लिए)
    fun <T : Any> unsubscribe(eventType: KClass<T>) {
        subscribers.remove(eventType)
    }

    // इवेंट प्रकाशित करना
    fun publish(event: Any) {
        val eventType = event::class
        subscribers[eventType]?.forEach { handler ->
            handler(event)
        }
    }
}

// उपयोग का उदाहरण
data class UserLoggedIn(val userId: String, val timestamp: Long)
data class DataLoaded(val data: String)

fun main() {
    val bus = EventBus()

    // यूज़र लॉगिन इवेंट की सब्सक्रिप्शन
    bus.subscribe<UserLoggedIn> { event ->
        println("उपयोगकर्ता ${event.userId} ने ${event.timestamp} पर लॉगिन किया")
    }

    // डेटा लोड इवेंट की सब्सक्रिप्शन
    bus.subscribe<DataLoaded> { event ->
        println("डेटा लोड हुआ: ${event.data}")
    }

    // इवेंट प्रकाशित करना
    bus.publish(UserLoggedIn("user123", System.currentTimeMillis()))
    bus.publish(DataLoaded("नमूना डेटा"))
}

रेडीमेड लाइब्रेरी: GreenRobot EventBus

वास्तविक प्रोजेक्ट्स में अक्सर रेडीमेड लाइब्रेरी का उपयोग किया जाता है। Kotlin/Android के लिए सबसे लोकप्रिय लाइब्रेरी GreenRobot EventBus है। यह Android कंपोनेंट्स के साथ काम करने के लिए ऑप्टिमाइज़ है और सपोर्ट करती है: