/**
* 建立FTP链接，FTP服务器地址、端口、登陆用户信息都在配置里配置即可。
* @throws IOException
*/
public boolean connectFtp(String ftpAddress, String ftpPort, String frpUserName, String frpPassword) throws IOException{
log.info("*****连接FTP服务器...*****");
try{
ftpClient.connect(ftpAddress, Integer.valueOf(ftpPort).intValue());
ftpClient.setControlEncoding("GB2312");
int reply = ftpClient.getReplyCode();
if(FTPReply.isPositiveCompletion(reply)){
if(ftpClient.login(frpUserName,frpPassword)){
log.info("*****连接FTP服务器成功！*****");
return true;
}
}else{
log.error("*****连接失败!响应代码为【"+ reply+"】*****");
}
disconnect();
}catch (Exception e) {
log.error("*****连接失败：" + e.getMessage());
}
return false;
} /**
* 设置FTP客户端 被动模式、数据模式为二进制、字符编码GBK
*/
public void setConnectType(){
try {
ftpClient.enterLocalPassiveMode();
ftpClient.setDefaultTimeout(1000 * 120);//120秒
ftpClient.setFileType(FTP.BINARY_FILE_TYPE);
ftpClient.setControlEncoding("GB2312");
} catch (IOException e) {
e.printStackTrace();
}
} /**
* 断开与远程服务器的连接
* @throws IOException
*/
public void disconnect() {
if(ftpClient.isConnected()){
try {
ftpClient.disconnect();
} catch (IOException e) {
e.printStackTrace();
}
}
} /**
* 过滤不符合的文件并批量下载
* @param remoteFileReg 文件前缀的正则表达式
* @param localPath 本地路径 .property 文件配置
* @param remote_down_path ftp文件路径
* @return List 下载到本地的文件路径 集合
* @throws IOException
*/
@SuppressWarnings("unchecked")
public List downloads(String remoteFileReg,String localPath,String remote_down_path) throws IOException{
List<String> fileNames = new ArrayList<String>();
log.info("*****转移到服务器目录：" + remote_down_path);
setConnectType();
boolean changeFlag = ftpClient.changeWorkingDirectory(remote_down_path);
FTPFile[] files = ftpClient.listFiles();
//String[] names = ftpClient.listNames();
log.info("*****改变目录是否成功：" + changeFlag);
log.info("*****服务器上report目录下所有校验报告的文件数为：【" +files.length + "】" );
if(files.length == 0){
log.info("*****未在服务器上找到文件！*****");
return null;
}else{//目录下有文件
//把 bak文件的前缀找出来 ，区分读取和未读取的xls 和 xlsx ,只下载 未读取的文件
List<String> bakList = new ArrayList<String>();
List<String> list = new ArrayList<String>(); for (int i = 0; i < files.length; i++) {
FTPFile ftpFile = files[i];
String fileName = ftpFile.getName(); if(!fileName.endsWith(".bak") && ftpFile == null){
log.info("******* "+ fileName + "文件无数据!");
continue;
}
//匹配指定的文件前缀 和后缀 为 .bak 格式的文件
//bak 文件是文件读取完毕后生成的标记文件
Pattern bak = Pattern.compile("^"+remoteFileReg+"\\.bak");
Matcher m = bak.matcher(fileName);
if (m.find()) {
//取.bak文件的 前缀
//System.out.println(fileName);
//System.out.println(fileName.split("\\.")[0]);
bakList.add(fileName.split("\\.")[0]);
continue;
} //匹配指定的文件前缀 和后缀 为 .xls .xlsx 格式的文件
//TODO 以后遇到其他的格式文件 需要把后缀抽出来作为参数传入
Pattern xls = Pattern.compile("^"+remoteFileReg+"\\.xls$"+"|"+"^"+remoteFileReg+"\\.xlsx$"+"|"+"^"+remoteFileReg+"\\.csv$");
Matcher mm = xls.matcher(fileName);
if(mm.find()){
list.add(fileName);
continue;
}
} Iterator<String> it = list.iterator();
while (it.hasNext()) {
String xls = it.next();
for (int i = 0; i < bakList.size(); i++) {
String bak = bakList.get(i);
//bak文件存在 , 去掉此文件
if (xls.indexOf(bak) !=-1) {
it.remove();
bakList.remove(i);
}
}
} for (String fFile : list) {
//下载未读取的文件
File downFile = new File(localPath + fFile);
//System.out.println(localPath);
File downPath = new File(localPath);
if(!downPath.exists()){
downPath.mkdirs();
}
String fileDir = remote_down_path + fFile;
OutputStream os = new FileOutputStream(downFile);
ftpClient.retrieveFile(new String(fileDir.getBytes("GB2312"),"ISO-8859-1"), os);
log.info("*****文件已下载到：" + downFile.getAbsolutePath() + "******");
fileNames.add(downFile.getAbsolutePath());
os.close();
}
log.info("**** 此次共下载了【"+list.size()+"】个文件! *****");
}
return fileNames;
} /**
* 上传标志文件
* @param remoteFile
* @param localFile
* @return
*/
public boolean upload(String localFileName,String remoteFileName){ boolean b = false;
try {
File file = new File(localFileName);
FileInputStream input = new FileInputStream(file);
b = ftpClient.changeWorkingDirectory(remoteFileName);
log.info("*****改变目录是否成功：" + b);
String remoteFile = remoteFileName + file.getName();
b = ftpClient.storeFile(new String(remoteFile.getBytes("GB2312"),"ISO-8859-1"), input);
if(b){
log.info(" ****** 标志文件"+localFileName+"上传成功!");
}
input.close();
} catch (FileNotFoundException e) {
e.printStackTrace();
} catch (IOException e) {
e.printStackTrace();
}
return b;
}