Netty：透明地使用SPDY和HTTP
生活随笔
收集整理的這篇文章主要介紹了
Netty：透明地使用SPDY和HTTP
小編覺得挺不錯的,現在分享給大家,幫大家做個參考.
大多數人已經從谷歌那里聽說過SPDY，該協議被提議作為老化的HTTP協議的替代品。 Web服務器是瀏覽器正在緩慢地實現該協議，并且支持正在增長。 在最近的文章中，我已經寫過SPDY的工作方式以及如何在Jetty中啟用SPDY支持。 由于Netty（最初來自JBoss）幾個月以來也支持SPDY 。由于Netty通常用于高性能協議服務器，因此SPDY是合乎邏輯的。 在本文中，我將向您展示如何創建一個基于Netty的基本服務器，該服務器在SPDY和HTTP之間進行協議協商。 它使用Netty snoop示例中的示例HTTPRequestHandler來消耗并產生一些HTTP內容。 為了使一切正常，我們需要做以下事情： 將NPN lib添加到引導路徑 將SSL上下文連接到NPN Api 將NPN庫添加到boothpath 首先是第一件事。 從http://repo2.maven.org/maven2/org/mortbay/jetty/npn/npn-boot/8.1.2.v2012下載NPN引導jar，并確保在運行服務器時像這樣啟動它： java -Xbootclasspath/p:<path_to_npn_boot_jar> 通過這段代碼，Java SSL支持NPN。 但是，我們仍然需要訪問此協商的結果。 我們需要知道我們使用的是HTTP還是SPDY，因為這決定了我們如何處理接收到的數據。 為此，Jetty提供了一個API。 為此和所需的Netty庫，我們將以下依賴項添加到pom中，因為我使用的是maven。 <dependency><groupId>io.netty</groupId><artifactId>netty</artifactId><version>3.4.1.Final</version></dependency><dependency><groupId>org.eclipse.jetty.npn</groupId><artifactId>npn-api</artifactId><version>8.1.2.v20120308</version></dependency> 將SSL上下文連接到NPN API 現在，我們已啟用NPN并將正確的API添加到項目中，我們可以配置Netty SSL處理程序。 在Netty中配置處理程序是在PipelineFactory中完成的。 對于我們的服務器，我創建了以下PipelineFactory： package smartjava.netty.spdy;
import static org.jboss.netty.channel.Channels.pipeline;import java.io.FileInputStream;
import java.security.KeyStore;import javax.net.ssl.KeyManagerFactory;
import javax.net.ssl.SSLContext;
import javax.net.ssl.SSLEngine;import org.eclipse.jetty.npn.NextProtoNego;
import org.jboss.netty.channel.ChannelPipeline;
import org.jboss.netty.channel.ChannelPipelineFactory;
import org.jboss.netty.handler.ssl.SslHandler;public class SPDYPipelineFactory implements ChannelPipelineFactory {private SSLContext context;public SPDYPipelineFactory() {try {KeyStore keystore = KeyStore.getInstance("JKS");keystore.load(new FileInputStream("src/main/resources/server.jks"),"secret".toCharArray());KeyManagerFactory kmf = KeyManagerFactory.getInstance("SunX509");kmf.init(keystore, "secret".toCharArray());context = SSLContext.getInstance("TLS");context.init(kmf.getKeyManagers(), null, null);} catch (Exception e) {e.printStackTrace();}}public ChannelPipeline getPipeline() throws Exception {// Create a default pipeline implementation.ChannelPipeline pipeline = pipeline();// Uncomment the following line if you want HTTPSSSLEngine engine = context.createSSLEngine();engine.setUseClientMode(false);NextProtoNego.put(engine, new SimpleServerProvider());NextProtoNego.debug = true;pipeline.addLast("ssl", new SslHandler(engine));pipeline.addLast("pipeLineSelector", new HttpOrSpdyHandler());return pipeline;}
} 在此類的構造函數中，我們設置了基本的SSL上下文。 我們使用的密鑰庫和密鑰是我使用java keytool創建的，這是常規的SSL配置。 收到請求后，將調用getPipeline操作來確定如何處理該請求。 在這里，我們使用Jetty-NPN-API提供的NextProtoNego類將SSL連接連接到NPN實現。 在此操作中，我們傳遞一個提供程序，該提供程序用作服務器的回調和配置。 我們還將NextProtoNego.debug設置為true。 這會打印出一些調試信息，從而使調試更加容易。 SimpleServerProvider的代碼非常簡單： public class SimpleServerProvider implements ServerProvider {private String selectedProtocol = null;public void unsupported() {//if unsupported, default to http/1.1selectedProtocol = "http/1.1";}public List<String> protocols() {return Arrays.asList("spdy/2","http/1.1");}public void protocolSelected(String protocol) {selectedProtocol = protocol;}public String getSelectedProtocol() { return selectedProtocol;}
} 此代碼幾乎是不言自明的。 沒有協議 ：可能尚未協商任何協議。 在那種情況下，我們沒有做任何特別的事情，只需正常處理即可。 有一個http協議 ：我們建立了一個處理程序鏈來處理HTTP請求。 有一個spdy協議 ：我們建立了一個處理程序鏈來處理SPDY請求。 有了這個鏈，我們最終由HttpRequestHandler接收到的所有消息都是HTTP請求。 我們可以正常處理此HTTP請求，然后返回HTTP響應。 各種管道配置將正確處理所有這些問題。 確保使用HTTP發送回正確的SPDY標頭 我們需要做的最后一步是測試。 我們將使用最新版本的Chrome進行測試，以測試SPDY是否正常運行，并使用wget測試正常的http請求。 我提到了鏈中最后一個處理程序HttpRequestHandler進行我們的HTTP處理。 我已經使用http://netty.io/docs/stable/xref/org/jboss/netty/example/http/snoop/Http…作為HTTPRequestHandler，因為那很好地返回了有關HTTP請求的信息，而我卻沒有做任何事。 如果不做任何更改就運行它，則會遇到問題。 為了將HTTP響應與正確的SPDY會話相關聯，我們需要將傳入請求中的標頭復制到響應中：“ X-SPDY-Stream-ID”標頭。 我將以下內容添加到HttpSnoopServerHandler中，以確保復制了這些標頭（實際上應該在單獨的處理程序中完成此操作）。 private final static String SPDY_STREAM_ID = = "X-SPDY-Stream-ID";private final static String SPDY_STREAM_PRIO = "X-SPDY-Stream-Priority";// in the writeResponse method addif (request.containsHeader(SPDY_STREAM_ID)) {response.addHeader(SPDY_STREAM_ID,request.getHeader(SPDY_STREAM_ID));// optional header for prioresponse.addHeader(SPDY_STREAM_PRIO,0);} 現在剩下的就是一臺具有啟動所有內容的主服務器的服務器，并且我們可以測試SPDY實現。 public class SPDYServer {public static void main(String[] args) {// bootstrap is used to configure and setup the serverServerBootstrap bootstrap = new ServerBootstrap(new NioServerSocketChannelFactory(Executors.newCachedThreadPool(),Executors.newCachedThreadPool()));bootstrap.setPipelineFactory(new SPDYPipelineFactory());bootstrap.bind(new InetSocketAddress(8443));}
} 啟動服務器，啟動Chrome，然后查看是否一切正常。 打開https：// localhost：8443 / thisIsATest網址，您應該得到如下所示的結果： 在服務器的輸出中，您可以看到一些NPN調試日志記錄： [S] NPN received for 68ce4f39[SSLEngine[hostname=null port=-1] SSL_NULL_WITH_NULL_NULL]
[S] NPN protocols [spdy/2, http/1.1] sent to client for 68ce4f39[SSLEngine[hostname=null port=-1] SSL_NULL_WITH_NULL_NULL]
[S] NPN received for 4b24e48f[SSLEngine[hostname=null port=-1] SSL_NULL_WITH_NULL_NULL]
[S] NPN protocols [spdy/2, http/1.1] sent to client for 4b24e48f[SSLEngine[hostname=null port=-1] SSL_NULL_WITH_NULL_NULL]
[S] NPN selected 'spdy/2' for 4b24e48f[SSLEngine[hostname=null port=-1] SSL_NULL_WITH_NULL_NULL] 額外的檢查是使用以下網址查看chrome瀏覽器中打開的SPDY會話：chrome：// net-internals /＃spdy 現在讓我們檢查普通的舊HTTP是否仍在工作。 從命令行執行以下操作： jos@Joss-MacBook-Pro.local:~$ wget --no-check-certificate https://localhost:8443/thisIsATest
--2012-04-27 16:29:09-- https://localhost:8443/thisIsATest
Resolving localhost... ::1, 127.0.0.1, fe80::1
Connecting to localhost|::1|:8443... connected.
WARNING: cannot verify localhost's certificate, issued by `/C=NL/ST=NB/L=Waalwijk/O=smartjava/OU=smartjava/CN=localhost':Self-signed certificate encountered.
HTTP request sent, awaiting response... 200 OK
Length: 285
Saving to: `thisIsATest'100%[==================================================================================>] 285 --.-K/s in 0s 2012-04-27 16:29:09 (136 MB/s) - `thisIsATest' saved [285/285]jos@Joss-MacBook-Pro.local:~$ cat thisIsATest
WELCOME TO THE WILD WILD WEB SERVER
===================================
VERSION: HTTP/1.1
HOSTNAME: localhost:8443
REQUEST_URI: /thisIsATestHEADER: User-Agent = Wget/1.13.4 (darwin11.2.0)
HEADER: Accept = */*
HEADER: Host = localhost:8443
HEADER: Connection = Keep-Alivejos@Joss-MacBook-Pro.local:~$ 而且有效！ Wget使用標準的HTTPS，我們得到一個結果，而chrome使用SPDY，并從同一處理程序中呈現結果。 在最后的幾天里，我還將發布有關如何為Play Framework 2.0啟用SPDY的文章，因為它們的Web服務器也基于Netty。 參考：來自Smart Java博客的JCG合作伙伴 Jos Dirksen 透明地使用Netty使用SPDY和HTTP 。
- 在Java中啟用NPN以確定要使用的協議。
- 根據協商的協議，確定使用HTTP還是SPDY。
- 確保使用HTTP發送回正確的SPDY標頭。
- 當客戶端不支持NPN時，將調用不受支持的操作。 在這種情況下，我們默認為HTTP。
- protocol（）操作返回服務器支持的協議
- 服務器和客戶端協商協議后，將調用protocolSelected操作
翻譯自: https://www.javacodegeeks.com/2012/05/netty-using-spdy-and-http-transparently.html
總結
以上是生活随笔為你收集整理的Netty：透明地使用SPDY和HTTP的全部內容，希望文章能夠幫你解決所遇到的問題。
- 上一篇： 微信自动收款怎么设置(微信自动收款怎么设
- 下一篇： JAXB和未映射的属性