ftp上传下载Java实现

import java.io.BufferedOutputStream;

import java.io.File;

import java.io.FileInputStream;

import java.io.FileOutputStream;

import java.io.FileWriter;

import java.io.IOException;

import java.io.InputStream;

import java.util.Arrays;

import java.util.List;

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.FTPListParseEngine;

import org.apache.commons.net.ftp.FTPReply;

import org.dom4j.Document;

import org.dom4j.DocumentHelper;

import org.dom4j.Element;

import org.dom4j.io.OutputFormat;

import org.dom4j.io.XMLWriter;

public class FtpHelper {

private FTPClient ftp = null;

/**

 * Ftp服务器

 */

private String server;

/**

 * 用户名

 */

private String uname;

/**

 * 密码

 */

private String password;

/**

 * 连接端口，默认21

 */

private int port = 21;

private Document document ;

public FtpHelper(String server, int port, String uname,

String password){

this.server = server;

if (this.port > 0){

this.port = port;

}

this.uname = uname;

this.password = password;

//初始化

ftp = new FTPClient();

}

/**

 * 连接FTP服务器

 * 

 * @param server

 * @param uname

 * @param password

 * @return

 * @throws Exception

 */

public FTPClient connectFTPServer() throws Exception {

try {

ftp.configure(getFTPClientConfig());

ftp.connect(this.server, this.port);

if (!ftp.login(this.uname, this.password)) {

ftp.logout();

ftp = null;

return ftp;

}

// 文件类型,默认是ASCII

ftp.setFileType(FTPClient.BINARY_FILE_TYPE);

ftp.setControlEncoding("GBK");

// 设置被动模式

ftp.enterLocalPassiveMode();

//ftp.setConnectTimeout(2000);

ftp.setBufferSize(1024);

// 响应信息

int replyCode = ftp.getReplyCode();

if ((!FTPReply.isPositiveCompletion(replyCode))) {

// 关闭Ftp连接

closeFTPClient();

// 释放空间

ftp = null;

throw new Exception("登录FTP服务器失败,请检查![Server:" + server + "、"

+ "User:" + uname + "、" + "Password:" + password);

} else {

return ftp;

}

} catch (Exception e) {

ftp.disconnect();

ftp = null;

throw e;

}

}

/**

 * 配置FTP连接参数

 * 

 * @return

 * @throws Exception

 */

public FTPClientConfig getFTPClientConfig() throws Exception {

String systemKey = FTPClientConfig.SYST_NT;

String serverLanguageCode = "zh";

FTPClientConfig conf = new FTPClientConfig(systemKey);

conf.setServerLanguageCode(serverLanguageCode);

conf.setDefaultDateFormatStr("yyyy-MM-dd");

return conf;

}

/**

 * 向FTP根目录上传文件

 * 

 * @param localFile

 * @param newName

 *            新文件名

 * @throws Exception

 */

public Boolean uploadFile(String localFile, String newName)

throws Exception {

InputStream input = null;

boolean success = false;

try {

File file = null;

if (checkFileExist(localFile)) {

file = new File(localFile);

}

input = new FileInputStream(file);

success = ftp.storeFile(newName, input);

if (!success) {

throw new Exception("文件上传失败!");

}

} catch (Exception e) {

throw e;

} finally {

if (input != null) {

input.close();

}

}

return success;

}

/**

 * 向FTP根目录上传文件

 * 

 * @param input

 * @param newName

 *            新文件名

 * @throws Exception

 */

public Boolean uploadFile(InputStream input, String newName)

throws Exception {

boolean success = false;

try {

success = ftp.storeFile(newName, input);

if (!success) {

throw new Exception("文件上传失败!");

}

} catch (Exception e) {

throw e;

} finally {

if (input != null) {

input.close();

}

}

return success;

}

/**

 * 向FTP指定路径上传文件

 * 

 * @param localFile

 * @param newName

 *            新文件名

 * @param remoteFoldPath

 * @throws Exception

 */

public Boolean uploadFile(String localFile, String newName,

String remoteFoldPath) throws Exception {

InputStream input = null;

boolean success = false;

try {

File file = null;

if (checkFileExist(localFile)) {

file = new File(localFile);

}

input = new FileInputStream(file);

// 改变当前路径到指定路径

if (!this.changeDirectory(remoteFoldPath)) {

System.out.println("服务器路径不存!");

return false;

}

success = ftp.storeFile(newName, input);

if (!success) {

throw new Exception("文件上传失败!");

}

} catch (Exception e) {

throw e;

} finally {

if (input != null) {

input.close();

}

}

return success;

}

/**

 * 向FTP指定路径上传文件

 * 

 * @param input

 * @param newName

 *            新文件名

 * @param remoteFoldPath

 * @throws Exception

 */

public Boolean uploadFile(InputStream input, String newName,

String remoteFoldPath) throws Exception {

boolean success = false;

try {

// 改变当前路径到指定路径

if (!this.changeDirectory(remoteFoldPath)) {

System.out.println("服务器路径不存!");

return false;

}

success = ftp.storeFile(newName, input);

if (!success) {

throw new Exception("文件上传失败!");

}

} catch (Exception e) {

throw e;

} finally {

if (input != null) {

input.close();

}

}

return success;

}

/**

 * 从FTP服务器下载文件

 * 

 * @param remotePath

 *            FTP路径(不包含文件名)

 * @param fileName

 *            下载文件名

 * @param localPath

 *            本地路径

 */

public Boolean downloadFile(String remotePath, String fileName,

String localPath) throws Exception {

BufferedOutputStream output = null;

boolean success = false;

try {

// 检查本地路径

this.checkFileExist(localPath);

// 改变工作路径

if (!this.changeDirectory(remotePath)) {

System.out.println("服务器路径不存在");

return false;

}

// 列出当前工作路径下的文件列表

List<FTPFile> fileList = this.getFileList();

if (fileList == null || fileList.size() == 0) {

System.out.println("服务器当前路径下不存在文件！");

return success;

}

for (FTPFile ftpfile : fileList) {

if (ftpfile.getName().equals(fileName)) {

File localFilePath = new File(localPath + File.separator

+ ftpfile.getName());

output = new BufferedOutputStream(new FileOutputStream(

localFilePath));

success = ftp.retrieveFile(ftpfile.getName(), output);

}

}

if (!success) {

throw new Exception("文件下载失败!");

}

} catch (Exception e) {

throw e;

} finally {

if (output != null) {

output.close();

}

}

return success;

}

/**

 * 从FTP服务器获取文件流

 * 

 * @param remoteFilePath

 * @return

 * @throws Exception

 */

public InputStream downloadFile(String remoteFilePath) throws Exception {

return ftp.retrieveFileStream(remoteFilePath);

}

/**

 * 获取FTP服务器上指定路径下的文件列表

 * 

 * @param filePath

 * @return

 */

public List<FTPFile> getFtpServerFileList(String remotePath)

throws Exception {

FTPListParseEngine engine = ftp.initiateListParsing(remotePath);

List<FTPFile> ftpfiles = Arrays.asList(engine.getNext(25));

return ftpfiles;

}

/**

 * 获取FTP服务器上[指定路径]下的文件列表

 * 

 * @param path

 * @return

 * @throws Exception

 */

public List<FTPFile> getFileList(String remotePath) throws Exception {

List<FTPFile> ftpfiles = Arrays.asList(ftp.listFiles(remotePath));

return ftpfiles;

}

/**

 * 获取FTP服务器[当前工作路径]下的文件列表

 * 

 * @param path

 * @return

 * @throws Exception

 */

public List<FTPFile> getFileList() throws Exception {

List<FTPFile> ftpfiles = Arrays.asList(ftp.listFiles());

return ftpfiles;

}

/**

 * 改变FTP服务器工作路径 

 * 

 * @param remoteFoldPath

 */

public Boolean changeDirectory(String remoteFoldPath) throws Exception {

return ftp.changeWorkingDirectory(remoteFoldPath);

}

/**

 * 删除文件

 * 

 * @param remoteFilePath

 * @return

 * @throws Exception

 */

public Boolean deleteFtpServerFile(String remoteFilePath) throws Exception {

return ftp.deleteFile(remoteFilePath);

}

/**

 * 创建目录

 * 

 * @param remoteFoldPath

 * @return

 */

public boolean createFold(String remoteFoldPath) throws Exception {

boolean flag = ftp.makeDirectory(remoteFoldPath);

if (!flag) {

throw new Exception("创建目录失败");

}

return false;

}

/**

 * 删除目录

 * @param remoteFoldPath

 * @return

 * @throws Exception

 */

public boolean deleteFold(String remoteFoldPath) throws Exception {

return ftp.removeDirectory(remoteFoldPath) ;

}

/**

 * 删除目录以及文件

 * 

 * @param remoteFoldPath

 * @return

 */

public boolean deleteFoldAndsubFiles(String remoteFoldPath)

throws Exception {

boolean success = false;

List<FTPFile> list = this.getFileList(remoteFoldPath);

if (list == null || list.size() == 0) {

return deleteFold(remoteFoldPath);

}

for (FTPFile ftpFile : list) {

String name = ftpFile.getName();

if (ftpFile.isDirectory()) {

success = deleteFoldAndsubFiles(remoteFoldPath + "/" + name);

if (!success)

break;

} else {

success = deleteFtpServerFile(remoteFoldPath + "/" + name);

if (!success)

break;

}

}

if (!success)

return false;

success = deleteFold(remoteFoldPath);

return success;

}

/**

 * 检查本地路径是否存在

 * 

 * @param filePath

 * @return

 * @throws Exception

 */

public boolean checkFileExist(String filePath) throws Exception {

boolean flag = false;

File file = new File(filePath);

if (!file.exists()) {

throw new Exception("本地路径不存在,请检查!");

} else {

flag = true;

}

return flag;

}

/**

 * 创建XML文件

 * @return

 */

public Element getCurrentElement(){

document = DocumentHelper.createDocument();

return document.addElement("root");

}

/**

 * 生成目录XML文件

 */

public void createDirectoryXML(String remotePath,Element fatherElement) throws Exception{

List<FTPFile> list = this.getFileList();

for(FTPFile ftpfile:list){

Element currentElement = fatherElement; //当前的目录节点

String newRemotePath = remotePath+ftpfile.getName();

if(ftpfile.isDirectory()){

Element dirElement = fatherElement.addElement("dir") ;

dirElement.addAttribute("name",ftpfile.getName());

currentElement = dirElement;

this.changeDirectory(newRemotePath); //从根目录开始

createDirectoryXML(newRemotePath,dirElement);

}else{

 Element fileElement = fatherElement.addElement("file");//文件节点

 fileElement.setText(ftpfile.getName()) ;

}

}

}

/**

 * 保存xml

 */

public void saveXML(){

XMLWriter output = new XMLWriter();

        //输出格式化

        OutputFormat format = OutputFormat.createPrettyPrint();

        try {

            output = new XMLWriter(new FileWriter("src/com/shine/Ftp/config/dir.xml"), format);

            output.write(this.document);

            output.close();

        } catch (IOException e) {

            e.printStackTrace();

        }

}

/**

 * 关闭FTP连接

 * 

 * @param ftp

 * @throws Exception

 */

public void closeFTPClient(FTPClient ftp) throws Exception {

try {

if (ftp.isConnected())

ftp.logout();

ftp.disconnect();

} catch (Exception e) {

throw new Exception("关闭FTP服务出错!");

}

}

/**

 * 关闭FTP连接

 * 

 * @throws Exception

 */

public void closeFTPClient() throws Exception {

this.closeFTPClient(this.ftp);

}

/**

 * Get Attribute Method

 * 

 */

public FTPClient getFtp() {

return ftp;

}

public String getServer() {

return server;

}

public String getUname() {

return uname;

}

public String getPassword() {

return password;

}

public int getPort() {

return port;

}

/**

 * Set Attribute Method

 * 

 */

public void setFtp(FTPClient ftp) {

this.ftp = ftp;

}

public void setServer(String server) {

this.server = server;

}

public void setUname(String uname) {

this.uname = uname;

}

public void setPassword(String password) {

this.password = password;

}

public void setPort(int port) {

this.port = port;

}

/**

 * 主方法(测试)

 * 

 * 问题：上传时命名的新文件名不能有中文，否则上传失败.

 * 

 * @param args

 */

public static void main(String[] args) {

try {

FtpHelper fu = new FtpHelper("192.168.2.18", 21, "administrator","sunshine");

fu.connectFTPServer();

Element fatherElement = fu.getCurrentElement();

fu.createDirectoryXML("/", fatherElement);

fu.saveXML();

} catch (Exception e) {

System.out.println("异常信息：" + e.getMessage());

}

}

}

标签： ftp服务器 ftp服务器下载 isp 服务器 连接ftp服务器

版权申明：本站文章部分自网络，如有侵权，请联系：west999com@outlook.com
特别注意：本站所有转载文章言论不代表本站观点！
本站所提供的图片等素材，版权归原作者所有，如需使用，请与原作者联系。