एंड्रॉइड (NDK) में JNI कॉलबैक का उपयोग करके "ऑब्जर्वर-सब्सक्राइबर" पैटर्न का कार्यान्वयन

Android (NDK) JNI कॉलबैक का कार्यान्वयन, ऑब्जर्वर- NDK और कॉलबैक के साथ सब्सक्राइबर पैटर्न, स्वयं लिखा EventBus या Rx

.... मुझे यह मिल गया "अंदर कोई उपयोगकर्ता सेव करने योग्य भाग नहीं हैं।" मैं देखना चाहता हूं कि वहां क्या है।
- रूसी घोंसले के शिकार गुड़िया बहुत गहराई तक। सच में, Orozco जुआन ने यह नहीं देखा कि रूसी घोंसले का शिकार गुड़िया क्या है।
"यह बकवास है, प्रोफेसर गुजरात।" इसकी जरूरत किसे है - इससे खिलवाड़ करने की।
"द एंड ऑफ़ द रेनबो" विंज वर्नर

काफी Android एप्लिकेशन हैं जो C ++ और Java कोड को मिलाते हैं। जावा व्यावसायिक तर्क को लागू करता है, और C ++ कंप्यूटिंग के सभी काम करता है, जो अक्सर ऑडियो प्रोसेसिंग में पाया जाता है। ऑडियो स्ट्रीम को कहीं अंदर संसाधित किया जाता है, और गैस और क्लच के साथ ब्रेक को ऊपर की ओर प्रदर्शित किया जाता है, और सभी प्रकार के मज़ेदार चित्रों के लिए डेटा।
खैर, ReactiveX के बाद से, यह पहले से ही परिचित है, इसलिए अपना हाथ नहीं बदलना है, और जेएनआई कालकोठरी के साथ परिचित तरीकों से काम करना है, आपको नियमित रूप से NDK के साथ परियोजनाओं में ऑब्जर्वर पैटर्न को लागू करने की आवश्यकता है। ठीक है, एक ही समय में, के लिए कोड की समझ पुरातत्वविदों जो लोग "किसी और के कोड को समझते हैं" बढ़ जाते हैं।
तो, कुछ सीखने का सबसे अच्छा तरीका यह है कि आप इसे स्वयं करें।
मान लें कि हम प्यार करते हैं और अपनी बाइक लिखना जानते हैं। और इसके परिणामस्वरूप हमें क्या मिलेगा:

• हस्ताक्षरकर्ताओं के लिए C ++ कोड से पोस्टबैक जैसा कुछ;
• मूल कोड में प्रसंस्करण का प्रबंधन, अर्थात्, जब ग्राहक नहीं होते हैं और उन्हें भेजने वाला कोई नहीं होता है, तो हमें बस्तियों में जाने के लिए मजबूर नहीं किया जा सकता है;
• विभिन्न JVM के बीच डेटा ट्रांसफर आवश्यक हो सकता है;
• और इसलिए दो बार उठने के लिए नहीं, एक ही समय में परियोजना प्रवाह के अंदर संदेश भेजने।

पूरा वर्किंग कोड GitHub पर उपलब्ध है । लेख इससे केवल अंश प्रदान करता है।

सिद्धांत और इतिहास का एक सा

हाल ही में मैं आरएक्स की बैठक में था और इसके बारे में सवालों की संख्या पर चकित था: रिएक्टिवएक्स कितनी तेजी से है और यह बिल्कुल कैसे काम करता है।
ReactiveX के लिए, मैं केवल यह कह सकता हूं कि जावा के लिए इसकी गति बहुत अधिक निर्भर करती है कि इसका उपयोग कितना उचित है; यदि सही तरीके से उपयोग किया जाता है, तो इसकी गति पर्याप्त है।
हमारी बाइक बहुत अधिक हल्की है, लेकिन यदि आपको आवश्यकता है, उदाहरण के लिए, एक संदेश कतार (जैसे प्रवाहशील), तो आपको इसे स्वयं लिखने की आवश्यकता है। क्योंकि आप जानते हैं कि सभी गड़बड़ियां केवल आपकी हैं।
सिद्धांत का एक सा: ऑब्जर्वर- सब्सक्राइबर पैटर्न एक ऐसा तंत्र है जो किसी वस्तु को अन्य वस्तुओं की स्थिति में बदलाव के बारे में अलर्ट प्राप्त करने की अनुमति देता है और इस प्रकार उनका निरीक्षण करता है। यह सॉफ्टवेयर घटकों के बीच कनेक्टिविटी और निर्भरता को कम करने के लिए किया जाता है, जो उन्हें उपयोग करने और अधिक कुशलता से परीक्षण करने की अनुमति देता है। एक ज्वलंत प्रतिनिधि जिसमें भाषा की अवधारणा का निर्माण किया गया है, वह सब कुछ है - स्मॉलटाक, सभी संदेश भेजने के विचार पर आधारित है। प्रभावित उद्देश्य-सी।

कार्यान्वयन

आइए DIY की सर्वश्रेष्ठ परंपराओं में प्रयास करें, ताकि बात करने के लिए, "एलईडी ब्लिंक करें"। यदि आप एंड्रॉइड NDK दुनिया में जेएनआई का उपयोग करते हैं, तो आप किसी भी धागे में एसिंक्रोनस रूप से जावा विधि का अनुरोध कर सकते हैं। यह हम अपने "ऑब्जर्वर" बनाने के लिए उपयोग करते हैं।

डेमो प्रोजेक्ट एंड्रॉइड स्टूडियो से नए प्रोजेक्ट टेम्पलेट पर आधारित है।

यह एक ऑटो जेनरेटेड तरीका है। उन्होंने टिप्पणी की:

// Used to load the 'native-lib' library on application startup. static { System.loadLibrary("native-lib"); } 

अब अपने लिए। पहला चरण nsubscribeListener विधि है।

 private native void nsubscribeListener(JNIListener JNIListener); 

यह C ++ कोड को जावा कोड का लिंक प्राप्त करने की अनुमति देता है ताकि JNIListener. इंटरफ़ेस को लागू करने वाले ऑब्जेक्ट पर कॉलबैक सक्षम किया जा JNIListener.

 public interface JNIListener { void onAcceptMessage(String string); void onAcceptMessageVal(int messVal); } 

मूल्यों को इसके तरीकों के कार्यान्वयन में स्थानांतरित किया जाएगा।

वर्चुअल मशीन के लिंक के प्रभावी कैशिंग के लिए, हम ऑब्जेक्ट के लिंक को भी सहेजते हैं। हमें इसके लिए एक वैश्विक लिंक मिलता है।

 Java_ua_zt_mezon_myjnacallbacktest_MainActivity_nsubscribeListener(JNIEnv *env, jobject instance, jobject listener) { env->GetJavaVM(&jvm); //store jvm reference for later call store_env = env; jweak store_Wlistener = env->NewWeakGlobalRef(listener); 

तुरंत तरीकों की लिंक गिनें और सहेजें। इसका मतलब है कि कॉलबैक को पूरा करने के लिए कम संचालन की आवश्यकता होती है।

 jclass clazz = env->GetObjectClass(store_Wlistener); jmethodID store_method = env->GetMethodID(clazz, "onAcceptMessage", "(Ljava/lang/String;)V"); jmethodID store_methodVAL = env->GetMethodID(clazz, "onAcceptMessageVal", "(I)V"); 

सब्सक्राइबर डेटा को ObserverChain क्लास रिकॉर्ड के रूप में संग्रहीत किया जाता है।

 class ObserverChain { public: ObserverChain(jweak pJobject, jmethodID pID, jmethodID pJmethodID); jweak store_Wlistener=NULL; jmethodID store_method = NULL; jmethodID store_methodVAL = NULL; }; 

डायनेमिक ऐरे स्टोर_वेल्टरनेवर_वेक्टर के लिए सब्सक्राइबर को सेव करें।

 ObserverChain *tmpt = new ObserverChain(store_Wlistener, store_method, store_methodVAL); store_Wlistener_vector.push_back(tmpt); 

अब जावा कोड से संदेशों को कैसे प्रसारित किया जाएगा।

नॉनटेक्स्ट मेथड को भेजे गए मेसेज को सभी हस्ताक्षरकर्ताओं को भेजा जाएगा।

 private native void nonNext(String message); 

कार्यान्वयन:

 Java_ua_zt_mezon_myjnacallbacktest_MainActivity_nonNext(JNIEnv *env, jobject instance, jstring message_) { txtCallback(env, message_); } 

समारोह txtCallback (env, message_); सभी हस्ताक्षरकर्ताओं को संदेश भेजता है।

 void txtCallback(JNIEnv *env, const _jstring *message_) { if (!store_Wlistener_vector.empty()) { for (int i = 0; i < store_Wlistener_vector.size(); i++) { env->CallVoidMethod(store_Wlistener_vector[i]->store_Wlistener, store_Wlistener_vector[i]->store_method, message_); } } } 

C ++ या C कोड से संदेशों को अग्रेषित करने के लिए, हम test_string_callback_fom_c फ़ंक्शन का उपयोग करते हैं

 void test_string_callback_fom_c(char *val) 

वह शुरू से ही सही जाँचता है कि कोई सबस्क्राइबर है या नहीं।

 if (store_Wlistener_vector.empty()) return; 

यह देखना आसान है कि संदेशों को भेजने के लिए उसी txtCallback फ़ंक्शन का उपयोग किया जाता है:

 void test_string_callback_fom_c(char *val) { if (store_Wlistener_vector.empty()) return; __android_log_print(ANDROID_LOG_VERBOSE, "GetEnv:", " start Callback to JNL [%d] \n", val); JNIEnv *g_env; if (NULL == jvm) { __android_log_print(ANDROID_LOG_ERROR, "GetEnv:", " No VM \n"); return; } // double check it's all ok JavaVMAttachArgs args; args.version = JNI_VERSION_1_6; // set your JNI version args.name = NULL; // you might want to give the java thread a name args.group = NULL; // you might want to assign the java thread to a ThreadGroup int getEnvStat = jvm->GetEnv((void **) &g_env, JNI_VERSION_1_6); if (getEnvStat == JNI_EDETACHED) { __android_log_print(ANDROID_LOG_ERROR, "GetEnv:", " not attached\n"); if (jvm->AttachCurrentThread(&g_env, &args) != 0) { __android_log_print(ANDROID_LOG_ERROR, "GetEnv:", " Failed to attach\n"); } } else if (getEnvStat == JNI_OK) { __android_log_print(ANDROID_LOG_VERBOSE, "GetEnv:", " JNI_OK\n"); } else if (getEnvStat == JNI_EVERSION) { __android_log_print(ANDROID_LOG_ERROR, "GetEnv:", " version not supported\n"); } jstring message = g_env->NewStringUTF(val);// txtCallback(g_env, message); if (g_env->ExceptionCheck()) { g_env->ExceptionDescribe(); } if (getEnvStat == JNI_EDETACHED) { jvm->DetachCurrentThread(); } } 

MainActivity में हम दो टेक्स्टव्यू और एक EditView बनाते हैं।

 <TextView android:id="@+id/sample_text_from_Presenter" android:layout_width="wrap_content" android:layout_height="wrap_content" android:layout_weight="1" android:padding="25dp" android:text="Hello World!from_Presenter" app:layout_constraintBottom_toTopOf="parent" app:layout_constraintEnd_toStartOf="parent" app:layout_constraintStart_toStartOf="parent" app:layout_constraintTop_toTopOf="parent" /> <TextView android:id="@+id/sample_text_from_act" android:layout_width="wrap_content" android:layout_height="wrap_content" android:layout_weight="1" android:text="Hello World from_ac!" app:layout_constraintBottom_toTopOf="parent" app:layout_constraintStart_toStartOf="@+id/sample_text_from_Presenter" app:layout_constraintTop_toTopOf="parent" /> <EditText android:id="@+id/edit_text" android:layout_width="wrap_content" android:layout_height="wrap_content" android:text="Hello World!" app:layout_constraintBottom_toTopOf="parent" app:layout_constraintStart_toStartOf="@+id/sample_text_from_act" app:layout_constraintTop_toTopOf="parent" /> 

OnCreate में, हम View को वेरिएबल्स के साथ बाँधते हैं और वर्णन करते हैं कि जब EditText में टेक्स्ट बदला जाता है, तो एक संदेश ग्राहकों को भेजा जाएगा।

 mEditText = findViewById(R.id.edit_text); mEditText.addTextChangedListener(new TextWatcher() { @Override public void beforeTextChanged(CharSequence charSequence, int i, int i1, int i2) { } @Override public void onTextChanged(CharSequence charSequence, int i, int i1, int i2) { nonNext(charSequence.toString()); } @Override public void afterTextChanged(Editable editable) { } }); tvPresenter = (TextView) findViewById(R.id.sample_text_from_Presenter); tvAct = (TextView) findViewById(R.id.sample_text_from_act); 

हम ग्राहकों को शुरू और पंजीकृत करते हैं:

 mPresenter = new MainActivityPresenterImpl(this); nsubscribeListener((MainActivityPresenterImpl) mPresenter); nlistener = new JNIListener() { @Override public void onAcceptMessage(String string) { printTextfrActObj(string); } @Override public void onAcceptMessageVal(int messVal) { } }; nsubscribeListener(nlistener); 

यह कुछ इस तरह दिखता है:

पूरा वर्किंग कोड GitHub https://github.com/NickZt/MyJNACallbackTest पर उपलब्ध है
आइए टिप्पणियों में जानते हैं कि अधिक विवरण में क्या वर्णन करना है।