Netty是基于JAVA NIO类库的异步通信框架，其特点是：异步非阻塞、基于事件驱动、高性能、高可靠性和高可定制性。

官网下载地址：http://netty.io/downloads.html

下面看HelloWorld代码，所需jar包： netty-all-4.1.0.CR3.jar

服务器端实现代码：package what21.netty.tcp;

import io.netty.bootstrap.ServerBootstrap;

import io.netty.channel.ChannelFuture;

import io.netty.channel.ChannelHandlerContext;

import io.netty.channel.ChannelInitializer;

import io.netty.channel.ChannelOption;

import io.netty.channel.ChannelPipeline;

import io.netty.channel.EventLoopGroup;

import io.netty.channel.SimpleChannelInboundHandler;

import io.netty.channel.nio.NioEventLoopGroup;

import io.netty.channel.socket.SocketChannel;

import io.netty.channel.socket.nio.NioServerSocketChannel;

import io.netty.handler.codec.LengthFieldBasedFrameDecoder;

import io.netty.handler.codec.LengthFieldPrepender;

import io.netty.handler.codec.string.StringDecoder;

import io.netty.handler.codec.string.StringEncoder;

import io.netty.util.CharsetUtil;

public class TcpServer {

// 循环事件处理组

static final EventLoopGroup bossGroup = new NioEventLoopGroup();

static final EventLoopGroup workerGroup = new NioEventLoopGroup();

/**

* 运行

*

* @param host

* @param port

*/

public static void run(String host,int port){

ServerBootstrap server = new ServerBootstrap();

server.group(bossGroup,workerGroup);

server.channel(NioServerSocketChannel.class);

server.childHandler(new ChannelInitializer() {

public void initChannel(SocketChannel ch) throws Exception {

ChannelPipeline pipeline = ch.pipeline();

pipeline.addLast("frameDecoder",

new LengthFieldBasedFrameDecoder(Integer.MAX_VALUE, 0, 4, 0, 4));

pipeline.addLast("frameEncoder",

new LengthFieldPrepender(4));

pipeline.addLast("decoder",

new StringDecoder(CharsetUtil.UTF_8));

pipeline.addLast("encoder",

new StringEncoder(CharsetUtil.UTF_8));

pipeline.addLast(new TcpServerHandler());

}

});

server.option(ChannelOption.SO_BACKLOG, 128);

server.childOption(ChannelOption.SO_KEEPALIVE, true);

try {

ChannelFuture cf = server.bind(host, port).sync();

cf.channel().closeFuture().sync();

} catch (InterruptedException e) {

e.printStackTrace();

}finally{

shutdown();

}

}

/**

* 服务器端消息处理

*/

static class TcpServerHandler extends SimpleChannelInboundHandler {

@Override

protected void channelRead0(ChannelHandlerContext ctx, Object msg)

throws Exception {

System.out.println("客户端消息>>>> " + msg);

ctx.channel().writeAndFlush("您好，客户端，我是服务器端。");

}

@Override

public void exceptionCaught(ChannelHandlerContext ctx,

Throwable cause) throws Exception {

cause.printStackTrace();

ctx.close();

}

}

/**

* 关闭

*/

protected static void shutdown() {

bossGroup.shutdownGracefully();

workerGroup.shutdownGracefully();

}

/**

* @param args

*/

public static void main(String[] args) {

// 服务地址

String ip = "0.0.0.0";

// 端口

int port = 54321;

TcpServer.run(ip,port);

}

}

客户端实现代码：package what21.netty.tcp;

import io.netty.bootstrap.Bootstrap;

import io.netty.channel.Channel;

import io.netty.channel.ChannelHandlerContext;

import io.netty.channel.ChannelInitializer;

import io.netty.channel.ChannelOption;

import io.netty.channel.ChannelPipeline;

import io.netty.channel.EventLoopGroup;

import io.netty.channel.SimpleChannelInboundHandler;

import io.netty.channel.nio.NioEventLoopGroup;

import io.netty.channel.socket.nio.NioSocketChannel;

import io.netty.handler.codec.LengthFieldBasedFrameDecoder;

import io.netty.handler.codec.LengthFieldPrepender;

import io.netty.handler.codec.string.StringDecoder;

import io.netty.handler.codec.string.StringEncoder;

import io.netty.util.CharsetUtil;

public class TcpClient {

/**

* 初始化Bootstrap

*

* @return

*/

public static final Bootstrap getBootstrap() {

EventLoopGroup group = new NioEventLoopGroup();

Bootstrap bootstrap = new Bootstrap();

bootstrap.group(group).channel(NioSocketChannel.class);

bootstrap.handler(new ChannelInitializer() {

@Override

protected void initChannel(Channel ch) throws Exception {

ChannelPipeline pipeline = ch.pipeline();

pipeline.addLast("frameDecoder",

new LengthFieldBasedFrameDecoder(Integer.MAX_VALUE, 0, 4, 0, 4));

pipeline.addLast("frameEncoder",

new LengthFieldPrepender(4));

pipeline.addLast("decoder",

new StringDecoder(CharsetUtil.UTF_8));

pipeline.addLast("encoder",

new StringEncoder(CharsetUtil.UTF_8));

pipeline.addLast("handler", new TcpClientHandler());

}

});

bootstrap.option(ChannelOption.SO_KEEPALIVE, true);

return bootstrap;

}

/**

* 客户器端消息处理

*/

static class TcpClientHandler extends SimpleChannelInboundHandler {

@Override

protected void channelRead0(ChannelHandlerContext ctx, Object msg)

throws Exception {

System.out.println("服务器端消息>>>> " + msg);

Thread.sleep(2*1000);

ctx.writeAndFlush("你好，我是客户端");

}

}

/**

* @param host

* @param port

* @return

*/

public static final Channel getChannel(String host,int port){

Channel channel = null;

try {

channel = getBootstrap().connect(host, port).sync().channel();

} catch (Exception e) {

return null;

}

return channel;

}

/**

* @param ip

* @param port

* @throws Exception

*/

public static void sendMsg(String ip,int port) throws Exception {

Channel channel = getChannel(ip,port);

if(channel!=null){

channel.writeAndFlush("你好，我是客户端").sync();

}else{

System.err.println("消息发送失败，连接尚未建立成功！");

}

}

/**

* @param args

*/

public static void main(String[] args) {

try {

TcpClient.sendMsg("127.0.0.1", 54321);

} catch (Exception e) {

e.printStackTrace();

}

}

}