客户端的Netty HTTP验证

Question

请看下面我写的测试代码。 使用纯java我设置了一个Authenticator并进行URI调用以获取一些xml数据并将其转换为对象。

我写了下面的代码来测试hotpotato（netty）与纯java（无流水线）的性能。

问题是，我无法弄清楚如何使用hotpotato或netty验证我的请求，两者的代码都可以接受，我只想测试性能差异（即查看将在5秒内执行多少次请求）。

public static void main(String[] args) throws Exception { 
     Authenticator.setDefault(new MyAuthenticator("DummyUser", "DummyPassword")); 

     int timeToTestFor = 5000; //5 seconds; 
     int count = 0; 
     System.out.println("Start time"); 
     long starttime = System.currentTimeMillis(); 
     do { 
      URL url = new URL(
        "http://example.com/rest/GetData.ashx?what=pizza&where=new%20york&visitorId=12345&sessionId=123456"); 

      SearchResultsDocument doc = SearchResultsDocument.Factory.parse(url); 
      count++; 
     } while (System.currentTimeMillis() - starttime < timeToTestFor); 
     System.out.println("DONE Total count=" + count); 

     System.out.println("Netty/Hotpotatoe Start time"); 
     count = 0; 
     starttime = System.currentTimeMillis(); 
     do { 
      // Create & initialise the client 
      HttpClient client = new DefaultHttpClient(); 
      client.init(); 


      // Setup the request 
      HttpRequest request = new DefaultHttpRequest(HttpVersion.HTTP_1_0, 
        HttpMethod.GET, "/rest/GetData.ashx?what=pizza&where=new%20york&visitorId=12345&sessionId=123456"); 

      // Execute the request, turning the result into a String 
      HttpRequestFuture future = client.execute("example.com", 80, request, 
        new BodyAsStringProcessor()); 
      future.awaitUninterruptibly(); 
      // Print some details about the request 
      System.out.println("A >> " + future); 

      // If response was >= 200 and <= 299, print the body 
      if (future.isSuccessfulResponse()) { 
       System.out.println("B >> "+future.getProcessedResult()); 
      } 

      // Cleanup 
      client.terminate(); 
      count++; 
     } while (System.currentTimeMillis() - starttime < timeToTestFor); 
     System.out.println("DONE Total count=" + count); 
    } 

Answer 1

以下是仅使用Netty使用基本身份验证的工作示例。测试Jetty作为需要基本认证的服务器。

import java.net.InetSocketAddress; 
import java.util.concurrent.Executors; 

import org.jboss.netty.bootstrap.ClientBootstrap; 
import org.jboss.netty.buffer.ChannelBuffer; 
import org.jboss.netty.buffer.ChannelBuffers; 
import org.jboss.netty.channel.ChannelHandlerContext; 
import org.jboss.netty.channel.ChannelPipeline; 
import org.jboss.netty.channel.ChannelPipelineFactory; 
import org.jboss.netty.channel.Channels; 
import org.jboss.netty.channel.ExceptionEvent; 
import org.jboss.netty.channel.MessageEvent; 
import org.jboss.netty.channel.SimpleChannelHandler; 
import org.jboss.netty.channel.socket.nio.NioClientSocketChannelFactory; 
import org.jboss.netty.handler.codec.base64.Base64; 
import org.jboss.netty.handler.codec.http.DefaultHttpRequest; 
import org.jboss.netty.handler.codec.http.HttpChunkAggregator; 
import org.jboss.netty.handler.codec.http.HttpClientCodec; 
import org.jboss.netty.handler.codec.http.HttpHeaders; 
import org.jboss.netty.handler.codec.http.HttpMethod; 
import org.jboss.netty.handler.codec.http.HttpResponse; 
import org.jboss.netty.handler.codec.http.HttpVersion; 
import org.jboss.netty.util.CharsetUtil; 

public class BasicAuthTest { 
private static final int PORT = 80; 
private static final String USERNAME = ""; 
private static final String PASSWORD = ""; 
private static final String URI = ""; 
private static final String HOST = ""; 

public static void main(String[] args) { 

    ClientBootstrap client = new ClientBootstrap(
      new NioClientSocketChannelFactory(
        Executors.newCachedThreadPool(), 
        Executors.newCachedThreadPool())); 

    client.setPipelineFactory(new ChannelPipelineFactory() { 

     @Override 
     public ChannelPipeline getPipeline() throws Exception { 
      ChannelPipeline pipeline = Channels.pipeline(); 
      pipeline.addLast("codec", new HttpClientCodec()); 
      pipeline.addLast("aggregator", new HttpChunkAggregator(5242880)); 
      pipeline.addLast("authHandler", new ClientMessageHandler()); 
      return pipeline; 
     } 
    }); 

    DefaultHttpRequest request = new DefaultHttpRequest(HttpVersion.HTTP_1_1, HttpMethod.GET, URI); 

    request.addHeader(HttpHeaders.Names.HOST, HOST); 

    String authString = USERNAME + ":" + PASSWORD; 
    ChannelBuffer authChannelBuffer = ChannelBuffers.copiedBuffer(authString, CharsetUtil.UTF_8); 
    ChannelBuffer encodedAuthChannelBuffer = Base64.encode(authChannelBuffer); 
    request.addHeader(HttpHeaders.Names.AUTHORIZATION, encodedAuthChannelBuffer.toString(CharsetUtil.UTF_8)); 

    client.connect(new InetSocketAddress(HOST, PORT)).awaitUninterruptibly().getChannel() 
      .write(request).awaitUninterruptibly(); 

} 

public static class ClientMessageHandler extends SimpleChannelHandler { 
    @Override 
    public void exceptionCaught(ChannelHandlerContext ctx, ExceptionEvent e) throws Exception { 
     e.getCause().printStackTrace(); 
    } 

    @Override 
    public void messageReceived(ChannelHandlerContext ctx, MessageEvent e) throws Exception { 
     HttpResponse httpResponse = (HttpResponse) e.getMessage(); 
     String json = httpResponse.getContent().toString(CharsetUtil.UTF_8); 
     System.out.println(json); 
    } 
} 

}