FTPClient简单例子

import java.io.File;

import java.io.FileInputStream; import java.io.FileOutputStream; import java.io.IOException;

import java.net.SocketException;

import org.apache.commons.net.ftp.FTPClient; import org.apache.commons.net.ftp.FTPFile;

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

public class FTP {

private String userName; //FTP 登录用户名 private String password; //FTP 登录密码

private String ip; //FTP 服务器地址IP地址 private int port; //FTP 端口

private FTPClient ftpClient = null; //FTP 客户端代理

public FTP(String userName,String password,String ip,int port) { this.userName = userName; this.password = password; this.ip = ip; this.port = port; }

public boolean connectServer() { boolean flag = true; if (ftpClient == null) { int reply; try {

System.out.println(\ ftpClient = new FTPClient();

ftpClient.setControlEncoding(\//文件名乱码,默认ISO8859-1，不支持中文

// System.out.println(\ ftpClient.setDefaultPort(port); ftpClient.connect(ip);

ftpClient.login(userName, password); System.out.println(\ System.out.print(ftpClient.getReplyString()); reply = ftpClient.getReplyCode(); ftpClient.setDataTimeout(120000);

if (!FTPReply.isPositiveCompletion(reply)) {

ftpClient.disconnect();

System.err.println(\ flag = false; }

} catch (SocketException e) { flag = false;

e.printStackTrace();

System.err.println(\登录ftp服务器 \失败,连接超时！\ } catch (IOException e) { flag = false;

e.printStackTrace();

System.err.println(\登录ftp服务器 \失败，FTP服务器无法打开！\ } }

System.out.println(\登陆ftp服务器成功\ return flag; }

public void listRemoteAllFiles(String path) { try {

FTPListParseEngine f = ftpClient.initiateListParsing(path);

while (f.hasNext()) {

FTPFile[] files = f.getNext(5); for(FTPFile file:files){ disFile(file,path); } }

} catch (IOException e) { e.printStackTrace(); } }

public void disFile(FTPFile file,String path){

if(file.isDirectory() && !file.getName().equals(\ System.out.println(File.separator + file.getName());

listRemoteAllFiles(path+ File.separator +file.getName());

}else if(!file.getName().equals(\ System.out.println(file.getName()); } }

public void closeConnect() {

System.out.println(\关闭ftp服务器\

try {

if (ftpClient != null) { ftpClient.logout(); ftpClient.disconnect(); }

} catch (Exception e) { e.printStackTrace(); } }

public void downFile(String remotePath,String fileName,String localPath) {

FTPFile[] fs; try {

ftpClient.changeWorkingDirectory(remotePath);//转移到FTP服务器目录 fs = ftpClient.listFiles(); for(FTPFile ff:fs){

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

File localFile = new File(localPath+ File.separator +ff.getName());

FileOutputStream is = new FileOutputStream(localFile); ftpClient.retrieveFile(ff.getName(), is); is.close(); } }

} catch (IOException e) { e.printStackTrace(); } }

public void upFile(String path, String filename, String localFilePath){ try {

FileInputStream in=new FileInputStream(new File(localFilePath)); ftpClient.changeWorkingDirectory(path); ftpClient.storeFile(filename, in); in.close();

} catch (Exception e) { e.printStackTrace(); } }

public static void main(String[] args) {

FTP ftp = new FTP(\ ftp.connectServer();

ftp.listRemoteAllFiles(\

// ftp.downFile(\测试报告\测试报告.mmap\// ftp.upFile(\测试报告\个人\\\\save\\\\zip\ ftp.closeConnect(); } }