http://blog.csdn.net/wumenglu1018/article/details/54233826
FTP的主动传输和被动传输
主动模式:
- 客户端从端口N向服务器21端口发起连接.
- 客户端再N+1端口监听服务器的连接.
-
服务器从端口20 向客户端 N+1 端口发起连接.
image.png
被动模式:
- 客户端从端口N向服务器21端口发起连接.
- 服务端在X端口(X>1024)监听客户端的连接.
-
客户端从端口N+1 向服务端 X 端口发起连接.
image.png
主动FTP：
命令连接：客户端 大于1024端口 -> 服务器 21端口
数据连接：客户端 大于1024端口 <- 服务器20端口
被动FTP：
命令连接：客户端 大于1024端口 -> 服务器 21端口
数据连接：客户端 大于1024端口 -> 服务器 大于1024端口
简要总结：
- 主动FTP对FTP服务器的管理有利，但对客户端的管理不利。因为FTP服务器企图与客户端的高位随机端口建立连接，而这个端口很有可能被客户端的防火墙阻塞掉。
- 被动FTP对FTP客户端的管理有利，但对服务器端的管理不利。因为客户端要与服务器端建立两个连接，其中一个连到一个高位随机端口，而这个端口很有可能被服务器端的防火墙阻塞掉。
办法:
- 既然FTP服务器的管理员需要他们的服务器有最多的客户连接，那么必须得支持被动FTP。我们可以通过为FTP服务器指定一个有限的端口范围来减小服务器高位端口的暴露。这样，不在这个范围的任何端口会被服务器的防火墙阻塞。虽然这没有消除所有针对服务器的危险，但它大大减少了危险.
例:
Class FTPParam : FTP所需参数
import lombok.Builder;
/**
* ftp配置属性
*/
@Builder
public class FTPParam {
private String host;
private int port;
private String username;
private String password;
private String uploadPath;
public String getHost() {
return host;
}
public void setHost(String host) {
this.host = host;
}
public int getPort() {
return port;
}
public void setPort(int port) {
this.port = port;
}
public String getUsername() {
return username;
}
public void setUsername(String username) {
this.username = username;
}
public String getPassword() {
return password;
}
public void setPassword(String password) {
this.password = password;
}
public String getUploadPath() {
return uploadPath;
}
public void setUploadPath(String uploadPath) {
this.uploadPath = uploadPath;
}
/* (non-Javadoc)
* @see java.lang.Object#toString()
*/
@Override
public String toString() {
StringBuilder builder = new StringBuilder();
builder.append("FTPParam [host=");
builder.append(host);
builder.append(", port=");
builder.append(port);
builder.append(", username=");
builder.append(username);
builder.append(", password=");
builder.append(password);
builder.append(", uploadPath=");
builder.append(uploadPath);
builder.append("]");
return builder.toString();
}
}
Class FTPUtil: ftp工具类
public class FTPUtil {
public final static Logger LOG = LoggerFactory.getLogger(FTPUtil.class);
/**
* 发送文件到FTP
*
* @param fileLocalPath 本地文件路径(包含文件名 eg: //var//temp//test)
* @param fileName 远程服务器文件名
* @param param ftp配置
* @return
*/
public static boolean downLoadFileToLocal(String fileLocalPath, String fileName, FTPParam param) {
LOG.info("开始下载文件至本地,param:{}",param);
//状态
boolean result = false;
FTPClient ftpClient = new FTPClient();
FileOutputStream fout = null;
try {
ftpClient.connect(param.getHost(), param.getPort());
//判断ftp连接
if(!FTPReply.isPositiveCompletion(ftpClient.getReplyCode())) {
LOG.error("ftp connect fail,host:{}",param.getHost());
ftpClient.disconnect();
return result;
}
LOG.info("ftpClient.connect success.");
//判断ftp登陆
if(!ftpClient.login(param.getUsername(), param.getPassword())) {
LOG.error("ftp login fail,username:{}",param.getHost());
ftpClient.logout();
return result;
}
//设置文件类型 ：二进制
ftpClient.setFileType(FTPClient.BINARY_FILE_TYPE);
//采用被动模式传输
ftpClient.enterLocalPassiveMode();
//设置路径
LOG.info("ftpClient.connect 设置路径:{}",param.getUploadPath());
boolean change = ftpClient.changeWorkingDirectory(param.getUploadPath());
if(change){
fout = new FileOutputStream(fileLocalPath);
result = ftpClient.retrieveFile(fileName, fout);
LOG.info("---FTP下载完成---");
}
else {
LOG.info("ftpClient.connect 设置路径失败：{}", param.getUploadPath());
}
} catch (Exception e) {
LOG.error("下载文件出错,报错:",e);
} finally {
try {
if(fout != null) {
fout.close();
}
if(ftpClient.isConnected()) {
ftpClient.logout();
ftpClient.disconnect();
}
} catch (IOException e) {
LOG.error("关闭FTP或字节流出错,报错:",e);
}
}
return result;
}
/**
* 发送文件到FTP
*
* @param fileLocalPath 本地文件路径(包含文件名 eg: //var//temp//test)
* @param fileName 文件名(上传到远程服务器的文件名)
* @param param ftp配置
* @return
*/
public static boolean upLoadFileToFTP(String fileLocalPath, String fileName, FTPParam param) {
LOG.info("开始发送文件至FTP,param:{}",param);
//状态
boolean fal = false;
FTPClient ftpClient = new FTPClient();
FileInputStream fis = null;
File file = null;
try {
ftpClient.connect(param.getHost(), param.getPort());
//判断ftp连接
if(!FTPReply.isPositiveCompletion(ftpClient.getReplyCode())) {
LOG.error("ftp connect fail,host:{}",param.getHost());
ftpClient.disconnect();
return fal;
}
LOG.info("ftpClient.connect success.");
//判断ftp登陆
if(!ftpClient.login(param.getUsername(), param.getPassword())) {
LOG.error("ftp login fail,username:{}",param.getHost());
ftpClient.logout();
return fal;
}
//设置文件类型 ：二进制
ftpClient.setFileType(FTPClient.BINARY_FILE_TYPE);
file = new File(fileLocalPath);
fis = new FileInputStream(file);
//采用被动模式传输
ftpClient.enterLocalPassiveMode();
//设置上传路径
boolean change = ftpClient.changeWorkingDirectory(param.getUploadPath());
LOG.info("ftpClient.connect 设置上传路径:{}",param.getUploadPath());
if(change) {
fal = ftpClient.storeFile(fileName, fis);
LOG.info("---FTP上传完成---");
}else{
LOG.info("ftpClient.connect 设置上传路径失败：{}",param.getUploadPath());
}
} catch (Exception e) {
LOG.error("上传FTP出错,报错:",e);
} finally {
try {
if(fis != null) {
fis.close();
}
fis = null;
file = null;
if(ftpClient.isConnected()) {
ftpClient.logout();
ftpClient.disconnect();
}
} catch (IOException e) {
LOG.error("关闭FTP或字节流出错,报错:",e);
}
}
return fal;
}
