目錄

目標(biāo)

代碼UML類圖

服務(wù)端

客戶端

Netty4實(shí)現(xiàn)服務(wù)端

Netty4實(shí)現(xiàn)客戶端

測試

小結(jié)

---

目標(biāo)

用netty4實(shí)現(xiàn)一個(gè)服務(wù)端和客戶端，兩者之間可以進(jìn)行測試通信

代碼UML類圖

服務(wù)端

客戶端

Netty4實(shí)現(xiàn)服務(wù)端

服務(wù)類

package com.mym.netty.server;import io.netty.bootstrap.ServerBootstrap; import io.netty.channel.*; import io.netty.channel.nio.NioEventLoopGroup; import io.netty.channel.socket.nio.NioServerSocketChannel; import io.netty.handler.codec.string.StringDecoder; import io.netty.handler.codec.string.StringEncoder;/*** netty服務(wù)端*/ public class NettyServer {public static void main(String[] args) {startServer();}public static void startServer(){//1.定義server啟動(dòng)類ServerBootstrap serverBootstrap = new ServerBootstrap();//2.定義工作組:boss分發(fā)請求給各個(gè)worker:boss負(fù)責(zé)監(jiān)聽端口請求，worker負(fù)責(zé)處理請求（讀寫）EventLoopGroup boss = new NioEventLoopGroup();EventLoopGroup worker = new NioEventLoopGroup();//3.定義工作組serverBootstrap.group(boss,worker);//4.設(shè)置通道channelserverBootstrap.channel(NioServerSocketChannel.class);//A//serverBootstrap.channelFactory(new ReflectiveChannelFactory(NioServerSocketChannel.class));//舊版本的寫法，但是此過程在A中有同樣過程//5.添加handler，管道中的處理器，通過ChannelInitializer來構(gòu)造serverBootstrap.childHandler(new ChannelInitializer<Channel>() {@Overrideprotected void initChannel(Channel channel) throws Exception {//此方法每次客戶端連接都會(huì)調(diào)用，是為通道初始化的方法//獲得通道channel中的管道鏈（執(zhí)行鏈、handler鏈）ChannelPipeline pipeline = channel.pipeline();pipeline.addLast(new StringDecoder());pipeline.addLast("serverHandler1",new ServerHandler());pipeline.addLast("serverHandler2",new ServerHandler2());pipeline.addLast(new StringEncoder());System.out.println("success to initHandler!");}});//6.設(shè)置參數(shù)//設(shè)置參數(shù)，TCP參數(shù)serverBootstrap.option(ChannelOption.SO_BACKLOG, 2048); //連接緩沖池的大小serverBootstrap.childOption(ChannelOption.SO_KEEPALIVE, true);//維持鏈接的活躍，清除死鏈接serverBootstrap.childOption(ChannelOption.TCP_NODELAY, true);//關(guān)閉延遲發(fā)送//7.綁定ip和porttry {ChannelFuture channelFuture = serverBootstrap.bind("0.0.0.0", 9099).sync();//Future模式的channel對象//7.5.監(jiān)聽關(guān)閉channelFuture.channel().closeFuture().sync(); //等待服務(wù)關(guān)閉，關(guān)閉后應(yīng)該釋放資源} catch (InterruptedException e) {System.out.println("server start got exception!");e.printStackTrace();}finally {//8.優(yōu)雅的關(guān)閉資源boss.shutdownGracefully();worker.shutdownGracefully();}} }

Handler1

package com.mym.netty.server;import io.netty.channel.ChannelHandlerContext; import io.netty.channel.ChannelInboundHandlerAdapter;public class ServerHandler extends ChannelInboundHandlerAdapter {/** ChannelInboundHandlerAdapter：ChannelInboundHandlerAdapter是ChannelInboundHandler的一個(gè)簡單實(shí)現(xiàn)，默認(rèn)情況下不會(huì)做任何處理，* 只是簡單的將操作通過fire*方法傳遞到ChannelPipeline中的下一個(gè)ChannelHandler中讓鏈中的下一個(gè)ChannelHandler去處理。** SimpleChannelInboundHandler：SimpleChannelInboundHandler支持泛型的消息處理，默認(rèn)情況下消息處理完將會(huì)被自動(dòng)釋放，無法提供* fire*方法傳遞給ChannelPipeline中的下一個(gè)ChannelHandler,如果想要傳遞給下一個(gè)ChannelHandler需要調(diào)用ReferenceCountUtil#retain方法。* */@Overridepublic void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {System.out.println("ServerHandler receive msg:"+msg.toString());//寫消息：先得到channel，在寫如通道然后flush刷新通道把消息發(fā)出去。ctx.channel().writeAndFlush("this is ServerHandler reply msg happend at !"+System.currentTimeMillis());//把消息往下一個(gè)Handler傳ctx.fireChannelRead(msg);} }

Handler2

package com.mym.netty.server;import io.netty.channel.ChannelHandlerContext; import io.netty.channel.ChannelInboundHandlerAdapter;public class ServerHandler2 extends ChannelInboundHandlerAdapter {@Overridepublic void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {System.out.println("ServerHandler2 receive msg:"+msg.toString());ctx.channel().writeAndFlush("this is ServerHandler2 reply msg happend at !"+System.currentTimeMillis());} }

Netty4實(shí)現(xiàn)客戶端

客戶端服務(wù)類

package com.mym.netty.client;import io.netty.bootstrap.Bootstrap; import io.netty.channel.*; import io.netty.channel.nio.NioEventLoopGroup; import io.netty.channel.socket.nio.NioSocketChannel; import io.netty.handler.codec.string.StringDecoder; import io.netty.handler.codec.string.StringEncoder;import java.io.BufferedReader; import java.io.InputStreamReader;/*** netty客戶端*/ public class NettySingleClient {public static void main(String[] args) {startClient();}public static void startClient(){//1.定義服務(wù)類Bootstrap clientBootstap = new Bootstrap();//2.定義執(zhí)行線程組EventLoopGroup worker = new NioEventLoopGroup();//3.設(shè)置線程池clientBootstap.group(worker);//4.設(shè)置通道clientBootstap.channel(NioSocketChannel.class);//5.添加HandlerclientBootstap.handler(new ChannelInitializer<Channel>() {@Overrideprotected void initChannel(Channel channel) throws Exception {System.out.println("client channel init!");ChannelPipeline pipeline = channel.pipeline();pipeline.addLast("StringDecoder",new StringDecoder());pipeline.addLast("StringEncoder",new StringEncoder());pipeline.addLast("ClientHandler",new ClientHandler());}});//6.建立連接ChannelFuture channelFuture = clientBootstap.connect("0.0.0.0",9099);try {//7.測試輸入BufferedReader bufferedReader = new BufferedReader(new InputStreamReader(System.in));while(true){System.out.println("請輸入：");String msg = bufferedReader.readLine();channelFuture.channel().writeAndFlush(msg);}} catch (Exception e) {e.printStackTrace();}finally {//8.關(guān)閉連接worker.shutdownGracefully();}} }

客戶端的handler

package com.mym.netty.client;import io.netty.channel.ChannelHandlerContext; import io.netty.channel.ChannelInboundHandlerAdapter;public class ClientHandler extends ChannelInboundHandlerAdapter {@Overridepublic void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {System.out.println("client receive msg:"+msg.toString());} }

測試

啟動(dòng)服務(wù)端和客戶端后，客戶端發(fā)送nihao!服務(wù)端回應(yīng)，然后客戶端發(fā)送hello，服務(wù)端回應(yīng)。?
服務(wù)端輸出

success to initHandler! ServerHandler receive msg:nihao！ ServerHandler2 receive msg:nihao！ ServerHandler receive msg:hello ServerHandler2 receive msg:hello

客戶端輸出

client channel init! 請輸入： nihao！ 請輸入： client receive msg:this is ServerHandler reply msg happend at !1531893027697this is ServerHandler2 reply msg happend at !1531893027698 hello 請輸入： client receive msg:this is ServerHandler reply msg happend at !1531893045446this is ServerHandler2 reply msg happend at !1531893045447

小結(jié)

需要注意的是，服務(wù)端和客戶端除了啟動(dòng)類和socket channel不一樣以外，其他幾乎一致的操作。

總結(jié)

以上是生活随笔為你收集整理的Netty4服务端和客户端实现的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。