Netty中ChannelInitializer的使用

    技术2025-01-29  6

    在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

    Processed: 0.009, SQL: 9