View Javadoc
1   /*
2    * Copyright 2014 The Netty Project
3    *
4    * The Netty Project licenses this file to you under the Apache License,
5    * version 2.0 (the "License"); you may not use this file except in compliance
6    * with the License. You may obtain a copy of the License at:
7    *
8    *   http://www.apache.org/licenses/LICENSE-2.0
9    *
10   * Unless required by applicable law or agreed to in writing, software
11   * distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
12   * WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
13   * License for the specific language governing permissions and limitations
14   * under the License.
15   */
16  package io.netty.example.spdy.client;
17  
18  import io.netty.bootstrap.Bootstrap;
19  import io.netty.channel.Channel;
20  import io.netty.channel.ChannelOption;
21  import io.netty.channel.EventLoopGroup;
22  import io.netty.channel.nio.NioEventLoopGroup;
23  import io.netty.channel.socket.nio.NioSocketChannel;
24  import io.netty.handler.codec.http.DefaultFullHttpRequest;
25  import io.netty.handler.codec.http.HttpHeaders;
26  import io.netty.handler.codec.http.HttpMethod;
27  import io.netty.handler.codec.http.HttpRequest;
28  import io.netty.handler.codec.http.HttpVersion;
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.SslContext;
35  import io.netty.handler.ssl.SslContextBuilder;
36  import io.netty.handler.ssl.util.InsecureTrustManagerFactory;
37  
38  /**
39   * An SPDY client that allows you to send HTTP GET to a SPDY server.
40   * <p>
41   * This class must be run with the JVM parameter: {@code java -Xbootclasspath/p:<path_to_npn_boot_jar> ...}. The
42   * "path_to_npn_boot_jar" is the path on the file system for the NPN Boot Jar file which can be downloaded from Maven at
43   * coordinates org.mortbay.jetty.npn:npn-boot. Different versions applies to different OpenJDK versions. See
44   * <a href="http://www.eclipse.org/jetty/documentation/current/npn-chapter.html">Jetty docs</a> for more information.
45   * <p>
46   * You may also use the {@code run-example.sh} script to start the client from the command line:
47   * <pre>
48   *     ./run-example.sh spdy-client
49   * </pre>
50   */
51  public final class SpdyClient {
52  
53      static final String HOST = System.getProperty("host", "127.0.0.1");
54      static final int PORT = Integer.parseInt(System.getProperty("port", "8443"));
55  
56      public static void main(String[] args) throws Exception {
57          // Configure SSL.
58          final SslContext sslCtx = SslContextBuilder.forClient()
59              .trustManager(InsecureTrustManagerFactory.INSTANCE)
60              .applicationProtocolConfig(new ApplicationProtocolConfig(
61                          Protocol.NPN,
62                          // NO_ADVERTISE is currently the only mode supported by both OpenSsl and JDK providers.
63                          SelectorFailureBehavior.NO_ADVERTISE,
64                          // ACCEPT is currently the only mode supported by both OpenSsl and JDK providers.
65                          SelectedListenerFailureBehavior.ACCEPT,
66                          ApplicationProtocolNames.SPDY_3_1,
67                          ApplicationProtocolNames.HTTP_1_1))
68              .build();
69  
70          HttpResponseClientHandler httpResponseHandler = new HttpResponseClientHandler();
71          EventLoopGroup workerGroup = new NioEventLoopGroup();
72  
73          try {
74              Bootstrap b = new Bootstrap();
75              b.group(workerGroup);
76              b.channel(NioSocketChannel.class);
77              b.option(ChannelOption.SO_KEEPALIVE, true);
78              b.remoteAddress(HOST, PORT);
79              b.handler(new SpdyClientInitializer(sslCtx, httpResponseHandler));
80  
81              // Start the client.
82              Channel channel = b.connect().syncUninterruptibly().channel();
83              System.out.println("Connected to " + HOST + ':' + PORT);
84  
85              // Create a GET request.
86              HttpRequest request = new DefaultFullHttpRequest(HttpVersion.HTTP_1_1, HttpMethod.GET, "");
87              request.headers().set(HttpHeaders.Names.HOST, HOST);
88              request.headers().set(HttpHeaders.Names.ACCEPT_ENCODING, HttpHeaders.Values.GZIP);
89  
90              // Send the GET request.
91              channel.writeAndFlush(request).sync();
92  
93              // Waits for the complete HTTP response
94              httpResponseHandler.queue().take().sync();
95              System.out.println("Finished SPDY HTTP GET");
96  
97              // Wait until the connection is closed.
98              channel.close().syncUninterruptibly();
99          } finally {
100             workerGroup.shutdownGracefully();
101         }
102     }
103 }