Netty is a NIO client server framework which enables quick and easy development of network applications such as protocol servers and clients. It greatly simplifies and streamlines network programming such as TCP and UDP socket server.
特征 不同的传输类型（blocking and non-blocking socket ）使用统一的API 拥有灵活的易扩展的事件模型 高低自定义的线程模型-single thread, one or more thread pools such as SEDA 高吞吐量，低时延 更少的资源占用 最小化不必要的内存拷贝 完全支持SSL/TLS和StartTLS 入门示例 添加依赖 1 2 3 4 5 6 <dependency > <groupId > io.netty</groupId > <artifactId > netty-all</artifactId > <version > 4.1.23.Final</version > <scope > compile</scope > </dependency >
Server端 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 import io.netty.bootstrap.ServerBootstrap;import io.netty.channel.*;import io.netty.channel.nio.NioEventLoopGroup;import io.netty.channel.socket.SocketChannel;import io.netty.channel.socket.nio.NioServerSocketChannel;import io.netty.handler.codec.serialization.ClassResolvers;import io.netty.handler.codec.serialization.ObjectDecoder;import io.netty.handler.codec.serialization.ObjectEncoder;public class NettyServer public void start (Integer port) throws InterruptedException EventLoopGroup bossGroup = new NioEventLoopGroup(); EventLoopGroup workGroup = new NioEventLoopGroup(4 ); ServerBootstrap bootstrap = new ServerBootstrap(); bootstrap.group(bossGroup, workGroup).channel(NioServerSocketChannel.class ) .localAddress (port ) .childHandler (new ChannelInitializer <SocketChannel >() { @Override protected void initChannel (SocketChannel ch) throws Exception ch.pipeline() .addLast(new ObjectDecoder(1024 *1024 , ClassResolvers.weakCachingConcurrentResolver(this .getClass().getClassLoader())) ) .addLast(new ObjectEncoder()) .addLast(new SimpleChannelInboundHandler<Object>() { @Override protected void channelRead0 (ChannelHandlerContext ctx, Object msg) throws Exception System.out.println("Receive message:" + msg); ctx.writeAndFlush("Hello " + msg); } }); } }); ChannelFuture channelFuture = bootstrap.bind().sync(); channelFuture.channel().closeFuture().sync(); bossGroup.shutdownGracefully().sync(); workGroup.shutdownGracefully().sync(); } public static void main (String[] args) try { NettyServer server = new NettyServer(); server.start(20000 ); } catch (InterruptedException e) { e.printStackTrace(); } } }
Client端 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 import io.netty.bootstrap.Bootstrap;import io.netty.channel.*;import io.netty.channel.nio.NioEventLoopGroup;import io.netty.channel.socket.SocketChannel;import io.netty.channel.socket.nio.NioSocketChannel;import io.netty.handler.codec.serialization.ClassResolvers;import io.netty.handler.codec.serialization.ObjectDecoder;import io.netty.handler.codec.serialization.ObjectEncoder;public class NettyClient public Channel channel; public void start (String host, Integer port) throws InterruptedException EventLoopGroup workGroup = new NioEventLoopGroup(4 ); Bootstrap bootstrap = new Bootstrap(); bootstrap.group(workGroup) .channel(NioSocketChannel.class ) .option (ChannelOption .CONNECT_TIMEOUT_MILLIS , 3000) .handler (new ChannelInitializer <SocketChannel >() { @Override protected void initChannel (SocketChannel ch) throws Exception ch.pipeline() .addLast(new ObjectDecoder(1024 *1024 , ClassResolvers.weakCachingConcurrentResolver(this .getClass().getClassLoader())) ) .addLast(new ObjectEncoder()) .addLast(new SimpleChannelInboundHandler<Object>() { @Override protected void channelRead0 (ChannelHandlerContext ctx, Object msg) throws Exception System.out.println("Receive msg: " + msg); } }); } }); channel = bootstrap.connect(host, port).sync().channel(); } public static void main (String[] args) try { NettyClient nettyClient = new NettyClient(); nettyClient.start("127.0.0.1" , 20000 ); if (nettyClient.channel != null && nettyClient.channel.isActive()){ System.out.println("Send message to server" ); nettyClient.channel.writeAndFlush("Junlan" ); } } catch (InterruptedException e) { e.printStackTrace(); } } }
