1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17 package io.netty.example.http2.helloworld.server;
18
19 import io.netty.bootstrap.ServerBootstrap;
20 import io.netty.channel.Channel;
21 import io.netty.channel.ChannelOption;
22 import io.netty.channel.EventLoopGroup;
23 import io.netty.channel.MultiThreadIoEventLoopGroup;
24 import io.netty.channel.nio.NioIoHandler;
25 import io.netty.channel.socket.nio.NioServerSocketChannel;
26 import io.netty.handler.codec.http2.Http2SecurityUtil;
27 import io.netty.handler.logging.LogLevel;
28 import io.netty.handler.logging.LoggingHandler;
29 import io.netty.handler.ssl.ApplicationProtocolConfig;
30 import io.netty.handler.ssl.ApplicationProtocolConfig.Protocol;
31 import io.netty.handler.ssl.ApplicationProtocolConfig.SelectedListenerFailureBehavior;
32 import io.netty.handler.ssl.ApplicationProtocolConfig.SelectorFailureBehavior;
33 import io.netty.handler.ssl.ApplicationProtocolNames;
34 import io.netty.handler.ssl.OpenSsl;
35 import io.netty.handler.ssl.SslContext;
36 import io.netty.handler.ssl.SslContextBuilder;
37 import io.netty.handler.ssl.SslProvider;
38 import io.netty.handler.ssl.SupportedCipherSuiteFilter;
39 import io.netty.pkitesting.CertificateBuilder;
40 import io.netty.pkitesting.X509Bundle;
41
42
43
44
45
46 public final class Http2Server {
47
48 static final boolean SSL = System.getProperty("ssl") != null;
49
50 static final int PORT = Integer.parseInt(System.getProperty("port", SSL? "8443" : "8080"));
51
52 public static void main(String[] args) throws Exception {
53
54 final SslContext sslCtx;
55 if (SSL) {
56 SslProvider provider = OpenSsl.isAlpnSupported() ? SslProvider.OPENSSL : SslProvider.JDK;
57 X509Bundle ssc = new CertificateBuilder()
58 .subject("cn=localhost")
59 .setIsCertificateAuthority(true)
60 .buildSelfSigned();
61 sslCtx = SslContextBuilder.forServer(ssc.toKeyManagerFactory())
62 .sslProvider(provider)
63
64
65 .ciphers(Http2SecurityUtil.CIPHERS, SupportedCipherSuiteFilter.INSTANCE)
66 .applicationProtocolConfig(new ApplicationProtocolConfig(
67 Protocol.ALPN,
68
69 SelectorFailureBehavior.NO_ADVERTISE,
70
71 SelectedListenerFailureBehavior.ACCEPT,
72 ApplicationProtocolNames.HTTP_2,
73 ApplicationProtocolNames.HTTP_1_1))
74 .build();
75 } else {
76 sslCtx = null;
77 }
78
79 EventLoopGroup group = new MultiThreadIoEventLoopGroup(NioIoHandler.newFactory());
80 try {
81 ServerBootstrap b = new ServerBootstrap();
82 b.option(ChannelOption.SO_BACKLOG, 1024);
83 b.group(group)
84 .channel(NioServerSocketChannel.class)
85 .handler(new LoggingHandler(LogLevel.INFO))
86 .childHandler(new Http2ServerInitializer(sslCtx));
87
88 Channel ch = b.bind(PORT).sync().channel();
89
90 System.err.println("Open your HTTP/2-enabled web browser and navigate to " +
91 (SSL? "https" : "http") + "://127.0.0.1:" + PORT + '/');
92
93 ch.closeFuture().sync();
94 } finally {
95 group.shutdownGracefully();
96 }
97 }
98 }