जावा नेटवर्क क्लाइंट डेवलपमेंट

कभी-कभी ऐसी परिस्थितियां होती हैं जब नेटवर्क इंटरैक्शन का उपयोग करना आवश्यक होता है, हालांकि, ब्याज के प्रोटोकॉल के लिए एक क्लाइंट मौजूद नहीं है, या इस क्लाइंट को भुगतान किया जाता है (मालिकाना), या यह पूरी तरह से अपना स्वयं का विकास है। इस लेख में, मैं वर्णन करूंगा कि नेटवर्किंग के लिए अपना खुद का क्लाइंट कैसे बनाया जाए। मैं इसके लिए आवश्यक सामान्य चरणों का वर्णन करूंगा।


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

<xsd:schema xmlns:xsd="http://www.w3.org/2001/XMLSchema" > <xsd:complexType name="FieldDescription"> <xsd:attribute name="name" type="xsd:string" /> <xsd:attribute name="defaultValue" type="xsd:string" /> </xsd:complexType> <xsd:complexType name="SequenceDescription"> <xsd:sequence> <xsd:element name="fieldDescription" type="FieldDescription" minOccurs="0" maxOccurs="unbounded" /> <xsd:element name="sequenceDescription" type="SequenceDescription" minOccurs="0" maxOccurs="unbounded" /> </xsd:sequence> <xsd:attribute name="sequenceName" type="xsd:string" /> </xsd:complexType> <xsd:complexType name="MessageDescription"> <xsd:sequence> <xsd:element name="sequenceDescription" type="SequenceDescription" minOccurs="0" maxOccurs="unbounded" /> <xsd:element name="fieldDescription" type="FieldDescription" minOccurs="0" maxOccurs="unbounded" /> </xsd:sequence> <xsd:attribute name="messageName" type="xsd:string" /> </xsd:complexType> <xsd:element name="DictionaryDescription"> <xsd:complexType> <xsd:sequence> <xsd:element name="messageDescription" type="MessageDescription" minOccurs="1" maxOccurs="unbounded" /> </xsd:sequence> </xsd:complexType> </xsd:element> </xsd:schema> 

उदाहरण के लिए, यह आरेख आपको संदेशों की जटिल, पदानुक्रमित संरचना का वर्णन करने की अनुमति देता है। अब आपको यह समझने की जरूरत है कि संदेश क्या है। संक्षेप में, यह खेतों और उनके अर्थों का मानचित्र है। निम्नलिखित संदेश इंटरफ़ेस की घोषणा करें:

 public interface IMessage { /** * Add field to message * @param name name of field (not null) * @param value value of field */ void addField(final String name, final Object value); /** * Remove field from message * @param name name of field (not null) */ void removeField(final String name); /** * Get message field by name * @param name name of field (not null) * @return value of field */ Object getField(final String name); /** * Check that field is set * @param name field name * @return true if field set, else false */ boolean isFieldSet(final String name); /** * Get set of message fields * @return set of message fields */ Set<String> getFieldNames(); /** * Get copy of message * @return new IMessage with copied fields */ IMessage cloneMessage(); /** * Compare messages by fields * @param message message for comparing * @return true/false */ boolean compare(final IMessage message); } 

इसके सभी तरीकों को लागू करते हुए, हमें एक वर्ग मिलता है जिसका उपयोग हम अपने कोड में संदेशों को प्राप्त करने और भेजने के लिए करेंगे। लेकिन जैसा कि आपने शायद देखा, यह उस संरचना से बहुत दूर है जिसे हमने सर्किट में रखा था, इसलिए हमें एक एनकोडर / डिकोडर की आवश्यकता है।

 public interface ICodec { /** * Encode list of IMessage to byte array * @param messages input messages * @return array of byte */ byte[] encode(List<IMessage> messages); /** * Decode array of byte to list of IMessage * @param bytes input array * @return list of IMessage */ List<IMessage> decode(byte[] bytes); } 

इस इंटरफ़ेस के अंतिम कार्यान्वयन को कंस्ट्रक्टर में IDEDIA इंटरफ़ेस का उदाहरण प्राप्त करना चाहिए, जिसका कार्य योजना के अनुसार संरचना को XML से स्कीम के अनुसार बनाई गई कक्षाओं के उदाहरणों में पढ़ना है। निम्नलिखित कोड स्निपेट को ऐसा करने के लिए चींटी में डालने की आवश्यकता है। यह स्निपेट jaxb का उपयोग करके योजना के अनुसार कक्षाएं बनाने के कार्य को परिभाषित करता है।

 <path id="jaxbcp"> <pathelement location="libs/jaxblibs/jaxb-api.jar" /> <pathelement location="libs/jaxblibs/jaxb-impl.jar" /> <pathelement location="libs/jaxblibs/jaxb-xjc.jar" /> <pathelement location="libs/jaxblibs/jsr173_1.0_api.jar" /> </path> <taskdef name="xjc" classname="com.sun.tools.xjc.XJCTask" classpathref="jaxbcp" / <xjc schema="xsd/schema.xsd" destdir="${gen.dir}" package="your.package.name"> <produces dir="${gen.dir}" includes="*" /> </xjc> 

हम निम्नलिखित कोड का उपयोग करके xml शब्दकोश पढ़ते हैं:

 try { jc = JAXBContext.newInstance(new Class[]{DictionaryDescription.class}); u = jc.createUnmarshaller(); File f = new File (path); JAXBElement<DictionaryDescription> root = u.unmarshal(new StreamSource(f), DictionaryDescription.class); DictionaryDescription s = root.getValue(); } catch (JAXBException e) { logger.error("Error during parsing dictionary", e); } 

अब सब कुछ तैयार है, ग्राहक को छोड़कर। आइए इसके लिए एक इंटरफ़ेस बनाएं।

 interface Client { void init(Map parameters); void connect(); void disconnect(); void sendMessage(IMessage msg); void addReceiveListener(IReceiveListener listener); void removeReceiveListener(IReceiveListener listener); } 

प्राप्त संदेशों को संसाधित करने के लिए ग्राहक / पर्यवेक्षक पैटर्न लागू करें। IReceiveListener का सब्सक्राइबर इंटरफ़ेस होगा। OnMessageReceived पद्धति में एक संदेश हैंडलर होगा। इस इंटरफ़ेस का उपयोग करके, आप ग्राहकों की एक विस्तृत श्रृंखला को लागू कर सकते हैं। उदाहरण के लिए: एक प्रॉक्सी (पुनर्निर्देशक), एक फ़ाइल / डेटाबेस / मेमोरी में बचत, एक सिम्युलेटर लागू करें जो स्वचालित रूप से आने वाले संदेशों का जवाब देगा।

 public interface WMQReceiveListener { /** * Handler of message * @param message message */ public void onMessageReceived(byte[] message); } 

यह सब, इसकी कनेक्टिविटी परत का कंकाल बनाया गया है। फिर आप इसे अपने सभी व्यावसायिक तर्क को लागू करने के लिए बना सकते हैं।