Java는 WatchService를 사용하여 디렉터리의 파일 변경 사항을 실시간으로 모니터링하고 한 줄씩 구문 분석합니다.

먼저 요구 사항에 대해 이야기해 보겠습니다. FTP를 통해 서버의 지정된 디렉터리에 합의된 형식의 파일을 업로드합니다. 업로드된 파일 형식이 해당 디렉터리에 있는 파일의 변경 사항을 실시간으로 모니터링할 수 있습니다. 요구 사항에 따라 각 줄을 읽고 구문 분석한 다음 데이터베이스에 쓴 다음 구문 분석 후 파일 이름을 바꿉니다.

1. 초기 아이디어

지정된 디렉터리의 파일 변경 사항을 1분마다 읽는 예약 작업을 설정합니다. 형식에 맞는 파일이 있으면 구문 분석합니다.

이 방법은 매우 번거롭고 비효율적입니다. 상태 탐색, 저장 및 비교에 모든 효율성이 소모됩니다! 그리고 OS의 많은 기능을 활용할 수 없습니다.

2. WatchService 소개

1. 이 클래스의 객체는 운영체제의 기본 파일 시스템 모니터입니다! OS 자체의 파일 시스템 모니터가 시스템의 모든 파일의 변경 사항을 모니터링할 수 있다는 것은 모두가 알고 있는 사실입니다. 이러한 모니터링에는 순회나 비교가 필요하지 않으며 신호 송수신을 기반으로 하는 모니터링이므로 효율성이 가장 높아야 합니다. 이제 Java는 패키징 후 Java 프로그램에서 직접 OS 파일 시스템 모니터를 사용할 수 있습니다.

2. 현재 OS 플랫폼에서 파일 시스템 모니터를 가져옵니다.

i. WatchService watcher = FileSystems.getDefault().newWatchService() ;

ii. FileSystems 클래스 이름을 보면 이것이 OS 플랫폼 파일 시스템에 속한다는 것을 알 수 있습니다. 다음으로 이 일련의 메서드가 파일 모니터를 직접 얻을 수 있음을 알 수 있습니다. 이 일련의 방법에 대해 자세히 설명합니다. 동일한 코드를 사용하여 동시에 여러 모니터를 얻을 수도 있습니다.

4. 모니터는 실제로 백그라운드에서 파일 변경으로 전송되는 신호를 모니터링하는 백그라운드 스레드입니다. . 여기서 위 코드를 통해 얻은 모니터는 새로 초기화된 스레드일 뿐이며, 준비 상태도 되지 않은 상태입니다.

3. 구현 과정

실제로는 스레드를 생성하는 것입니다. 초기화 과정에서 watchService를 사용하여 디렉터리의 파일 변경 사항을 실시간으로 모니터링하고, 조건에 맞는 파일이 있으면 추가하고, 합의된 형식에 따라 파일을 구문 분석한 후 데이터베이스에 기록합니다. 다음과 같습니다!

　1. Web.xml 리스너 구성 파일은 리스너를 모니터링합니다

<?xml version="1.0" encoding="UTF-8"?><web-app version="2.5" xmlns="http://java.sun.com/xml/ns/javaee"xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xsi:schemaLocation="http://java.sun.com/xml/ns/javaee 
    "><context-param><param-name>contextConfigLocation</param-name><param-value>classpath:root-context.xml</param-value></context-param><filter><filter-name>CharacterEncodingFilter</filter-name><filter-class>org.springframework.web.filter.CharacterEncodingFilter</filter-class><init-param><param-name>encoding</param-name><param-value>UTF-8</param-value></init-param><init-param><param-name>forceEncoding</param-name><param-value>true</param-value></init-param></filter><filter-mapping><filter-name>CharacterEncodingFilter</filter-name><url-pattern>/*</url-pattern></filter-mapping><filter><filter-name>sitemesh</filter-name><filter-class>com.opensymphony.sitemesh.webapp.SiteMeshFilter</filter-class></filter><filter-mapping><filter-name>sitemesh</filter-name><url-pattern>/*</url-pattern></filter-mapping><servlet><servlet-name>appServlet</servlet-name><servlet-class>org.springframework.web.servlet.DispatcherServlet</servlet-class><init-param><param-name>contextConfigLocation</param-name><param-value>classpath:servlet-context.xml</param-value></init-param><load-on-startup>1</load-on-startup></servlet><servlet-mapping><servlet-name>appServlet</servlet-name><url-pattern>/</url-pattern></servlet-mapping><!-- 配置spring监听器 --><listener><listener-class>org.springframework.web.context.ContextLoaderListener</listener-class></listener><!-- 配置监控文件变化监听器 --><listener><listener-class>com.zealer.ad.listener.ThreadStartUpListenser</listener-class></listener><listener><listener-class>com.zealer.ad.listener.SessionLifecycleListener</listener-class></listener>
    <jsp-config>  <taglib>   <taglib-uri>/tag</taglib-uri>   <taglib-location>/WEB-INF/tag/tag.tld</taglib-location>  </taglib></jsp-config><welcome-file-list><welcome-file>index.jsp</welcome-file></welcome-file-list><session-config><session-timeout>45</session-timeout></session-config></web-app>

　2. ThreadStartUpListenser 클래스를 작성하여 ServletContextListener를 구현하고 Tomcat이 시작될 때 백그라운드 스레드를 생성합니다

　　

ThreadStartUpListenser.java

package com.zealer.ad.listener;import javax.servlet.ServletContextEvent;import javax.servlet.ServletContextListener;import org.apache.commons.logging.Log;import org.apache.commons.logging.LogFactory;import org.springframework.stereotype.Component;import com.zealer.ad.task.WatchFilePathTask;

@Componentpublic class ThreadStartUpListenser implements ServletContextListener
{private static WatchFilePathTask r = new WatchFilePathTask();private Log log = LogFactory.getLog(ThreadStartUpListenser.class);    /* * tomcat启动的时候创建一个线程
     * */@Overridepublic void contextInitialized(ServletContextEvent paramServletContextEvent)
    {
        r.start();
        log.info("ImportUserFromFileTask is started!");
    }    /* * tomcat关闭的时候销毁这个线程
     * */@Overridepublic void contextDestroyed(ServletContextEvent paramServletContextEvent)
    {
        r.interrupt();
    }

}

　3. 만들기 디렉터리 파일 변경 모니터링 클래스 지정

　　

WatchFilePathTask.java

  WatchFilePathTask  Log log = LogFactory.getLog(WatchFilePathTask.   String filePath = ConfigUtils.getInstance().getValue("userfile_path" watchService ="获取监控服务"+="@@@:Path:"+ String todayFormat = DateTime.now().toString("yyyyMMdd"= = existFiles.listFiles( ((todayFormat+".txt"  ( !=ImportUserFromFileTask task = (ImportUserFromFileTask) SpringUtils.getApplicationContext().getBean("importUserFromFileTask"WatchKey key = (= (WatchEvent<?>String fileName =((todayFormat+".txt"= path.toFile().getAbsolutePath()+File.separator+"import filePath:"+ImportUserFromFileTask task = (ImportUserFromFileTask) SpringUtils.getApplicationContext().getBean("importUserFromFileTask");"启动线程导入用户数据"+

　　4. WatchFilePathTask

package com.zealer.ad.task;import com.zealer.ad.entity.AutoPutUser;import com.zealer.ad.entity.Bmsuser;import com.zealer.ad.service.AutoPutUserService;import org.apache.commons.logging.Log;import org.apache.commons.logging.LogFactory;import org.joda.time.DateTime;import java.io.BufferedReader;import java.io.File;import java.io.FileInputStream;import java.io.InputStreamReader;import java.util.Date;import javax.annotation.Resource;/**
 * 解析用户文件及入库线程,由WatchFilePathTask启动
 * @author cancer
 * */public class ImportUserFromFileTask extends Thread {private Log log = LogFactory.getLog(ImportUserFromFileTask.class);private String fileName;
    @Resource(name = "autoPutUserService")private AutoPutUserService autoPutUserService;

    @Overridepublic void run() {
        File file = new File(fileName);if (file.exists() && file.isFile()) {
            log.debug("：@@@准备开始休眠10秒钟：" + file);//休眠十分钟，防止文件过大还没完全拷贝到指定目录下，这里的线程就开始读取文件try {
                sleep(10000);
            } catch (InterruptedException e1) {
                e1.printStackTrace();
            }

            InputStreamReader read;try {
                read = new InputStreamReader(new FileInputStream(file), "UTF-8");

                BufferedReader bufferedReader = new BufferedReader(read);
                String lineTxt = null;int count = 0;
                Boolean f = false;while ((lineTxt = bufferedReader.readLine()) != null) {if ((null == lineTxt) || "".equals(lineTxt)) {continue;
                    }if (lineTxt.startsWith("'")) {
                        lineTxt = lineTxt.substring(1, lineTxt.length());
                    }//解析分隔符为', 'String[] lines = lineTxt.split("', '");int length = lines.length;if (length < 2) {continue;
                    }

                    Bmsuser bmsuser = new Bmsuser();
                    bmsuser.setName(lines[0]);if (!"".equals(lines[1])) {
                        bmsuser.setCity(lines[1]);
                    }
　　　　　　　　　　　　//根据唯一索引已经存在的数据则不插入f = autoPutUserService.insertIgnore(bmsuser);if (f) {
                        count++;
                    }
                }//汇总数据AutoPutUser autoPutUser = new AutoPutUser();
                autoPutUser.setTotalCount(autoPutUserService.getUserCount());
                autoPutUser.setCount(count);
                autoPutUser.setCountDate(new Date(System.currentTimeMillis()));

                String today = DateTime.now().toString("yyyy-MM-dd");
                Integer oldCount = autoPutUserService.getOldCount(today);//如果今天导入过了就更新否则插入if (!oldCount.equals(0)) {
                    autoPutUserService.updateUserData(autoPutUser, today,
                        oldCount);
                } else {
                    autoPutUserService.gatherUserData(autoPutUser);
                }//注意：要关闭流                read.close();
            } catch (Exception e) {
                log.error(e.getMessage(), e);
            }

            File newFile = new File(file.getPath() +System.currentTimeMillis() + ".complate");
            file.renameTo(newFile);
        } else {
            log.error(fileName + " file is not exists");
        }
    }public String getFileName() {return fileName;
    }public void setFileName(String fileName) {this.fileName = fileName;
    }public AutoPutUserService getAutoPutUserService() {return autoPutUserService;
    }public void setAutoPutUserService(AutoPutUserService autoPutUserService) {this.autoPutUserService = autoPutUserService;
    }
}

에서 시작하는 사용자 파일 구문 분석 및 데이터베이스 가져오기를 위한 스레드 생성:

1.SQL 스크립트

CREATE TABLE `bmsuser` (
  `id` int(255) unsigned NOT NULL AUTO_INCREMENT,
  `name` varchar(32) DEFAULT NULL ,
  `city` varchar(32) DEFAULT NULL COMMENT ,  PRIMARY KEY (`bmsid`),  UNIQUE KEY `bbLoginName` (`bbLoginName`)
) ENGINE=InnoDB  DEFAULT CHARSET=utf8;

2. 파일 형식, 이름은 yyyyMMdd.txt

'张三', '深圳'

위 내용은 Java는 WatchService를 사용하여 디렉터리의 파일 변경 사항을 실시간으로 모니터링하고 한 줄씩 구문 분석합니다.의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!