java 文件传输(netty) 实例源码

服务器端：

package com.rrkd.server;


import io.netty.bootstrap.ServerBootstrap;
import io.netty.channel.ChannelFuture;
import io.netty.channel.ChannelOption;
import io.netty.channel.EventLoopGroup;
import io.netty.channel.nio.NioEventLoopGroup;
import io.netty.channel.socket.nio.NioServerSocketChannel;

import java.io.IOException;

import org.apache.log4j.Logger;
import org.apache.log4j.PropertyConfigurator;
import org.springframework.core.io.FileSystemResourceLoader;

import com.rrkd.util.FileTransferProperties;

public class FileTransferServer {
	
	private Logger log = Logger.getLogger(FileTransferServer.class);
	
	public void bind(int port) throws Exception {
		EventLoopGroup bossGroup = new NioEventLoopGroup();
		EventLoopGroup workerGroup = new NioEventLoopGroup();
		try {
			ServerBootstrap b = new ServerBootstrap();
			b.group(bossGroup, workerGroup)
			.channel(NioServerSocketChannel.class)
			.option(ChannelOption.SO_BACKLOG, 1024)
			.childHandler(new FileChannelInitializer());
			
			log.info("bind port:" port);
			
			ChannelFuture f = b.bind(port).sync();
			f.channel().closeFuture().sync();
		} finally {
			bossGroup.shutdownGracefully();
			workerGroup.shutdownGracefully();
		}
	}

	public static void main(String[] args) {
		init();
		// 获取端口
		int port  = FileTransferProperties.getInt("port",10012);
		
		if (args != null && args.length > 0) {
			try {
				port = Integer.valueOf(args[0]);
			} catch (NumberFormatException e) {
				e.printStackTrace();
			}
		}
		try {
			new FileTransferServer().bind(port);
		} catch (Exception e) {
			e.printStackTrace();
		}
	}
	
	
	private static void init(){
		try
        {
			//请把加载属性文件放在 加载日志配置的上面，因为读取日志输出的目录配置在 属性文件里面
			FileTransferProperties.load("classpath:systemConfig.properties");
			
			System.setProperty("WORKDIR", FileTransferProperties.getString("WORKDIR","/"));
			
            PropertyConfigurator.configure(new FileSystemResourceLoader().getResource(
                    "classpath:log4j.xml").getInputStream());
        } catch (IOException e){
            e.printStackTrace();
        }
	}
}

客户端：

package com.rrkd.client;

import io.netty.bootstrap.Bootstrap;
import io.netty.channel.Channel;
import io.netty.channel.ChannelFuture;
import io.netty.channel.ChannelInitializer;
import io.netty.channel.ChannelOption;
import io.netty.channel.EventLoopGroup;
import io.netty.channel.nio.NioEventLoopGroup;
import io.netty.channel.socket.nio.NioSocketChannel;
import io.netty.handler.codec.serialization.ClassResolvers;
import io.netty.handler.codec.serialization.ObjectDecoder;
import io.netty.handler.codec.serialization.ObjectEncoder;

import java.io.File;

import com.rrkd.model.RequestFile;
import com.rrkd.util.MD5FileUtil;

public class FileTransferClient {
	public void connect(int port, String host, final RequestFile echoFile) throws Exception {
		EventLoopGroup group = new NioEventLoopGroup();
		try {
			Bootstrap b = new Bootstrap();
			b.group(group).channel(NioSocketChannel.class).option(ChannelOption.TCP_NODELAY, true).handler(new ChannelInitializer<Channel>() {

				@Override
				protected void initChannel(Channel ch) throws Exception {
					ch.pipeline().addLast(new ObjectEncoder());
					ch.pipeline().addLast(new ObjectDecoder(Integer.MAX_VALUE, ClassResolvers.weakCachingConcurrentResolver(null))); // 最大长度
					
					ch.pipeline().addLast(new NettyMessageDecoder());//设置服务器端的编码和解码
					ch.pipeline().addLast(new NettyMessageEncoder());
					ch.pipeline().addLast(new FileTransferClientHandler(echoFile));
				}
			});
			ChannelFuture f = b.connect(host, port).sync();
			f.channel().closeFuture().sync();
		} finally {
			group.shutdownGracefully();
		}
	}
 
	public static void main(String[] args) {
		int port = 10012;
		/*if (args != null && args.length > 0) {
			try {
				port = Integer.valueOf(args[0]);
			} catch (NumberFormatException e) {
				e.printStackTrace();
			}
		}*/
		try {
			RequestFile echo = new RequestFile();
			File file = new File("C://Users/Administrator/Desktop/项目已实现内容.docx");  //  "D://files/xxoo" args[0] ".amr"
			String fileName = file.getName();// 文件名
			echo.setFile(file);
			echo.setFile_md5(MD5FileUtil.getFileMD5String(file));
			echo.setFile_name(fileName);
			echo.setFile_type(getSuffix(fileName));
			echo.setStarPos(0);// 文件开始位置
			new FileTransferClient().connect(port, "127.0.0.1", echo);
		} catch (Exception e) {
			e.printStackTrace();
		}
	}
	
	
	private static String getSuffix(String fileName)
    {
        String fileType = fileName.substring(fileName.lastIndexOf("."), fileName.length());
        return fileType;
    }
}

资源下载

此资源下载价格为2D币（VIP免费），请先登录

资源文件列表

rrkd-file-client/.classpath , 509
rrkd-file-client/.project , 568
rrkd-file-client/.settings/org.eclipse.core.resources.prefs , 150
rrkd-file-client/.settings/org.eclipse.jdt.core.prefs , 695
rrkd-file-client/.settings/org.eclipse.m2e.core.prefs , 121
rrkd-file-client/pom.xml , 1050
rrkd-file-client/src/main/java/com/rrkd/client/FileTransferClient.java , 2643
rrkd-file-client/src/main/java/com/rrkd/client/FileTransferClientHandler.java , 3461
rrkd-file-client/src/main/java/com/rrkd/client/NettyMessageDecoder.java , 1187
rrkd-file-client/src/main/java/com/rrkd/client/NettyMessageEncoder.java , 500
rrkd-file-client/src/main/java/com/rrkd/model/Event.java , 253
rrkd-file-client/src/main/java/com/rrkd/model/RecvieMessage.java , 507
rrkd-file-client/src/main/java/com/rrkd/model/RequestFile.java , 1610
rrkd-file-client/src/main/java/com/rrkd/model/ResponseFile.java , 1449
rrkd-file-client/src/main/java/com/rrkd/model/SecureModel.java , 572
rrkd-file-client/src/main/java/com/rrkd/util/MD5FileUtil.java , 2437
rrkd-file-client/src/main/java/com/rrkd/util/ObjectConvertUtil.java , 2271
rrkd-file-client/src/test/java/com/rrkd/PushTask.java , 448
rrkd-file-client/src/test/java/com/rrkd/QueueTask.java , 206
rrkd-file-client/src/test/java/com/rrkd/TestA.java , 257
rrkd-file-client/src/test/java/com/rrkd/ThreadPool.java , 994
rrkd-file-server/.classpath , 566
rrkd-file-server/.fatjar , 365
rrkd-file-server/.project , 568
rrkd-file-server/.settings/org.eclipse.core.resources.prefs , 150
rrkd-file-server/.settings/org.eclipse.jdt.core.prefs , 695
rrkd-file-server/.settings/org.eclipse.m2e.core.prefs , 121
rrkd-file-server/pom.xml , 1477
rrkd-file-server/src/main/java/com/rrkd/code/NettyMessageDecoder.java , 1157
rrkd-file-server/src/main/java/com/rrkd/code/NettyMessageEncoder.java , 498
rrkd-file-server/src/main/java/com/rrkd/model/Event.java , 253
rrkd-file-server/src/main/java/com/rrkd/model/RecvieMessage.java , 507
rrkd-file-server/src/main/java/com/rrkd/model/RequestFile.java , 1448
rrkd-file-server/src/main/java/com/rrkd/model/ResponseFile.java , 1588
rrkd-file-server/src/main/java/com/rrkd/model/SecureModel.java , 572
rrkd-file-server/src/main/java/com/rrkd/server/FileChannelInitializer.java , 985
rrkd-file-server/src/main/java/com/rrkd/server/FileTransferServer.java , 2247
rrkd-file-server/src/main/java/com/rrkd/server/FileTransferServerHandler.java , 3576
rrkd-file-server/src/main/java/com/rrkd/server/SecureServerHandler.java , 1984
rrkd-file-server/src/main/java/com/rrkd/util/FileTransferProperties.java , 1670
rrkd-file-server/src/main/java/com/rrkd/util/MD5FileUtil.java , 2437
rrkd-file-server/src/main/java/com/rrkd/util/ObjectConvertUtil.java , 2271
rrkd-file-server/src/main/resources/log4j.xml , 2827
rrkd-file-server/src/main/resources/systemConfig.properties , 544