dubbo快速學(xué)習(xí)6-課件源代碼培訓(xùn)high performance remoting

協(xié)議、傳輸、線201241提SimpleRPC&DataHeader&IOModel&TCP&linux2 o(“hi,Public<T>TgetProxy(Class<T>interfaceClass,Stringhost,intpublicObjectinvoke(Objectproxy,Methodmethod,Object[]arguments)throwsThrowable{Socketsocket=newSocket(host,port);ObjectOutputStreamoutput=newObjectInputStreaminput=newreturninput.readObject();}} PublicString ServerSocketserver=newfinalSocketsocket=server.accept();newThread(newRunnable(){ObjectInputStreaminput=newStringmethodName=Object[]arguments=(Object[])input.readObject();ObjectOutputStreamoutput=new}客戶 服務(wù)3問(wèn)題在哪網(wǎng)絡(luò)傳輸方序列化方線程模型：每連接每線4三協(xié)傳線5Data6Data getProxyand

ReadFrom

Writeto

ReadFrom

Writeto7AppendDataDubboDataData Bit0-4Bit0-4-8-14-16-19-0TotalFragmentTimetoHeaderSourceIPOptions(ifHeaderLength>5BitBit0-4-8916-24-0DestinationWindowUrgentpointer(ifURGOptions(ifDataOffset>BitBit0-8-16-24-0MagicMagicSerialization32-Id96-data9DataPortUnification-Magic多協(xié)議支兼LongIdVSId同步轉(zhuǎn)異擴(kuò)展DataHeader同步轉(zhuǎn)異并行發(fā)起多個(gè)請(qǐng)求，但只使用一個(gè)線Future<Xxx>xxxFuture=Body幾個(gè)關(guān)鍵因Serialization Serialization壓縮壓縮Body服務(wù)調(diào)用時(shí)間主要消Dubbo序列化主要優(yōu)化目SerializationSpecialbasicMultiplexChunkOrderedvs.Contractvs.Self-Poisonvs.Self-

IO模模IO模IOTCP選IO模從內(nèi)核緩沖區(qū)拷貝到進(jìn)程緩異步BlockingI/ONon-BlockingI/OI/OMultiplexingSignal-DrivenI/OAsynchronous

IO模型之間的區(qū)NIO帶來(lái)了什NIOReactor模NIO網(wǎng)絡(luò)框架的典型模組EventloopMinaNetty都是此模式的實(shí)Reactor示意NIOTCP選SO_RCVBUF和MSS=MTU+40，一般以太網(wǎng)卡的MTU=1500字節(jié)。MSSMTU buffer和sendbuffer應(yīng)該同時(shí)增加帶寬延遲乘積——為了優(yōu)化TCP吞吐量（假設(shè)為合理的無(wú)差錯(cuò)邏輯管道的容量計(jì)BDP=帶寬xNagle Socket. net、服務(wù)調(diào)用),隔2個(gè)小中軟中Linux內(nèi)核優(yōu)化-Linux內(nèi)核開(kāi)啟RPS,小包處理提升使用LinuxKernel2.6.35開(kāi)啟該功能Dubbo的TPS提高RPSReceivePacketSteeringhashah中斷運(yùn)行的，cpuahcpu上線程模線程模型內(nèi)Reactor線程模序列化線業(yè)務(wù)線程派發(fā)策Reactor單線程模Reactor多線程模Reactor多線程模IO線程處理序列CodecCodec&donextinthread clear可以改進(jìn)業(yè)務(wù)線程處理

clear

ReaddataFrame donextinthreadpool

CodecReactor多線程模

線程派發(fā)策Connect(連接建立Disconnect(連接斷開(kāi)MessageReceived(消息已接受Sent(消息已發(fā)送ExceptionCaught(異常5個(gè)事件共享同一個(gè)線程Connectdisconnect使用獨(dú)立線程池(size為全部不派發(fā)線程池，IO線程處ThreadPool設(shè)置多少線程合充分利用cpu線程數(shù)量ThreadPool從CPU角度而線程數(shù)量的設(shè)置就是由CPU決定的ThreadPool線程數(shù)=(182508020*2線程數(shù)=(501828050*1/13ThreadPool公式線程數(shù)量=（線程總時(shí)間/瓶頸資源時(shí)間）*瓶頸資源的線程并行瓶頸資源的線程并行數(shù)=瓶頸資源的總份數(shù)/單次請(qǐng)求占用瓶頸資源的約束如果線程數(shù)不夠，則QPSS其他優(yōu)其他優(yōu)LockfreedataBuffercopy(ZeroJVMGC注意性能的短板效應(yīng)，避免過(guò)度