workertask.java

这是一个实施监控程序, 这是一个实施监控程序,

package com.util.task;

import java.io.File;
import java.io.FilenameFilter;
import java.io.IOException;
import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.Date;
import java.util.Iterator;
import java.util.List;
import java.util.TimerTask;

import org.jdom.JDOMException;


public class WorkerTask extends TimerTask {
	//private final Timer timer=new Timer();
	
	private String typePath="";
	
	private JDOMParser jdom=new JDOMParser();
	private java.util.Timer timer =new java.util.Timer(true);
		
	 public WorkerTask(String globalType)
		{ 
			this.typePath=globalType;
		}
	public  void run(){
			System.out.println("监测任务正在执行....");
					List xmlList=jdom.hasMoreXML(typePath);
					if(xmlList!=null&&xmlList.size()>0){
						//List list_file=this.getExistFiles(typePath);
						//System.out.println(xmlList.size());
						///int flag=0;
						//for(int i=0;i<list_file.size();i++){
						List list_Rec=null;
							for(Iterator it=xmlList.iterator();it.hasNext();){
							
								String file=(String) it.next();
								//System.out.println("3333333333"+file);
								jdom.setFilePath(file);
								//boolean succ;
								//List list=null;
									//try {
										// jdom.parser(file);
									
									//} catch (Exception e) {
										// TODO Auto-generated catch block
										//System.err.println("--------"+e.getMessage());
										
									//}
										 list_Rec=jdom.parser(file);
									if(list_Rec!=null&&list_Rec.size()>0)
									{
											
											try{
											 jdom.copyFileToDir(SysPathGlobal.getBakPath(), new File(file));
												
											}catch(Exception e){
												System.err.println("--------"+e.getMessage());
											}
											Iterator iter=list_Rec.iterator();
											while(iter.hasNext()){
												Record record=(Record)iter.next();
												WriteToDB.getInstance().executeProcToDB(record);
											}
											
									}else{
											jdom.saveErrFile(new File(file), SysPathGlobal.getErrorPath());
										}
						
									
									jdom.delThisFile(file);
										System.out.println("***************** "+file);
										
								
							//	flag++;
							
							//	System.out.println("-------$$$$$$$$$$$$$$      "+flag);
						}
						
						
					}
				
			
					

	}
			
	
	 public static void main(String[] args) {   
		   Date date=new Date();
		   SimpleDateFormat sdf= new SimpleDateFormat("yyyyMMddHHmmss");
		   System.out.println("---------"+sdf.format(date));
		
		  System.out.println(new File("D:\\test\\A\\6000A_000.xml").length());
		  System.out.println("--------------AAAAAAAAAAAA");
		  //字符串分割
		  	String str="";
		  	File _temp=new File("D:/test/A/6000A_000.xml");
		  	int index=_temp.getPath().lastIndexOf(_temp.separator);
		  	String sub=_temp.getPath().substring(0,_temp.getPath().lastIndexOf(_temp.separator));
		  	int index2=sub.lastIndexOf("\\");
		  		System.out.println(sub);
		  		
		  		String tPath=sub.substring(0,sub.lastIndexOf("\\"));
		  		System.out.println(tPath);
		  		System.out.println(sub.substring(sub.lastIndexOf("\\")+1,sub.length()));
			 // Pattern p=Pattern.compile("\\");
			 //Matcher match=p.matcher(_temp.getPath());
			 

		  }
	

		public void start(WorkerTask task,int delay, int internal){
			timer.schedule(this,delay*1000,internal*1000);
		}
		public void cancelTask(){
			this.cancel();
			
		}
		   
	 }