Netty中ChannelInitializer的使用

在Netty客户端和服务端我们都会使用到ChannelInitializer进行消息的处理，那么ChannelInitializer的作用和使用场合以及如何使用下文将会介绍。

ChannelInitializer的作用：用来进行设置出站解码器和入站编码器。

使用场合：客户端和服务端之间消息的传递包含特殊字符需要统一编码格式时，在客户端和服务端加上ChannelInitializer继承类，重写initChannel方法，设置编码和解码格式。但当传输的数据不包含特殊字符例如报文时，客户端和服务端不需要写ChannelInitializer继承类。

代码举例：
客户端：

package client;

import io.netty.channel.ChannelInitializer;
import io.netty.channel.ChannelPipeline;
import io.netty.channel.socket.SocketChannel;
import io.netty.handler.codec.string.StringDecoder;
import io.netty.handler.codec.string.StringEncoder;
import io.netty.util.CharsetUtil;

public class ClientChannelInitializer extends ChannelInitializer<SocketChannel> {
    protected void initChannel(SocketChannel channel) throws Exception {
        ChannelPipeline p = channel.pipeline();
        p.addLast("decoder", new StringDecoder(CharsetUtil.UTF_8));
        p.addLast("encoder", new StringEncoder(CharsetUtil.UTF_8));
        p.addLast(new ClientHandler());
    }
}

服务端：

package com.safelocate.app.nettyServer;

import io.netty.channel.ChannelInitializer;
import io.netty.channel.socket.SocketChannel;
import io.netty.handler.codec.string.StringDecoder;
import io.netty.handler.codec.string.StringEncoder;
import io.netty.util.CharsetUtil;
public class ServerChannelInitializer extends ChannelInitializer<SocketChannel> {
    @Override
    protected void initChannel(SocketChannel channel) throws Exception {
        channel.pipeline().addLast("decoder",new StringDecoder(CharsetUtil.UTF_8));
        channel.pipeline().addLast("encoder",new StringEncoder(CharsetUtil.UTF_8));
        channel.pipeline().addLast(new ServerHandler());
    }
}

https://www.cnblogs.com/myitnews/p/12213602.html