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.bootstrap.Bootstrap;
19 import io.netty5.channel.Channel;
20 import io.netty5.channel.EventLoopGroup;
21 import io.netty5.channel.MultithreadEventLoopGroup;
22 import io.netty5.channel.nio.NioHandler;
23 import io.netty5.channel.socket.nio.NioSocketChannel;
24 import io.netty5.handler.ssl.SslContext;
25 import io.netty5.handler.ssl.SslContextBuilder;
26 import io.netty5.handler.ssl.util.InsecureTrustManagerFactory;
27
28
29
30
31
32 public final class FactorialClient {
33
34 static final boolean SSL = System.getProperty("ssl") != null;
35 static final String HOST = System.getProperty("host", "127.0.0.1");
36 static final int PORT = Integer.parseInt(System.getProperty("port", "8322"));
37 static final int COUNT = Integer.parseInt(System.getProperty("count", "1000"));
38
39 public static void main(String[] args) throws Exception {
40
41 final SslContext sslCtx;
42 if (SSL) {
43 sslCtx = SslContextBuilder.forClient()
44 .trustManager(InsecureTrustManagerFactory.INSTANCE).build();
45 } else {
46 sslCtx = null;
47 }
48
49 EventLoopGroup group = new MultithreadEventLoopGroup(NioHandler.newFactory());
50 try {
51 Bootstrap b = new Bootstrap();
52 b.group(group)
53 .channel(NioSocketChannel.class)
54 .handler(new FactorialClientInitializer(sslCtx));
55
56
57 Channel channel = b.connect(HOST, PORT).asStage().get();
58
59
60 FactorialClientHandler handler = (FactorialClientHandler) channel.pipeline().last();
61
62
63 System.err.format("Factorial of %,d is: %,d", COUNT, handler.getFactorial());
64 } finally {
65 group.shutdownGracefully();
66 }
67 }
68 }