package com.zhangjun.ftp;
import java.io.File;
import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.io.IOException;
import java.util.ArrayList;
import java.util.List;
import org.apache.commons.io.IOUtils;
import org.apache.commons.net.ftp.FTPClient;
import org.apache.commons.net.ftp.FTPFile;
import org.apache.commons.net.ftp.FTPReply;
/**
* ftp连接管理(使用apache commons-net-1.4.1 lib)
*
* @author 张军
* @version 1.0 20120912
*/
public class FTPClientUtil {
private FTPClient ftpClient = null;
private String server;
private int port;
private String userName;
private String userPassword;
public static void main(String[] args) {
FtpClientUtil f = new FtpClientUtil("10.3.12.17", 21, "was", "was");
try {
if (f.open()) {
// 远程路径为相对路径
f.get("/opt/IBM/WebSphere/AppServer/profiles/AppSrv01/qunarlog.txt", "E:/zhangjun.txt");
f.close();
}
} catch (Exception e) {
e.printStackTrace();
}
}
public FtpClientUtil(String server, int port, String userName, String userPassword) {
this.server = server;
this.port = port;
this.userName = userName;
this.userPassword = userPassword;
}
/**
* 链接到服务器
*
* @return
* @throws Exception
*/
public boolean open() {
if (ftpClient != null && ftpClient.isConnected()) {
return true;
}
try {
ftpClient = new FTPClient();
// 连接
ftpClient.connect(this.server, this.port);
ftpClient.login(this.userName, this.userPassword);
// 检测连接是否成功
int reply = ftpClient.getReplyCode();
if (!FTPReply.isPositiveCompletion(reply)) {
this.close();
System.exit(1);
}
// 设置上传模式binally or ascii
ftpClient.setFileType(ftpClient.BINARY_FILE_TYPE);
return true;
} catch (Exception ex) {
// 关闭
this.close();
return false;
}
}
private boolean cd(String dir) throws IOException {
if (ftpClient.changeWorkingDirectory(dir)) {
return true;
} else {
return false;
}
}
/**
* 获取目录下所有的文件名称
*
* @param filePath
* @return
* @throws IOException
*/
private FTPFile[] getFileList(String filePath) throws IOException {
FTPFile[] list = ftpClient.listFiles();
return list;
}
/**
* 循环将设置工作目录
*/
public boolean changeDir(String ftpPath) {
if (!ftpClient.isConnected()) {
return false;
}
try {
// 将路径中的斜杠统一
char[] chars = ftpPath.toCharArray();
StringBuffer sbStr = new StringBuffer(256);
for (int i = 0; i < chars.length; i++) {
if ('\\' == chars[i]) {
sbStr.append('/');
} else {
sbStr.append(chars[i]);
}
}
ftpPath = sbStr.toString();
if (ftpPath.indexOf('/') == -1) {
// 只有一层目录
ftpClient.changeWorkingDirectory(new String(ftpPath.getBytes(), "iso-8859-1"));
} else {
// 多层目录循环创建
String[] paths = ftpPath.split("/");
for (int i = 0; i < paths.length; i++) {
ftpClient.changeWorkingDirectory(new String(paths[i].getBytes(), "iso-8859-1"));
}
}
return true;
} catch (Exception e) {
return false;
}
}
/**
* 循环创建目录,并且创建完目录后,设置工作目录为当前创建的目录下
*/
public boolean mkDir(String ftpPath) {
if (!ftpClient.isConnected()) {
return false;
}
try {
// 将路径中的斜杠统一
char[] chars = ftpPath.toCharArray();
StringBuffer sbStr = new StringBuffer(256);
for (int i = 0; i < chars.length; i++) {
if ('\\' == chars[i]) {
sbStr.append('/');
} else {
sbStr.append(chars[i]);
}
}
ftpPath = sbStr.toString();
if (ftpPath.indexOf('/') == -1) {
// 只有一层目录
ftpClient.makeDirectory(new String(ftpPath.getBytes(), "iso-8859-1"));
ftpClient.changeWorkingDirectory(new String(ftpPath.getBytes(), "iso-8859-1"));
} else {
// 多层目录循环创建
String[] paths = ftpPath.split("/");
for (int i = 0; i < paths.length; i++) {
ftpClient.makeDirectory(new String(paths[i].getBytes(), "iso-8859-1"));
ftpClient.changeWorkingDirectory(new String(paths[i].getBytes(), "iso-8859-1"));
}
}
return true;
} catch (Exception e) {
return false;
}
}
/**
* 上传文件到FTP服务器
*
* @param localPathAndFileName
* 本地文件目录和文件名
* @param ftpFileName
* 上传后的文件名
* @param ftpDirectory
* FTP目录如:/path1/pathb2/,如果目录不存在回自动创建目录
* @throws Exception
*/
public boolean put(String localDirectoryAndFileName, String ftpFileName, String ftpDirectory) {
if (!ftpClient.isConnected()) {
return false;
}
boolean flag = false;
if (ftpClient != null) {
File srcFile = new File(localDirectoryAndFileName);
FileInputStream fis = null;
try {
fis = new FileInputStream(srcFile);
// 创建目录
this.mkDir(ftpDirectory);
ftpClient.setBufferSize(1024);
ftpClient.setControlEncoding("UTF-8");
// 设置文件类型(二进制)
ftpClient.setFileType(FTPClient.BINARY_FILE_TYPE);
// 上传
flag = ftpClient.storeFile(new String(ftpFileName.getBytes(), "iso-8859-1"), fis);
} catch (Exception e) {
this.close();
return false;
} finally {
IOUtils.closeQuietly(fis);s
}
}
return flag;
}
/**
* 从FTP服务器上下载文件并返回下载文件长度
*
* @param ftpDirectoryAndFileName
* @param localDirectoryAndFileName
* @return
* @throws Exception
*/
public long get(String ftpDirectoryAndFileName, String localDirectoryAndFileName) {
long result = 0;
if (!ftpClient.isConnected()) {
return 0;
}
ftpClient.enterLocalPassiveMode();
try {
// 将路径中的斜杠统一
char[] chars = ftpDirectoryAndFileName.toCharArray();
StringBuffer sbStr = new StringBuffer(256);
for (int i = 0; i < chars.length; i++) {
if ('\\' == chars[i]) {
sbStr.append('/');
} else {
sbStr.append(chars[i]);
}
}
ftpDirectoryAndFileName = sbStr.toString();
String filePath = ftpDirectoryAndFileName.substring(0, ftpDirectoryAndFileName.lastIndexOf("/"));
String fileName = ftpDirectoryAndFileName.substring(ftpDirectoryAndFileName.lastIndexOf("/") + 1);
this.changeDir(filePath);
ftpClient.retrieveFile(new String(fileName.getBytes(), "iso-8859-1"),
new FileOutputStream(localDirectoryAndFileName)); // download
System.out.print(ftpClient.getReplyString()); // check result
} catch (IOException e) {
e.printStackTrace();
}
return result;
}
/**
* 返回FTP目录下的文件列表
*
* @param ftpDirectory
* @return
*/
public List getFileNameList(String ftpDirectory) {
List list = new ArrayList();
if (!open())
return list;
try {
DataInputStream dis = new DataInputStream(ftpClient.nameList(ftpDirectory));
String filename = "";
while ((filename = dis.readLine()) != null) {
list.add(filename);
}
} catch (Exception e) {
e.printStackTrace();
}
return list;
return list;
}
/**
* 删除FTP上的文件
*
* @param ftpDirAndFileName
*/
public boolean deleteFile(String ftpDirAndFileName) {
if (!ftpClient.isConnected()) {
return false;
}
return true;
}
/**
* 删除FTP目录
*
* @param ftpDirectory
*/
public boolean deleteDirectory(String ftpDirectory) {
if (!ftpClient.isConnected()) {
return false;
}
return true;
}
/**
* 关闭链接
*/
public void close() {
try {
if (ftpClient != null && ftpClient.isConnected())
ftpClient.disconnect();
} catch (Exception e) {
e.printStackTrace();
}
}
public FTPClient getFtpClient() {
return ftpClient;
}
public void setFtpClient(FTPClient ftpClient) {
this.ftpClient = ftpClient;
}
}
[转载]Java实现FTP服务器的上传、下载、删除、查看文件列表
最后编辑于 :
©著作权归作者所有,转载或内容合作请联系作者
- 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
- 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
- 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
推荐阅读更多精彩内容
- 任务1:架设ftp网站,实现文件的上传和下载 任务2:用ubuntu偷听win10和winserve2000的上传...
- 最快速简单的实现附件(各种类型文件,doc,word,excel,ppt,pdf,MP4,MP3,apk,等等)上...
- 搭建IIS文件服务器 一、当然,开始肯定没有IIS,那该怎么办?需要一个软件环境进行搭建,具体方法如下:不啰嗦了 ...
- 初学jemeter,找个例子练手。 1.打开jemeter,创建一个线程组 IP 为你FTP服务的IP Remo...
- 废话不多说,直接上干货!首先去下载个 无脑安装起来吧,跟打LOL一样。 第一步: 第二步: 第三步: 第五步: 第...