Netty文件传输，使用HttpChunk

public class HttpClient {private ClientBootstrap bootstrap;private String host="localhost";private Channel channel;private boolean futureSuccess;private int port=8080;public HttpClient() {}public ChannelFuture connect() {bootstrap = new ClientBootstrap(new NioClientSocketChannelFactory(Executors.newCachedThreadPool(), Executors.newCachedThreadPool()));HttpResponseHandler clientHandler = new HttpResponseHandler();bootstrap.setPipelineFactory(new HttpClientPipelineFactory(clientHandler));bootstrap.setOption("tcpNoDelay", true);bootstrap.setOption("keepAlive", true);return bootstrap.connect(new InetSocketAddress(host,port));}public boolean checkFutureState(ChannelFuture channelFuture) {// Wait until the connection attempt succeeds or fails.channel = channelFuture.awaitUninterruptibly().getChannel();channelFuture.addListener(new ChannelFutureListener() {@Overridepublic void operationComplete(ChannelFuture connectFuture) throws Exception {if (!connectFuture.isSuccess()) {connectFuture.getCause().printStackTrace();// connectFuture.getChannel().close();// bootstrap.releaseExternalResources();futureSuccess = false;} else {futureSuccess = true;}}});return futureSuccess;}public ChannelFuture write(HttpRequest request) {return channel.write(request);}public void Close() {// Close the connection. Make sure the close operation ends because// all I/O operations are asynchronous in Netty.channel.close().awaitUninterruptibly();// Shut down all thread pools to exit.bootstrap.releaseExternalResources();}}

public class HttpClientPipelineFactory implements ChannelPipelineFactory {      private final HttpResponseHandler handler;        public HttpClientPipelineFactory(HttpResponseHandler handler) {          this.handler = handler;      }            public ChannelPipeline getPipeline() throws Exception {          ChannelPipeline pipeline = pipeline();                    pipeline.addLast("decoder", new HttpResponseDecoder());          //pipeline.addLast("aggregator", new HttpChunkAggregator(6048576));          pipeline.addLast("encoder", new HttpRequestEncoder());          pipeline.addLast("chunkedWriter", new ChunkedWriteHandler());          pipeline.addLast("handler", handler);                    return pipeline;      }  }  

@ChannelPipelineCoverage("one")  public class HttpResponseHandler extends SimpleChannelUpstreamHandler {      private volatile boolean readingChunks;      private File downloadFile;      private FileOutputStream fOutputStream = null;        @Override      public void messageReceived(ChannelHandlerContext ctx, MessageEvent e) throws Exception {          if (e.getMessage() instanceof HttpResponse) {              DefaultHttpResponse httpResponse = (DefaultHttpResponse) e.getMessage();              String fileName = httpResponse.getHeader("Content-Disposition").substring(20);              downloadFile = new File(System.getProperty("user.dir") + File.separator + "download" + fileName);              readingChunks = httpResponse.isChunked();          } else {              HttpChunk httpChunk = (HttpChunk) e.getMessage();              if (!httpChunk.isLast()) {                  ChannelBuffer buffer = httpChunk.getContent();                  if (fOutputStream == null) {                      fOutputStream = new FileOutputStream(downloadFile);                  }                  while (buffer.readable()) {                      byte[] dst = new byte[buffer.readableBytes()];                      buffer.readBytes(dst);                      fOutputStream.write(dst);                  }              } else {                  readingChunks = false;              }              fOutputStream.flush();          }          if (!readingChunks) {              fOutputStream.close();          }      }        @Override      public void exceptionCaught(ChannelHandlerContext ctx, ExceptionEvent e) throws Exception {          System.out.println(e.getCause());      }  }  

public class ClientMain {      public static void main(String[] args) {          HttpClient httpClient=new HttpClient();          ChannelFuture connectFuture=httpClient.connect();          if (httpClient.checkFutureState(connectFuture)) {              System.out.println("connect ok");              HttpRequest request=new DefaultHttpRequest(HttpVersion.HTTP_1_1, HttpMethod.GET, "thunder.zip");  //          HttpRequest request=new DefaultHttpRequest(HttpVersion.HTTP_1_1, HttpMethod.GET, "thunder.java");              ChannelFuture writeFuture= httpClient.write(request);              if (httpClient.checkFutureState(writeFuture)) {                  System.out.println("write ok");              }          }      }  }