solr DIH 知识梳理

killerxf

package org.apache.solr.handler.dataimport.scheduler;　　
　　import java.io.IOException;
　　import java.net.HttpURLConnection;
　　import java.net.MalformedURLException;
　　import java.net.URL;
　　import java.text.DateFormat;
　　import java.text.ParseException;
　　import java.text.SimpleDateFormat;
　　import java.util.Date;
　　import java.util.Timer;
　　import java.util.TimerTask;
　　import org.slf4j.Logger;
　　import org.slf4j.LoggerFactory;
　　

　　public abstract>　　{
　　protected String syncEnabled;
　　protected String[] syncCores;
　　protected String server;
　　protected String port;
　　protected String webapp;
　　protected String params;
　　protected String interval;
　　protected String cores;
　　protected SolrDataImportProperties p;
　　protected boolean singleCore;
　　protected String reBuildIndexParams;
　　protected String reBuildIndexBeginTime;
　　protected String reBuildIndexInterval;
　　private String webAppName;
　　protected static final Logger logger = LoggerFactory.getLogger(BaseTimerTask.class)
　　;
　　
　　public BaseTimerTask(String webAppName, Timer t) throws Exception
　　{
　　this.webAppName = webAppName;
　　
　　this.p = new SolrDataImportProperties();
　　reloadParams();
　　
　　if (!this.syncEnabled.equals("1")) {
　　throw new Exception("Schedule disabled");
　　}
　　if ((this.syncCores == null) || ((this.syncCores.length == 1) &&
　　(this.syncCores[0]
　　.isEmpty()))) {
　　this.singleCore = true;

　　logger.info(" Single core>　　} else {
　　this.singleCore = false;

　　logger.info(new StringBuilder().append(" Multiple cores>　　}
　　}
　　

　　protected void>　　{
　　this.p.loadProperties(true);
　　this.syncEnabled = this.p.getProperty("syncEnabled");
　　this.cores = this.p.getProperty("syncCores");
　　this.server = this.p.getProperty("server");
　　this.port = this.p.getProperty("port");
　　this.webapp = this.p.getProperty("webapp");
　　this.params = this.p.getProperty("params");
　　this.interval = this.p.getProperty("interval");
　　this.syncCores = (this.cores != null ? this.cores.split(",") : null);
　　
　　this.reBuildIndexParams = this.p
　　.getProperty("reBuildIndexParams");
　　
　　this.reBuildIndexBeginTime = this.p
　　.getProperty("reBuildIndexBeginTime");
　　
　　this.reBuildIndexInterval = this.p
　　.getProperty("reBuildIndexInterval");
　　
　　fixParams(this.webAppName);
　　}
　　
　　protected void fixParams(String webAppName) {
　　if ((this.server == null) || (this.server.isEmpty()))
　　this.server = "localhost";
　　if ((this.port == null) || (this.port.isEmpty()))
　　this.port = "8080";
　　if ((this.webapp == null) || (this.webapp.isEmpty()))
　　this.webapp = webAppName;

　　if ((this.interval == null) || (this.interval.isEmpty()) || (getIntervalInt()