SolrCore2.9.1源码分析备忘

简介: Solr2.9.1  代码 下面的分析有点散,围绕solrcore展开,重点是query流程,细入是getSearcher 内容中有一些直接从参考链接里面拷贝的。 【1】SolrCore功能点     0.JMX的初始化—》远程监控使用 进入参考链接http://lucidworks

Solr2.9.1 
代码 下面的分析有点散,围绕solrcore展开,重点是query流程,细入是getSearcher


内容中有一些直接从参考链接里面拷贝的。

【1】SolrCore功能点

   
0.JMX
的初始化》远程监控使用
进入参考链接http://lucidworks.lucidimagination.com/display/solr/Using+JMX+with+Solr
默认情况下不会起到JMX

   
1.
初始化加载solrconfig.xml 
配置信息----》整个检索层的配置

2.updatehandler  --》写索引,关联的updateProcessorchains,内部重新打开索引writer。

Commit的时候会getSearcher从而打开新的reader视图,solrIndexSearcher之后就可见。

3 SolrIndexSearcher---》查询索引的入口,关联  
查询解析的QquerParse、高亮、searchComponent、【读reader共享、写需要同步reader,SolrIndexSearch打开的都是readonlyreader
线程安全并且单例,提升性能

4 
事件支持:firstSearcherListenersnewSearcherListeners
这里可以作为扩展自己的reader服务的入口

5. 
查询返回的responseWriter

   
6
 
前提准备索位置Directory、索引readerreaderfactory 
,间接关联reader管理,

7 
索引的删除策略加载


【2】execute分析


SolrCore中有两个execute方法:

    1.
execute(SolrQueryRequest req, SolrQueryResponse rsp)

   
2.execute(SolrRequestHandler handler, SolrQueryRequest req,
SolrQueryResponse rsp)


对于第一个方法,没有像第二个方法那样的handler参数,但是其实其内部通过这样一个方法来获得handler
的:SolrRequestHandler
handler = getRequestHandler(req.getQueryType())
。也就是说我们通过在req中指定qt参数的值就可以获得我们想要的处理

器,当然这些处理器需要在solrconfig.xml

requestHandler元素中定义(配置文件中有大量requestHandler)。这样服务器在建立时才能建立相应的处理器实例。

  这里我发现在获取处理器时,参数为""null还是standard都能得到StandardRequestHandler的实例

SolrCore::execute的流程

   1.
进行handler合法性的检查,不能为null,否则抛出错误。

2.final NamedListresponseHeader = new
SimpleOrderedMap()

      
rsp.add("responseHeader", responseHeader);

      

建立一个单序映射表并将其作为响应头加入到rsp中。

3.NamedList toLog = rsp.getToLog();

 获得rspToLog对象,并从请求中获得一些相关信息加入,这些信息有webapp,path,params

4.handler.handleRequest(req,rsp);

5.StringBuilder sb = new
StringBuilder();....

  
rspToLog中获得信息并将其加入到sb中,然后在日志中输出。


分析了SolrCore中的execute方法的流程,而且可以看到具体执行查询过程的语句是:handler.handleRequest(req,rsp)。请注意查询时候,这里的变量的类型是:

handlerStandardRequestHandler

req:SolrRequestParsers类中的一个匿名类。

rsp:SolrQueryResponse

 query调用流

StandardRequestHandler extends
SearchHandler
solrcore::execute.handler.handlerRequest(),


转为solrcore::execute.StandardRequestHandler.handlerRequest


转为SearchHandler.handlerRequest() 
SearchHandler extends
RequestHandlerBase


转为RequestHandlerBase.handlerRequest() 
真正执行handlerRequest()


RequestHandlerBase.handlerRequest()

设置httpcachinghandleRequestBody(),


抽象的handlerRequestBody()在子类SearchHandler中实现了,


转回SearchHandler.handlerRequestBody(),其中对QueryComponent 
执行prepareprocess


prepare中生成QParser,注意只有queryComponent中生成了Qparser,其他的没有生成。并且Qparser 
是从staticgetParser() 
中拿到,而Qparser.getParser()中又是从SolrCore.getQueryPlugin() 
通过solrconfig.xml中配置获取。

SolrCore 中 Searcher
Control
部分有点复杂

----getSearcher的逻辑

getSearcher – (forceNew,
returnSearcher, waitSearcher-Futures)


关注solr全局三个点调用getSearcher函数
: solrCore初始化时(false, false, null)QueryComponent处理查询请求时(false, true, null)UpdateHandler在处理commit请求时(true, false, new Future[1])


外部调用

EmbededSolrServer.request-->在执行core.execute() 
之前,从coregetRequestHandler_parserbuildRequestFrom(), new SolrQueryResponse()

返回SolrQueryRequestBase

SolrQueryRequestBase

protected RefCounted searcherHolder;

  publicSolrIndexSearcher getSearcher()
{

   
if(core == null) return null;//a request for a core admin
will no have a core

   
// should this reach out and get a
searcher from the core singleton, or

   
// should the core populate one in a
factory method to create requests?

   
// or there could be a setSearcher()
method that Solr calls

   
if(searcherHolder==null) {

     
searcherHolder= core.getSearcher();

   
}

   
returnsearcherHolder.get();

  }

 

 public void close() {

   
if(searcherHolder!=null) {

     
searcherHolder.decref();

     
searcherHolder= null;

   
}

  }

当调用SolrQueryRequestBasegetSearcher()时,如果是第一次调用,会转而调用core.getSearcher()
其会使得到的searcherHolder的引用计数增一。而对称的,SolrQueryRequestBaseclose()方法使searcherHolder的引用计数减一,一增一减平衡了。
这也使得当新的索引到来时,仍旧提供查询服务的SolrIndexSearcher不会立 即关闭,直到其引用计数减为0才关闭。所以,在使用SolrQueryRequest时,要确保请求的最后调用其close方法,否则那些无用的SolrIndexSearcher就不会被释放,直到句柄耗尽或者OOM掉。

 


引用对象

引用对象的典型使用是SolrCore,看下相关代码:

 
 
 
 
 
 
 
 
 
 
 
 
 
 

引用计数就是refCount了。SolrCore实例的获得是通过调用CoreContainer SolrCore getCore(String name)得到,其实现是:

 
 
 
 
 
 
 
 

也就是说CoreContainer显示的openSolrCore,所以在得到SolrCore实例后,也需要显示的close它。因为SolrQueryRequestBase用到了SolrCore,所以在处理请求的最后,要确保调用了SolrCoreclose方法。当然,对于查 询端,SolrCore实例在整个生命周期内通常并不会真正被close,除非显示的调用了reload等操作。

相关文章
|
3天前
|
人工智能 JSON 机器人
让龙虾成为你的“公众号分身” | 阿里云服务器玩Openclaw
本文带你零成本玩转OpenClaw:学生认证白嫖6个月阿里云服务器,手把手配置飞书机器人、接入免费/高性价比AI模型(NVIDIA/通义),并打造微信公众号“全自动分身”——实时抓热榜、AI选题拆解、一键发布草稿,5分钟完成热点→文章全流程!
10464 47
让龙虾成为你的“公众号分身” | 阿里云服务器玩Openclaw
|
23天前
|
人工智能 JavaScript Ubuntu
5分钟上手龙虾AI!OpenClaw部署(阿里云+本地)+ 免费多模型配置保姆级教程(MiniMax、Claude、阿里云百炼)
OpenClaw(昵称“龙虾AI”)作为2026年热门的开源个人AI助手,由PSPDFKit创始人Peter Steinberger开发,核心优势在于“真正执行任务”——不仅能聊天互动,还能自动处理邮件、管理日程、订机票、写代码等,且所有数据本地处理,隐私完全可控。它支持接入MiniMax、Claude、GPT等多类大模型,兼容微信、Telegram、飞书等主流聊天工具,搭配100+可扩展技能,成为兼顾实用性与隐私性的AI工具首选。
23631 121
|
9天前
|
人工智能 JavaScript API
解放双手!OpenClaw Agent Browser全攻略(阿里云+本地部署+免费API+网页自动化场景落地)
“让AI聊聊天、写代码不难,难的是让它自己打开网页、填表单、查数据”——2026年,无数OpenClaw用户被这个痛点困扰。参考文章直击核心:当AI只能“纸上谈兵”,无法实际操控浏览器,就永远成不了真正的“数字员工”。而Agent Browser技能的出现,彻底打破了这一壁垒——它给OpenClaw装上“上网的手和眼睛”,让AI能像真人一样打开网页、点击按钮、填写表单、提取数据,24小时不间断完成网页自动化任务。
2235 5

热门文章

最新文章