快捷導(dǎo)航

elasticsearch分布式及數(shù)據(jù)的功能源碼分析

更新時(shí)間：2022年04月21日 14:46:14 作者：zziawan

這篇文章主要為大家介紹了elasticsearch分布式及數(shù)據(jù)功能源碼分析，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進(jìn)步，早日升職加薪

從功能上說(shuō)，可以分為兩部分,分布式功能和數(shù)據(jù)功能。分布式功能主要是節(jié)點(diǎn)集群及集群附屬功能如restful借口、集群性能檢測(cè)功能等，數(shù)據(jù)功能主要是索引和搜索。代碼上這些功能并不是完全獨(dú)立，而是由相互交叉部分。當(dāng)然分布式功能是為數(shù)據(jù)功能服務(wù)，數(shù)據(jù)功能肯定也難以完全獨(dú)立于分布式功能。

它的源碼有以下幾個(gè)特點(diǎn)：

模塊化：

每個(gè)功能都以模塊化的方式實(shí)現(xiàn)，最后以一個(gè)借口向外暴露，最終通過(guò)guice（google輕量級(jí)DI框架）進(jìn)行管理。整個(gè)系統(tǒng)有30多個(gè)模塊（version1.5）。

接口解耦：

es代碼中使用了大量的接口進(jìn)行代碼解耦，剛開(kāi)始看的感覺(jué)是非常難以找到相關(guān)功能的實(shí)現(xiàn)，但是也正是這些接口使得代碼實(shí)現(xiàn)的非常優(yōu)雅。

異步通信：

作為一個(gè)高效的分布式系統(tǒng)，es中異步通信實(shí)現(xiàn)非常之多，從集群通信到搜索功能，使用了異步通信框架netty作為節(jié)點(diǎn)間的通信框架。

以上的這些特點(diǎn)在后面的代碼分析中會(huì)一一體現(xiàn)。概述的結(jié)尾以es的啟動(dòng)過(guò)程來(lái)結(jié)束，es的啟動(dòng)類(lèi)是Bootstrap，啟動(dòng)腳本調(diào)研這個(gè)類(lèi)的main方法開(kāi)始啟動(dòng)node。它的類(lèi)圖如下所示：

上圖僅僅顯示了它的field，其中node是要啟動(dòng)的節(jié)點(diǎn)。keepAliveThread線程保證節(jié)點(diǎn)運(yùn)行期間Bootstrap會(huì)一直存在，可以接收關(guān)機(jī)命令進(jìn)行從而優(yōu)雅關(guān)閉。下面是啟動(dòng)前的屬性設(shè)置，代碼如下：

private void setup(boolean addShutdownHook, Tuple<Settings, Environment> tuple) throws Exception {
     if (tuple.v1().getAsBoolean("bootstrap.mlockall", false)) {//嘗試鎖定內(nèi)存
            Natives.tryMlockall();
        }
        tuple = setupJmx(tuple);
        NodeBuilder nodeBuilder = NodeBuilder.nodeBuilder().settings(tuple.v1()).loadConfigSettings(false);
        node = nodeBuilder.build();//初始化node
        if (addShutdownHook) {//添加關(guān)閉node的hook
            Runtime.getRuntime().addShutdownHook(new Thread() {
                @Override
                public void run() {
                    node.close();
                }
            });
        }
    }

嘗試鎖定內(nèi)存左右是保證節(jié)點(diǎn)運(yùn)行期間的內(nèi)存不變動(dòng)，以防因?yàn)閮?nèi)存變得帶來(lái)性能上的波動(dòng)，這里調(diào)用的是c方法。最后來(lái)看一下main方法：

public static void main(String[] args) {
.... 
String stage = "Initialization";//標(biāo)明啟動(dòng)階段用于構(gòu)造錯(cuò)誤信息。
        try {
            if (!foreground) {
                Loggers.disableConsoleLogging();
                System.out.close();
            }
            bootstrap.setup(true, tuple);
            stage = "Startup";
            bootstrap.start();//bootstrap的啟動(dòng)過(guò)程也就是node的啟動(dòng)過(guò)程
            if (!foreground) {
                System.err.close();
            }
//構(gòu)造一個(gè)線程，保證bootstrap不退出，仍然可以接收命令。
            keepAliveLatch = new CountDownLatch(1); 
            // keep this thread alive (non daemon thread) until we shutdown/
            Runtime.getRuntime().addShutdownHook(new Thread() {
                @Override
                public void run() {
                    keepAliveLatch.countDown();
                }
            });
            keepAliveThread = new Thread(new Runnable() {
                @Override
                public void run() {
                    try {
                        keepAliveLatch.await();
                    } catch (InterruptedException e) {
                        // bail out
                    }
                }
            }, "elasticsearch[keepAlive/" + Version.CURRENT + "]");
            keepAliveThread.setDaemon(false);
            keepAliveThread.start();
        } catch (Throwable e) {
            ESLogger logger = Loggers.getLogger(Bootstrap.class);
            if (bootstrap.node != null) {
                logger = Loggers.getLogger(Bootstrap.class, bootstrap.node.settings().get("name"));
            }
            String errorMessage = buildErrorMessage(stage, e);
            if (foreground) {
                System.err.println(errorMessage);
                System.err.flush();
            } else {
                logger.error(errorMessage);
            }
            Loggers.disableConsoleLogging();
            if (logger.isDebugEnabled()) {
                logger.debug("Exception", e);
            }
            System.exit(3);
        }

main函數(shù)有省略，這里start函數(shù)調(diào)用node的start函數(shù)，node的start函數(shù)中將各個(gè)模塊加載啟動(dòng)，從而啟動(dòng)整個(gè)系統(tǒng)。這一過(guò)程將在接下來(lái)進(jìn)行分析。node啟動(dòng)后會(huì)注入hook，同時(shí)啟動(dòng)keepAliveThread，至此整個(gè)node就啟動(dòng)起來(lái)。

以上就是elasticsearch分布式及數(shù)據(jù)功能源碼分析的詳細(xì)內(nèi)容，更多關(guān)于elasticsearch分布式及數(shù)據(jù)功能的資料請(qǐng)關(guān)注腳本之家其它相關(guān)文章！

您可能感興趣的文章: