`
jayghost
  • 浏览: 441922 次
  • 性别: Icon_minigender_1
  • 来自: 成都
社区版块
存档分类
最新评论

Netty文件传输,使用HttpChunk

    博客分类:
  • Java
阅读更多

利用Netty中提供的HttpChunk简单实现文件传输

服务端基本和Netty官方文档中的example:http--file一样。

客户端:

HttpClient:

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() {
			@Override
			public 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();
	}
}

 HttpClientPipelineFactory:

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;
	}
}

HttpResponseHandler:

@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());
	}
}

  main:

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");
			}
		}
	}
}

 

改天看看零拷贝方式

 

 

 

分享到:
评论

相关推荐

    用netty实现文件传输

    在本文中,我们将深入探讨如何利用 Netty 4.0.23 版本来实现文件的传输,这包括客户端和服务器端的交互过程。 1. **Netty 基本概念** - **BossGroup 和 WorkerGroup**:Netty 中的核心概念,BossGroup 负责接收新...

    netty文件传输服务端与客户端以及协议说明

    通用的netty传输协议 通过该协议进行文件传输 文件传输客户端与服务端 可以根据文件的最后更新时间来增量传输文件 源码开放,通过eclipse或者idea导入代码即可运行 协议开放,协议是自定义的协议,大家可以根据需求...

    采用netty与protobuf进行文件传输

    本话题聚焦于使用Netty和Protocol Buffers(Protobuf)来实现文件传输,这是一种现代且高性能的技术组合,尤其适用于大规模分布式系统。 Netty是一个开源的异步事件驱动的网络应用程序框架,用于快速开发可维护的高...

    Netty5多文件、大文件上传源码

    综上所述,"Netty5多文件、大文件上传源码"涉及到的技术点包括Netty框架的使用、多文件上传的实现、大文件分块传输、长连接管理、心跳机制、错误处理与重试策略、性能优化以及安全性措施。这些知识点共同构建了一个...

    NETTY 分布式文件传输

    标题中的“NETTY 分布式文件传输”是指利用Netty框架构建一个能够在多个节点间进行文件传输的服务。Netty是一个高性能、异步事件驱动的网络应用程序框架,它为开发自定义网络协议或高并发的客户端-服务器应用提供了...

    Netty 文件上传获取进度条

    在处理文件上传时,为了提供良好的用户体验,通常需要实现文件上传的进度条功能,让用户能够实时了解文件传输的状态。在传统的HTTP协议中,这通常依赖于JavaScript的定时轮询来实现,但这种方式效率较低且消耗资源。...

    基于Netty实现的文件上传

    Netty提供了丰富的ChannelHandler(通道处理器)和ByteBuf(字节缓冲区)等组件,使得开发人员可以方便地处理各种网络协议,包括HTTP和FTP等涉及文件传输的协议。在文件上传场景下,服务器端通常需要创建一个...

    netty文件传输

    总的来说,Netty 的文件传输功能强大且易于使用,结合 Java NIO 的优势,使得它成为开发高性能网络应用的理想选择。通过理解并实践 Netty 的文件传输机制,开发者可以更好地利用 Netty 构建出满足业务需求的应用。...

    netty4.0文件分片上传+断点续传+权限校验

    在Netty中,我们可以使用ChannelHandlerContext的writeAndFlush方法将文件流分割成多个数据块(chunk),然后逐个发送。每个数据块可以设定合适的大小,例如1MB,这样可以确保网络拥塞时,服务器能够及时响应。 1. ...

    Netty+H5实现实时进度条文件上传,支持断点续传

    Netty+H5实现实时进度条文件上传,支持断点续传。 1、WebSocketServer:服务启动类 2、服务启动后,浏览器访问http://localhost:9999 3、FileWebSocketFrameHandler类SERVER_SAVE_PATH常量为文件上传保存路经

    netty-codec-http2-4.1.74.Final-API文档-中文版.zip

    赠送Maven依赖信息文件:netty-codec-http2-4.1.74.Final.pom; 包含翻译后的API文档:netty-codec-http2-4.1.74.Final-javadoc-API文档-中文(简体)版.zip; Maven坐标:io.netty:netty-codec-http2:4.1.74.Final; ...

    使用netty使用http协议开发文件服务器

    在本示例中,我们将探讨如何使用Netty实现一个基于HTTP协议的文件服务器。 首先,我们需要理解HTTP协议。HTTP(超文本传输协议)是互联网上应用最广泛的一种网络协议,它规定了客户端(如浏览器)和服务器之间数据...

    netty file server 文件服务

    - 优化:对于大文件,可以使用分块传输或者断点续传,提高下载效率。同时,考虑设置缓存策略,减少重复读取同一文件的压力。 5. **异常处理**: 在 Netty 中,异常处理是非常重要的部分。当出现错误时,可以通过 ...

    netty-codec-http-4.1.27.Final-API文档-中英对照版.zip

    赠送Maven依赖信息文件:netty-codec-http-4.1.27.Final.pom; 包含翻译后的API文档:netty-codec-http-4.1.27.Final-javadoc-API文档-中文(简体)-英语-对照版.zip; Maven坐标:io.netty:netty-codec-...

    netty-codec-http-4.1.11.Final-API文档-中文版.zip

    赠送Maven依赖信息文件:netty-codec-http-4.1.11.Final.pom; 包含翻译后的API文档:netty-codec-http-4.1.11.Final-javadoc-API文档-中文(简体)版.zip; Maven坐标:io.netty:netty-codec-http:4.1.11.Final; ...

    netty-codec-http2-4.1.73.Final-API文档-中文版.zip

    赠送Maven依赖信息文件:netty-codec-http2-4.1.73.Final.pom; 包含翻译后的API文档:netty-codec-http2-4.1.73.Final-javadoc-API文档-中文(简体)版.zip; Maven坐标:io.netty:netty-codec-http2:4.1.73.Final; ...

    netty-codec-http-4.1.68.Final-API文档-中英对照版.zip

    赠送Maven依赖信息文件:netty-codec-http-4.1.68.Final.pom; 包含翻译后的API文档:netty-codec-http-4.1.68.Final-javadoc-API文档-中文(简体)-英语-对照版.zip; Maven坐标:io.netty:netty-codec-...

    实例:如何使用Netty下载文件

    文件下载是网络通信中的常见场景,Netty通过其强大的非阻塞I/O模型,可以高效地处理大文件传输。首先,我们需要理解Netty的基本组件,包括Bootstrap(启动器)、ServerBootstrap(服务器启动器)、Channel(通道)、...

    netty-codec-http-4.1.73.Final-API文档-中文版.zip

    赠送Maven依赖信息文件:netty-codec-http-4.1.73.Final.pom; 包含翻译后的API文档:netty-codec-http-4.1.73.Final-javadoc-API文档-中文(简体)版.zip; Maven坐标:io.netty:netty-codec-http:4.1.73.Final; ...

    基于Netty和WebSocket的大文件分块上传断点续传处理器设计源码

    本大文件分块上传断点续传处理器基于Netty和WebSocket实现,包含41个文件,包括Java源代码、XML配置文件、LICENSE文件、Markdown文档、Properties配置文件和HTML页面。系统界面友好,功能完善,适合用于大文件的上传...

Global site tag (gtag.js) - Google Analytics