🤸🏽 👶🏼 👎🏼 Apache MINA के साथ एक सरल सर्वर बनाना 🏴󠁧󠁢󠁳󠁣󠁴󠁿 🐙 🎒

Apache MINA जावा में क्लाइंट-सर्वर एप्लिकेशन लिखने के लिए एक ओपन सोर्स लाइब्रेरी है। नवीनतम संस्करण - 2.0.4 - 14 जून, 2011 को जारी किया गया था।

इस लेख में, मैं इस लाइब्रेरी का उपयोग करके एक सरल सर्वर बनाने की प्रक्रिया का वर्णन करूंगा।

हम क्या लिख रहे हैं?

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

तो चलिए शुरू करते हैं।

परियोजना के लिए कनेक्शन

मुख्य मीना-कोर लाइब्रेरी के अलावा, आपको slf4j (जावा के लिए सिंपल लॉगिंग फैकेड) लाइब्रेरी को भी कनेक्ट करने की आवश्यकता है, जिसे MINA विभिन्न लॉगिंग सिस्टम के इंटरफ़ेस के रूप में उपयोग करता है, उदाहरण के लिए, Apache log4j। कनेक्ट को slf4j-api और लॉगिंग कार्यान्वयन में से एक की आवश्यकता होती है। हमारे उदाहरण में, लॉगिंग का उपयोग नहीं किया जाएगा, और इसलिए, आप slf4j-nop का उपयोग कर सकते हैं।

एंट्री पॉइंट और IoAcceptor

मुख्य अनुप्रयोग विधि में, हमें एक IoAceptor - एक ऑब्जेक्ट बनाने और कॉन्फ़िगर करने की आवश्यकता होगी जो आने वाले कनेक्शनों को स्वीकार करेगा। हमें इसके निम्नलिखित तरीकों की आवश्यकता होगी ( IoAcceptor IoService इंटरफ़ेस का विस्तार करता है और इसमें कुछ तरीके घोषित किए गए हैं):

```
DefaultIoFilterChainBuilder getFilterChain() 
```
- तथाकथित "फ़िल्टर श्रृंखला" लौटाता है;
```
 void setHandler(IoHandler handler) 
```
- हैंडलर सेट करता है - वह वस्तु जिसमें सर्वर का मुख्य तर्क स्थित है;
```
 void bind(SocketAddress localAddress) 
```
- निर्दिष्ट पते पर सुनना शुरू करता है।

हमारे उदाहरण के लिए, NioSocketAcceptor , जो कि TCP / IP के लिए IoAceptor का कार्यान्वयन है, उपयुक्त है ।

फ़िल्टर श्रृंखला और प्रोटोकॉल

हैंडलर में जाने से पहले, सभी घटनाओं (एक कनेक्शन को स्वीकार करना, डेटा प्राप्त करना, आदि) तथाकथित "फिल्टर श्रृंखला" के माध्यम से जाते हैं। फ़िल्टर किसी भी क्रिया को कर सकते हैं जो हैंडलर में हो सकती है, लेकिन वहां बहुत उपयुक्त नहीं है - लॉगिंग, आदि।

अलग से विचार करने लायक फिल्टर में से एक प्रोटोकॉलकोडेकफिल्टर है । इस फ़िल्टर का उद्देश्य ट्रांसमिशन के दौरान बाइट्स के अनुक्रम के लिए एक निश्चित ऑब्जेक्ट से डेटा को परिवर्तित करना है और रिसेप्शन पर बाइट्स के अनुक्रम से एक सजाया वस्तु है। फ़िल्टर निर्माणकर्ताओं में से एक इस तरह दिखता है:

 ProtocolCodecFilter(ProtocolCodecFactory factory)

इस लेख में मैं अपने स्वयं के "कारखाने", मेरे प्रोटोकॉल के निर्माण पर स्पर्श नहीं करूँगा, हमारे उदाहरण के लिए MINA में सबसे सरल और पहले से लागू किए गए प्रोटोकॉल में से एक उपयुक्त है - TextLine ("factory" - TextLineCodecFactory ), जो बाइट्स के एक क्रम को स्ट्रिंग ( स्ट्रिंग ) और इसके विपरीत में परिवर्तित करता है। । इसके अलावा, जब स्ट्रिंग को भेजा जाता है, तो लाइन टर्मिनेटर को जोड़ दिया जाएगा, और प्राप्त होने पर, लाइन को "फिल्टर चेन" या हैंडलर के साथ ही प्रेषित किया जाएगा जब एक ही लाइन टर्मिनेटर प्राप्त होता है। एन्कोडिंग और लाइन वर्ण का अंत कंस्ट्रक्टर में निर्दिष्ट किया जा सकता है:

 TextLineCodecFactory(Charset charset, String encodingDelimiter, String decodingDelimiter)

इस प्रकार, हैंडलर को हमारे मामले में, स्ट्रिंग्स ( स्ट्रिंग ) में, सजाने वाली वस्तुओं से निपटना होगा।

DefaultIoFilterChainBuilder वस्तु में फिल्टर जोड़ने के कई तरीके हैं, लेकिन हमें केवल एक की आवश्यकता है:

 void addLast(String name, IoFilter filter)

यह विधि श्रृंखला के अंत में एक फिल्टर जोड़ती है।

तो अब हम मुख्य विधि लिख सकते हैं:

 public static void main(String[] args) throws IOException { IoAcceptor acceptor = new NioSocketAcceptor(); acceptor.getFilterChain().addLast("codec", new ProtocolCodecFilter(new TextLineCodecFactory(Charset.defaultCharset(), System.lineSeparator(), System.lineSeparator()))); acceptor.setHandler(new MyMinaServerHandler()); acceptor.bind(new InetSocketAddress(12345)); }

हैंडलर, IoHandler और IoSession

एक हैंडलर IoHandler इंटरफ़ेस का कार्यान्वयन है जिसमें निम्नलिखित विधियाँ शामिल हैं:

```
 void sessionCreated(IoSession session) 
```
- जब एक कनेक्शन स्वीकार किया जाता है;
```
 void sessionOpened(IoSession session) 
```
- सत्र के बाद बुलाया;
```
 void sessionClosed(IoSession session) 
```
- कनेक्शन बंद होने पर बुलाया जाता है;
```
 void sessionIdle(IoSession session, IdleStatus status) 
```
- कहा जाता है जब निष्क्रिय (टाइमआउट द्वारा);
```
 void messageReceived(IoSession session, Object message) 
```
- डेटा प्राप्त होने पर बुलाया;
```
 void messageSent(IoSession session, Object message) 
```
- डेटा भेजते समय कॉल किया जाता है;
```
 void exceptionCaught(IoSession session, Throwable cause) 
```
- अपवाद होने पर बुलाया जाता है।

हमारे उदाहरण में, यह केवल उनमें से एक जोड़े को लागू करने के लिए पर्याप्त है - sessionOpened और messageReceived , इसलिए इंटरफ़ेस को सीधे लागू करने के बजाय, हम IoHandlerAdapter वर्ग का विस्तार कर सकते हैं, जो इंटरफ़ेस का एक खाली कार्यान्वयन है, और हमें उन तरीकों को ओवरराइड करना चाहिए जिनकी हमें ज़रूरत है।

IoSession ऑब्जेक्ट एक सत्र प्रतिनिधित्व है (यह एक कनेक्शन भी है)। हमें इसके कुछ तरीकों की आवश्यकता होगी:

```
 WriteFuture write(Object message) 
```
- डेटा भेजता है;
```
 CloseFuture close(boolean immediately) 
```
- कनेक्शन बंद कर देता है। यदि तुरंत - गलत है, तो सभी डेटा भेजे जाने के बाद ही कनेक्शन बंद हो जाएगा।

IoSession हमें कनेक्शन से संबंधित डेटा को स्टोर करने की भी अनुमति देता है, और हम कनेक्शन के समय को बचाने के लिए इस अवसर का उपयोग करेंगे। ऐसा करने के लिए, हम दो तरीकों का उपयोग करेंगे:

 Object setAttribute(Object key, Object value)

```
 Object getAttribute(Object key) 
```

तो, अब हम एक हैंडलर लिख सकते हैं:

 public class MyMinaServerHandler extends IoHandlerAdapter { public void sessionOpened(IoSession session) { session.setAttribute("time", System.currentTimeMillis()); session.write("Hello!"); } public void messageReceived(IoSession session, Object message) { switch (((String) message).trim()) { case "time": session.write(String.format("You connected %d seconds ago", (System.currentTimeMillis() - (Long) session.getAttribute("time")) / 1000)); break; case "q": session.write("Bye!"); session.close(false); break; } } }

वह सब

हौसले से इकट्ठे सर्वर को चलाएं और कमांड लाइन या टर्मिनल पर लिखें:

 telnet localhost 12345

सर्वर आदेशों का जवाब देता है:

 Trying 127.0.0.1... Connected to localhost. Escape character is '^]'. Hello! time You connected 11 seconds ago q Bye! Connection closed by foreign host.

पूर्ण स्रोत कोड यहां डाउनलोड किया जा सकता है ।
पढ़ने के लिए धन्यवाद!

Apache MINA के साथ एक सरल सर्वर बनाना