एक बार एक समय में, दूर तक ... परियोजना, मुझे नेट्टी पर http- request के प्रसंस्करण करने की आवश्यकता थी। दुर्भाग्यवश, Netty में http अनुरोधों की मैपिंग के लिए कोई मानक सुविधाजनक तंत्र नहीं थे (और यह ढांचा उसके लिए बिल्कुल भी नहीं है), इसलिए, हमारे स्वयं के तंत्र को लागू करने का निर्णय लिया गया।

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

नेट्टी उच्च-प्रदर्शन नेटवर्क अनुप्रयोगों को विकसित करने के लिए एक रूपरेखा है। आप प्रोजेक्ट वेबसाइट पर इसके बारे में अधिक पढ़ सकते हैं।
नेट्टी सॉकेट सर्वर बनाने के लिए बहुत सुविधाजनक कार्यक्षमता प्रदान करता है, लेकिन मेरी राय में, यह कार्यक्षमता REST सर्वर बनाने के लिए बहुत सुविधाजनक नहीं है।

मानक नेट्टी इंजन का उपयोग करके प्रसंस्करण का अनुरोध करें

channelRead में अनुरोधों को संसाधित करने के लिए , आपको channelRead वर्ग से इनहेरिट करना होगा और channelRead मेथड को ओवरराइड करना channelRead ।

 public class HttpMappingHandler extends ChannelInboundHandlerAdapter { @Override public void channelRead(ChannelHandlerContext ctx, Object msg) { } } 

Http अनुरोधों को संसाधित करने के लिए आवश्यक जानकारी प्राप्त करने के लिए, msg ऑब्जेक्ट को HttpRequest डाला जा सकता है।

 HttpRequest request = (HttpRequest) msg; 

उसके बाद, आप इस अनुरोध से कोई भी जानकारी प्राप्त कर सकते हैं। उदाहरण के लिए, अनुरोध का URL।

 String uri = request.uri(); 

अनुरोध का प्रकार।

 HttpMethod httpMethod = request.method(); 

और सामग्री।

 ByteBuf byteBuf = ((HttpContent) request).content(); 

उदाहरण के लिए, सामग्री POST अनुरोध के मुख्य भाग में पारित हो सकती है। ByteBuf , Netty लाइब्रेरी से एक वर्ग है, इसलिए json parsers के साथ काम करने की संभावना नहीं है, लेकिन इसे बहुत आसानी से एक स्ट्रिंग में डाला जा सकता है।

 String content = byteBuf.toString(StandardCharsets.UTF_8); 

यह, सामान्य तौर पर, सभी है। उपरोक्त विधियों का उपयोग करके, आप http अनुरोधों को संसाधित कर सकते हैं। सच है, सब कुछ एक जगह में संसाधित करना होगा, अर्थात् channelRead विधि में। भले ही हम विभिन्न तरीकों और वर्गों में प्रसंस्करण अनुरोधों के तर्क को अलग करते हैं, फिर भी आपको URL को इन तरीकों से कहीं एक जगह पर मैप करना होगा।

मानचित्रण का अनुरोध करें

ठीक है, जैसा कि आप देख सकते हैं, मानक नेट्टी कार्यक्षमता का उपयोग करके http- अनुरोधों के मानचित्रण को लागू करना संभव है। सच है, यह बहुत सुविधाजनक नहीं होगा। मैं किसी तरह http-रिक्वेस्ट की प्रोसेसिंग को अलग-अलग तरीकों से पूरी तरह से अलग करना चाहूंगा (उदाहरण के लिए, जैसा कि स्प्रिंग में किया गया है)। प्रतिबिंब की मदद से, एक समान दृष्टिकोण को लागू करने का प्रयास किया गया था। अंक पुस्तकालय इससे निकला । इसका सोर्स कोड यहां पाया जा सकता है ।
संख्या पुस्तकालय का उपयोग करके अनुरोध मैपिंग का उपयोग करने के लिए, यह AbstractHttpMappingHandler वर्ग से वारिस करने के लिए पर्याप्त है, जिसके बाद आप इस कक्षा में अनुरोध हैंडलर विधि बना सकते हैं। इन विधियों के लिए मुख्य आवश्यकता यह है कि वे FullHttpResponse या उसके वंशज को FullHttpResponse । आप यह दिखा सकते हैं कि इस अनुरोध को क्या एनोटेशन का उपयोग करके http अनुरोध किया जाएगा:

• @Get
• @Post
• @Put
• @Delete

एनोटेशन नाम इंगित करता है कि किस प्रकार का अनुरोध कहा जाएगा। चार प्रकार के अनुरोधों का समर्थन किया जाता है: GET , POST , PUT और DELETE । एनोटेशन में value पैरामीटर के रूप में, आपको URL निर्दिष्ट करना होगा, जब एक्सेस किया जाता है, तो वांछित विधि को बुलाया जाएगा।

GET हैंडलर कैसा दिखता है, इसका एक उदाहरण, जो स्ट्रिंग लौटाता है Hello, world! ।

 public class HelloHttpHandler extends AbstractHttpMappingHandler { @Get("/test/get") public DefaultFullHttpResponse test() { return new DefaultFullHttpResponse(HttpVersion.HTTP_1_1, OK, Unpooled.copiedBuffer("Hello, world!", StandardCharsets.UTF_8)); } } 

अनुरोध पैरामीटर

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

• @PathParam
• @QueryParam
• @RequestBody

@PathParam

पथ पैरामीटर को पास करने के लिए, @PathParam एनोटेशन का @PathParam । एनोटेशन के value पैरामीटर के रूप में इसका उपयोग करते समय, आपको पैरामीटर नाम निर्दिष्ट करना होगा। इसके अलावा, अनुरोध URL में पैरामीटर नाम भी निर्दिष्ट होना चाहिए।

GET हैंडलर किस तरह से id पथ पैरामीटर पारित किया जाता है और कौन सा पैरामीटर लौटाता है, इसका एक उदाहरण।

 public class HelloHttpHandler extends AbstractHttpMappingHandler { @Get("/test/get/{id}") public DefaultFullHttpResponse test(@PathParam(value = "id") int id) { return new DefaultFullHttpResponse(HttpVersion.HTTP_1_1, OK, Unpooled.copiedBuffer(id, StandardCharsets.UTF_8)); } } 

@QueryParam

क्वेरी पैरामीटर पास करने के लिए, @QueryParam एनोटेशन का @QueryParam । एनोटेशन के value पैरामीटर के रूप में इसका उपयोग करते समय, आपको पैरामीटर नाम निर्दिष्ट करना होगा। पैरामीटर एनोटेशन को required एनोटेशन पैरामीटर का उपयोग करके नियंत्रित किया जा सकता है।

GET हैंडलर कैसा दिखेगा, इसका एक उदाहरण, जिससे क्वेरी पैरामीटर message पास हो जाता है और जो इस पैरामीटर को वापस करता है।

 public class HelloHttpHandler extends AbstractHttpMappingHandler { @Get("/test/get") public DefaultFullHttpResponse test(@QueryParam(value = "message") String message) { return new DefaultFullHttpResponse(HttpVersion.HTTP_1_1, OK, Unpooled.copiedBuffer(message, StandardCharsets.UTF_8)); } } 

@RequestBody

POST अनुरोधों के मुख्य भाग को प्रेषित करने के लिए, @RequestBody एनोटेशन का @RequestBody । इसलिए, इसे केवल POST अनुरोधों में उपयोग करने की अनुमति है। यह माना जाता है कि json प्रारूप डेटा अनुरोध निकाय के रूप में प्रेषित किया जाएगा। इसलिए, JsonParser उपयोग करने के लिए, हैंडलर क्लास कंस्ट्रक्टर को JsonParser इंटरफ़ेस कार्यान्वयन पास करना आवश्यक है, जो अनुरोध निकाय के डेटा पार्स करने में लगे होंगे। इसके अलावा, लाइब्रेरी में पहले से ही JsonParserDefault का डिफ़ॉल्ट कार्यान्वयन है। यह कार्यान्वयन jackson को पार्सर के रूप में उपयोग करता है।

POST अनुरोध हैंडलर कैसा होगा, इसका एक उदाहरण एक अनुरोध निकाय है।

 public class HelloHttpHandler extends AbstractHttpMappingHandler { @Post("/test/post") public DefaultFullHttpResponse test(@RequestBody Message message) { return new DefaultFullHttpResponse(HttpVersion.HTTP_1_1, OK, Unpooled.copiedBuffer("{id: '" + message.getId() +"', msg: '" + message.getMessage() + "'}", StandardCharsets.UTF_8)); } } 

Message वर्ग इस प्रकार है।

 public class Message { private int id; private String message; public Message() { } public int getId() { return id; } public void setId(int id) { this.id = id; } public String getMessage() { return message; } public void setMessage(String message) { this.message = message; } } 

हैंडलिंग में त्रुटि

यदि अनुरोधों के प्रसंस्करण के दौरान कोई Exception होता है और इसे हैंडलर विधियों के कोड में इंटरसेप्ट नहीं किया जाता है, तो 500 वें कोड के साथ उत्तर वापस आ जाएगा। त्रुटि से निपटने के लिए कुछ तर्क लिखने के लिए, यह हैंडलर वर्ग में exceptionCaught विधि को फिर से परिभाषित करने के लिए पर्याप्त है।

 public class HelloHttpHandler extends AbstractHttpMappingHandler { @Override public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception { super.exceptionCaught(ctx, cause); ctx.writeAndFlush(new DefaultFullHttpResponse(HttpVersion.HTTP_1_1, HttpResponseStatus.INTERNAL_SERVER_ERROR)); } } 

निष्कर्ष

यह, सामान्य तौर पर, सभी है। मुझे उम्मीद है कि यह दिलचस्प था और किसी के लिए उपयोगी होगा।

संख्या पुस्तकालय का उपयोग करके नेटी http http उदाहरण कोड यहाँ उपलब्ध है ।