開發(fā)中需要用到ES的插件, 開發(fā)ES插件需要了解ES的內(nèi)部結構, 于是再次開始學習ES的源碼。一方面了解插件開發(fā)的套路,一方面了解get接口的實現(xiàn)細節(jié)。
成都創(chuàng)新互聯(lián)公司堅持“要么做到,要么別承諾”的工作理念,服務領域包括:成都做網(wǎng)站、網(wǎng)站建設、企業(yè)官網(wǎng)、英文網(wǎng)站、手機端網(wǎng)站、網(wǎng)站推廣等服務,滿足客戶于互聯(lián)網(wǎng)時代的羅源網(wǎng)站設計、移動媒體設計的需求,幫助企業(yè)找到有效的互聯(lián)網(wǎng)解決方案。努力成為您成熟可靠的網(wǎng)絡建設合作伙伴!
了解ES的原理,源碼是文檔最好的補充。源碼甚至比文檔更有助于了解ES的內(nèi)部核心。
首先從git上clone下源碼:
git clone https://github.com/elastic/elasticsearch.git
cd elasticsearch
git tag -l
git checkout v2.4.5
sh run.sh
如果使用run.sh沒有成功,再試一次, 有可能是maven的jar包沒有下載到。
這里使用v2.4.5是由于在編譯es的過程中會用到相關的jar包,而https://oss.sonatype.org/content/repositories/snapshots/org/elasticsearch/rest-api-spec/
并不是所有版本的jar包都有, 所以從中選取了v2.4.5, 這跟手機選號一樣,純屬個人主觀。
這里JDK要換成1.8, 1.7的jdk maven會報protocol_verson
錯誤。
編譯成功后,就會生成elasticsearch的zip包, 需要解壓,因為源碼中會用到conf文件。
cd /home/shgy/es_workspace/elasticsearch/distribution/zip/target/releases/
unzip elasticsearch-2.4.5-SNAPSHOT.zip
mv elasticsearch-2.4.5-SNAPSHOT /opt/
編譯完成后, 將源碼import到intellij中, intellij的啟動參數(shù)
vm options :
-Des.path.home=/opt/elasticsearch-2.4.5-SNAPSHOT
Program arguments:
start
啟動成功后使用
curl http://localhost:9200
即可看到經(jīng)典的
{
"name" : "Ruckus",
"cluster_name" : "elasticsearch",
"cluster_uuid" : "ZIl7g86YRiGv8Dqz4DCoAQ",
"version" : {
"number" : "2.4.5",
"build_hash" : "c849dd13904f53e63e88efc33b2ceeda0b6a1276",
"build_timestamp" : "2018-08-12T01:30:55Z",
"build_snapshot" : true,
"lucene_version" : "5.5.4"
},
"tagline" : "You Know, for Search"
}
從源碼啟動成功后, 可以做的事情就多了。 比如看看You Know, for Search
是怎么來的;看看ES內(nèi)部的index/get/search等接口內(nèi)部是如何運行的。
更重要的是, 可以將相關接口的邏輯套用, 依樣畫葫蘆開發(fā)plugin實現(xiàn)自己的業(yè)務邏輯。
以debug的方式啟動es后, 第一個斷點可以打在org.elasticsearch.http.netty.HttpRequestHandler.messageReceived()
,這是netty的編程模式。
比如You Know, for Search
, 通過debug, 可以了解到其調(diào)用鏈為:HttpRequestHandler.messageReceived() --- RestMainAction.handleRequest()
Rest_xxx_Action是es所有http接口通用的套路。比如:
RestSearchAction _search
RestGetAction /{index}/{type}/{id}
RestIndexAction /{index}/{type}/{id}
......
可以說, Rest_xxx_Action是es的外殼, 整個ES的結構大致如下圖所示: