摘要：通過(guò)進(jìn)行網(wǎng)絡(luò)編程，可以提高網(wǎng)絡(luò)通信的開(kāi)發(fā)效率的同時(shí)大大提高網(wǎng)絡(luò)通信的效率。用于初始化，創(chuàng)建為的類型。實(shí)現(xiàn)傳輸對(duì)象的和都依賴于自定義的進(jìn)行定義。到這里一個(gè)簡(jiǎn)單的就實(shí)現(xiàn)完畢了。

通過(guò)java進(jìn)行網(wǎng)絡(luò)編程，netty可以提高網(wǎng)絡(luò)通信的開(kāi)發(fā)效率的同時(shí)大大提高網(wǎng)絡(luò)通信的效率。下面來(lái)看下如何使用netty進(jìn)行高效編程。

    io.nettynetty-all
    4.0.25.Final

netty3和netty4在編程api上有一定的區(qū)別，本篇是通過(guò)netty4進(jìn)行實(shí)踐的。

netty服務(wù)端和客戶端的創(chuàng)建都是依賴于Bootstrap句柄對(duì)象，下面我們看下服務(wù)端是如何通過(guò)ServerBootstrap創(chuàng)建服務(wù)的。

serverBootstrap.group(new NioEventLoopGroup(), new NioEventLoopGroup()).channel(NioServerSocketChannel.class)
    .localAddress(new InetSocketAddress(nettyServerConfig.getListenPort()))
    .childHandler(new ChannelInitializer() {
        @Override
        public void initChannel(SocketChannel ch) throws Exception {
            ch.pipeline().addLast(
                    new NettyEncoder(),
                    new NettyDecoder(),
                    new NettyConnetManageHandler(),
                    new EchoServerHandler());
        }
    });

ChannelFuture f = serverBootstrap.bind().sync();

大家去看源碼就可以知道上面都是在初始化ServerBootstrap對(duì)象的屬性：

io.netty.bootstrap.ServerBootstrap#group(io.netty.channel.EventLoopGroup, io.netty.channel.EventLoopGroup)第一個(gè)參數(shù)是用于接收請(qǐng)求的EventLoopGroup，第二個(gè)參數(shù)是處理請(qǐng)求的EventLoopGroup。

io.netty.bootstrap.AbstractBootstrap#channel用于初始化channelFactory，channel創(chuàng)建為NioServerSocketChannel的類型。

io.netty.bootstrap.AbstractBootstrap#localAddress(java.net.SocketAddress)這個(gè)沒(méi)什么好說(shuō)的設(shè)置監(jiān)聽(tīng)的地址。

io.netty.bootstrap.ServerBootstrap#childHandler數(shù)據(jù)流的handler處理器，上面我們?cè)O(shè)置了四個(gè)handler，分別有數(shù)據(jù)流出和流進(jìn)是待處理的handler鏈。

上面都是在初始化句柄接下來(lái)，serverBootstrap.bind().sync()同步開(kāi)啟服務(wù)。

bootstrap.group(new NioEventLoopGroup()).channel(NioSocketChannel.class)
    .handler(new ChannelInitializer() {
        @Override
        public void initChannel(SocketChannel ch) throws Exception {
            ch.pipeline().addLast(
                    new NettyEncoder(),
                    new NettyDecoder(),
                    new NettyClientHandler());
        }
    });

bootstrap.connect(new InetSocketAddress(ip, port));

客戶端句柄初始化相對(duì)來(lái)說(shuō)簡(jiǎn)單，初始化處理EventLoopGroup，channel factory，handler處理鏈，最后connect就可以連接到netty的服務(wù)端了。

1、NettyEncoder

public class NettyEncoder extends MessageToByteEncoder {

    @Override
    public void encode(ChannelHandlerContext ctx, NettyCommand msg, ByteBuf out)
            throws Exception {

        out.writeBytes(msg.encode());
    }
}

2、NettyDecoder

public class NettyDecoder extends ByteToMessageDecoder {

    @Override
    protected void decode(ChannelHandlerContext ctx, ByteBuf in, List