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 
事件支持:firstSearcherListeners、newSearcherListeners
这里可以作为扩展自己的reader服务的入口

5. 
查询返回的responseWriter

   
6
 
前提准备索位置Directory、索引reader的readerfactory 
,间接关联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();

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

4.handler.handleRequest(req,rsp);

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

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


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

handler:StandardRequestHandler

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()中

设置httpcaching、handleRequestBody(),


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


转回SearchHandler.handlerRequestBody(),其中对QueryComponent 
执行prepare、process


在prepare中生成QParser,注意只有queryComponent中生成了Qparser,其他的没有生成。并且Qparser 
是从static的getParser() 
中拿到,而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() 
之前,从core中getRequestHandler,_parser中buildRequestFrom(), 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;

   
}

  }

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

 


引用对象

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

 
 
 
 
 
 
 
 
 
 
 
 
 
 

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

 
 
 
 
 
 
 
 

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

相关文章
|
11天前
|
人工智能 JSON API
全网刷屏的 Jev 模型正式开放!一手实战测评 + 保姆级教程
全网爆火的 Jev 模型是什么?有什么用?怎么使用?怎么接入 AI 编程工具?效果真的好么?傻子可懂的 Jev 保姆级实战教程 + 项目实战测评来啦
7853 14
|
9天前
|
人工智能 测试技术 API
最近全网爆火的 Jev 到底是什么?适合干什么、怎么用,一篇讲透!
Jev是TypeSafe AI推出的“系统一模型”,不生成文本,专做毫秒级结构化决策:Choice(多选)、Score(打分)、Noul(是非概率)。响应快193倍、成本低444倍,适合工单路由、内容审核、测试定级等高频判断场景。
1712 4
最近全网爆火的 Jev 到底是什么?适合干什么、怎么用,一篇讲透!
|
10天前
|
人工智能 并行计算 PyTorch
秋叶 ComfyUI 2026 整合包 v3.2 完整部署教程:Python 3.13 + Torch 2.13 全栈升级
秋叶aaaki ComfyUI 2026年8月整合包v3.2正式发布!全面升级Python 3.13.11、PyTorch 2.13.0+cu130及ComfyUI v0.30.2,原生支持MiniMax H3、Wan 2.2、Qwen-Image-2.1等2026主流音视频/图像模型,解压即用,无需环境配置。
1545 11
|
6天前
|
人工智能 JavaScript 芯片
DeepSeek 官方偷偷上传 Harness 桌面端安装包,我已经用上了。。附最新下载地址
DeepSeek Harness 官方的桌面端安装包被网友扒出来了,2 分钟讲明白如何使用,体验如何,适合作为 AI 编程工具么?附最新 Windows 和 Mac 双端的下载地址
1487 1
|
8天前
|
人工智能 编解码 并行计算
MiniMax-H3 一键整合包技术文档:8G 显存运行 AI 漫剧制作 —— 角色替换 / 动作迁移 / 文图生视频部署与调参指南
MiniMax H3 是 MiniMax 开源的全模态视频生成模型,支持文/图/音/视多条件输入,输出最高2K、15秒带双声道音频视频。本文档详述其Int8量化版在8GB显存下的本地一键部署、三段式工作流(EDIT/REPLACE/CONTINUE)、参数调优及常见问题排查。(239字)
|
23天前
|
人工智能 自然语言处理 安全
阿里云千问办公 QwenWork详细介绍:产品核心能力、典型场景、价格及常见问题解答
千问办公是阿里云推出的一站式AI办公平台,主打"不止于对话,更注重交付",依托通义千问旗舰大模型,用户一句话即可完成数据分析、PPT生成、视频剪辑等复杂任务,直接输出可用成果。产品深度打通钉钉生态与企业OA,覆盖桌面端、网页端,提供企业标准版198元/人/月等多档订阅方案,新用户注册即赠2000积分,适配工程师、HR、财务等多职业办公场景,成为能动手干活的"全能AI同事"。
3755 10
|
18天前
|
缓存 IDE Java
【保姆级】Android Studio下载、安装和汉化教程(2026最新)
Android Studio 是 Google 官方推出的免费 Android 应用开发集成环境,基于 IntelliJ IDEA,内置模拟器、调试器、性能分析及 Compose 界面工具,功能全面,文档丰富,是安卓开发首选工具。(239字)
1914 1

热门文章

最新文章