netty源代碼解析(2)——客戶端流程_第1頁(yè)
已閱讀1頁(yè)，還剩6頁(yè)未讀， 繼續(xù)免費(fèi)閱讀

下載本文檔

版權(quán)說(shuō)明：本文檔由用戶提供并上傳，收益歸屬內(nèi)容提供方，若內(nèi)容存在侵權(quán)，請(qǐng)進(jìn)行舉報(bào)或認(rèn)領(lǐng)

文檔簡(jiǎn)介

1、前一篇文章分析了ty的服務(wù)端流程，接下來(lái)分析一下客戶端的大致流程，客戶端啟動(dòng)代碼如下Java代碼代碼1.ClientBootstrapbootstrap=newClientBootstrap(newNioClientSocketChannelFacty(Executs.newCachedThreadPool()2.Executs.newCachedThreadPool()))3.4.bootstrap.setPipelineFacty(

2、newChannelPipelineFacty()5.6.@Override7.publicChannelPipelinegetPipeline()throwsException8.ChannelPipelinepipleline=pipeline()9.pipleline.addLast(“encode“newObjectEncoder(104857616))10.pipleline.addLast(“decode“newObject

3、Decoder(104857616ClassResolvers.weakCachingConcurrentResolver(null)))11.pipleline.addLast(“hler“hler)12.returnpipleline13.14.)15.16.bootstrap.setOption(“receiveBufferSize“104857664)17.bootstrap.setOption(“child.tcpNoDela

4、y“true)關(guān)閉Nagle算法18.tcp定期發(fā)送心跳包比如IM里邊定期探測(cè)對(duì)方是否下線19.只有tcp長(zhǎng)連接下才有意義20.bootstrap.setOption(“child.keepAlive“true)21.ChannelFuturefuture=bootstrap.connect(newISocketAddress(addresspt))22.Channelchannel=future.awaitUninterruptibl

5、y().getChannel()客戶端事件處理順序如下：UpStream.ChannelState.OPEN（已經(jīng)open）–DownStream.ChannelState.BOUND(需要綁定)——DownStream.CONNECTED(需要連接)—–UpStream.ChannelState.BOUND(已經(jīng)綁定)——UpStream.CONNECTED(連接成功)在connect的時(shí)候做了如下處理Java代碼代碼1.public

6、ChannelFutureconnect(finalSocketAddressremoteAddressfinalSocketAddresslocalAddress)2.3.if(remoteAddress==null)4.thrownewNullPointerException(“remoteAddress“)5.接下來(lái)要繼續(xù)connect了Java代碼代碼1.if(remoteAddress==null)2.thrownewNull

7、PointerException(“remoteAddress“)3.4.ChannelFuturefuture=future(channeltrue)5.channel.getPipeline().sendDownstream(newDownstreamChannelStateEvent(6.channelfutureChannelState.CONNECTEDremoteAddress))7.returnfuture這樣就會(huì)出發(fā)Do

8、wnstream的ChannelState.CONNECTED事件。接下來(lái)就要由NioClientSocketPipelineSink來(lái)進(jìn)行處理了Java代碼代碼1.switch(state)2.caseOPEN:3.if(Boolean.FALSE.equals(value))4.channel.wker.close(channelfuture)5.6.break7.caseBOUND:8.if(value!=null)9.bind(

9、channelfuture(SocketAddress)value)10.else11.channel.wker.close(channelfuture)12.13.break14.caseCONNECTED:15.if(value!=null)16.connect(channelfuture(SocketAddress)value)17.else18.channel.wker.close(channelfuture)19.20.bre

溫馨提示

  • 1. 本站所有資源如無(wú)特殊說(shuō)明，都需要本地電腦安裝OFFICE2007和PDF閱讀器。圖紙軟件為CAD,CAXA,PROE,UG,SolidWorks等.壓縮文件請(qǐng)下載最新的WinRAR軟件解壓。
  • 2. 本站的文檔不包含任何第三方提供的附件圖紙等，如果需要附件，請(qǐng)聯(lián)系上傳者。文件的所有權(quán)益歸上傳用戶所有。
  • 3. 本站RAR壓縮包中若帶圖紙，網(wǎng)頁(yè)內(nèi)容里面會(huì)有圖紙預(yù)覽，若沒(méi)有圖紙預(yù)覽就沒(méi)有圖紙。
  • 4. 未經(jīng)權(quán)益所有人同意不得將文件中的內(nèi)容挪作商業(yè)或盈利用途。
  • 5. 眾賞文庫(kù)僅提供信息存儲(chǔ)空間，僅對(duì)用戶上傳內(nèi)容的表現(xiàn)方式做保護(hù)處理，對(duì)用戶上傳分享的文檔內(nèi)容本身不做任何修改或編輯，并不能對(duì)任何下載內(nèi)容負(fù)責(zé)。
  • 6. 下載文件中如有侵權(quán)或不適當(dāng)內(nèi)容，請(qǐng)與我們聯(lián)系，我們立即糾正。
  • 7. 本站不保證下載資源的準(zhǔn)確性、安全性和完整性, 同時(shí)也不承擔(dān)用戶因使用這些下載資源對(duì)自己和他人造成任何形式的傷害或損失。

評(píng)論

0/150

提交評(píng)論