2019獨角獸企業重金招聘Python工程師標準>>>

Server

package com.netty;import io.netty.bootstrap.ServerBootstrap; import io.netty.buffer.ByteBuf; import io.netty.buffer.Unpooled; import io.netty.channel.ChannelFuture; import io.netty.channel.ChannelInitializer; import io.netty.channel.ChannelOption; import io.netty.channel.EventLoopGroup; import io.netty.channel.nio.NioEventLoopGroup; import io.netty.channel.socket.SocketChannel; import io.netty.channel.socket.nio.NioServerSocketChannel; import io.netty.handler.codec.DelimiterBasedFrameDecoder; import io.netty.handler.codec.string.StringDecoder;public class Server {public static void main(String[] args) throws Exception {//1.第一個線程是用于接收client連接的EventLoopGroup bossGroup = new NioEventLoopGroup();//2.第二個線程是用于實際的業務處理操作的EventLoopGroup workGroup = new NioEventLoopGroup();ServerBootstrap b = new ServerBootstrap();b.group(bossGroup, workGroup).channel(NioServerSocketChannel.class).childHandler(new ChannelInitializer<SocketChannel>() {@Overrideprotected void initChannel(SocketChannel sc) throws Exception {ByteBuf buf = Unpooled.copiedBuffer("$_".getBytes());sc.pipeline().addLast(new DelimiterBasedFrameDecoder(1024, buf)); //分隔符sc.pipeline().addLast(new StringDecoder());//發送string類型sc.pipeline().addLast(new ServerHandler());}}).option(ChannelOption.SO_KEEPALIVE, true);ChannelFuture f = b.bind(1234).sync();f.channel().closeFuture().sync();bossGroup.shutdownGracefully();workGroup.shutdownGracefully();} }

?

?

ServerHandler

package com.netty;import io.netty.buffer.ByteBuf; import io.netty.buffer.Unpooled; import io.netty.channel.ChannelHandlerAdapter; import io.netty.channel.ChannelHandlerContext; import io.netty.util.ReferenceCountUtil;public class ServerHandler extends ChannelHandlerAdapter {@Overridepublic void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {try {/*ByteBuf buf = (ByteBuf) msg;byte[] data = new byte[buf.readableBytes()];buf.readBytes(data);String request = new String(data,"utf-8");System.out.println(request);*/System.out.println("--------->"+msg);String response = "Hi Client";ctx.writeAndFlush(Unpooled.copiedBuffer(response.getBytes()));} finally {ReferenceCountUtil.release(msg);}}@Overridepublic void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {// TODO Auto-generated method stubsuper.exceptionCaught(ctx, cause);} }

?

?

Client

package com.netty;import io.netty.bootstrap.Bootstrap; import io.netty.buffer.Unpooled; import io.netty.channel.ChannelFuture; import io.netty.channel.ChannelInitializer; import io.netty.channel.EventLoopGroup; import io.netty.channel.nio.NioEventLoopGroup; import io.netty.channel.socket.SocketChannel; import io.netty.channel.socket.nio.NioSocketChannel;public class Client {public static void main(String[] args) throws Exception {EventLoopGroup group = new NioEventLoopGroup();Bootstrap b = new Bootstrap();b.group(group).channel(NioSocketChannel.class).handler(new ChannelInitializer<SocketChannel>() {@Overrideprotected void initChannel(SocketChannel sc) throws Exception {sc.pipeline().addLast(new ClientHandler());}});ChannelFuture f = b.connect("127.0.0.1", 1234).sync();f.channel().write(Unpooled.copiedBuffer("hello word$_".getBytes()));f.channel().write(Unpooled.copiedBuffer("hello word$_".getBytes()));f.channel().write(Unpooled.copiedBuffer("hello word$_".getBytes()));f.channel().flush();f.channel().closeFuture().sync();group.shutdownGracefully();} }

?

?

ClientHandler

package com.netty;import io.netty.buffer.ByteBuf; import io.netty.channel.ChannelHandlerAdapter; import io.netty.channel.ChannelHandlerContext;public class ClientHandler extends ChannelHandlerAdapter {@Overridepublic void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {ByteBuf buf = (ByteBuf) msg;byte[] data = new byte[buf.readableBytes()];buf.readBytes(data);String request = new String(data,"utf-8");System.out.println(request);}@Overridepublic void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {// TODO Auto-generated method stubsuper.exceptionCaught(ctx, cause);} }

?

?

?

?

?

?

?

轉載于:https://my.oschina.net/u/2562032/blog/891889

創作挑戰賽新人創作獎勵來咯，堅持創作打卡瓜分現金大獎

總結

以上是生活随笔為你收集整理的netty简单笔记的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。