1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16 package io.netty5.example.factorial;
17
18 import io.netty5.channel.ChannelInitializer;
19 import io.netty5.channel.ChannelPipeline;
20 import io.netty5.channel.socket.SocketChannel;
21 import io.netty5.handler.codec.compression.ZlibCodecFactory;
22 import io.netty5.handler.codec.compression.ZlibWrapper;
23 import io.netty5.handler.ssl.SslContext;
24
25
26
27
28 public class FactorialClientInitializer extends ChannelInitializer<SocketChannel> {
29
30 private final SslContext sslCtx;
31
32 public FactorialClientInitializer(SslContext sslCtx) {
33 this.sslCtx = sslCtx;
34 }
35
36 @Override
37 public void initChannel(SocketChannel ch) {
38 ChannelPipeline pipeline = ch.pipeline();
39
40 if (sslCtx != null) {
41 pipeline.addLast(sslCtx.newHandler(ch.bufferAllocator(), FactorialClient.HOST, FactorialClient.PORT));
42 }
43
44
45 pipeline.addLast(ZlibCodecFactory.newZlibEncoder(ZlibWrapper.GZIP));
46 pipeline.addLast(ZlibCodecFactory.newZlibDecoder(ZlibWrapper.GZIP));
47
48
49 pipeline.addLast(new BigIntegerDecoder());
50 pipeline.addLast(new NumberEncoder());
51
52
53 pipeline.addLast(new FactorialClientHandler());
54 }
55 }