🛫 🧑🏼 🧙🏻 जावा NIO में उच्च प्रदर्शन SUN / ONCRPC सर्वर 🕑 🏈 ✝️

DCache लेख चर्चा करता है कि इसे NFS सर्वर के रूप में कैसे उपयोग किया जाए। लेकिन मौजूदा ग्राहकों के साथ इंटरऑपरेबिलिटी सिस्टम का उपयोग करने के लिए पर्याप्त नहीं है। प्रदर्शन भी शीर्ष पर होना चाहिए। NFS प्रोटोकॉल का वर्कहॉर्स ONCRPC प्रोटोकॉल है। DCache में, हम grizzly nio ढांचे के आधार पर अपने स्वयं के कार्यान्वयन का उपयोग करते हैं।

युवा के लिए थोड़ा इतिहास

ONC RPC (ओपन नेटवर्क कम्प्यूटिंग रिमोट प्रोसिजर कॉल) सन माइक्रोसिस्टम्स द्वारा 80 के दशक के अंत में और NFSv2 के साथ 1995 में प्रकाशित एक प्रोटोकॉल है। ONCRPC ने तेजी से वितरण प्राप्त किया और व्यापक रूप से 2000 की शुरुआत तक इसका उपयोग किया गया, जिसे CORBA, SOAP, और बाद में REST और JSON-RPC जैसे फैशनेबल विकल्पों द्वारा दबा दिया गया। हालांकि, अभी भी ONCRPC का उपयोग किया जाता है, जहां सादगी और गति फैशन की तुलना में अधिक महत्वपूर्ण है - नेटवर्क फाइल सिस्टम में।

कार्यान्वयन

दूसरी बाइक का आविष्कार न करने के लिए, सबसे पहले हमने रिमोट टी के कार्यान्वयन का उपयोग किया, लेकिन जल्द ही हम ऐसी सीमाओं का सामना करने लगे जिन्हें आसानी से हल नहीं किया जा सकता था: आईपीवी 6, जीएसएसएपीआई, एनआईओ। इसलिए बाइक का आविष्कार करना था, लेकिन खरोंच से नहीं। हमने रिमोटटी के साथ संगतता को अधिकतम रखा और पहले से लिखे गए कोड को अनुकूलित किया।

ग्रिजली-NIO

असल में, हमने ग्रिज़ली-एनआईओ लिया, जिसका इस्तेमाल ग्लासफिश में किया गया था। सभी आधुनिक एनआईओ फ्रेमवर्क की तरह, ग्रिजली ईवेंट हैंडलिंग और कमांड टेम्प्लेट की एक श्रृंखला पर आधारित है। यही है, हम उन फिल्टर की एक श्रृंखला का वर्णन करते हैं जिन्हें एक निश्चित घटना पर कहा जाता है।

package org.glassfish.grizzly.filterchain; import java.io.IOException; public interface Filter { public void onAdded(FilterChain fc); public void onRemoved(FilterChain fc); public void onFilterChainChanged(FilterChain fc); public NextAction handleRead(FilterChainContext fcc) throws IOException; public NextAction handleWrite(FilterChainContext fcc) throws IOException; public NextAction handleConnect(FilterChainContext fcc) throws IOException; public NextAction handleAccept(FilterChainContext fcc) throws IOException; public NextAction handleEvent(FilterChainContext fcc, FilterChainEvent fce) throws IOException; public NextAction handleClose(FilterChainContext fcc) throws IOException; public void exceptionOccurred(FilterChainContext fcc, Throwable thrwbl); }

हैंडलएक्सएएनएक्सएक्स के तरीके नेक्स्टएक्शन को वापस करते हैं, जो स्टॉपएशन या कंटिन्यूएशन हो सकता है। यदि फ़िल्टर StopAction देता है, तो चेन प्रोसेसिंग बंद हो जाती है। हम मुख्य रूप से handleRead और handleWrite में रुचि रखते हैं, जो नेटवर्क कनेक्शन को पढ़ते और लिखते समय आह्वान किया जाता है।

  @Override public NextAction handleRead(FilterChainContext ctx) throws IOException { Buffer messageBuffer = ctx.getMessage(); if (!isMessageArrived(messageBuffer)) { //     //    return ctx.getStopAction(messageBuffer); } //    ctx.setMessage(getMessage(messageBuffer)); return ctx.getInvokeAction(); }

लड़ाई कोड

 import java.io.IOException; import java.nio.ByteOrder; import org.glassfish.grizzly.Buffer; import org.glassfish.grizzly.filterchain.BaseFilter; import org.glassfish.grizzly.filterchain.FilterChainContext; import org.glassfish.grizzly.filterchain.NextAction; import org.glassfish.grizzly.memory.BuffersBuffer; public class RpcMessageParserTCP extends BaseFilter { /** * RPC fragment record marker mask */ private final static int RPC_LAST_FRAG = 0x80000000; /** * RPC fragment size mask */ private final static int RPC_SIZE_MASK = 0x7fffffff; @Override public NextAction handleRead(FilterChainContext ctx) throws IOException { Buffer messageBuffer = ctx.getMessage(); if (messageBuffer == null) { return ctx.getStopAction(); } if (!isAllFragmentsArrived(messageBuffer)) { return ctx.getStopAction(messageBuffer); } ctx.setMessage(assembleXdr(messageBuffer)); final Buffer reminder = messageBuffer.hasRemaining() ? messageBuffer.split(messageBuffer.position()) : null; return ctx.getInvokeAction(reminder); } @Override public NextAction handleWrite(FilterChainContext ctx) throws IOException { Buffer b = ctx.getMessage(); int len = b.remaining() | RPC_LAST_FRAG; Buffer marker = GrizzlyMemoryManager.allocate(4); marker.order(ByteOrder.BIG_ENDIAN); marker.putInt(len); marker.flip(); marker.allowBufferDispose(true); b.allowBufferDispose(true); Buffer composite = GrizzlyMemoryManager.createComposite(marker, b); composite.allowBufferDispose(true); ctx.setMessage(composite); return ctx.getInvokeAction(); } private boolean isAllFragmentsArrived(Buffer messageBuffer) throws IOException { final Buffer buffer = messageBuffer.duplicate(); buffer.order(ByteOrder.BIG_ENDIAN); while (buffer.remaining() >= 4) { int messageMarker = buffer.getInt(); int size = getMessageSize(messageMarker); /* * fragmen size bigger than we have received */ if (size > buffer.remaining()) { return false; } /* * complete fragment received */ if (isLastFragment(messageMarker)) { return true; } /* * seek to the end of the current fragment */ buffer.position(buffer.position() + size); } return false; } private static int getMessageSize(int marker) { return marker & RPC_SIZE_MASK; } private static boolean isLastFragment(int marker) { return (marker & RPC_LAST_FRAG) != 0; } private Xdr assembleXdr(Buffer messageBuffer) { Buffer currentFragment; BuffersBuffer multipleFragments = null; boolean messageComplete; do { int messageMarker = messageBuffer.getInt(); int size = getMessageSize(messageMarker); messageComplete = isLastFragment(messageMarker); int pos = messageBuffer.position(); currentFragment = messageBuffer.slice(pos, pos + size); currentFragment.limit(size); messageBuffer.position(pos + size); if (!messageComplete & multipleFragments == null) { /* * we use composite buffer only if required * as they not for free. */ multipleFragments = GrizzlyMemoryManager.create(); } if (multipleFragments != null) { multipleFragments.append(currentFragment); } } while (!messageComplete); return new Xdr(multipleFragments == null ? currentFragment : multipleFragments); } }

यदि हम डेटा की कमी के कारण श्रृंखला को रोकते हैं, तो हैंडल को अगली कॉल में एक समग्र बफर (कई बफ़र्स से मिलकर) होगा।

आदिम सर्वर ऐसा दिखता है

  public static void main(String[] args) throws IOException { FilterChainBuilder filterChainBuilder = FilterChainBuilder.stateless(); filterChainBuilder.add(new TransportFilter()); filterChainBuilder.add(new /*   */); filterChainBuilder.add(new /*   */); final TCPNIOTransport transport = TCPNIOTransportBuilder.newInstance().build(); transport.setProcessor(filterChainBuilder.build()); transport.bind(HOST, PORT); transport.start(); System.in.read(); }

प्रोजेक्ट पृष्ठ पर आप कई उदाहरण पा सकते हैं। डिफ़ॉल्ट रूप से, ग्रिज़ली मशीन पर प्रोसेसर के रूप में कई थ्रेड्स बनाएंगे। इस दृष्टिकोण ने व्यवहार में खुद को साबित कर दिया है। 24 कोर वाली मशीन पर, हमारा एनएफएस सर्वर आसानी से लगभग एक हजार ग्राहकों को सेवा प्रदान करता है।

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

oncrpc4j

सभी ONCRPC कोड को एक आसान-से-अलग-अलग लाइब्रेरी के रूप में डिज़ाइन किया गया है। दो विशिष्ट एकीकरण विकल्प समर्थित हैं - एक सेवा जिसे एप्लिकेशन में बनाया गया है या स्प्रिंग बीन के रूप में आरंभिक सेवा।

एंबेडेड आवेदन

 import org.dcache.xdr.RpcDispatchable; import org.dcache.xdr.RpcCall; import org.dcache.xdr.XdrVoid; import org.dcache.xdr.OncRpcException; public class Svcd { private static final int DEFAULT_PORT = 1717; private static final int PROG_NUMBER = 111017; private static final int PROG_VERS = 1; public static void main(String[] args) throws Exception { RpcDispatchable dummy = new RpcDispatchable() { @Override public void dispatchOncRpcCall(RpcCall call) throws OncRpcException, IOException { call.reply(XdrVoid.XDR_VOID); } }; OncRpcSvc service = new OncRpcSvcBuilder() .withTCP() .withAutoPublish() .withPort(DEFAULT_PORT) .withSameThreadIoStrategy() .build(); service.register(new OncRpcProgram(PROG_NUMBER, PROG_VERS), dummy); service.start(); } }

वसंत एकता

मैं XML से नहीं डरता

 <?xml version="1.0" encoding="UTF-8"?> <beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-2.5.xsd"> <bean id="my-rpc-svc" class="me.mypackage.Svcd"> <description>My RPC service</description> </bean> <bean id="my-rpc" class="org.dcache.xdr.OncRpcProgram"> <description>My RPC program number</description> <constructor-arg index="0" value="1110001" /> <constructor-arg index="1" value="1" /> </bean> <bean id="rpcsvc-builder" class="org.dcache.xdr.OncRpcSvcFactoryBean"> <description>Onc RPC service builder</description> <property name="port" value="1717"/> <property name="useTCP" value="true"/> </bean> <bean id="oncrpcsvc" class="org.dcache.xdr.OncRpcSvc" init-method="start" destroy-method="stop"> <description>My RPC service</description> <constructor-arg ref="rpcsvc-builder"/> <property name="programs"> <map> <entry key-ref="my-rpc" value-ref="my-rpc-svc"/> </map> </property> </bean> </beans>

उत्पादकता

जैसा कि आप ग्राफ से देख सकते हैं, जावा में कोड न केवल 'सी' में लिखा गया है, बल्कि लिनक्स कर्नेल से भी आगे निकल जाता है (एक बग के कारण, मुझे आशा है कि, पहले से ही तय हो गया है)।

कोड चोरी और योगदान करने के लिए

कोड LGPL लाइसेंस के तहत जीथब पर उपलब्ध है।

जावा NIO में उच्च प्रदर्शन SUN / ONCRPC सर्वर