网络文件传输 java代码_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() {

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

}

}