RxJava का उपयोग करके Android में तत्काल खोज को लागू करना

मैं एक नए एप्लिकेशन पर काम कर रहा हूं, जैसा कि आमतौर पर होता है, एपीआई के माध्यम से डेटा प्राप्त करने के लिए बैकेंड सेवा के साथ संचार करता है। इस उदाहरण में, मैं एक खोज फ़ंक्शन विकसित करूँगा, जिसमें से एक विशेषता पाठ दर्ज करते समय एक त्वरित खोज सही होगी।

तुरंत खोज

कुछ भी जटिल नहीं है, आपको लगता है। आपको पृष्ठ पर खोज घटक को रखने की आवश्यकता है (सबसे अधिक संभावना है, टूलबार में), onTextChange घटना onTextChange कनेक्ट करें और खोज करें। तो यहाँ है कि मैंने क्या किया:

 override fun onCreateOptionsMenu(menu: Menu?): Boolean { menuInflater.inflate(R.menu.menu_main, menu) val searchView = menu?.findItem(R.id.action_search)?.actionView as SearchView // Set up the query listener that executes the search searchView.setOnQueryTextListener(object : SearchView.OnQueryTextListener { override fun onQueryTextSubmit(query: String?): Boolean { Log.d(TAG, "onQueryTextSubmit: $query") return false } override fun onQueryTextChange(newText: String?): Boolean { Log.d(TAG, "onQueryTextChange: $newText") return false } }) return super.onCreateOptionsMenu(menu) } 

लेकिन यहाँ समस्या है। चूँकि मुझे इनपुट के समय पर एक खोज अधिकार को लागू करने की आवश्यकता होती है, जब भी एक onQueryTextChange() ईवेंट हैंडलर की onQueryTextChange() , मैं परिणामों का पहला सेट प्राप्त करने के लिए एपीआई की ओर मुड़ता हूं। लॉग निम्नानुसार हैं:

 D/MainActivity: onQueryTextChange: T D/MainActivity: onQueryTextChange: TE D/MainActivity: onQueryTextChange: TES D/MainActivity: onQueryTextChange: TEST D/MainActivity: onQueryTextSubmit: TEST 

इस तथ्य के बावजूद कि मैं सिर्फ अपने अनुरोध को प्रिंट कर रहा हूं, पांच एपीआई कॉल हैं, जिनमें से प्रत्येक एक खोज करता है। उदाहरण के लिए, क्लाउड में, आपको API पर प्रत्येक कॉल के लिए भुगतान करना होगा। इस प्रकार, जब मैं अपना अनुरोध दर्ज करता हूं, तो मुझे भेजने से पहले थोड़ी देरी की आवश्यकता होती है, ताकि अंत में केवल एक एपीआई कॉल किया जाए।

अब, मान लीजिए कि मैं कुछ और खोजना चाहता हूं। मैं परीक्षण हटाता हूं और अन्य वर्ण दर्ज करता हूं:

 D/MainActivity: onQueryTextChange: TES D/MainActivity: onQueryTextChange: TE D/MainActivity: onQueryTextChange: T D/MainActivity: onQueryTextChange: D/MainActivity: onQueryTextChange: S D/MainActivity: onQueryTextChange: SO D/MainActivity: onQueryTextChange: SOM D/MainActivity: onQueryTextChange: SOME D/MainActivity: onQueryTextChange: SOMET D/MainActivity: onQueryTextChange: SOMETH D/MainActivity: onQueryTextChange: SOMETHI D/MainActivity: onQueryTextChange: SOMETHIN D/MainActivity: onQueryTextChange: SOMETHING D/MainActivity: onQueryTextChange: SOMETHING D/MainActivity: onQueryTextChange: SOMETHING E D/MainActivity: onQueryTextChange: SOMETHING EL D/MainActivity: onQueryTextChange: SOMETHING ELS D/MainActivity: onQueryTextChange: SOMETHING ELSE D/MainActivity: onQueryTextChange: SOMETHING ELSE D/MainActivity: onQueryTextSubmit: SOMETHING ELSE 

20 एपीआई कॉल हैं! थोड़ी देरी से इन कॉल्स की संख्या कम हो जाएगी। मैं डुप्लिकेट से छुटकारा भी चाहता हूं ताकि फसली पाठ दोहराए गए अनुरोधों के लिए न हो। मैं भी शायद कुछ तत्वों को फ़िल्टर करना चाहता हूं। उदाहरण के लिए, क्या आपको प्रवेश किए गए वर्णों के बिना खोज करने या एक वर्ण द्वारा खोज करने की क्षमता की आवश्यकता है?

प्रतिक्रियाशील प्रोग्रामिंग

आगे क्या करना है, इसके लिए कई विकल्प हैं, लेकिन अभी मैं एक ऐसी तकनीक पर ध्यान केंद्रित करना चाहता हूं, जिसे आमतौर पर प्रतिक्रियाशील प्रोग्रामिंग और आरएक्सजाव लाइब्रेरी के रूप में जाना जाता है। जब मैं पहली बार प्रतिक्रियात्मक प्रोग्रामिंग में आया, तो मैंने निम्नलिखित विवरण देखा:

ReactiveX एक एपीआई है जो अतुल्यकालिक संरचनाओं के साथ काम करता है और ऑब्जर्वर और इटरेटर पैटर्न के संयोजन के साथ-साथ कार्यात्मक प्रोग्रामिंग सुविधाओं के साथ डेटा स्ट्रीम या घटनाओं में हेरफेर करता है।

यह परिभाषा ReactiveX की प्रकृति और शक्तियों को पूरी तरह से स्पष्ट नहीं करती है। और अगर यह समझाता है, तो केवल उन लोगों के लिए जो पहले से ही इस ढांचे के सिद्धांतों से परिचित हैं। मैंने इस तरह के चार्ट भी देखे:

आरेख ऑपरेटर की भूमिका को समझाता है, लेकिन सार को पूरी तरह से नहीं समझता है। तो, आइए देखें कि क्या मैं एक सरल उदाहरण के साथ इस आरेख को अधिक स्पष्ट रूप से समझा सकता हूं।

आइए पहले हमारा प्रोजेक्ट तैयार करें। आपको अपने आवेदन की build.gradle फ़ाइल में एक नई लाइब्रेरी की आवश्यकता होगी:

 implementation "io.reactivex.rxjava2:rxjava:2.1.14" 

लाइब्रेरी को लोड करने के लिए प्रोजेक्ट निर्भरता को सिंक करना याद रखें।

अब हम एक नया समाधान देखते हैं। पुरानी पद्धति का उपयोग करते हुए, मैंने प्रत्येक नए चरित्र में प्रवेश करते ही एपीआई एक्सेस किया। नई पद्धति का उपयोग करते हुए, मैं एक Observable करने जा रहा हूं:

 override fun onCreateOptionsMenu(menu: Menu?): Boolean { menuInflater.inflate(R.menu.menu_main, menu) val searchView = menu?.findItem(R.id.action_search)?.actionView as SearchView // Set up the query listener that executes the search Observable.create(ObservableOnSubscribe<String> { subscriber -> searchView.setOnQueryTextListener(object : SearchView.OnQueryTextListener { override fun onQueryTextChange(newText: String?): Boolean { subscriber.onNext(newText!!) return false } override fun onQueryTextSubmit(query: String?): Boolean { subscriber.onNext(query!!) return false } }) }) .subscribe { text -> Log.d(TAG, "subscriber: $text") } return super.onCreateOptionsMenu(menu) } 

यह कोड पुराने कोड की तरह ही काम करता है। लॉग निम्नानुसार हैं:

 D/MainActivity: subscriber: T D/MainActivity: subscriber: TE D/MainActivity: subscriber: TES D/MainActivity: subscriber: TEST D/MainActivity: subscriber: TEST 

हालांकि, नई तकनीक का उपयोग करने के बीच महत्वपूर्ण अंतर एक प्रतिक्रियाशील धारा की उपस्थिति है - Observable । पाठ हैंडलर (या इस मामले में हैंडलर का अनुरोध) तत्वों को onNext() विधि का उपयोग करके स्ट्रीम में भेजता है। और Observable के सदस्य हैं जो इन तत्वों को संसाधित करते हैं।

प्रसंस्करण के लिए तार की सूची को कम करने के लिए सदस्यता लेने से पहले हम तरीकों की एक श्रृंखला बना सकते हैं। आरंभ करने के लिए, भेजा गया पाठ हमेशा निचला होगा और पंक्ति के आरंभ और अंत में कोई स्थान नहीं होगा:

 Observable.create(ObservableOnSubscribe<String> { ... }) .map { text -> text.toLowerCase().trim() } .subscribe { text -> Log.d(TAG, "subscriber: $text" } 

मैंने सबसे महत्वपूर्ण भाग दिखाने के लिए तरीकों में कटौती की। अब वही लॉग निम्नानुसार हैं:

 D/MainActivity: subscriber: t D/MainActivity: subscriber: te D/MainActivity: subscriber: tes D/MainActivity: subscriber: test D/MainActivity: subscriber: test 

अब अधिक सामग्री की अपेक्षा करते हुए, 250ms की देरी लागू करें:

 Observable.create(ObservableOnSubscribe<String> { ... }) .map { text -> text.toLowerCase().trim() } .debounce(250, TimeUnit.MILLISECONDS) .subscribe { text -> Log.d(TAG, "subscriber: $text" } 

और अंत में, डुप्लिकेट स्ट्रीम को हटा दें ताकि केवल पहला अनूठा अनुरोध संसाधित हो। बाद के समान अनुरोधों को अनदेखा किया जाएगा:

 Observable.create(ObservableOnSubscribe<String> { ... }) .map { text -> text.toLowerCase().trim() } .debounce(100, TimeUnit.MILLISECONDS) .distinct() .subscribe { text -> Log.d(TAG, "subscriber: $text" } 

लगभग। ट्रांस। इस मामले में, यह विशेष उचित है कि distinctUntilChanged() ऑपरेटर का उपयोग करें, क्योंकि अन्यथा, किसी भी स्ट्रिंग पर बार-बार खोज के मामले में, क्वेरी को केवल अनदेखा किया जाएगा। और इस तरह की खोज को लागू करते समय, केवल अंतिम सफल अनुरोध पर ध्यान देना और नए को अनदेखा करना उचित है यदि यह पिछले एक के साथ समान है।

अंत में, हम खाली प्रश्नों को फ़िल्टर करते हैं:

 Observable.create(ObservableOnSubscribe<String> { ... }) .map { text -> text.toLowerCase().trim() } .debounce(100, TimeUnit.MILLISECONDS) .distinct() .filter { text -> text.isNotBlank() } .subscribe { text -> Log.d(TAG, "subscriber: $text" } 

इस बिंदु पर, आप देखेंगे कि लॉग में केवल एक (या शायद दो) संदेश प्रदर्शित होता है, जो कम एपीआई कॉल को इंगित करता है। इस मामले में, आवेदन पर्याप्त रूप से काम करना जारी रखेगा। इसके अलावा, ऐसे मामले जब आप कुछ दर्ज करते हैं, लेकिन फिर हटाते हैं और फिर से प्रवेश करते हैं, तो एपीआई में कम कॉल आएंगे।

कई और अलग-अलग ऑपरेटर हैं जो आप अपने लक्ष्यों के आधार पर इस पाइपलाइन में जोड़ सकते हैं। मेरा मानना ​​है कि वे एपीआई के साथ संपर्क करने वाले इनपुट क्षेत्रों के साथ काम करने के लिए बहुत उपयोगी हैं। पूरा कोड इस प्रकार है:

 // Set up the query listener that executes the search Observable.create(ObservableOnSubscribe<String> { subscriber -> searchView.setOnQueryTextListener(object : SearchView.OnQueryTextListener { override fun onQueryTextChange(newText: String?): Boolean { subscriber.onNext(newText!!) return false } override fun onQueryTextSubmit(query: String?): Boolean { subscriber.onNext(query!!) return false } }) }) .map { text -> text.toLowerCase().trim() } .debounce(250, TimeUnit.MILLISECONDS) .distinct() .filter { text -> text.isNotBlank() } .subscribe { text -> Log.d(TAG, "subscriber: $text") } 

अब मैं एक एपीआई कॉल शुरू करने के लिए ViewModel को कॉल के साथ लॉग संदेश को बदल सकता हूं। हालाँकि, यह किसी अन्य आलेख के लिए एक विषय है।

निष्कर्ष

ऑब्जर्वबल में पाठ तत्वों को लपेटने और RxJava का उपयोग करने के लिए इस सरल तकनीक के साथ, आप सर्वर ऑपरेशन करने के लिए आवश्यक एपीआई कॉल की संख्या को कम कर सकते हैं, साथ ही साथ अपने एप्लिकेशन की जवाबदेही में सुधार कर सकते हैं। इस लेख में, हमने RxJava की पूरी दुनिया का केवल एक छोटा सा हिस्सा कवर किया है, इसलिए मैं आपको इस पर अतिरिक्त पढ़ने के लिए लिंक छोड़ता हूं:

• डैन ल्यू ग्रॉकिंग RxJava (यह वह साइट है जिसने मुझे सही दिशा में आगे बढ़ने में मदद की)।
• ReactiveX साइट (मैं अक्सर पाइपलाइन का निर्माण करते समय इस साइट को संदर्भित करता हूं)।