ftp上传工具类中，我的业务有点复杂，先读取文件进行解析，将解析的某个字段取出来，以这个字段命名文件，把文件复制到服务器，同时把服务器上的文件删除，在进行读取之后，在下载文件的时候出错，需要重新再连接一下ftp就可以下载了
package io.sbed.common.utils;
import com.alibaba.fastjson.JSONObject;
import io.sbed.modules.api.utils.XmlUtil;
import org.apache.commons.lang.StringUtils;
import org.apache.commons.net.ftp.FTP;
import org.apache.commons.net.ftp.FTPClient;
import org.apache.commons.net.ftp.FTPFile;
import org.apache.commons.net.ftp.FTPReply;
import java.io.*;
import java.net.UnknownHostException;
import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.Date;
import java.util.List;
/**
* @Author：liujiawan
* @Date：Created in 2018-08-15 上午 10:01
* @Description
* @Modified By：
*/
public class FtpUtils {
/**
* 字符编码
*/
private static final String DEFAULT_CHARSET = "UTF-8";
/**
* 默认超时间
*/
private static final int DEFAULT_TIMEOUT = 120 * 1000;
/**
* 默认上传目录
*/
private static final String DAILY_FILE_PATH = "aole";
/**
* ftp地址
*/
private final String host;
/**
* 端口号
*/
private final int port;
/**
* 用户名
*/
private final String username;
/**
* 密码
*/
private final String password;
private static FTPClient ftpClient;
private volatile String ftpBasePath;
private static final String OUT_PATH="/4200.IMPBA.SWBEBTRADE.REPORT/out/";
private static final String LOCALPATH="d:"+FileUtils.getStaticPath();
private FtpUtils(String host, String username, String password) {
this(host, 3321, username, password, DEFAULT_CHARSET);
setTimeout(DEFAULT_TIMEOUT, DEFAULT_TIMEOUT, DEFAULT_TIMEOUT);
}
private FtpUtils(String host, int port, String username, String password, String charset) {
ftpClient = new FTPClient();
ftpClient.setControlEncoding(charset);
this.host = StringUtils.isEmpty(host) ? "localhost" : host;
this.port = (port <= 0) ? 21 : port;
this.username = StringUtils.isEmpty(username) ? "anonymous" : username;
this.password = password;
}
/**
* <p>Description:[创建默认的ftp客户端]</p>
* @param host 主机名或者ip地址
* @param username ftp用户名
* @param password ftp密码
*/
public static FtpUtils createFtpClient(String host, String username, String password) {
return new FtpUtils(host, username, password);
}
/**
* <p>Description:[创建自定义属性的ftp客户端]</p>
* @param host 主机名或者ip地址
* @param port ftp端口
* @param username ftp用户名
* @param password ftp密码
* @param charset 字符集
*/
public static FtpUtils createFtpClient(String host, int port, String username, String password, String charset) {
return new FtpUtils(host, port, username, password, charset);
}
/**
* <p>Description:[设置超时时间]</p>
* @param defaultTimeout 超时时间
* @param connectTimeout 超时时间
* @param dataTimeout 超时时间
*/
public void setTimeout(int defaultTimeout, int connectTimeout, int dataTimeout) {
ftpClient.setDefaultTimeout(defaultTimeout);
ftpClient.setConnectTimeout(connectTimeout);
ftpClient.setDataTimeout(dataTimeout);
}
public void connect() throws IOException {
try {
ftpClient.connect(host, port);
} catch (UnknownHostException e) {
throw new IOException("Can't find FTP server :" + host);
}
int reply = ftpClient.getReplyCode();
if (!FTPReply.isPositiveCompletion(reply)) {
disconnect();
throw new IOException("Can't connect to server :" + host);
}
if (!ftpClient.login(username, password)) {
disconnect();
throw new IOException("Can't login to server :" + host);
}
ftpClient.setFileType(FTP.BINARY_FILE_TYPE);
ftpClient.enterLocalPassiveMode();
initFtpBasePath();
}
/**
* <p>Description:[连接ftp时保存刚登陆ftp时的路径]</p>
*/
private void initFtpBasePath() throws IOException {
if (StringUtils.isEmpty(ftpBasePath)) {
synchronized (this) {
if (StringUtils.isEmpty(ftpBasePath)) {
ftpBasePath = ftpClient.printWorkingDirectory();
}
}
}
}
/**
* <p>Description:[ftp是否处于连接状态，是连接状态返回<tt>true</tt>]</p>
* Created on 2018/6/5
*
* @return boolean 是连接状态返回<tt>true</tt>
* @author 叶向阳
*/
public boolean isConnected() {
return ftpClient.isConnected();
}
/**
* <p>Description:[上传文件到对应日期文件下，
* 如当前时间是2018-06-06，则上传到[ftpBasePath]/[DAILY_FILE_PATH]/2018/06/06/下]</p>
* @param fileName 文件名
* @param inputStream 文件输入流
* @return java.lang.String
*/
public String uploadFileToDailyDir(String fileName, InputStream inputStream) throws IOException {
changeWorkingDirectory(ftpBasePath);
SimpleDateFormat dateFormat = new SimpleDateFormat("/yyyy/MM/dd");
String formatDatePath = dateFormat.format(new Date());
String uploadDir = DAILY_FILE_PATH + formatDatePath;
makeDirs(uploadDir);
storeFile(fileName, inputStream);
return formatDatePath + "/" + fileName;
}
/**
* <p>Description:[根据uploadFileToDailyDir返回的路径，从ftp下载文件到指定输出流中]</p>
* @param dailyDirFilePath 方法uploadFileToDailyDir返回的路径
* @param outputStream 输出流
* @author 叶向阳
*/
public void downloadFileFromDailyDir(String dailyDirFilePath, OutputStream outputStream) throws IOException {
changeWorkingDirectory(ftpBasePath);
String ftpRealFilePath = DAILY_FILE_PATH + dailyDirFilePath;
ftpClient.retrieveFile(ftpRealFilePath, outputStream);
}
/**
* <p>Description:[获取ftp上指定文件名到输出流中]</p>
* Created on 2018/6/5
*
* @param ftpFileName 文件在ftp上的路径 如绝对路径 /home/ftpuser/123.txt 或者相对路径 123.txt
* @param out 输出流
* @author 叶向阳
*/
public void retrieveFile(String ftpFileName, OutputStream out) throws IOException {
try {
FTPFile[] fileInfoArray = ftpClient.listFiles(ftpFileName);
if (fileInfoArray == null || fileInfoArray.length == 0) {
throw new FileNotFoundException("File '" + ftpFileName + "' was not found on FTP server.");
}
FTPFile fileInfo = fileInfoArray[0];
if (fileInfo.getSize() > Integer.MAX_VALUE) {
throw new IOException("File '" + ftpFileName + "' is too large.");
}
if (!ftpClient.retrieveFile(ftpFileName, out)) {
throw new IOException("Error loading file '" + ftpFileName + "' from FTP server. Check FTP permissions and path.");
}
out.flush();
} finally {
closeStream(out);
}
}
/**
* <p>Description:[将输入流存储到指定的ftp路径下]</p>
* Created on 2018/6/6
*
* @param ftpFileName 文件在ftp上的路径 如绝对路径 /home/ftpuser/123.txt 或者相对路径 123.txt
* @param in 输入流
* @author 叶向阳
*/
public void storeFile(String ftpFileName, InputStream in) throws IOException {
try {
if (!ftpClient.storeFile(ftpFileName, in)) {
throw new IOException("Can't upload file '" + ftpFileName + "' to FTP server. Check FTP permissions and path.");
}
} finally {
closeStream(in);
}
}
/**
* <p>Description:[根据文件ftp路径名称删除文件]</p>
* Created on 2018/6/6
*
* @param ftpFileName 文件ftp路径名称
* @author 叶向阳
*/
public static void deleteFile(String ftpFileName) throws IOException {
if (!ftpClient.deleteFile(ftpFileName)) {
throw new IOException("Can't remove file '" + ftpFileName + "' from FTP server.");
}
}
/**
* <p>Description:[上传文件到ftp]</p>
* Created on 2018/6/6
*
* @param ftpFileName 上传到ftp文件路径名称
* @param localFile 本地文件路径名称
* @author 叶向阳
*/
public void upload(String ftpFileName, File localFile) throws IOException {
if (!localFile.exists()) {
throw new IOException("Can't upload '" + localFile.getAbsolutePath() + "'. This file doesn't exist.");
}
InputStream in = null;
try {
in = new BufferedInputStream(new FileInputStream(localFile));
if (!ftpClient.storeFile(ftpFileName, in)) {
throw new IOException("Can't upload file '" + ftpFileName + "' to FTP server. Check FTP permissions and path.");
}
} finally {
closeStream(in);
}
}
/**
* <p>Description:[上传文件夹到ftp上]</p>
* @param remotePath ftp上文件夹路径名称
* @param localPath 本地上传的文件夹路径名称
*/
public void uploadDir(String remotePath, String localPath) throws IOException {
localPath = localPath.replace("\\\\", "/");
File file = new File(localPath);
if (file.exists()) {
if (!ftpClient.changeWorkingDirectory(remotePath)) {
ftpClient.makeDirectory(remotePath);
ftpClient.changeWorkingDirectory(remotePath);
}
File[] files = file.listFiles();
if (null != files) {
for (File f : files) {
if (f.isDirectory() && !".".equals(f.getName()) && !"..".equals(f.getName())) {
uploadDir(remotePath + "/" + f.getName(), f.getPath());
} else if (f.isFile()) {
upload(remotePath + "/" + f.getName(), f);
}
}
}
}
}
/**
* <p>Description:[下载ftp文件到本地上]</p>
* Created on 2018/6/6
*
* @param ftpFileName ftp文件路径名称
* @param localFile 本地文件路径名称
* @author 叶向阳
*/
public static void download(String ftpFileName, File localFile) throws IOException {
OutputStream out = null;
try {
FTPFile[] fileInfoArray = ftpClient.listFiles(ftpFileName);
if (fileInfoArray == null || fileInfoArray.length == 0) {
throw new FileNotFoundException("File " + ftpFileName + " was not found on FTP server.");
}
FTPFile fileInfo = fileInfoArray[0];
if (fileInfo.getSize() > Integer.MAX_VALUE) {
throw new IOException("File " + ftpFileName + " is too large.");
}
out = new BufferedOutputStream(new FileOutputStream(localFile));
if (!ftpClient.retrieveFile(ftpFileName, out)) {
throw new IOException("Error loading file " + ftpFileName + " from FTP server. Check FTP permissions and path.");
}
out.flush();
} finally {
closeStream(out);
}
}
/**
* <p>Description:[改变工作目录]</p>
* Created on 2018/6/6
*
* @param dir ftp服务器上目录
* @return boolean 改变成功返回true
* @author 叶向阳
*/
public boolean changeWorkingDirectory(String dir) {
if (!ftpClient.isConnected()) {
return false;
}
try {
return ftpClient.changeWorkingDirectory(dir);
} catch (IOException e) {
}
return false;
}
/**
* <p>Description:[下载ftp服务器下文件夹到本地]</p>
* @param remotePath ftp上文件夹路径名称
* @param localPath 本地上传的文件夹路径名称
* @return void
*/
public static void downloadDir(String remotePath, String localPath) throws IOException {
localPath = localPath.replace("\\\\", "/");
File file = new File(localPath);
if (!file.exists()) {
file.mkdirs();
}
FTPFile[] ftpFiles = ftpClient.listFiles(remotePath);
for (int i = 0; ftpFiles != null && i < ftpFiles.length; i++) {
FTPFile ftpFile = ftpFiles[i];
if (ftpFile.isDirectory() && !".".equals(ftpFile.getName()) && !"..".equals(ftpFile.getName())) {
downloadDir(remotePath + "/" + ftpFile.getName(), localPath + "/" + ftpFile.getName());
} else {
download(remotePath + "/" + ftpFile.getName(), new File(localPath + "/" + ftpFile.getName()));
}
}
}
/**
* <p>Description:[列出ftp上文件目录下的文件]</p>
* @param filePath ftp上文件目录
* @return java.util.List<java.lang.String>
*/
public List<String> listFileNames(String filePath) throws IOException {
FTPFile[] ftpFiles = ftpClient.listFiles(filePath);
List<String> fileList = new ArrayList<>();
if (ftpFiles != null) {
for (int i = 0; i < ftpFiles.length; i++) {
FTPFile ftpFile = ftpFiles[i];
if (ftpFile.isFile()) {
fileList.add(ftpFile.getName());
}
}
}
return fileList;
}
/**
* <p>Description:[发送ftp命令到ftp服务器中]</p>
* Created on 2018/6/6
*
* @param args ftp命令
*/
public void sendSiteCommand(String args) throws IOException {
if (!ftpClient.isConnected()) {
ftpClient.sendSiteCommand(args);
}
}
/**
* <p>Description:[获取当前所处的工作目录]</p>
* @return java.lang.String 当前所处的工作目录
*/
public String printWorkingDirectory() {
if (!ftpClient.isConnected()) {
return "";
}
try {
return ftpClient.printWorkingDirectory();
} catch (IOException e) {
// do nothing
}
return "";
}
/**
* <p>Description:[切换到当前工作目录的父目录下]</p>
* @return boolean 切换成功返回true
*/
public boolean changeToParentDirectory() {
if (!ftpClient.isConnected()) {
return false;
}
try {
return ftpClient.changeToParentDirectory();
} catch (IOException e) {
// do nothing
}
return false;
}
/**
* <p>Description:[返回当前工作目录的上一级目录]</p>
* @return java.lang.String 当前工作目录的父目录
*/
public String printParentDirectory() {
if (!ftpClient.isConnected()) {
return "";
}
String w = printWorkingDirectory();
changeToParentDirectory();
String p = printWorkingDirectory();
changeWorkingDirectory(w);
return p;
}
/**
* <p>Description:[创建目录]</p>
* @param pathname 路径名
* @return boolean 创建成功返回true
*/
public boolean makeDirectory(String pathname) throws IOException {
return ftpClient.makeDirectory(pathname);
}
/**
* <p>Description:[创建多个目录]</p>
* @param pathname 路径名
*/
public void makeDirs(String pathname) throws IOException {
pathname = pathname.replace("\\\\", "/");
String[] pathnameArray = pathname.split("/");
for (String each : pathnameArray) {
if (StringUtils.isNotEmpty(each)) {
ftpClient.makeDirectory(each);
ftpClient.changeWorkingDirectory(each);
}
}
}
/**
* <p>Description:[关闭流]</p>
* Created on 2018/6/6
* @param stream 流
*/
private static void closeStream(Closeable stream) {
if (stream != null) {
try {
stream.close();
} catch (IOException ex) {
// do nothing
}
}
}
/**
* <p>Description:[关闭ftp连接]</p>
*/
public void disconnect() {
if (null != ftpClient && ftpClient.isConnected()) {
try {
ftpClient.logout();
ftpClient.disconnect();
} catch (IOException ex) {
// do nothing
}
}
}
public static void main(String[] args) throws IOException {
FtpUtils ftpCli = FtpUtils.createFtpClient("", "nstest01", "nstest01");
ftpCli.connect();
File file = new File("D:\\a.xml");
ftpCli.upload("a.xml", file);
}
public static void readFtpDir() throws Exception {
FtpUtils ftpCli = FtpUtils.createFtpClient("", "nstest01", "nstest01");
ftpCli.connect();
FTPFile[] ftpFiles = ftpClient.listFiles(OUT_PATH);
JSONObject jsonObject=null;
for (int i = 0; ftpFiles != null && i < ftpFiles.length; i++) {
FTPFile ftpFile = ftpFiles[i];
if (!ftpFile.isDirectory()){
String temp=readXmlToString(OUT_PATH+ftpFile.getName(),ftpClient);
jsonObject= XmlUtil.xmltoJson(temp);
jsonObject= (JSONObject) jsonObject.get("ROOT");
jsonObject= (JSONObject) jsonObject.get("Declaration");
if("10".equals(jsonObject.get("Status").toString())){
ftpCli.connect();
download(OUT_PATH+ftpFile.getName(), new File(LOCALPATH + "/" + jsonObject.get("OrgMessageID").toString()+".xml"));
deleteFile(OUT_PATH+ftpFile.getName());
}
}
}
}
public static String readXmlToString(String ftpFile, FTPClient ftp) {
StringBuffer buffer=new StringBuffer("");
String str = "";
InputStream is = null;
BufferedReader br = null;
try {
// 获取ftp上的文件
is = ftp.retrieveFileStream(ftpFile);
//转为字节流
br = new BufferedReader(new InputStreamReader(is));
while((str=br.readLine())!=null){
buffer.append(str);
}
br.close();
} catch (IOException e) {
e.printStackTrace();
}
return buffer.toString();
}
}