public classFTPUtils {private static final Logger LOG = LoggerFactory.getLogger(FTPUtils.class);/*** 获取FTPClient对象

*

*@paramftpHost FTP主机服务器

*@paramftpPassword FTP 登录密码

*@paramftpUserName FTP登录用户名

*@paramftpPort FTP端口 默认为21

*@return

*/

private staticFTPClient getFTPClient(String ftpHost, String ftpPassword,

String ftpUserName,int ftpPort) throwsIOException {

FTPClient ftpClient= null;

ftpClient= newFTPClient();

ftpClient.connect(ftpHost, ftpPort);//连接FTP服务器

ftpClient.login(ftpUserName, ftpPassword);//登陆FTP服务器

if (!FTPReply.isPositiveCompletion(ftpClient.getReplyCode())) {

LOG.info("未连接到FTP，用户名或密码错误。");

ftpClient.disconnect();

}else{

LOG.info("FTP连接成功。");

}returnftpClient;

}/*** 去 服务器的FTP路径下上读取文件

*

*@paramftpPath

*@param*@return

*/

public static ListreadConfigFileForFTP(String ftpPath, String ftpHost, String ftpPassword,

String ftpUserName,intftpPort) {

InputStream in;

FTPClient ftpClient= null;try{

ftpClient=getFTPClient(ftpHost, ftpPassword, ftpUserName, ftpPort);

List list = new ArrayList<>();

LOG.info("开始读取绝对路径" + ftpPath + "文件!");try{

ftpClient.setControlEncoding("UTF-8"); //中文支持

ftpClient.setFileType(FTPClient.BINARY_FILE_TYPE);

ftpClient.enterLocalPassiveMode();

ftpClient.changeWorkingDirectory(ftpPath);

FTPFile[] ftpFiles=ftpClient.listFiles(ftpPath);for(FTPFile file : ftpFiles) {

String name=file.getName();

in= ftpClient.retrieveFileStream(new String(name.getBytes("UTF-8"), "ISO-8859-1"));if (in != null) {

StringBuffer resultBuffer= newStringBuffer();

BufferedReader br= new BufferedReader(newInputStreamReader(in));

String data;try{while ((data = br.readLine()) != null) {

resultBuffer.append(data);

}

String string=resultBuffer.toString();

JSONArray jsonArray=JSONArray.parseArray(string);

list.add(jsonArray);

in.close();boolean flag =ftpClient.deleteFile(name);if(flag) {

System.out.println("删除文件成功");

}

ftpClient.completePendingCommand();

}catch(IOException e) {

LOG.error("文件读取错误。");

e.printStackTrace();

}

}else{

LOG.error("in为空，不能读取。");

}

}

}catch(FileNotFoundException e) {

LOG.error("没有找到" + ftpPath + "文件");

e.printStackTrace();

}catch(SocketException e) {

LOG.error("连接FTP失败.");

e.printStackTrace();

}catch(IOException e) {

e.printStackTrace();

LOG.error("文件读取错误。");

}returnlist;

}catch(SocketException e) {

LOG.info("FTP的IP地址可能错误，请正确配置。");

}catch(IOException e) {

LOG.info("FTP的端口错误,请正确配置。");

}return null;

}/*** * 删除文件 *

*

*@parampathname FTP服务器保存目录 *

*@paramfilename 要删除的文件名称 *

*@return

*/

private static voiddeleteFile(String pathname, String filename, FTPClient ftpClient) {try{

System.out.println("开始删除文件");//切换FTP目录

ftpClient.changeWorkingDirectory(pathname);boolean flag =ftpClient.deleteFile(filename);

ftpClient.logout();if(flag) {

System.out.println("删除文件成功");

}

}catch(Exception e) {

System.out.println("删除文件失败");

e.printStackTrace();

}finally{if(ftpClient.isConnected()) {try{

ftpClient.disconnect();

}catch(IOException e) {

e.printStackTrace();

}

}

}

}

}