测评系统核心代码

linzhijie

2021-03-11 84fea994d2db7dc313ad1774f34eb12a45f8d6e7

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
package com.ots.project.tool.report.reportCalculation.socket.netty;
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;
public class NettyClientInitializer extends ChannelInitializer<SocketChannel> {
    private NettyClient nettyClient;
    public NettyClientInitializer(NettyClient nettyClient) {
        this.nettyClient = nettyClient;
    }
    protected void initChannel(SocketChannel ch) {
        ChannelPipeline pipeline = ch.pipeline();
 
 
 
        
        pipeline.addLast("decoder", new StringDecoder());
        pipeline.addLast("encoder", new StringEncoder());
        
        pipeline.addLast(new NettyClientHandler(nettyClient));
    }
}