उच्च प्रदर्शन कैसे लिखें नेटी क्लाइंट

Question

मैं Google प्रोटोकॉल बफर संदेशों को भेजने के लिए एक बेहद कुशल टीसीपी क्लाइंट चाहता हूं। मैं सर्वर/क्लाइंट विकसित करने के लिए नेटटी लाइब्रेरी का उपयोग कर रहा हूं।

परीक्षणों में सर्वर प्रति सेकंड 500k लेनदेन को संभालने में सक्षम होता है, बिना किसी समस्या के, लेकिन ग्राहक प्रति सेकंड 180k लेन-देन की चोटी पर जाता है।

मैंने नेटटी दस्तावेज़ीकरण में दिए गए उदाहरणों पर अपने क्लाइंट को आधारित किया है, लेकिन अंतर यह है कि मैं सिर्फ संदेश भेजना चाहता हूं और भूलना चाहता हूं, मुझे कोई प्रतिक्रिया नहीं चाहिए (जो कि अधिकांश उदाहरण प्राप्त होते हैं)। क्या मेरे क्लाइंट को अनुकूलित करने के लिए वैसे भी है, ताकि मैं एक उच्च टीपीएस प्राप्त कर सकूं?

क्या मेरा ग्राहक एकाधिक चैनल बनाए रखता है, या क्या मुझे एक चैनल के साथ उच्च थ्रूपुट प्राप्त करने में सक्षम होना चाहिए?

Answer 1

1) यदि ग्राहक केवल भेजने, प्राप्त करने में नहीं में रुचि रखता है, तो आप हमेशा की तरह नीचे

channel.setReadable(false); 

2) आप प्रवाह क्षमता बढ़ा सकते हैं चैनल से पढ़ने बहुत आसानी से प्रति कई ग्राहक चैनलों होने से अक्षम कर सकते हैं ग्राहक, और यह भी स्केल कर सकते हैं।

3) और आप (पढ़ें/लिखें के लिए सामान्य रूप में प्रदर्शन में सुधार करने के लिए) में तोड़ मरोड़ निम्न कर सकते हैं

• इसके OrderdMemoryAwareThreadPoolExecutor के साथ एक EXecutionHandler, जोड़कर pipline की तरह एक SEDA के लिए बेहतर (न्यूनतम के साथ, इष्टतम मूल्य के साथ अधिकतम चैनल स्मृति)

  bootstrap.setPipelineFactory(new ChannelPipelineFactory() { 
      @Override 
      public ChannelPipeline getPipeline() throws Exception { 
       return Channels.pipeline(
         executionHandler1,//sharable 
         new MessageDecoderHandler(), 
         new MessageEncoderHandler(), 
         executionHandler2,//sharable 
         new BusinessLogicHandler1(), 
         new BusinessLogicHandler2()); 
      } 
  }); 
  

• इष्टतम मूल्य (करने के लिए चैनल की writeBufferHighWaterMark स्थापना सुनिश्चित करें कि एक बड़ा मान सेट भीड़ नहीं बनाएगा करें)

  bootstrap.setOption("writeBufferHighWaterMark", 10 * 64 * 1024);

• SO_READ, SO_WRITE बफर आकार

  bootstrap.setOption("sendBufferSize", 1048576); bootstrap.setOption("receiveBufferSize", 1048576);

• टीसीपी को सक्षम करने से कोई देरी स्थापना

  bootstrap.setOption("tcpNoDelay", true);

Answer 2

मैं अगर यकीन नहीं है "tcpNoDelay "सुधार करने में मदद करता है थ्रूपुट प्रदर्शन में सुधार करने के लिए देरी है। कोई भी कम नहीं, मैंने कोशिश की और देखा कि थ्रूपुट वास्तव में 90% से अधिक गिर गया है।