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

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

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

 外部通過調(diào)用postingservice的get方法獲取到對應(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初始化時注入，當(dāng)然es的1.5版本只是使用了默認(rèn)的DefaultPostingFormatProvider。postformat的獲取則是通過postingprovider的get的方法，而對應(yīng)的postingformat初始化在構(gòu)造方法總實現(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。這一部分的實現(xiàn)多數(shù)都跟codec的實現(xiàn)類似，后面的分析中會對其中的一些做詳細(xì)的介紹。對于寫索引的方法都在Engine中。這里封裝了所有對于索引寫操作的方法，后面會詳細(xì)分析。

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

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

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

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

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

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

最新評論