javanio處理長(zhǎng)連接

1、JavaNIO處理長(zhǎng)連接處理長(zhǎng)連接最近恰好要寫一個(gè)處理長(zhǎng)連接的服務(wù)，接收日志包，然后打包成syslog形式再轉(zhuǎn)發(fā)，所以在它的基礎(chǔ)上改了一下。主要改了兩個(gè)類，一個(gè)是Server，因?yàn)槲覀冎魂P(guān)注read事件，所以write事件我們暫不處理。另外，在處理完ON_READ事件后，不能執(zhí)行key.cancel()。Java代碼1.packagenioserver2.3.impt.ISocketAddress4.impt.ServerSocket5

2、.imptjava.nio.channels.ionKey6.imptjava.nio.channels.7.imptjava.nio.channels.ServerSocketChannel8.imptjava.nio.channels.SocketChannel9.imptjava.util.Iterat10.imptjava.util.LinkedList11.imptjava.util.List12.imptjava.util.

3、Set13.14.15.16.Title:主控服務(wù)線程采用NIO實(shí)現(xiàn)的長(zhǎng)連接服務(wù)器17.@authsxl18.@version1.019.20.21.publicclassServerimplementsRunnable22.privatestatic23.privateServerSocketChannelsschannel24.privateISocketAddressaddress25.protectedNotifiernotif

4、ier26.privateintpt27.28.29.創(chuàng)建主控服務(wù)線程30.@parampt服務(wù)端口31.@throwsjava.lang.Exception32.33.publicstaticintMAX_THREADS=474.處理IO事件75.if(key.isAcceptable())76.Acceptthenewconnection77.ServerSocketChannelssc=(ServerSocketChannel)k

5、ey.channel()78.notifier.fireOnAccept()79.SocketChannelsc=ssc.accept()80.sc.configureBlocking(false)81.觸發(fā)接受連接事件82.Requestrequest=newRequest(sc)83.notifier.fireOnAccepted(request)84.注冊(cè)讀操作以進(jìn)行下一步的讀操作85.sc.register(ionKey.OP_

6、READrequest)86.87.elseif(key.isReadable())88.Reader.processRequest(key)提交讀服務(wù)線程讀取客戶端數(shù)據(jù)89.90.91.92.93.catch(Exceptione)94.continue95.96.97.98.另一個(gè)改動(dòng)的類是Reader，改變對(duì)1的處理，這里不是break，而是拋出異常。在讀取完buffer的數(shù)據(jù)后，將數(shù)據(jù)包傳遞給另外兩個(gè)線程進(jìn)行syslog的發(fā)送和