一、我對(duì)Netty的理解：

　　一個(gè)開發(fā)網(wǎng)絡(luò)編程的框架，改善了NIO框架的缺點(diǎn)。

二、第一個(gè)netty小程序

　　1.服務(wù)器啟動(dòng)類ServerBootstrap:在該類中配置服務(wù)器連接數(shù)，是否延遲，長(zhǎng)連接？添加數(shù)據(jù)操作類等等

　　　　

1 1.定義一個(gè)端口 2 *2.在該類構(gòu)造方法中傳入端口參數(shù)，并在該類構(gòu)造時(shí)調(diào)用bind()方法初始化服務(wù)器端配置 3 *3.在bind()方法中先實(shí)例兩個(gè)EventLoopGroup（boss和worker）用來管理線程----- 4 * EventLoopGroup boss = new NioEventLoopGroup(); 5 EventLoopGroup worker = new NioEventLoopGroup(); 6 4.使用ServerBootstrap類來初始化netty服務(wù)器，并且開始監(jiān)聽端口的socket請(qǐng)求 7 ServerBootstrap bootstrap = new ServerBootstrap(); 8 5.根據(jù)ServerBootstrap內(nèi)封裝好的方法設(shè)置服務(wù)器基礎(chǔ)信息 9 bootstrap.group(boss, worker);//boss和worker兩個(gè)線程池 10 bootstrap.channel(NioServerSocketChannel.class); 11 bootstrap.option(ChannelOption.SO_BACKLOG, 1024); // 連接數(shù) 12 bootstrap.option(ChannelOption.TCP_NODELAY, true); // 不延遲，消息立即發(fā)送 13 bootstrap.childOption(ChannelOption.SO_KEEPALIVE, true); // 長(zhǎng)連接 14 bootstrap.childHandler(new ChannelInitializer<SocketChannel>() { 15 @Override 16 protected void initChannel(SocketChannel socketChannel) throws Exception { 17 ChannelPipeline p = socketChannel.pipeline();創(chuàng)建Channel通道 18 p.addLast(new NettyServerHandler()); //往通道中添加i/o事件處理類 19 } 20 }); 21 6.配置好服務(wù)器，在服務(wù)器啟動(dòng)時(shí)綁定闖入的port端口，等待同步 22 ChannelFuture f = bootstrap.bind(port).sync(); 23 7.如果綁定成功 24 if(f.isSuccess()){ 25 26 } 27 f.channel().closeFuture().sync(); 28 8.優(yōu)雅釋放 29 boss.shutdownGracefully(); 30 worker.shutdownGracefully();

這樣服務(wù)器端啟動(dòng)類就寫好了，接下來寫服務(wù)器端對(duì)客戶端發(fā)來數(shù)據(jù)的操作類

　　2.數(shù)據(jù)操作類ServerHandler：在該類中對(duì)客戶端發(fā)來的數(shù)據(jù)進(jìn)行操作，發(fā)送給客戶端數(shù)據(jù)

　　

* 1.繼承ChannelHandlerAdapter，重寫channelRead方法* @Overridepublic void channelRead(ChannelHandlerContext ctx, Object msg) {* 2.channelRead方法中的msg參數(shù)（服務(wù)器接收到的客戶端發(fā)送的消息）強(qiáng)制轉(zhuǎn)換成ByteBuf類型* ByteBuf buf = (ByteBuf) msg;* 3.寫一個(gè)getMessage(ByteBuf xx)方法（返回String），在該方法中：* ---首先通過ByteBuf類的readBytes()方法將msg轉(zhuǎn)換成字節(jié)數(shù)組* byte[] con = new byte[buf.readableBytes()];buf.readBytes(con);---返回String，指定編碼(有可能出現(xiàn)不支持的編碼類型異常，所以要trycatch)new String(con,"UTF-8");4.對(duì)已經(jīng)轉(zhuǎn)換成String類型的數(shù)據(jù)進(jìn)行操作System.out.println("服務(wù)器接收到消息：" + recieved);* 5.服務(wù)端往客戶端發(fā)送數(shù)據(jù)（數(shù)據(jù)類型ByteBuf）* try {ctx.writeAndFlush(getSendByteBuf("APPLE"));} catch (UnsupportedEncodingException e) {e.printStackTrace();}6. getSendByteBuf(String xxx)方法將服務(wù)端發(fā)送的數(shù)據(jù)轉(zhuǎn)換成ByteBuf類型byte[] req = message.getBytes("UTF-8");ByteBuf pingMessage = Unpooled.buffer();pingMessage.writeBytes(req);return pingMessage;*/

　　以上兩步就完成了對(duì)Netty服務(wù)器端的基本配置,接下來編寫客戶端代碼，首先是客戶端啟動(dòng)類

　　3.ClientBootstrap,跟第一步寫ServerBootstrap類類似

　　

*1.定義兩個(gè)變量：客戶端端口號(hào)和服務(wù)器IP地址*2.在構(gòu)造方法中傳入這兩個(gè)參數(shù)，在該類構(gòu)造的同時(shí)啟動(dòng)start()方法（start()方法要拋出線程中斷異常）*3.在start()方法中實(shí)例客戶端線程對(duì)象* EventLoopGroup eventLoopGroup = new NioEventLoopGroup();4.實(shí)例客戶端啟動(dòng)類：BootstrapBootstrap bootstrap = new Bootstrap();對(duì)啟動(dòng)信息進(jìn)行配置：bootstrap.channel(NioSocketChannel.class);bootstrap.group(eventLoopGroup);bootstrap.option(ChannelOption.SO_KEEPALIVE, true);//長(zhǎng)連接bootstrap.remoteAddress(host, port);//服務(wù)器主機(jī)地址端口號(hào)bootstrap.handler(new ChannelInitializer<SocketChannel>() {//添加客戶端數(shù)據(jù)處理類@Overrideprotected void initChannel(SocketChannel socketChannel)throws Exception { socketChannel.pipeline().addLast(new NettyClientHandler());}});5.在客戶端啟動(dòng)時(shí)連接服務(wù)器ip和端口ChannelFuture cf = bootstrap.connect(host,port).sync();6.如果連接成功if(cf.isSuccess()){}7.關(guān)閉通道cf.channel.closeFuture().sync();8.優(yōu)雅釋放eventLoopGroup.shutdownGracefully();*/

　　4.最后寫客戶端數(shù)據(jù)操作類，ClientHandler

*1.首先跟服務(wù)器操作類一樣繼承ChannelHandlerAdapter類，重寫channelRead和channelActive兩個(gè)方法*其中channelActive方法是用來發(fā)送客戶端信息的，channelRead方法客戶端是接收服務(wù)器數(shù)據(jù)的*2.先聲明一個(gè)全局變量firstMessage，用來接收客戶端發(fā)出去的信息的值*3.在channelActive方法中把要傳輸?shù)臄?shù)據(jù)轉(zhuǎn)化為字節(jié)數(shù)組* byte[] data = "服務(wù)器，給我一個(gè)APPLE".getBytes();* firstMessage = Unpooled.buffer();firstMessage.writeBytes(data);* ctx.writeAndFlush(firstMessage);*4.在channelRead方法中* ByteBuf buf = (ByteBuf) msg;String rev = getMessage(buf);System.out.println("客戶端收到服務(wù)器數(shù)據(jù):" + rev);}private String getMessage(ByteBuf buf) {byte[] con = new byte[buf.readableBytes()];buf.readBytes(con);try {return new String(con, "UTF-8");} catch (UnsupportedEncodingException e) {e.printStackTrace();return null;}}*/

　　

　　ok，第一個(gè)netty程序完成

　　

?

轉(zhuǎn)載于:https://www.cnblogs.com/qiuhx/p/6400972.html

總結(jié)

以上是生活随笔為你收集整理的初学Netty（杰哥好久不见）的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問題。

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