自动扫描FTP文件工具类 ScanFtp.java

package com.util;
import java.io.BufferedInputStream;
import java.io.BufferedOutputStream;
import java.io.File;
import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.io.IOException;
/**
* 自动扫描FTP文件工具类
* 需要定时执行
*/
public class ScanFtp {
//服务器图片路径文件夹
private String serverLocal = "D:/TOOLS/Tomcat 6.0/webapps/BCCCSM/modelforcast/";
//图片上传文件夹存放路径,文件夹内应包含AGCM CSM ZS 3个子文件夹分别存放需要扫描到tomcat中的图片
private String saveLocal = "D:/modelForcast/";
/**
* 获得远程权限
* @return
*/
private void getFTPAdress(){
//登陆成功
}
/**
* 开始扫描
* @throws IOException
*/
private void scan() throws IOException {
this.getFTPAdress();
File file = new File(saveLocal + "AGCM"); //打开AGCM
File[] array = file.listFiles();
String fileName;
File fileTemp;
for(int i = 0; i < array.length; i++){
if(array[i].isFile()) {
fileTemp = array[i];
fileName = fileTemp.getName();//取出文件名
if (!fileName.equals("humbs.db")) {
this.saveFile(fileTemp, 1);//分析每一个文件名字并存储
System.out.println(fileName + " saved");
}
}
}
file = new File(saveLocal + "CSM"); //打开CSM
array = file.listFiles();
for(int i = 0; i < array.length; i++){
if(array[i].isFile()) {
fileTemp = array[i];
fileName = fileTemp.getName();//取出文件名
if (!fileName.equals("humbs.db")) {
this.saveFile(fileTemp, 2);//分析每一个文件名字并存储
System.out.println(fileName + " saved");
}
}
}
file = new File(saveLocal + "ZS"); //打开ZS
array = file.listFiles();
for(int i = 0; i < array.length; i++){
if(array[i].isFile()) {
fileTemp = array[i];
fileName = fileTemp.getName();//取出文件名
if (!fileName.equals("humbs.db")) {
this.saveFile(fileTemp, 3);//分析每一个文件名字并存储
System.out.println(fileName + " saved");
}
}
}
}
/**
* 开始执行
* @throws IOException
*/
public void execute() throws IOException{
scan();//开始扫描
}
/**
* 按类型存储
* @param file
* @param type
* @throws IOException
*/
private void saveFile(File file, int type) throws IOException {
String fileName = file.getName();
//类型A C 和指数3种
String year = fileName.substring(1, 5);//获得发布年份
String date = fileName.substring(5, 9);//获得发布日期包含月日
String var = null;//获得变量名字
String dir = serverLocal;//存储目录名字
if (type == 1 ) {
var = fileName.substring(11, 15);
dir = dir + "AGCM/" + var + "/" + year + "/" + date;
} else if(type == 2) {
var = fileName.substring(11, 15);
dir = dir + "CSM/" + var + "/" + year + "/" + date;
} else {
var = fileName.substring(11, 15);//指数的暂时没处理
dir = dir + "ZS/" + var + "/" + year + "/" + date;
}
//判断是否存在这样的目录没有就自动创建
File savePath = new File(dir);
if(!savePath.exists()) {
savePath.mkdirs();
}
File saveFile = new File(dir + "/" + fileName);
if(!saveFile.exists()){//如果不存在,就存文件
FileInputStream fis = null;//这里用本地复制暂时代替FTP
FileOutputStream fos =null;
BufferedInputStream bis =null;
BufferedOutputStream bos =null;
int c;
fis = new FileInputStream(file);
bis = new BufferedInputStream(fis);
fos = new FileOutputStream(dir + "/" + fileName);
bos = new BufferedOutputStream(fos);
while((c = bis.read())!= -1)
bos.write(c);
bos.flush();
if(bos != null) bos.close();
if(bis != null) bis.close();
if(fos != null) fos.close();
if(fis != null) fos.close();
} else {
System.out.println("文件已经存在,不进行存储,可清理当前文件.");
}
}
/**
* 测试方法
* @param argv
* @throws IOException
*/
public static void main(String argv[]) {
ScanFtp s = new ScanFtp();
try {
s.scan();
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}

时间： 2024-10-10 17:42:25

自动扫描FTP文件工具类 ScanFtp.java的相关文章

读取Config文件工具类 PropertiesConfig.java

package com.util; import java.io.BufferedInputStream; import java.io.FileInputStream; import java.io.InputStream; import java.util.Properties; /** * 读取Config文件工具类 * @version 1.0 * @since JDK 1.6 */ public class PropertiesConfig { /** * 获取整个配置文件中的属性 *

java中IO写文件工具类

下面是一些根据常用java类进行组装的对文件进行操作的类,平时,我更喜欢使用Jodd.io中提供的一些对文件的操作类,里面的方法写的简单易懂. 其中jodd中提供的JavaUtil类中提供的方法足够我们使用,里面的方法写的非常简练,例如append,read等方法,封装更好,更符合面向对象, 这里面我写的一些方法可多都是模仿jodd,从里面进行抽取出来的. /** * 获取路径文件夹下的所有文件 * @param path * @return */ public static File[] ge

【工具类】JAVA 以行为单位读取文件并比对

package test20140709; import java.io.BufferedReader; import java.io.File; import java.io.FileReader; import java.io.IOException; import java.util.ArrayList; import java.util.List; /** * 以行为单位读取文件并比对,显示不同行 * @author fushihua-wb * @date 2014-7-11 */ pu

Java 通过Xml导出Excel文件，Java Excel 导出工具类，Java导出Excel工具类

Java 通过Xml导出Excel文件,Java Excel 导出工具类,Java导出Excel工具类 ============================== ?Copyright 蕃薯耀 2017年9月13日 http://www.cnblogs.com/fanshuyao/ 直接上代码: import java.io.IOException; import java.lang.reflect.InvocationTargetException; import java.lang.ref

java生成excel文件工具类实例

import java.io.File; import java.io.IOException; import jxl.Workbook; import jxl.write.Label; import jxl.write.WritableSheet; import jxl.write.WritableWorkbook; import jxl.write.WriteException; import jxl.write.biff.RowsExceededException; import org.

java常用工具类（java技术交流群57388149）

package com.itjh.javaUtil; import java.util.ArrayList; import java.util.List; /** * * String工具类. <br> * * @author 宋立君 * @date 2014年06月24日 */ public class StringUtil { private static final int INDEX_NOT_FOUND = -1; private static final String EMPTY =

Java字符串转16 进制工具类Hex.java

原文:Java字符串转16 进制工具类Hex.java 源代码下载地址:http://www.zuidaima.com/share/1550463378410496.htm Java 字符串转 16 进制工具类 Hex.java 实现 16进制 0xfecd .. 和 java 字符串之间的互转换! 如果做开发,通常用户登陆密码都会 mad5(salt + pwd) 然后再将 md 之后的数据 hex 一下. 这个工具类,就是实现此效果的. /* * */ package com.zuidaim

UrlUtils工具类，Java URL工具类，Java URL链接工具类

UrlUtils工具类,Java URL工具类,Java URL链接工具类 >>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>> ?Copyright 蕃薯耀 2017年7月15日 http://www.cnblogs.com/fanshuyao/ Java代码 import java.util.Ha

Java日期工具类，Java时间工具类，Java时间格式化

Java日期工具类,Java时间工具类,Java时间格式化 >>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>> ?Copyright 蕃薯耀 2017年2月4日 15:03:27 星期六 http://www.cnblogs.co