package cn.ipanel.app.newspapers.util;
import java.io.BufferedReader;
import java.io.DataInputStream;
import java.io.File;
import java.io.FileInputStream;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.RandomAccessFile;
import java.util.ArrayList;
import java.util.Iterator;
import java.util.List;
import java.util.StringTokenizer;
import org.apache.log4j.Logger;
import sun.net.TelnetInputStream;
import sun.net.TelnetOutputStream;
import sun.net.ftp.FtpClient;
/**
* FTP工具类<br>
* 注：上传，可上传文件、文件夹；下载，仅实现下载文件功能，不能识别子文件夹
* @version 1.0.0
*/
public class FtpUtil
{
private static Logger logger = Logger.getLogger(FtpUtil.class);
private FtpClient ftpClient;
/**
* 连接FTP服务器，使用默认FTP端口
* @since
* @param serverIp
* 服务器Ip地址
* @param user
* 登陆用户
* @param password
* 密码
* @throws IOException
*/
public void connect(String serverIp, String user, String password)
throws Exception
{
try
{
ftpClient =
new FtpClient();
ftpClient.openServer(serverIp);
ftpClient.login(user, password);
ftpClient.binary();
}
catch (Exception ex)
{
throw new Exception(ex);
}
}
/**
* 连接ftp服务器，指定端口
* @since
* @param serverIp
* @param port
* 服务器FTP端口号
* @param user
* @param password
* @throws IOException
*/
public void connect(String serverIp,
int port, String user, String password)
throws Exception
{
try
{
ftpClient =
new FtpClient();
ftpClient.openServer(serverIp, port);
ftpClient.login(user, password);
ftpClient.binary();
}
catch (Exception ex)
{
throw new Exception(ex);
}
}
/**
* 断开与ftp服务器的连接
* @since
* @throws IOException
*/
public void disConnect()
throws Exception
{
try
{
if (ftpClient !=
null)
{
ftpClient.sendServer(
"QUIT\r\n");
ftpClient.readServerResponse();
}
}
catch (IOException ex)
{
logger.error(
"DisConnect to FTP server failure! Detail:", ex);
throw new Exception(ex);
}
}
/**
* 上传文件至FTP服务器，保持原文件名
*
* @throws java.lang.Exception
* @return -1 文件不存在或不能读取; >0 成功上传，返回文件的大小
* @param localFile
* 待上传的本地文件
*/
public long upload(File localFile)
throws Exception
{
if (localFile ==
null)
{
return -
1;
}
return this.upload(localFile, localFile.getName());
}
/**
* 上传文件至FTP服务器，保持原文件名
*
* @throws java.lang.Exception
* @return -1 文件不存在或不能读取; >0 成功上传，返回文件的大小
* @param localFilePath
* 待上传的本地文件路径
*/
public long upload(String localFilePath)
throws Exception
{
return this.upload(
new File(localFilePath));
}
/**
* 上传文件至FTP服务器，并重命名文件
*
* @throws java.lang.Exception
* @return -1 文件不存在或不能读取; >0 成功上传，返回文件的大小
* @param localFilePath
* 待上传的本地文件路径
* @param rename
* 远程文件重命名
*/
public long upload(String localFilePath, String rename)
throws Exception
{
return this.upload(
new File(localFilePath), rename);
}
/**
* 上传文件至FTP服务器，并重命名文件
*
* @throws java.lang.Exception
* @return -1 文件不存在或不能读取; >0 成功上传，返回文件的大小
* @param localFile
* 待上传的本地文件
* @param rename
* 远程文件重命名
*/
public long upload(File localFile, String rename)
throws Exception
{
if (localFile ==
null || !localFile.exists() || !localFile.canRead())
{
return -
1;
}
long fileSize = localFile.length();
try
{
if (localFile.isDirectory())
{
ftpClient.sendServer(
"XMKD " + rename +
"\r\n");
ftpClient.readServerResponse();
File[] subFiles = localFile.listFiles();
ftpClient.cd(rename);
try
{
for (
int i =
0; i < subFiles.length; i++)
{
fileSize += upload(subFiles[i]);
}
}
finally
{
ftpClient.cdUp();
}
}
else
{
this.writeFileToServer(localFile, rename);
}
return fileSize;
}
catch (Exception ex)
{
throw new Exception(ex);
}
}
/**
* 从ftp下载文件到本地
*
* @throws java.lang.Exception
* @return
* @param localFilePath
* 本地生成的文件名
* @param remoteFilePath
* 服务器上的文件名
*/
public long download(String remoteFilePath, String localFilePath)
throws Exception
{
long result =
0;
TelnetInputStream tis =
null;
RandomAccessFile raf =
null;
DataInputStream puts =
null;
try
{
tis = ftpClient.get(remoteFilePath);
raf =
new RandomAccessFile(
new File(localFilePath),
"rw");
raf.seek(
0);
int ch;
puts =
new DataInputStream(tis);
while ((ch = puts.read()) >=
0)
{
raf.write(ch);
}
}
catch (Exception ex)
{
logger.error(
"Downloading file failure! Detail:", ex);
throw new Exception(ex);
}
finally
{
try
{
puts.close();
if (tis !=
null)
{
tis.close();
}
if (raf !=
null)
{
raf.close();
}
}
catch (Exception ex)
{
throw new Exception(ex);
}
}
return result;
}
/**
* 设置FTP服务器的当前路径<br>
* 可以是绝对路径，也可以是相对路径
* @since
* @param dirPath
* 服务器文件夹路径，空代表ftp根目录
* @throws IOException
*/
public void cd(String dirPath)
throws Exception
{
try
{
if (dirPath !=
null && dirPath.length() >
0)
{
ftpClient.cd(dirPath);
}
}
catch (Exception ex)
{
throw new Exception(ex);
}
}
/**
* 在服务器上创建指定路径的目录，并转到此目录
* @since
* @param dirPath
* @throws Exception
*/
public void mkd(String dirPath)
throws Exception
{
try
{
if (dirPath !=
null && dirPath.length() >
0)
{
StringTokenizer st =
new StringTokenizer(dirPath.replaceAll(
"\\\\",
"/"),
"/");
String dirName =
"";
while (st.hasMoreElements())
{
dirName = (String) st.nextElement();
ftpClient.sendServer(
"XMKD " + dirName +
"\r\n");
ftpClient.readServerResponse();
ftpClient.cd(dirName);
}
}
}
catch (Exception ex)
{
throw new Exception(ex);
}
}
/**
* 删除FTP服务器目录
* @since
* @param directory
* @throws Exception
*/
public void rmd(String directory)
throws Exception
{
try
{
if (directory !=
null && directory.length() >
0)
{
ftpClient.cd(directory);
try
{
this.cld();
}
finally
{
ftpClient.cdUp();
}
ftpClient.sendServer(
"XRMD " + directory +
"\r\n");
ftpClient.readServerResponse();
}
}
catch (Exception ex)
{
throw new Exception(ex);
}
}
/**
* 清空当前目录
* @since
* @throws Exception
*/
public void cld()
throws Exception
{
for (Iterator<String> it = getFileList().iterator(); it.hasNext();)
{
this.delf(it.next());
}
for (Iterator<String> it = getDirList().iterator(); it.hasNext();)
{
this.rmd(it.next());
}
}
/**
* 删除FTP服务器文件
* @since
* @param filePath
* @throws Exception
*/
public void delf(String filePath)
throws Exception
{
try
{
if (filePath !=
null && filePath.length() >
0)
{
ftpClient.sendServer(
"DELE " + filePath +
"\r\n");
ftpClient.readServerResponse();
}
}
catch (Exception ex)
{
throw new Exception(ex);
}
}
/**
* 以指定文件名，将本地文件写到FTP服务器
* @since
* @param localFile
* 待上传的本地文件
* @param fileName
* 写入远程FTP服务器的文件名
* @throws Exception
*/
private void writeFileToServer(File localFile, String fileName)
throws Exception {
TelnetOutputStream tos =
null;
FileInputStream fis =
new FileInputStream(localFile);
try {
tos = ftpClient.put(fileName);
byte[] bytes =
new byte[
102400];
int c;
while ((c = fis.read(bytes)) != -
1) {
tos.flush();
tos.write(bytes,
0, c);
}
}
catch (Exception ex) {
throw new Exception(ex);
}
finally {
if (fis !=
null) {
fis.close();
}
if (tos !=
null) {
tos.flush();
tos.close();
}
}
}
/**
* 取得FTP上某个目录下的所有文件名列表
*
* @since
* @return
* @throws Exception
*/
public List<String>
getFileList()
throws Exception
{
List<String> fileList =
new ArrayList<String>();
BufferedReader br =
null;
try
{
String fileItem;
br =
new BufferedReader(
new InputStreamReader(ftpClient.list()));
while ((fileItem = br.readLine()) !=
null)
{
if (fileItem.startsWith(
"-") && !fileItem.endsWith(
".") && !fileItem.endsWith(
".."))
{
fileList.add(parseFileName(fileItem));
}
}
}
catch (Exception ex)
{
logger.error(
"Failure to get directory list from ftp server!", ex);
throw new Exception(ex);
}
finally
{
if (br !=
null)
{
try
{
br.close();
}
catch (Exception ex)
{
throw new Exception(ex);
}
}
}
return fileList;
}
/**
* 取得FTP上某个目录下的所有子文件夹名列表
*
* @since
* @return
* @throws Exception
*/
public List<String>
getDirList()
throws Exception
{
List<String> dirList =
new ArrayList<String>();
BufferedReader br =
null;
try
{
String fileItem;
br =
new BufferedReader(
new InputStreamReader(ftpClient.list()));
while ((fileItem = br.readLine()) !=
null)
{
if (fileItem.startsWith(
"d") && !fileItem.endsWith(
".") && !fileItem.endsWith(
".."))
{
dirList.add(parseFileName(fileItem));
}
}
}
catch (Exception ex)
{
logger.info(
"Failure to get directory list from ftp server!", ex);
throw new Exception(ex);
}
finally
{
if (br !=
null)
{
try
{
br.close();
}
catch (Exception ex)
{
throw new Exception(ex);
}
}
}
return dirList;
}
/**
* 从文件信息中解析出文件（文件夹）名
*
* @since
* @param fileItem
* @return
* @throws Exception
*/
private String
parseFileName(String fileItem)
throws Exception
{
StringTokenizer st =
new StringTokenizer(fileItem);
int index =
0;
while (st.hasMoreTokens())
{
if (index <
8)
{
st.nextToken();
}
else
{
return st.nextToken(
"").trim();
}
index++;
}
return null;
}
/**
* 上传下载测试
*
* @since
* @param args
* @throws Exception
*/
public static void main(String[] args)
throws Exception
{
FtpUtil ftp =
new FtpUtil();
try
{
ftp.connect(
"xx.xx.xx.xx",
"ftp",
"ftp");
ftp.cd(
"/home/sasftp");
List<String> list =
new ArrayList<String>();
list.add(
"czybxw.txt");
list.add(
"zjyb.txt");
for (
int i =
0; i < list.size(); i++)
{
String fileName = (String) list.get(i);
System.out.println(fileName);
ftp.download(fileName,
"E:\\text" + File.separator + fileName);
}
}
catch (Exception ex)
{
logger.error(
"Uploading file failure! Detail:", ex);
}
finally
{
ftp.disConnect();
}
}
}
转载于:https://www.cnblogs.com/bilaisheng/p/10210964.html
相关资源：JAVA上百实例源码以及开源项目
