RxJava Java: रिएक्टिव प्रोग्रामिंग की पूरी गाइड

1. RxJava क्या है और इसकी आवश्यकता क्यों है?

RxJava Java भाषा में रिएक्टिव प्रोग्रामिंग के लिए एक लाइब्रेरी है, जो Observable (देखने योग्य) और Observer (देखने वाला) की अवधारणा को लागू करती है। यह कंपोज़ेबल ऑपरेटरों के माध्यम से एसिंक्रोनस डेटा स्ट्रीम और इवेंट्स को प्रोसेस करने की सुविधा देती है। पारंपरिक callback या Future/Promise के विपरीत, RxJava डेटा स्ट्रीम को ट्रांसफॉर्म, फ़िल्टर और कंबाइन करने के लिए शक्तिशाली टूल्स प्रदान करती है, जिससे कोड अधिक पठनीय, अनुमानित और मल्टीथ्रेडिंग से जुड़ी त्रुटियों से कम प्रभावित होता है।

RxJava की आवश्यकता क्यों है? आधुनिक Java एप्लिकेशन डेवलपमेंट (विशेषकर Android, Spring WebFlux पर सर्वर एप्लिकेशन, माइक्रोसर्विसेज) में लगातार एसिंक्रोनसिटी से जुड़ी समस्याएं आती हैं: नेटवर्क से डेटा लोड करना, डेटाबेस के साथ काम करना, यूज़र इवेंट्स को प्रोसेस करना। RxJava इन समस्याओं को हल करती है, सभी प्रकार की एसिंक्रोनस सीक्वेंस के लिए एक समान API प्रदान करके। यह "callback hell" (कॉलबैक का जाल) से बचाती है, एसिंक्रोनस चेन में एरर हैंडलिंग को सरल बनाती है, और थ्रेड्स (Schedulers) के प्रबंधन के लिए शक्तिशाली साधन प्रदान करती है।

RxJava के मुख्य लाभ: डिक्लेरेटिव (आप बताते हैं कि क्या करना है, कैसे नहीं), कंपोज़ेबल (ऑपरेटर आसानी से जुड़ते हैं), डेटा खपत की गति को नियंत्रित करने के लिए backpressure (प्रतिदबाव) का समर्थन, और समृद्ध इकोसिस्टम (RxAndroid, RxJava2Extensions, RxRelay)। यह लाइब्रेरी सक्रिय रूप से समर्थित है और उद्योग में व्यापक रूप से उपयोग की जाती है, विशेषकर Android डेवलपमेंट (Retrofit + RxJava, Room + RxJava) में।

2. इंस्टॉलेशन

RxJava Maven Central के माध्यम से वितरित की जाती है। इसे प्रोजेक्ट में जोड़ने के लिए, अपने build.gradle (Gradle के लिए) या pom.xml (Maven के लिए) फ़ाइल में डिपेंडेंसी जोड़ें।

Gradle (Android / Java प्रोजेक्ट)

dependencies {
    implementation 'io.reactivex.rxjava3:rxjava:3.1.8'
}

Maven

<dependency>
    <groupId>io.reactivex.rxjava3</groupId>
    <artifactId>rxjava</artifactId>
    <version>3.1.8</version>
</dependency>

Android प्रोजेक्ट्स के लिए, मुख्य थ्रेड पर काम करने के लिए अक्सर RxAndroid भी जोड़ा जाता है:

implementation 'io.reactivex.rxjava3:rxandroid:3.0.2'

3. त्वरित शुरुआत — न्यूनतम कार्यशील उदाहरण

एक सरल Observable बनाते हैं जो "Hello" और "World" स्ट्रिंग्स उत्पन्न करता है, और उस पर सब्सक्राइब करते हैं:

import io.reactivex.rxjava3.core.Observable;
import io.reactivex.rxjava3.core.Observer;
import io.reactivex.rxjava3.disposables.Disposable;

public class RxJavaQuickStart {
    public static void main(String[] args) {
        // Observable बनाएं जो दो एलिमेंट उत्सर्जित करता है
        Observable<String> observable = Observable.just("Hello", "World");

        // Observer बनाएं
        Observer<String> observer = new Observer<String>() {
            @Override
            public void onSubscribe(Disposable d) {
                System.out.println("सब्सक्रिप्शन स्थापित हुआ");
            }

            @Override
            public void onNext(String s) {
                System.out.println("प्राप्त हुआ: " + s);
            }

            @Override
            public void onError(Throwable e) {
                System.err.println("त्रुटि: " + e.getMessage());
            }

            @Override
            public void onComplete() {
                System.out.println("स्ट्रीम समाप्त हुई");
            }
        };

        // सब्सक्राइब करें
        observable.subscribe(observer);
    }
}

आउटपुट:

सब्सक्रिप्शन स्थापित हुआ
प्राप्त हुआ: Hello
प्राप्त हुआ: World
स्ट्रीम समाप्त हुई

4. मुख्य तरीके/क्लासेस

4.1 Observable.just()

सिग्नेचर: public