1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16 package io.netty.example.factorial;
17
18 import io.netty.bootstrap.Bootstrap;
19 import io.netty.channel.ChannelFuture;
20 import io.netty.channel.EventLoopGroup;
21 import io.netty.channel.nio.NioEventLoopGroup;
22 import io.netty.channel.socket.nio.NioSocketChannel;
23 import io.netty.handler.ssl.SslContext;
24 import io.netty.handler.ssl.SslContextBuilder;
25 import io.netty.handler.ssl.util.InsecureTrustManagerFactory;
26
27
28
29
30
31 public final class FactorialClient {
32
33 static final boolean SSL = System.getProperty("ssl") != null;
34 static final String HOST = System.getProperty("host", "127.0.0.1");
35 static final int PORT = Integer.parseInt(System.getProperty("port", "8322"));
36 static final int COUNT = Integer.parseInt(System.getProperty("count", "1000"));
37
38 public static void main(String[] args) throws Exception {
39
40 final SslContext sslCtx;
41 if (SSL) {
42 sslCtx = SslContextBuilder.forClient()
43 .trustManager(InsecureTrustManagerFactory.INSTANCE).build();
44 } else {
45 sslCtx = null;
46 }
47
48 EventLoopGroup group = new NioEventLoopGroup();
49 try {
50 Bootstrap b = new Bootstrap();
51 b.group(group)
52 .channel(NioSocketChannel.class)
53 .handler(new FactorialClientInitializer(sslCtx));
54
55
56 ChannelFuture f = b.connect(HOST, PORT).sync();
57
58
59 FactorialClientHandler handler =
60 (FactorialClientHandler) f.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 }