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.buffer.Unpooled;
20  import io.netty.channel.Channel;
21  import io.netty.channel.ChannelOption;
22  import io.netty.channel.EventLoopGroup;
23  import io.netty.channel.nio.NioEventLoopGroup;
24  import io.netty.channel.socket.nio.NioSocketChannel;
25  import io.netty.handler.codec.http.DefaultFullHttpRequest;
26  import io.netty.handler.codec.http.HttpHeaderNames;
27  import io.netty.handler.codec.http.HttpHeaderValues;
28  import io.netty.handler.codec.http.HttpMethod;
29  import io.netty.handler.codec.http.HttpRequest;
30  import io.netty.handler.codec.http.HttpVersion;
31  import io.netty.handler.ssl.ApplicationProtocolConfig;
32  import io.netty.handler.ssl.ApplicationProtocolConfig.Protocol;
33  import io.netty.handler.ssl.ApplicationProtocolConfig.SelectedListenerFailureBehavior;
34  import io.netty.handler.ssl.ApplicationProtocolConfig.SelectorFailureBehavior;
35  import io.netty.handler.ssl.ApplicationProtocolNames;
36  import io.netty.handler.ssl.SslContext;
37  import io.netty.handler.ssl.SslContextBuilder;
38  import io.netty.handler.ssl.util.InsecureTrustManagerFactory;
39  
40  /**
41   * An SPDY client that allows you to send HTTP GET to a SPDY server.
42   * <p>
43   * This class must be run with the JVM parameter: {@code java -Xbootclasspath/p:<path_to_npn_boot_jar> ...}. The
44   * "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
45   * coordinates org.mortbay.jetty.npn:npn-boot. Different versions applies to different OpenJDK versions. See
46   * <a href="http://www.eclipse.org/jetty/documentation/current/npn-chapter.html">Jetty docs</a> for more information.
47   * <p>
48   * You may also use the {@code run-example.sh} script to start the client from the command line:
49   * <pre>
50   *     ./run-example.sh spdy-client
51   * </pre>
52   */
53  public final class SpdyClient {
54  
55      static final String HOST = System.getProperty("host", "127.0.0.1");
56      static final int PORT = Integer.parseInt(System.getProperty("port", "8443"));
57  
58      public static void main(String[] args) throws Exception {
59          // Configure SSL.
60          final SslContext sslCtx = SslContextBuilder.forClient()
61              .trustManager(InsecureTrustManagerFactory.INSTANCE)
62              .applicationProtocolConfig(new ApplicationProtocolConfig(
63                          Protocol.NPN,
64                          // NO_ADVERTISE is currently the only mode supported by both OpenSsl and JDK providers.
65                          SelectorFailureBehavior.NO_ADVERTISE,
66                          // ACCEPT is currently the only mode supported by both OpenSsl and JDK providers.
67                          SelectedListenerFailureBehavior.ACCEPT,
68                          ApplicationProtocolNames.SPDY_3_1,
69                          ApplicationProtocolNames.HTTP_1_1))
70              .build();
71  
72          HttpResponseClientHandler httpResponseHandler = new HttpResponseClientHandler();
73          EventLoopGroup workerGroup = new NioEventLoopGroup();
74  
75          try {
76              Bootstrap b = new Bootstrap();
77              b.group(workerGroup);
78              b.channel(NioSocketChannel.class);
79              b.option(ChannelOption.SO_KEEPALIVE, true);
80              b.remoteAddress(HOST, PORT);
81              b.handler(new SpdyClientInitializer(sslCtx, httpResponseHandler));
82  
83              // Start the client.
84              Channel channel = b.connect().syncUninterruptibly().channel();
85              System.out.println("Connected to " + HOST + ':' + PORT);
86  
87              // Create a GET request.
88              HttpRequest request = new DefaultFullHttpRequest(
89                      HttpVersion.HTTP_1_1, HttpMethod.GET, "", Unpooled.EMPTY_BUFFER);
90              request.headers().set(HttpHeaderNames.HOST, HOST);
91              request.headers().set(HttpHeaderNames.ACCEPT_ENCODING, HttpHeaderValues.GZIP);
92  
93              // Send the GET request.
94              channel.writeAndFlush(request).sync();
95  
96              // Waits for the complete HTTP response
97              httpResponseHandler.queue().take().sync();
98              System.out.println("Finished SPDY HTTP GET");
99  
100             // Wait until the connection is closed.
101             channel.close().syncUninterruptibly();
102         } finally {
103             workerGroup.shutdownGracefully();
104         }
105     }
106 }