🚏 🏊 🤰🏼 ResultReceiver के माध्यम से धाराओं के बीच संचार 👲🏻 👩🏽‍🤝‍👩🏼 🀄️

जैसा कि प्रत्येक एंड्रॉइड एंड्रॉइड एंड्रॉइड एसडीके डेवलपर जानता है, यह समानांतर धागे में निष्पादित करने के लिए एक विशेष कोड कोड को बाध्य करने के कई तरीके प्रदान करता है। मल्टीथ्रेडिंग अच्छा है, लेकिन इसे व्यवस्थित करने के अलावा, आपको थ्रेड्स के बीच एक संचार चैनल स्थापित करने की भी आवश्यकता है। उदाहरण के लिए, UI थ्रेड और पृष्ठभूमि कार्य चलाने वाले थ्रेड के बीच। इस लघु निबंध में मैं बिल्ट-इन ResultReceiver वर्ग के उपयोग पर आधारित विधियों में से एक को उजागर करना चाहता हूं।

ज्वाइन करने के बजाय

अधिकांश एंड्रॉइड प्रोजेक्ट्स में, आपको बाहरी दुनिया के साथ संचार को व्यवस्थित करना होगा, अर्थात। नेटवर्किंग का आयोजन करें। मैं यह नहीं दोहराऊंगा कि यूआई स्ट्रीम में इतने लंबे समय तक चलने वाले कोड को निष्पादित करना बुरा क्यों है। यह सामान्य ज्ञान है। इसके अलावा, एपीआई 11 (हनीकॉम्ब जो) के साथ शुरू, सिस्टम डेवलपर हाथों को धड़कता है जब वह यूआई स्ट्रीम में नेटवर्क कॉल करने की कोशिश करता है।
यूआई स्ट्रीम को एक समानांतर स्ट्रीम (जिसमें, उदाहरण के लिए, एक HTTP अनुरोध किया जाता है) के साथ संचार करने के लिए विकल्पों में से एक है, जो अंतर्निहित सिस्टम क्लास android.os.ResultReceiver साथ सेवा के साथ उपयोग पर आधारित है।

दृष्टिकोण वास्तुकला के बारे में थोड़ा

एक अलग थ्रेड को व्यवस्थित करने के लिए, मैंने IntentService को चुना। वह क्यों है और एक साधारण सेवा नहीं है? क्योंकि IntentService, जब कोई कमांड इस पर आता है, स्वचालित रूप से UI से अलग थ्रेड में onHandleIntent(Intent intent) विधि को निष्पादित करना शुरू कर देता है। सरल सेवा इसे अनुमति नहीं देती है क्योंकि इसे मुख्य धागे में निष्पादित किया जाता है। स्वतंत्र रूप से सेवा से एक धारा की शुरुआत को व्यवस्थित करना आवश्यक है।
गतिविधि और इरादे के बीच संचार इंटेंट्स का उपयोग करके किया जाएगा।

कोड

सबसे पहले, स्रोत कोड, फिर वहां क्या हो रहा है और कैसे पर एक संक्षिप्त टिप्पणी के नीचे।

परिणामी कार्यान्वयन

 public class AppResultsReceiver extends ResultReceiver { public interface Receiver { public void onReceiveResult(int resultCode, Bundle data); } private Receiver mReceiver; public AppResultsReceiver(Handler handler) { super(handler); } public void setReceiver(Receiver receiver) { mReceiver = receiver; } @Override protected void onReceiveResult(int resultCode, Bundle resultData) { if (mReceiver != null) { mReceiver.onReceiveResult(resultCode, resultData); } } }

यहां आपको कॉलबैक ( Receiver ) पर ध्यान देना चाहिए। onReceiveResult() में परिणाम प्राप्त होने पर, एक गैर-शून्य कॉलबैक के लिए एक चेक बनाया जाता है। सक्रियण कोड में आगे यह दिखाया जाएगा कि इस कॉलबैक का उपयोग करके रिसीवर को कैसे सक्रिय और निष्क्रिय करना है।

IntentService

 public class AppService extends IntentService { public AppService() { this("AppService"); } public AppService(String name) { super(name); } @Override protected void onHandleIntent(Intent intent) { final ResultReceiver receiver = intent.getParcelableExtra(Constants.RECEIVER); receiver.send(Constants.STATUS_RUNNING, Bundle.EMPTY); final Bundle data = new Bundle(); try { Thread.sleep(Constants.SERVICE_DELAY); data.putString(Constants.RECEIVER_DATA, "Sample result data"); } catch (InterruptedException e) { data.putString(Constants.RECEIVER_DATA, "Error"); } receiver.send(Constants.STATUS_FINISHED, data); } }

onHandleIntent() को कॉलिंग कोड (UI क्लासेस आदि) startService() निष्पादित करने के बाद कहा जाएगा। ResultReceiver उदाहरण इरादे से निकाला जाएगा और कमांड "ठीक है, मैं काम पर गया" उसे तुरंत भेजा जाएगा। इस पद्धति में उपयोगी कार्य करने के बाद, परिणाम (मॉडल कक्षाएं, तार, JSON से निकाले गए कुछ भी) बंडल में रखे जाते हैं और रिसीवर को भेजे जाते हैं। इसके अलावा, प्रतिक्रिया के प्रकार (स्थिरांक द्वारा वर्णित) को इंगित करने के लिए विभिन्न कोड का उपयोग किया जाता है। कैसे ResultReceiver प्राप्त करता है और डेटा भेजता है इसके स्रोतों में पढ़ा जा सकता है।

सेवा में कमांड भेजना और परिणाम को संसाधित करना (गतिविधि)

 public class MainActivity extends Activity implements AppResultsReceiver.Receiver { private AppResultsReceiver mReceiver; private ProgressBar mProgress; @Override protected void onCreate(Bundle savedInstanceState) { super.onCreate(savedInstanceState); setContentView(R.layout.activity_main); mProgress = (ProgressBar) findViewById(R.id.progressBar); } @Override protected void onResume() { super.onResume(); mReceiver = new AppResultsReceiver(new Handler()); mReceiver.setReceiver(this); } @Override protected void onPause() { super.onPause(); mReceiver.setReceiver(null); } public void onStartButtonClick(View anchor) { final Intent intent = new Intent("SOME_COMMAND_ACTION", null, this, AppService.class); intent.putExtra(Constants.RECEIVER, mReceiver); startService(intent); } @Override public void onReceiveResult(int resultCode, Bundle data) { switch (resultCode) { case Constants.STATUS_RUNNING : mProgress.setVisibility(View.VISIBLE); break; case Constants.STATUS_FINISHED : mProgress.setVisibility(View.INVISIBLE); Toast.makeText(this, "Service finished with data: " + data.getString(Constants.RECEIVER_DATA), Toast.LENGTH_SHORT).show(); break; } } }

यहां सब कुछ सरल है। गतिविधि AppResultsReceiver.Receiver इंटरफ़ेस को लागू AppResultsReceiver.Receiver है। शुरू करते समय, यह रिसीवर का एक उदाहरण बनाता है, जब रोका जाता है, तो यह सेवा से प्रतिक्रियाएं सुनने से अलग हो जाता है। जब एक बटन क्लिक किया जाता है, तो एक कमांड (आशय) बनता है, हमारे ResultReceiver का लिंक इसमें रखा जाता है, और सेवा शुरू होती है।
किसी सेवा से प्रतिक्रिया प्राप्त करते समय, प्रतिक्रिया कोड onReceiveResult() विधि में जाँच की जाती है और इसी क्रिया को निष्पादित किया जाता है। वह सब है।

डेमो एप्लिकेशन सरल दिखता है, इसमें केवल एक बटन है "अनुरोध भेजें"।

डेमो प्रोजेक्ट का सोर्स कोड GitHub पर उपलब्ध है

एक निष्कर्ष के बजाय

पृष्ठभूमि सेवा में एक कमांड संसाधित करना केवल एक अपमान के लिए लागू किया जाता है: धारा बस थोड़ी देर के लिए रोक दी जाती है। बेशक, वास्तविक अनुप्रयोगों में, आपको कमांड (कार्रवाई) के कोड को स्थानांतरित करने की आवश्यकता है जिसे निष्पादित करने की आवश्यकता है, अतिरिक्त पैरामीटर, आदि। आपके हाथों में ओ.ओ.पी. यह भी याद रखने योग्य है कि डेटा (उदाहरण के लिए, मॉडल) जो बंडल में पैक किए गए हैं, पार्सलेबल ऑब्जेक्ट होने चाहिए। इससे उनकी क्रमिकता में वृद्धि होगी।
बेशक, वर्णित दृष्टिकोण अंतिम सत्य नहीं है। हम विभिन्न स्थापत्य दृष्टिकोण, साधन और संयोजन चुनने के लिए स्वतंत्र हैं। चाहे वह AsyncTask, सेवा + थ्रेड + ब्रॉडकास्टसीवर हो, या यूआई स्ट्रीम में हैंडलर के माध्यम से संदेश का "मैनुअल" प्रसारण हो। चुनें, जैसा कि वे कहते हैं, आप। लेकिन यह पूरी तरह से अलग कहानी है।

ResultReceiver के माध्यम से धाराओं के बीच संचार