1   
2   
3   
4   
5   
6   
7   
8   
9   
10  
11  
12  
13  
14  
15  
16  
17  package io.netty.example.http2.helloworld.frame.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  }