इंटरबैंड बातचीत। डेवलपर के लिए विषुव

फिर से नमस्कार! फिर, एक ट्यूटोरियल के रूप में बहुत सारे कोड। ;)

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

इस पोस्ट में मैं बात करना चाहता हूं कि बंडल एक दूसरे के साथ कैसे संवाद कर सकते हैं।

उदाहरण के लिए, एक सरल कार्य है जो निम्नानुसार तैयार किया गया है: "वर्करबंडल बंडल में पृष्ठभूमि सेवा प्रत्येक 20 सेकंड में" प्रीवर्कफंक्शन "नामक कुछ करती है, इसके बाद हैंडलरबंडल बंडल को इस बारे में पता लगाना चाहिए और निष्पादन बंडल को सूचित करना चाहिए, ताकि वह "वर्कफ़ंक्शन" चलाए।

लेकिन चलो इसके साथ शुरू नहीं करते हैं, लेकिन एक सरल के साथ: एक निश्चित रजिस्टर बंडल है जो बंडलों की एक रजिस्ट्री को बनाए रखना चाहिए जो लॉन्च के समय इसमें पंजीकृत किया जा सकता है और बंद होने के समय रजिस्टर से हटा दिया जा सकता है।

इस समस्या को हल करने के लिए, हम EventAdmin सेवा का उपयोग करते हैं, जो बंडलों के बीच घटनाओं के आदान-प्रदान के लिए एक कतार है। सबसे पहले, रजिस्टर बंडल के एक्टिवेटर को लिखें, जिसमें दूसरे बंडल के संदेश प्राप्त होंगे।

संदेश रिसेप्शन कार्यान्वयन

public class Activator implements BundleActivator { private Register mRegister; public void start(BundleContext context) throws Exception { mRegister = new Register(); /* *       . */ context.registerService(EventHandler.class.getName(), new ActivationEventHandler(mRegister), getHandlerServiceProperties( "ru/futurelink/app/web/usecase/Activator" )); /* *     */ Dictionary<String, Object> props = new Hashtable<String, Object>(); props.put("contextName", "app"); context.registerService(ApplicationConfiguration.class.getName(), new ApplicationConfig(mRegister), props ); } public void stop(BundleContext context) throws Exception {} protected Dictionary<String, Object> getHandlerServiceProperties(String... topics) { Dictionary<String, Object> result = new Hashtable<String, Object>(); result.put(EventConstants.EVENT_TOPIC, topics); return result; } } 

यहां हम एक ऐसी सेवा को पंजीकृत करते हैं जो विषय पंक्ति "आरयू / फ्यूचरलिंक / ऐप / वेब / यूसेकस / एक्टीवेटर" के साथ संदेश संसाधित करता है (इस विषय के साथ संदेशों की सदस्यता)। यह इस तथ्य पर ध्यान देने योग्य है कि इस तरह के विषय के साथ संदेश किसी भी बंडल द्वारा प्राप्त किया जा सकता है जो इसे सदस्यता लेता है। चूंकि इस तरह की रजिस्ट्री का कोई लाभ नहीं होता है - इसे इस मामले में आरएपी एप्लिकेशन सेवा को आगे स्थानांतरित किया जाना चाहिए, जहां इसका उपयोग किया जाएगा। इसलिए, हम कंस्ट्रक्टर में एक पैरामीटर जोड़कर इस पोस्ट से ApplicationConfig को ओवरराइड करते हैं।

 public class ApplicationConfig implements ApplicationConfiguration { private Register mRegister; public ApplicationConfig(Register register) { mRegister = register; } } 

स्वयं रजिस्टर क्लास कुछ विशेष का प्रतिनिधित्व नहीं करता है, इसका कार्यान्वयन महत्वपूर्ण नहीं है। उदाहरण के लिए, यह केवल पंजीकृत बंडल नामों का एक संग्रह हो सकता है।

लेकिन यह रजिस्ट्री रिसीवर संदेश हैंडलर है:

 public class ActivationEventHandler implements EventHandler { private Register mRegister; public UseCaseActivationEventHandler(Register register) { mRegister = register; } @Override public void handleEvent(Event event) { String bundle = (String) event.getProperty("bundleName"); Integer activated = (Integer) event.getProperty("activated"); BundleContext context = (BundleContext)event.getProperty("bundleContext"); if (activated == 1) { mRegister.registerBundle(bundle, context); } else { mRegister.unregisterBundle(bundle); } } } 

यह वह जगह है जहाँ प्रसंस्करण समाप्त होता है। उपरोक्त विषय के साथ एक संदेश प्राप्त होने पर, एक बंडल जिसका नाम बंडल नाम पैरामीटर में भेजा जाता है, पंजीकृत किया जाएगा। यदि पैरामीटर == 1 सक्रिय है, तो यह माना जाता है कि बंडल को रजिस्ट्री में जोड़ा जाना चाहिए, अन्यथा, वहां से हटा दिया जाता है।

संदेश भेजने का कार्यान्वयन

आइए एक बंडल एक्टिवेटर बनाएं जो इसके आरंभ और रुकने के बारे में संदेश भेजेगा।

 public class ClientActivator implements BundleActivator { private ServiceTracker mServiceTracker; private EventAdmin mEventAdmin; private Logger mLogger; private String mBundleName; public ClientActivator() {} public void addUsecase(UseCaseInfo info) { mBundleName = info.getBundleName(); } @Override public void start(BundleContext context) throws Exception { mServiceTracker = new ServiceTracker( context, EventAdmin.class.getName(), null); mServiceTracker.open(); mEventAdmin = (EventAdmin) mServiceTracker.getService(); postActivationEvent(context); } @Override public void stop(BundleContext context) throws Exception { postDeactivationEvent(context); } private void postActivationEvent(BundleContext context) { if (mEventAdmin != null) { //     Dictionary<String, Object> props = new Hashtable<String, Object>(); props.put("bundleName", mBundleName); props.put("bundleContext", context); props.put("activated", 1); mEventAdmin.postEvent( new Event("ru/futurelink/app/web/usecase/Activator", props)); } else { mLogger.error("Cannot get to EventAdmin service!"); } } private void postDeactivationEvent(BundleContext context) { if (mEventAdmin != null) { Dictionary<String, Object> props = new Hashtable<String, Object>(); props.put("bundleName", mBundleName); props.put("activated", 0); mEventAdmin.postEvent( new Event("ru/futurelink/app/web/usecase/Activator", props)); mServiceTracker.close(); } else { System.out.println("Cannot get to EventAdmin service!"); } } protected Dictionary<String, Object> getHandlerServiceProperties(String... topics) { Dictionary<String, Object> result = new Hashtable<String, Object>(); result.put(EventConstants.EVENT_TOPIC, topics); return result; } } 

यहां क्या हो रहा है? जब बंडल सक्रिय होता है, तो हमें एक EventAdmin सेवा ऑब्जेक्ट मिलता है, जिसे स्वाभाविक रूप से सिस्टम में लॉन्च किया जाना चाहिए। यदि यह नहीं चल रहा है, तो mEventAdmin == अशक्त। कार्य के तर्क पर अच्छी तरह से और आगे - हम अपने बंडल की शुरुआत और रोक के बारे में एक संदेश भेजते हैं।

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

वैसे, आपको यह भी ध्यान देना चाहिए कि बंडल का संदर्भ संदेश में भी प्रसारित किया गया है।

एक पृष्ठभूमि सेवा का कार्यान्वयन जो एक साथी के साथ संवाद कर सकता है और उसे उसकी स्थिति के बारे में EventAdmin के माध्यम से सूचित कर सकता है, जो ऊपर दी गई है, पहले से ही एक तुच्छ कार्य है।

मुझे इस विषय पर प्रश्न और परिवर्धन चाहिए ...;)