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等操作。

相关文章
|
21天前
|
Linux 程序员 数据格式
【2026最新】Notepad++下载、安装和使用一篇搞定(附中文版安装包)
Notepad++ 是一款免费开源、轻量高效的 Windows 文本编辑器,支持 C/Python/HTML 等 80+ 语言语法高亮、代码折叠、正则替换、编码转换及插件扩展,专为程序员与文本处理用户打造,完美替代系统记事本。(239字)
|
12天前
|
人工智能 JSON 自然语言处理
让教学更智慧:用阿里云百炼工作流,自动生成中小学教材内容#小有可为#有温度的AI
通过可视化工作流编排,将大模型推理能力转化为标准化的教学内容生成引擎。教师只需输入教材标题和适用学段,即可自动获得结构完整、符合课程标准的章节内容,大幅降低备课门槛,助力教育资源均衡化。
493 127
|
7天前
|
人工智能 缓存 安全
Claude Code 封号真实原因曝光,这次彻底不装了,直接针对国内开发者的账号下手?
Claude Code 封号潮背后:逆向扒出客户端隐写区域标记,Anthropic 政策收紧叠加 DeepSeek 7 月涨价,国产替代更紧迫。
|
16天前
|
存储 人工智能 监控
QoderWork完全指南:从入门到精通,把“AI实习生”变成你的全能工作搭档
阿里云2026年推出的桌面端AI工作助手QoderWork,不止聊天,更可动手干活:本地运行、安全可控,支持文件整理、数据分析、PPT生成、网页开发等;内置专家套件、多Agent协作与自定义Skills,让AI真正成为你身边的“AI实习生”。
|
7天前
|
人工智能 安全 程序员
终于,Claude Code 封号的原因被曝光了!竟然针对中国用户,植入隐形代码?!
通俗易懂地揭秘 Claude Code 封号的手段,分享一些自己对 AI 编程困境的思考,Codex、Cursor、DeepSeek、智谱 GLM、甚至是豆包,都有所行动了
424 1
|
8天前
|
人工智能 安全 Cloud Native
Higress 新发布:AI Gateway 能力增强,Gateway API 及其推理扩展持续打磨
增强 AI 网关能力,持续打磨 Gateway API 及其推理扩展。
377 125
|
16天前
|
机器学习/深度学习 人工智能 调度
🐴 HappyHorse 1.1 现已上线阿里云百炼!快来查收模型使用指南,现在调用享 6 折~
HappyHorse 1.1 是新一代视频生成大模型,全面升级动态表现力、角色一致性、指令遵循、视觉质感与音画协同能力。支持I2V/T2V/R2V三类生成,适配短剧、电商广告、品牌营销等场景,提供高质、流畅、可控的AI视频生产力。
931 5
🐴 HappyHorse 1.1 现已上线阿里云百炼!快来查收模型使用指南,现在调用享 6 折~