從本篇開始，對(duì)elasticsearch的介紹將進(jìn)入數(shù)據(jù)功能部分（index），這一部分包括索引的創(chuàng)建，管理，數(shù)據(jù)索引及搜索等相關(guān)功能。對(duì)于這一部分的介紹，首先對(duì)各個(gè)功能模塊的分析，然后詳細(xì)分析數(shù)據(jù)索引和搜索的整個(gè)流程。

這一部分從代碼包結(jié)構(gòu)上可以分為：index， indices及l(fā)ucene（common）幾個(gè)部分。index包中的代碼主要是各個(gè)功能對(duì)應(yīng)于lucene的底層操作，它們的操作對(duì)象是index的shard，是elasticsearch對(duì)lucene各個(gè)功能的擴(kuò)展和封裝。indices部分是對(duì)index部分功能的封裝，集群對(duì)于底層索引的操作多數(shù)通過這一部分提供的接口來進(jìn)行。common包下的lucene部分代碼主要是對(duì)于索引一些讀操作（索引級(jí)別）的封裝。如讀取索引元數(shù)據(jù)，搜索中用到的一些過濾器的實(shí)現(xiàn)等。

在index部分通過對(duì)lucene的封裝，為es提供了索引操作各個(gè)功能的接口。如codec，這一部分是lucene索引寫入的部分。在4.x后這一部分被分開成為單獨(dú)的一層，在這里對(duì)其進(jìn)行了封裝。postformat是lucene中倒排表的寫入格式，封裝后通過postingformatservice對(duì)外提供。而具體的postform則是由postprovide提供。它的繼承關(guān)系如下所示：

 外部通過調(diào)用postingservice的get方法獲取到對(duì)應(yīng)的postingprovider，代碼如下所示：

public PostingsFormatProvider get(String name) throws ElasticsearchIllegalArgumentException {
        PostingsFormatProvider provider = providers.get(name);
        if (provider == null) {
            throw new ElasticsearchIllegalArgumentException("failed to find postings_format [" + name + "]");
        }
        return provider;
    }

這里的provides在service初始化時(shí)注入，當(dāng)然es的1.5版本只是使用了默認(rèn)的DefaultPostingFormatProvider。postformat的獲取則是通過postingprovider的get的方法，而對(duì)應(yīng)的postingformat初始化在構(gòu)造方法總實(shí)現(xiàn)：

public DefaultPostingsFormatProvider(@Assisted String name, @Assisted Settings postingsFormatSettings) {
        super(name);
        this.minBlockSize = postingsFormatSettings.getAsInt("min_block_size", BlockTreeTermsWriter.DEFAULT_MIN_BLOCK_SIZE);
        this.maxBlockSize = postingsFormatSettings.getAsInt("max_block_size", BlockTreeTermsWriter.DEFAULT_MAX_BLOCK_SIZE);
        this.postingsFormat = new Lucene41PostingsFormat(minBlockSize, maxBlockSize);
    }

可以看到這里就是初始化了lucene的postingformat。這一部分的實(shí)現(xiàn)多數(shù)都跟codec的實(shí)現(xiàn)類似，后面的分析中會(huì)對(duì)其中的一些做詳細(xì)的介紹。對(duì)于寫索引的方法都在Engine中。這里封裝了所有對(duì)于索引寫操作的方法，后面會(huì)詳細(xì)分析。

關(guān)于common部分的lucene的功能基本都是對(duì)lucene的讀操作，如對(duì)于segment信息讀取的方法如下所示：

public static SegmentInfos readSegmentInfos(Directory directory) throws IOException {
        final SegmentInfos sis = new SegmentInfos();
        sis.read(directory);
        return sis;
    }

直接調(diào)用了lucene的segmentInfos類讀取segment信息。這一部分在后面會(huì)單獨(dú)分析，這里只是簡(jiǎn)單介紹一下。

index部分是shard基本的接口，這里的操作都是針對(duì)于單個(gè)機(jī)器單個(gè)shard（lucene index）的操作，不涉及集群。而indice部分則通過封裝index的相關(guān)功能為集群對(duì)于index的操作提供了相關(guān)接口。如這里的store部分，只是提供了一個(gè)實(shí)現(xiàn)類IndiceStore，它的實(shí)現(xiàn)如下所示。

它實(shí)現(xiàn)了多個(gè)handle類用于處理來自集群的相關(guān)請(qǐng)求。跟之前結(jié)束的handler一樣，這些內(nèi)部類會(huì)接收處理屬于本節(jié)點(diǎn)的請(qǐng)求，轉(zhuǎn)發(fā)屬于本節(jié)點(diǎn)請(qǐng)求到對(duì)應(yīng)節(jié)點(diǎn)。

以上就是elasticsearch數(shù)據(jù)（index）部分的代碼結(jié)構(gòu)。這里只是簡(jiǎn)單的概述，后面會(huì)對(duì)對(duì)應(yīng)的部分進(jìn)行詳細(xì)分析，更多關(guān)于elasticsearch索引index數(shù)據(jù)功能的資料請(qǐng)關(guān)注腳本之家其它相關(guān)文章！

最新評(píng)論