java 两个通过java代码操作FTP的类,上传下载删除,获取文件

http://heisetoufa.iteye.com/blog/1932229

1.
Java代码


import java.io.File;

import java.io.FileInputStream;

import java.io.IOException;

import java.io.InputStream;

import org.apache.commons.logging.Log;

import org.apache.commons.logging.LogFactory;

import sun.net.TelnetInputStream;

import sun.net.TelnetOutputStream;

import sun.net.ftp.FtpClient;

public class FtpBusiness {

private final static Log logger = LogFactory.getLog(FtpBusiness.class);

/**

* 创建连接

*

* @param IP FTP服务器地址

* @param userName FTP服务器用户名

* @param passWord FTP服务器密码

* @return

* @throws Exception

*/

public FtpClient ftpConnection(String IP, String userName, String passWord)

throws Exception {

FtpClient fc = null;

try {

fc = new FtpClient();

fc.openServer(IP);

fc.login(userName, passWord);

fc.binary();

} catch (Exception e) {

logger.error(e);

}

return fc;

}

/**

* 关闭连接

*

* @param fc FTP连接对象

* @return

*/

public boolean ftpClose(FtpClient fc) {

try {

fc.closeServer();

} catch (Exception e) {

logger.error(e);

return false;

}

return true;

}

/**

* 获取当前目录

*

* @param fc FTP连接对象

* @return

*/

public String ftpPWD(FtpClient fc){

try {

return fc.pwd();

} catch (Exception e) {

logger.error(e);

return null;

}

}

public void ftpCD(FtpClient fc, String path){

try {

fc.cd(path);

} catch (Exception e) {

logger.error("FTP 转换到目录" + path + "异常：" + e);

}

}

/**

* 获取文件列表

*

* @param fc FTP连接对象

* @return

* @throws Exception

*/

public String ftpList(FtpClient fc){

try {

TelnetInputStream is = fc.list();

StringBuffer sb = new StringBuffer();

int k;

while ((k = is.read()) != -1) {

sb.append((char) k);

}

is.close();

return new String(sb.toString().getBytes("iso-8859-1"), "GBK");

} catch (Exception e) {

logger.error(e);

return null;

}

}

/**

* 下载文件

*

* @param fc FTP连接对象

* @param filename 下载的文件名称

* @return

* @throws Exception

*/

public InputStream getFile(FtpClient fc, String filename){

InputStream is = null;

try {

fc.binary();

is = fc.get(filename);

return is;

} catch (Exception e) {

logger.error("下载文件:" + filename + " 异常");

return null;

}

}

/**

* 上传文件

*

* @param fc FTP连接对象

* @param filename 上传的文件名称

* @return

* @throws IOException

*/

public boolean ftpPut(FtpClient fc, String filename, String Url) {

FileInputStream is = null;

TelnetOutputStream os = null;

try {

os = fc.put(filename);

File file_in = new File(Url);

is = new FileInputStream(file_in);

byte[] bytes = new byte[1024];

int c;

while ((c = is.read(bytes)) != -1) {

os.write(bytes, 0, c);

}

} catch (IOException ex) {

logger.error(ex);

return false;

} finally {

try {

is.close();

os.close();

} catch (Exception e) {

logger.error(e);

}

}

return true;

}

/**

* 删除文件

*

* @param fc FTP连接对象

* @param filename 删除的文件名称

* @return

*/

public boolean ftpDelete(FtpClient fc, String filename) {

try {

fc.cd(ftpPWD(fc));

} catch (IOException e) {

logger.error(e);

return false;

}

fc.sendServer("dele " + filename + "\r\n");

try {

fc.readServerResponse();

} catch (IOException e) {

logger.error(e);

}

return true;

}

public static void main(String[] args) throws Exception {

String IP = "111.222.333.444";

String userName = "testftpU";

String userPassword = "testftpP";

FtpClient fc = null;

String fileList = "";

// 文件名为项目路径下的文件

String upFileName = "d:\\a.txt";

String dictionary = "";

FtpBusiness ftp = new FtpBusiness();

// 链接FTP

fc = ftp.ftpConnection(IP, userName, userPassword);

// 获得文件列表

fileList = ftp.ftpList(fc);

logger.info("当前文件列表：\n" + fileList);

// 获得当前目录

dictionary = ftp.ftpPWD(fc);

logger.info("当前目录：" + dictionary);

// 上传文件

ftp.ftpPut(fc, upFileName, "d:\\a.txt");

// 下载文件

// ftp.getFile(fc, "b.txt");

// 删除文件

// ftp.ftpDelete(fc, "PSS.rar");

// 关闭连接

ftp.ftpClose(fc);

}

}

2

Java代码


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[i];

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

}

}