FTP帮助类

rksqucnzvr

import java.io.File;  
import java.io.FileInputStream;  
import java.io.FileNotFoundException;  
import java.io.FileOutputStream;  
import java.io.IOException;  
import java.io.InputStream;  
import java.io.OutputStream;  
import org.apache.commons.net.ftp.FTP;  
import org.apache.commons.net.ftp.FTPClient;  
import org.apache.commons.net.ftp.FTPClientConfig;  
import org.apache.commons.net.ftp.FTPFile;  
import org.apache.commons.net.ftp.FTPReply;  
public class ftpTest {  
/**
* 获得连接-FTP方式
* @param hostname FTP服务器地址
* @param port FTP服务器端口
* @param username FTP登录用户名
* @param password FTP登录密码
* @return FTPClient
*/  
public FTPClient getConnectionFTP(String hostName, int port, String userName, String passWord) {  
//创建FTPClient对象  
FTPClient ftp = new FTPClient();  
try {  
//连接FTP服务器  
ftp.connect(hostName, port);  
//下面三行代码必须要，而且不能改变编码格式，否则不能正确下载中文文件  
ftp.setControlEncoding("GBK");  
FTPClientConfig conf = new FTPClientConfig(FTPClientConfig.SYST_NT);  
conf.setServerLanguageCode("zh");  
//登录ftp  
ftp.login(userName, passWord);  
if (!FTPReply.isPositiveCompletion(ftp.getReplyCode())) {  
ftp.disconnect();  
System.out.println("连接服务器失败");  
}  
System.out.println("登陆服务器成功");  
} catch (IOException e) {  
e.printStackTrace();  
}  
return ftp;  
}  
/**
* 关闭连接-FTP方式
* @param ftp FTPClient对象
* @return boolean
*/  
public boolean closeFTP(FTPClient ftp) {  
if (ftp.isConnected()) {  
try {  
ftp.disconnect();  
System.out.println("ftp已经关闭");  
return true;  
} catch (Exception e) {  
e.printStackTrace();  
}  
}  
return false;  
}  
/**
* 上传文件-FTP方式
* @param ftp FTPClient对象
* @param path FTP服务器上传地址
* @param filename 本地文件路径
* @param inputStream 输入流
* @return boolean
*/  
public boolean uploadFile(FTPClient ftp, String path, String fileName, InputStream inputStream) {  
boolean success = false;  
try {  
ftp.changeWorkingDirectory(path);//转移到指定FTP服务器目录  
FTPFile[] fs = ftp.listFiles();//得到目录的相应文件列表  
fileName = ftpTest.changeName(fileName, fs);  
fileName = new String(fileName.getBytes("GBK"),"ISO-8859-1");  
path = new String(path.getBytes("GBK"), "ISO-8859-1");  
//转到指定上传目录  
ftp.changeWorkingDirectory(path);  
//将上传文件存储到指定目录  
ftp.setFileType(FTP.BINARY_FILE_TYPE);  
//如果缺省该句 传输txt正常 但图片和其他格式的文件传输出现乱码  
ftp.storeFile(fileName, inputStream);  
//关闭输入流  
inputStream.close();  
//退出ftp  
ftp.logout();  
//表示上传成功  
success = true;  
System.out.println("上传成功。。。。。。");  
} catch (Exception e) {  
e.printStackTrace();  
}  
return success;  
}  
/**
* 删除文件-FTP方式
* @param ftp FTPClient对象
* @param path FTP服务器上传地址
* @param filename FTP服务器上要删除的文件名
* @return
*/  
public boolean deleteFile(FTPClient ftp, String path, String fileName) {  
boolean success = false;  
try {  
ftp.changeWorkingDirectory(path);//转移到指定FTP服务器目录  
fileName = new String(fileName.getBytes("GBK"), "ISO-8859-1");  
path = new String(path.getBytes("GBK"), "ISO-8859-1");  
ftp.deleteFile(fileName);  
ftp.logout();  
success = true;  
} catch (Exception e) {  
e.printStackTrace();  
}  
return success;  
}  
/**
* 上传文件-FTP方式
* @param ftp FTPClient对象
* @param path FTP服务器上传地址
* @param fileName 本地文件路径
* @param localPath 本里存储路径
* @return boolean
*/  
public boolean downFile(FTPClient ftp, String path, String fileName, String localPath) {  
boolean success = false;  
try {  
ftp.changeWorkingDirectory(path);//转移到FTP服务器目录  
FTPFile[] fs = ftp.listFiles(); //得到目录的相应文件列表  
for (FTPFile ff : fs) {  
if (ff.getName().equals(fileName)) {  
File localFile = new File(localPath + "\\" + ff.getName());  
OutputStream outputStream = new FileOutputStream(localFile);  
//将文件保存到输出流outputStream中  
ftp.retrieveFile(new String(ff.getName().getBytes("GBK"), "ISO-8859-1"), outputStream);  
outputStream.flush();  
outputStream.close();  
System.out.println("下载成功");  
}  
}  
ftp.logout();  
success = true;  
} catch (Exception e) {  
e.printStackTrace();  
}  
return success;  
}  
/**
* 判断是否有重名文件
* @param fileName
* @param fs
* @return
*/  
public static boolean isFileExist(String fileName, FTPFile[] fs) {  
for (int i = 0; i < fs.length; i++) {  
FTPFile ff = fs;  
if (ff.getName().equals(fileName)) {  
return true; //如果存在返回 正确信号  
}  
}  
return false; //如果不存在返回错误信号  
}  
/**
* 根据重名判断的结果 生成新的文件的名称
* @param fileName
* @param fs
* @return
*/  
public static String changeName(String fileName, FTPFile[] fs) {  
int n = 0;  
//      fileName = fileName.append(fileName);  
while (isFileExist(fileName.toString(), fs)) {  
n++;  
String a = "[" + n + "]";  
int b = fileName.lastIndexOf(".");//最后一出现小数点的位置  
int c = fileName.lastIndexOf("[");//最后一次"["出现的位置  
if (c < 0) {  
c = b;  
}  
StringBuffer name = new StringBuffer(fileName.substring(0, c));//文件的名字  
StringBuffer suffix = new StringBuffer(fileName.substring(b + 1));//后缀的名称  
fileName = name.append(a) + "." + suffix;  
}  
return fileName.toString();  
}  
/**
*  
* @param args
*  
* @throws FileNotFoundException
*  
* 测试程序
*  
*/  
public static void main(String[] args) throws FileNotFoundException {  
String path = "/home1/ftproot/textftp/test/";  
File f1 = new File("d:\\a.txt");  
String filename = f1.getName();  
System.out.println(filename);  
//InputStream input = new FileInputStream(f1);  
//ftpTest a = new ftpTest();  
//a.uploadFile("172.25.5.193", 21, "shiyanming", "123", path, filename, input);  
/*
* String path ="D:\\ftpindex\\"; File f2 = new
* File("D:\\ftpindex\\old.txt"); String filename2= f2.getName();
* System.out.println(filename2); ftpTest a = new
* ftpTest(); a.downFile("172.25.5.193", 21, "shi", "123", path,
* filename2, "C:\\");
*/  
ftpTest a = new ftpTest();  
InputStream input = new FileInputStream(f1);  
//      a.uploadFile("218.108.250.205", 21, "hwyhftp", "!#hwyhftp", path, filename, input);  
//a.deleteFile("218.108.250.205", 21, "hwyhftp", "!#hwyhftp", path, filename);  
//      a.downFile("218.108.250.205", 21, "hwyhftp", "!#hwyhftp", path, "欢[2].txt");  
FTPClient ftp = a.getConnectionFTP("111.222.333.444", 21, "testU", "testP");  
//      a.deleteFile(ftp, path, "a[2].txt");  
a.uploadFile(ftp, path, filename, input);  
a.closeFTP(ftp);  
}  
}  
　　

FTP异常信息 写道

java.io.IOException: Host attempting data connection 172.17.209.254 is not same as server 172.17.205.250
　　ftp的工作原理 

       ftp要用到两个tcp连接即要使用两个端口 
       一个是命令链路：用来传递命令 
       一个是数据链路：用来上传下载数据 

       连接ftp server时有active和passive两种模式 
       通常使用主动模式可完成上传下载 
    主动模式工作原理 
        客户端使用命令链路主动告诉服务端：我打开了XX端口，你来连我吧 
     被动模式工作原理 
        跟主动模式相反，服务端告诉客户端：我打开了XX端口，你来连我吧 

解决方法:


写道

remoteverification
This parameter allows to enable/disable remote host connections verification. It should help when getting "Host attempting data connection ip address is not same as server" issue. Disable verification with remoteverification="false". Default is value is "true".


ftpClient.setRemoteVerificationEnabled(false);