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类的相关方法实现进一步的处理

简要类图如下