solr dataimport 数据导入源码分析（一）

solr处理请求的接口为SolrRequestHandler.java ,由handleRequest方法处理来自http的请求

/***********************************************************************
 * Module:  SolrRequestHandler.java
 * Author:  Administrator
 * Purpose: Defines the Interface SolrRequestHandler
 ***********************************************************************/

import java.util.*;

/** @pdOid 92641501-9fac-4850-bf72-43e262d42eff */
public interface SolrRequestHandler {
   /** @param args
    * @pdOid 0d916c92-cb61-408c-844d-a756cc1e9a41 */
   void init(NamedList args);
   /** @param req 
    * @param rsp
    * @pdOid 35c91800-4167-49d1-aefe-c961fb7082d1 */
   void handleRequest(SolrQueryRequest req, SolrQueryResponse rsp);

} 

公用的实现类为RequestHandlerBase.java

 /***********************************************************************

 * Module:  RequestHandlerBase.java
 * Author:  Administrator
 * Purpose: Defines the Class RequestHandlerBase
 ***********************************************************************/

import java.util.*;

/** @pdOid 9e2891cc-6977-4d7e-86f8-d406a3493599 */
public abstract class RequestHandlerBase implements SolrRequestHandler {
   /** @param args
    * @pdOid 48f0c55d-b3a3-4736-8e47-1c866398eeef */
   public void init(NamedList args) {
       
     }
   
   /** @param req 
    * @param rsp
    * @exception Exception
    * @pdOid 3eec0a97-ed48-4f4e-b78b-142247478b69 */
   public abstract void handleRequestBody(SolrQueryRequest req, SolrQueryResponse rsp) throws Exception;
   /** @param req 
    * @param rsp
    * @pdOid 7b97a1ac-509c-4a03-aaed-a2bbd320dbcc */
   public void handleRequest(SolrQueryRequest req, SolrQueryResponse rsp) {
     
   }

}

这是一个抽象类，其中抽象方法handleRequestBody 由子类实现，真正的处理逻辑在子类的handleRequestBody方法

 由handleRequest调用子类的  handleRequestBody方法，这是一种典型的模板方法设计模式

负责数据导入的实现类为DataImportHandler.java，示例代码如下 

 /***********************************************************************

 * Module:  DataImportHandler.java
 * Author:  Administrator
 * Purpose: Defines the Class DataImportHandler
 ***********************************************************************/

import java.util.*;

/** @pdOid 1277dd7d-601d-45c7-a2ef-1836f46db6f3 */
public class DataImportHandler extends RequestHandlerBase {
   /** @pdOid 6e53bcab-98f0-4ce1-97a0-1c15e9be51ac */
   private DataImporter importer;
   
   /** @param req 
    * @param rsp
    * @exception Exception
    * @pdOid 15ebeea5-1faf-4d9d-89bb-3c4be63bf15a */
   public void handleRequestBody(SolrQueryRequest req, SolrQueryResponse rsp) throws Exception {
     importer.runCmd(requestParams, sw);
   
   }

}

DataImportHandler类持有DataImporter的引用，调用DataImporter类的相关方法实现进一步的处理

简要类图如下