Netty实例-简单的服务端-client实现，凝视具体

       书籍推荐：                                       实例代码 ：http://download.csdn.net/detail/jiangtao_st/7677503

w=unionnojs&f=http%3A%2F%2Fai.taobao.com%2Fauction%2Fedetail.htm%3Fe%3DNwfw%252Fe17lVwjmraEDZVrLn4D8gsQRSnlTCbL1Om%252BR1KLltG5xFicOdXrTUTgh9sMDPIwxrc30rhSWkknj6ZtyddMKr6k2rzZWTzGpWlbfZAnZymzZ1oZjeIZWR1bMnHu%26unid%3D28416740%26ptype%3D100010%26from%3Dbasic&k=5ccfdb950740ca16&c=un&b=alimm_0&p=mm_28416740_6610563_22760419">

watermark/2/text/aHR0cDovL2Jsb2cuY3Nkbi5uZXQvamlhbmd0YW9fc3Q=/font/5a6L5L2T/fontsize/400/fill/I0JBQkFCMA==/dissolve/70/gravity/SouthEast" >

1. Netty Server端实现

   /**
    *
    * <p>
    * 	Netty Server Simple
    * </p>
    *
    * @author 卓轩
    * @创建时间：2014年7月7日
    * @version： V1.0
    */
   
   public class NettyServer {
   
   	private final int port = 8989;
   
   	@Test
   	public void nettyServer(){
   
   		EventLoopGroup bossGroup = new NioEventLoopGroup();
   		EventLoopGroup workerGroup = new NioEventLoopGroup();
   
   		try {
   			ServerBootstrap serverBootstrap = new ServerBootstrap();
   			serverBootstrap.group(bossGroup,workerGroup)
   				.channel(NioServerSocketChannel.class)
   				.option(ChannelOption.SO_BACKLOG, 1024)
   				.childHandler(new ChildChannelHandler());
   
   			//绑定端口、同步等待
   			ChannelFuture futrue = serverBootstrap.bind(port).sync();
   
   			//等待服务监听端口关闭
   			futrue.channel().closeFuture().sync();
   		} catch (InterruptedException e) {
   			// TODO Auto-generated catch block
   			e.printStackTrace();
   		}finally{
   			//退出，释放线程等相关资源
   			bossGroup.shutdownGracefully();
   			workerGroup.shutdownGracefully();
   		}
   
   	}
   
   	private class ChildChannelHandler extends ChannelInitializer<SocketChannel>{
   		@Override
   		protected void initChannel(SocketChannel ch) throws Exception {
   
   			ch.pipeline().addLast(new SimpleServerHandler());
   		}
   	}
   
   }
   

2. Netty Client 实现

   /**
    *
    * <p>
    * 	NettyClient  实现
    * </p>
    *
    * @author 卓轩
    * @创建时间：2014年7月7日
    * @version： V1.0
    */
   public class NettyClient {
   
   	public void connect(int port,String host){
   
   		EventLoopGroup group = new NioEventLoopGroup();
   
   		try {
   			Bootstrap bootstrap = new Bootstrap();
   			bootstrap.group(group)
   			.channel(NioSocketChannel.class)
   			.option(ChannelOption.TCP_NODELAY, true)
   			.handler(new ChannelInitializer<SocketChannel>() {
   
   				@Override
   				protected void initChannel(SocketChannel ch) throws Exception {
   					ch.pipeline().addLast(new SimpleClientHandler());
   				}
   			});
   			//发起异步链接操作
   			ChannelFuture channelFuture = bootstrap.connect(host, port).sync();
   
   			channelFuture.channel().closeFuture().sync();
   		} catch (InterruptedException e) {
   			// TODO Auto-generated catch block
   			e.printStackTrace();
   		}finally{
   			//关闭，释放线程资源
   			group.shutdownGracefully();
   		}
   	}
   
   	@Test
   	public void nettyClient(){
   
   		new NettyClient().connect(8989, "localhost");
   	}
   
   }

3. ServerHander 处理程序 

   /**
    *
    * <p>
    * 	Server接收消息处理Handler
    * </p>
    *
    * @author 卓轩
    * @创建时间：2014年7月7日
    * @version： V1.0
    */
   public class SimpleServerHandler extends ChannelInboundHandlerAdapter {
   
   	@Override
   	public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
   
   		ByteBuf buf = (ByteBuf)msg;
   		byte [] req = new byte[buf.readableBytes()];
   
   		buf.readBytes(req);
   
   		String message = new String(req,"UTF-8");
   
   		System.out.println("Netty-Server:Receive Message,"+ message);
   
   	}
   }

4. ClientHander 处理程序

   /**
    *
    * <p>
    * Client Handler
    * </p>
    *
    * @author 卓轩
    * @创建时间：2014年7月7日
    * @version： V1.0
    */
   public class SimpleClientHandler extends ChannelInboundHandlerAdapter {
   
   	private ByteBuf clientMessage;
   
   	public SimpleClientHandler() {
   
   		byte [] req = "Call-User-Service".getBytes();
   		clientMessage = Unpooled.buffer(req.length);
   		clientMessage.writeBytes(req);
   	}
   
   	@Override
   	public void channelActive(ChannelHandlerContext ctx) throws Exception {
   
   		ctx.writeAndFlush(clientMessage);
   
   	}
   
   	@Override
   	public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
   		ByteBuf buf = (ByteBuf)msg;
   		byte [] req = new byte[buf.readableBytes()];
   
   		buf.readBytes(req);
   
   		String message = new String(req,"UTF-8");
   
   		System.out.println("Netty-Client:Receive Message,"+ message);
   	}
   
   	@Override
   	public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {
   
   		ctx.close();
   	}
   }