分布式任務(wù)調(diào)度組件 LTS 用戶文檔

LTS用戶文檔

LTS(light-task-scheduler)主要用于解決分布式任務(wù)調(diào)度問題，支持實(shí)時(shí)任務(wù)殊鞭，定時(shí)任務(wù)和Cron任務(wù)。有較好的伸縮性尼桶，擴(kuò)展性操灿，健壯穩(wěn)定性而被多家公司使用闭翩，同時(shí)也希望開源愛好者一起貢獻(xiàn)唯袄。

項(xiàng)目地址

github地址: https://github.com/ltsopensource/light-task-scheduler

oschina地址: http://git.oschina.net/hugui/light-task-scheduler

例子: https://github.com/ltsopensource/lts-examples

框架概況

LTS 有主要有以下四種節(jié)點(diǎn)：

  • JobClient：主要負(fù)責(zé)提交任務(wù), 并接收任務(wù)執(zhí)行反饋結(jié)果忌卤。
  • JobTracker：負(fù)責(zé)接收并分配任務(wù)，任務(wù)調(diào)度福澡。
  • TaskTracker：負(fù)責(zé)執(zhí)行任務(wù)，執(zhí)行完反饋給JobTracker忿檩。
  • LTS-Admin：（管理后臺(tái)）主要負(fù)責(zé)節(jié)點(diǎn)管理东抹，任務(wù)隊(duì)列管理，監(jiān)控管理等本缠。

其中JobClient斥扛，JobTracker，TaskTracker節(jié)點(diǎn)都是無狀態(tài)的丹锹。 可以部署多個(gè)并動(dòng)態(tài)的進(jìn)行刪減稀颁，來實(shí)現(xiàn)負(fù)載均衡，實(shí)現(xiàn)更大的負(fù)載量, 并且框架采用FailStore策略使LTS具有很好的容錯(cuò)能力卷仑。

LTS注冊(cè)中心提供多種實(shí)現(xiàn)（Zookeeper峻村，redis等），注冊(cè)中心進(jìn)行節(jié)點(diǎn)信息暴露锡凝，master選舉粘昨。(Mongo or Mysql)存儲(chǔ)任務(wù)隊(duì)列和任務(wù)執(zhí)行日志, netty or mina做底層通信, 并提供多種序列化方式fastjson, hessian2, java等。

LTS支持任務(wù)類型：

  • 實(shí)時(shí)任務(wù)：提交了之后立即就要執(zhí)行的任務(wù)窜锯。
  • 定時(shí)任務(wù)：在指定時(shí)間點(diǎn)執(zhí)行的任務(wù)张肾，譬如 今天3點(diǎn)執(zhí)行（單次）。
  • Cron任務(wù)：CronExpression锚扎，和quartz類似（但是不是使用quartz實(shí)現(xiàn)的）譬如 0 0/1 * * * ?

支持動(dòng)態(tài)修改任務(wù)參數(shù),任務(wù)執(zhí)行時(shí)間等設(shè)置,支持后臺(tái)動(dòng)態(tài)添加任務(wù),支持Cron任務(wù)暫停,支持手動(dòng)停止正在執(zhí)行的任務(wù)(有條件),支持任務(wù)的監(jiān)控統(tǒng)計(jì),支持各個(gè)節(jié)點(diǎn)的任務(wù)執(zhí)行監(jiān)控,JVM監(jiān)控等等.

架構(gòu)圖

概念說明

節(jié)點(diǎn)組

  1. 英文名稱 NodeGroup,一個(gè)節(jié)點(diǎn)組等同于一個(gè)小的集群吞瞪，同一個(gè)節(jié)點(diǎn)組中的各個(gè)節(jié)點(diǎn)是對(duì)等的，等效的驾孔，對(duì)外提供相同的服務(wù)芍秆。
  2. 每個(gè)節(jié)點(diǎn)組中都有一個(gè)master節(jié)點(diǎn)，這個(gè)master節(jié)點(diǎn)是由LTS動(dòng)態(tài)選出來的翠勉，當(dāng)一個(gè)master節(jié)點(diǎn)掛掉之后妖啥，LTS會(huì)立馬選出另外一個(gè)master節(jié)點(diǎn)，框架提供API監(jiān)聽接口給用戶对碌。

FailStore

  1. 顧名思義荆虱，這個(gè)主要是用于失敗了存儲(chǔ)的，主要用于節(jié)點(diǎn)容錯(cuò)朽们，當(dāng)遠(yuǎn)程數(shù)據(jù)交互失敗之后怀读，存儲(chǔ)在本地，等待遠(yuǎn)程通信恢復(fù)的時(shí)候骑脱，再將數(shù)據(jù)提交菜枷。
  2. FailStore主要用戶JobClient的任務(wù)提交，TaskTracker的任務(wù)反饋惜姐，TaskTracker的業(yè)務(wù)日志傳輸?shù)膱?chǎng)景下犁跪。
  3. FailStore目前提供幾種實(shí)現(xiàn)：leveldb,rocksdb,berkeleydb,mapdb,ltsdb椿息，用于可以自由選擇使用哪種,用戶也可以采用SPI擴(kuò)展使用自己的實(shí)現(xiàn)。

流程圖

下圖是一個(gè)標(biāo)準(zhǔn)的實(shí)時(shí)任務(wù)執(zhí)行流程坷衍。

image.png

目前后臺(tái)帶有由ztajy提供的一個(gè)簡(jiǎn)易的認(rèn)證功能. 用戶名密碼在auth.cfg中,用戶自行修改.

特性

1寝优、Spring支持

LTS可以完全不用Spring框架，但是考慮到很用用戶項(xiàng)目中都是用了Spring框架枫耳，所以LTS也提供了對(duì)Spring的支持乏矾，包括Xml和注解，引入lts-spring.jar即可迁杨。

2钻心、業(yè)務(wù)日志記錄器

在TaskTracker端提供了業(yè)務(wù)日志記錄器，供應(yīng)用程序使用铅协，通過這個(gè)業(yè)務(wù)日志器捷沸，可以將業(yè)務(wù)日志提交到JobTracker，這些業(yè)務(wù)日志可以通過任務(wù)ID串聯(lián)起來狐史，可以在LTS-Admin中實(shí)時(shí)查看任務(wù)的執(zhí)行進(jìn)度痒给。

3、SPI擴(kuò)展支持

SPI擴(kuò)展可以達(dá)到零侵入骏全，只需要實(shí)現(xiàn)相應(yīng)的接口苍柏，并實(shí)現(xiàn)即可被LTS使用，目前開放出來的擴(kuò)展接口有
對(duì)任務(wù)隊(duì)列的擴(kuò)展姜贡，用戶可以不選擇使用mysql或者mongo作為隊(duì)列存儲(chǔ)试吁，也可以自己實(shí)現(xiàn)。
對(duì)業(yè)務(wù)日志記錄器的擴(kuò)展楼咳，目前主要支持console熄捍，mysql，mongo母怜，用戶也可以通過擴(kuò)展選擇往其他地方輸送日志治唤。

4、故障轉(zhuǎn)移

當(dāng)正在執(zhí)行任務(wù)的TaskTracker宕機(jī)之后糙申，JobTracker會(huì)立馬將分配在宕機(jī)的TaskTracker的所有任務(wù)再分配給其他正常的TaskTracker節(jié)點(diǎn)執(zhí)行。

5船惨、節(jié)點(diǎn)監(jiān)控

可以對(duì)JobTracker柜裸，TaskTracker節(jié)點(diǎn)進(jìn)行資源監(jiān)控，任務(wù)監(jiān)控等粱锐，可以實(shí)時(shí)的在LTS-Admin管理后臺(tái)查看疙挺，進(jìn)而進(jìn)行合理的資源調(diào)配。

6怜浅、多樣化任務(wù)執(zhí)行結(jié)果支持

LTS框架提供四種執(zhí)行結(jié)果支持铐然，EXECUTE_SUCCESS蔬崩，EXECUTE_FAILED，EXECUTE_LATER搀暑，EXECUTE_EXCEPTION沥阳，并對(duì)每種結(jié)果采取相應(yīng)的處理機(jī)制，譬如重試自点。

EXECUTE_SUCCESS: 執(zhí)行成功,這種情況桐罕，直接反饋客戶端（如果任務(wù)被設(shè)置了要反饋給客戶端）。
EXECUTE_FAILED：執(zhí)行失敗桂敛，這種情況功炮，直接反饋給客戶端，不進(jìn)行重試术唬。
EXECUTE_LATER：稍后執(zhí)行（需要重試）薪伏，這種情況，不反饋客戶端粗仓，重試策略采用1min嫁怀，2min，3min的策略潦牛，默認(rèn)最大重試次數(shù)為10次眶掌，用戶可以通過參數(shù)設(shè)置修改這個(gè)重試次數(shù)。
EXECUTE_EXCEPTION：執(zhí)行異常, 這種情況也會(huì)重試(重試策略巴碗，同上)

7朴爬、FailStore容錯(cuò)

采用FailStore機(jī)制來進(jìn)行節(jié)點(diǎn)容錯(cuò)，F(xiàn)ail And Store橡淆，不會(huì)因?yàn)檫h(yuǎn)程通信的不穩(wěn)定性而影響當(dāng)前應(yīng)用的運(yùn)行召噩。具體FailStore說明，請(qǐng)參考概念說明中的FailStore說明逸爵。

項(xiàng)目編譯打包

項(xiàng)目主要采用maven進(jìn)行構(gòu)建具滴，目前提供shell腳本的打包。 環(huán)境依賴：Java(jdk1.6+) Maven

用戶使用一般分為兩種：

1师倔、Maven構(gòu)建

可以通過maven命令將lts的jar包上傳到本地倉庫中构韵。在父pom.xml中添加相應(yīng)的repository，并用deploy命令上傳即可趋艘。具體引用方式可以參考lts中的例子即可疲恢。

2、直接Jar引用

需要將lts的各個(gè)模塊打包成單獨(dú)的jar包瓷胧，并且將所有l(wèi)ts依賴包引入显拳。具體引用哪些jar包可以參考lts中的例子即可。

JobTracker和LTS-Admin部署

提供(cmd)windows和(shell)linux兩種版本腳本來進(jìn)行編譯和部署:

運(yùn)行根目錄下的sh build.sh或build.cmd腳本搓萧，會(huì)在dist目錄下生成lts-{version}-bin文件夾

下面是其目錄結(jié)構(gòu)杂数，其中bin目錄主要是JobTracker和LTS-Admin的啟動(dòng)腳本宛畦。jobtracker 中是 JobTracker的配置文件和需要使用到的jar包，lts-admin是LTS-Admin相關(guān)的war包和配置文件揍移。 lts-{version}-bin的文件結(jié)構(gòu)

-- lts-${version}-bin
|-- bin
| |-- jobtracker.cmd
| |-- jobtracker.sh
| |-- lts-admin.cmd
| |-- lts-admin.sh
| |-- lts-monitor.cmd
| |-- lts-monitor.sh
| |-- tasktracker.sh
|-- conf
| |-- log4j.properties
| |-- lts-admin.cfg
| |-- lts-monitor.cfg
| |-- readme.txt
| |-- tasktracker.cfg
| |-- zoo
| |-- jobtracker.cfg
| |-- log4j.properties
| |-- lts-monitor.cfg
|-- lib
| |-- *.jar
|-- war
|-- jetty
| |-- lib
| |-- *.jar
|-- lts-admin.war

JobTracker啟動(dòng)次和。如果你想啟動(dòng)一個(gè)節(jié)點(diǎn)，直接修改下conf/zoo下的配置文件羊精，然后運(yùn)行 sh jobtracker.sh zoo start即可斯够，如果你想啟動(dòng)兩個(gè)JobTracker節(jié)點(diǎn)，那么你需要拷貝一份zoo,譬如命名為zoo2,修改下zoo2下的配置文件喧锦，然后運(yùn)行sh jobtracker.sh zoo2 start即可读规。logs文件夾下生成jobtracker-zoo.out日志。
LTS-Admin啟動(dòng).修改conf/lts-monitor.cfg和conf/lts-admin.cfg下的配置燃少，然后運(yùn)行bin下的sh lts-admin.sh或lts-admin.cmd腳本即可束亏。logs文件夾下會(huì)生成lts-admin.out日志，啟動(dòng)成功在日志中會(huì)打印出訪問地址阵具，用戶可以通過這個(gè)訪問地址訪問了碍遍。

JobClient（部署）使用

需要引入lts的jar包有l(wèi)ts-jobclient-{version}.jar，lts-core-{version}.jar 及其它第三方依賴jar阳液。

API方式啟動(dòng)

JobClient jobClient = new RetryJobClient();
jobClient.setNodeGroup("test_jobClient");
jobClient.setClusterName("test_cluster");
jobClient.setRegistryAddress("zookeeper://127.0.0.1:2181");
jobClient.start();

// 提交任務(wù)
Job job = new Job();
job.setTaskId("3213213123");
job.setParam("shopId", "11111");
job.setTaskTrackerNodeGroup("test_trade_TaskTracker");
// job.setCronExpression("0 0/1 * * * ?");  // 支持 cronExpression表達(dá)式
// job.setTriggerTime(new Date()); // 支持指定時(shí)間執(zhí)行
Response response = jobClient.submitJob(job);

Spring XML方式啟動(dòng)

<bean id="jobClient" class="com.github.ltsopensource.spring.JobClientFactoryBean">
    <property name="clusterName" value="test_cluster"/>
    <property name="registryAddress" value="zookeeper://127.0.0.1:2181"/>
    <property name="nodeGroup" value="test_jobClient"/>
    <property name="masterChangeListeners">
        <list>
            <bean class="com.github.ltsopensource.example.support.MasterChangeListenerImpl"/>
        </list>
    </property>
    <property name="jobFinishedHandler">
        <bean class="com.github.ltsopensource.example.support.JobFinishedHandlerImpl"/>
    </property>
    <property name="configs">
        <props>
            <!-- 參數(shù) -->
            <prop key="job.fail.store">leveldb</prop>
        </props>
    </property>
</bean>

Spring 全注解方式

@Configuration
public class LTSSpringConfig {

    @Bean(name = "jobClient")
    public JobClient getJobClient() throws Exception {
        JobClientFactoryBean factoryBean = new JobClientFactoryBean();
        factoryBean.setClusterName("test_cluster");
        factoryBean.setRegistryAddress("zookeeper://127.0.0.1:2181");
        factoryBean.setNodeGroup("test_jobClient");
        factoryBean.setMasterChangeListeners(new MasterChangeListener[]{
                new MasterChangeListenerImpl()
        });
        Properties configs = new Properties();
        configs.setProperty("job.fail.store", "leveldb");
        factoryBean.setConfigs(configs);
        factoryBean.afterPropertiesSet();
        return factoryBean.getObject();
    }
}

TaskTracker(部署使用)

需要引入lts的jar包有l(wèi)ts-tasktracker-{version}.jar怕敬，lts-core-{version}.jar 及其它第三方依賴jar。 ###定義自己的任務(wù)執(zhí)行類

public class MyJobRunner implements JobRunner {
    @Override
    public Result run(JobContext jobContext) throws Throwable {
        try {
            // TODO 業(yè)務(wù)邏輯
            // 會(huì)發(fā)送到 LTS (JobTracker上)
            jobContext.getBizLogger().info("測(cè)試帘皿，業(yè)務(wù)日志啊啊啊啊啊");

        } catch (Exception e) {
            return new Result(Action.EXECUTE_FAILED, e.getMessage());
        }
        return new Result(Action.EXECUTE_SUCCESS, "執(zhí)行成功了东跪，哈哈");
    }
}

API方式啟動(dòng)

TaskTracker taskTracker = new TaskTracker();
taskTracker.setJobRunnerClass(MyJobRunner.class);
taskTracker.setRegistryAddress("zookeeper://127.0.0.1:2181");
taskTracker.setNodeGroup("test_trade_TaskTracker");
taskTracker.setClusterName("test_cluster");
taskTracker.setWorkThreads(20);
taskTracker.start();

Spring XML方式啟動(dòng)

<bean id="taskTracker" class="com.github.ltsopensource.spring.TaskTrackerAnnotationFactoryBean" init-method="start">
    <property name="jobRunnerClass" value="com.github.ltsopensource.example.support.MyJobRunner"/>
    <property name="bizLoggerLevel" value="INFO"/>
    <property name="clusterName" value="test_cluster"/>
    <property name="registryAddress" value="zookeeper://127.0.0.1:2181"/>
    <property name="nodeGroup" value="test_trade_TaskTracker"/>
    <property name="workThreads" value="20"/>
    <property name="masterChangeListeners">
        <list>
            <bean class="com.github.ltsopensource.example.support.MasterChangeListenerImpl"/>
        </list>
    </property>
    <property name="configs">
        <props>
            <prop key="job.fail.store">leveldb</prop>
        </props>
    </property>
</bean>

Spring注解方式啟動(dòng)

@Configuration
public class LTSSpringConfig implements ApplicationContextAware {
    private ApplicationContext applicationContext;
    @Override
    public void setApplicationContext(ApplicationContext applicationContext) throws BeansException {
        this.applicationContext = applicationContext;
    }
    @Bean(name = "taskTracker")
    public TaskTracker getTaskTracker() throws Exception {
        TaskTrackerAnnotationFactoryBean factoryBean = new TaskTrackerAnnotationFactoryBean();
        factoryBean.setApplicationContext(applicationContext);
        factoryBean.setClusterName("test_cluster");
        factoryBean.setJobRunnerClass(MyJobRunner.class);
        factoryBean.setNodeGroup("test_trade_TaskTracker");
        factoryBean.setBizLoggerLevel("INFO");
        factoryBean.setRegistryAddress("zookeeper://127.0.0.1:2181");
        factoryBean.setMasterChangeListeners(new MasterChangeListener[]{
                new MasterChangeListenerImpl()
        });
        factoryBean.setWorkThreads(20);
        Properties configs = new Properties();
        configs.setProperty("job.fail.store", "leveldb");
        factoryBean.setConfigs(configs);

        factoryBean.afterPropertiesSet();
//        factoryBean.start();
        return factoryBean.getObject();
    }
}

參數(shù)說明

參數(shù)說明

使用建議

一般在一個(gè)JVM中只需要一個(gè)JobClient實(shí)例即可，不要為每種任務(wù)都新建一個(gè)JobClient實(shí)例鹰溜，這樣會(huì)大大的浪費(fèi)資源虽填，因?yàn)橐粋€(gè)JobClient可以提交多種任務(wù)。相同的一個(gè)JVM一般也盡量保持只有一個(gè)TaskTracker實(shí)例即可曹动，多了就可能造成資源浪費(fèi)斋日。當(dāng)遇到一個(gè)TaskTracker要運(yùn)行多種任務(wù)的時(shí)候，請(qǐng)參考下面的 "一個(gè)TaskTracker執(zhí)行多種任務(wù)"墓陈。

一個(gè)TaskTracker執(zhí)行多種任務(wù)

有的時(shí)候恶守，業(yè)務(wù)場(chǎng)景需要執(zhí)行多種任務(wù)，有些人會(huì)問贡必，是不是要每種任務(wù)類型都要一個(gè)TaskTracker去執(zhí)行熬的。我的答案是否定的，如果在一個(gè)JVM中赊级，最好使用一個(gè)TaskTracker去運(yùn)行多種任務(wù)，因?yàn)橐粋€(gè)JVM中使用多個(gè)TaskTracker實(shí)例比較浪費(fèi)資源（當(dāng)然當(dāng)你某種任務(wù)量比較多的時(shí)候岔绸，可以將這個(gè)任務(wù)單獨(dú)使用一個(gè)TaskTracker節(jié)點(diǎn)來執(zhí)行）理逊。那么怎么才能實(shí)現(xiàn)一個(gè)TaskTracker執(zhí)行多種任務(wù)呢橡伞。下面是我給出來的參考例子。

/**
 * 總?cè)肟诮唬?taskTracker.setJobRunnerClass(JobRunnerDispatcher.class)
 * JobClient 提交 任務(wù)時(shí)指定 Job 類型  job.setParam("type", "aType")
 */
public class JobRunnerDispatcher implements JobRunner {

    private static final ConcurrentHashMap<String/*type*/, JobRunner>
            JOB_RUNNER_MAP = new ConcurrentHashMap<String, JobRunner>();

    static {
        JOB_RUNNER_MAP.put("aType", new JobRunnerA()); // 也可以從Spring中拿
        JOB_RUNNER_MAP.put("bType", new JobRunnerB());
    }

    @Override
    public Result run(JobContext jobContext) throws Throwable {
        Job job = jobContext.getJob();
        String type = job.getParam("type");
        return JOB_RUNNER_MAP.get(type).run(job);
    }
}

class JobRunnerA implements JobRunner {
    @Override
    public Result run(JobContext jobContext) throws Throwable {
        //  TODO A類型Job的邏輯
        return null;
    }
}

class JobRunnerB implements JobRunner {
    @Override
    public Result run(JobContext jobContext) throws Throwable {
        // TODO B類型Job的邏輯
        return null;
    }
}

TaskTracker的JobRunner測(cè)試

一般在編寫TaskTracker的時(shí)候兑徘，只需要測(cè)試JobRunner的實(shí)現(xiàn)邏輯是否正確，又不想啟動(dòng)LTS進(jìn)行遠(yuǎn)程測(cè)試羡洛。為了方便測(cè)試挂脑，LTS提供了JobRunner的快捷測(cè)試方法。自己的測(cè)試類集成com.github.ltsopensource.tasktracker.runner.JobRunnerTester即可欲侮，并實(shí)現(xiàn)initContext和newJobRunner方法即可崭闲。如lts-examples中的例子：

public class TestJobRunnerTester extends JobRunnerTester {

    public static void main(String[] args) throws Throwable {
        //  Mock Job 數(shù)據(jù)
        Job job = new Job();
        job.setTaskId("2313213");

        JobContext jobContext = new JobContext();
        jobContext.setJob(job);

        JobExtInfo jobExtInfo = new JobExtInfo();
        jobExtInfo.setRetry(false);

        jobContext.setJobExtInfo(jobExtInfo);

        // 運(yùn)行測(cè)試
        TestJobRunnerTester tester = new TestJobRunnerTester();
        Result result = tester.run(jobContext);
        System.out.println(JSON.toJSONString(result));
    }

    @Override
    protected void initContext() {
        // TODO 初始化Spring容器
    }

    @Override
    protected JobRunner newJobRunner() {
        return new TestJobRunner();
    }
}

Spring Quartz Cron任務(wù)無縫接入

對(duì)于Quartz的Cron任務(wù)只需要在Spring配置中增加一下代碼就可以接入LTS平臺(tái)

<bean class="com.github.ltsopensource.spring.quartz.QuartzLTSProxyBean">
    <property name="clusterName" value="test_cluster"/>
    <property name="registryAddress" value="zookeeper://127.0.0.1:2181"/>
    <property name="nodeGroup" value="quartz_test_group"/>
</bean>

Spring Boot 支持

@SpringBootApplication
@EnableJobTracker       // 啟動(dòng)JobTracker
@EnableJobClient        // 啟動(dòng)JobClient
@EnableTaskTracker      // 啟動(dòng)TaskTracker
@EnableMonitor          // 啟動(dòng)Monitor
public class Application {
    public static void main(String[] args) {
        SpringApplication.run(Application.class, args);
    }
}

剩下的就只是在application.properties中添加相應(yīng)的配置就行了, 具體見lts-example中的com.github.ltsopensource.examples.springboot包下的例子

多網(wǎng)卡選擇問題

當(dāng)機(jī)器有內(nèi)網(wǎng)兩個(gè)網(wǎng)卡的時(shí)候，有時(shí)候威蕉，用戶想讓LTS的流量走外網(wǎng)網(wǎng)卡刁俭，那么需要在host中，把主機(jī)名稱的映射地址改為外網(wǎng)網(wǎng)卡地址即可韧涨，內(nèi)網(wǎng)同理牍戚。

關(guān)于節(jié)點(diǎn)標(biāo)識(shí)問題

如果在節(jié)點(diǎn)啟動(dòng)的時(shí)候設(shè)置節(jié)點(diǎn)標(biāo)識(shí),LTS會(huì)默認(rèn)設(shè)置一個(gè)UUID為節(jié)點(diǎn)標(biāo)識(shí),可讀性會(huì)比較差,但是能保證每個(gè)節(jié)點(diǎn)的唯一性,如果用戶能自己保證節(jié)點(diǎn)標(biāo)識(shí)的唯一性,可以通過 setIdentity 來設(shè)置,譬如如果每個(gè)節(jié)點(diǎn)都是部署在一臺(tái)機(jī)器(一個(gè)虛擬機(jī))上,那么可以將identity設(shè)置為主機(jī)名稱

SPI擴(kuò)展說明

支持JobLogger,JobQueue等等的SPI擴(kuò)展

和其它解決方案比較

LTS-Admin使用jetty啟動(dòng)(默認(rèn))，不定期掛掉解決方案 見issue#389

歡迎關(guān)注 高廣超的簡(jiǎn)書博客 與 收藏文章 虑粥！
歡迎關(guān)注 頭條號(hào)：互聯(lián)網(wǎng)技術(shù)棧 如孝！

個(gè)人介紹：

高廣超：多年一線互聯(lián)網(wǎng)研發(fā)與架構(gòu)設(shè)計(jì)經(jīng)驗(yàn)，擅長(zhǎng)設(shè)計(jì)與落地高可用娩贷、高性能第晰、可擴(kuò)展的互聯(lián)網(wǎng)架構(gòu)。目前從事大數(shù)據(jù)相關(guān)研發(fā)與架構(gòu)工作育勺。

本文首發(fā)在 高廣超的簡(jiǎn)書博客 轉(zhuǎn)載請(qǐng)注明但荤！

?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請(qǐng)聯(lián)系作者
  • 人面猴
    序言：七十年代末，一起剝皮案震驚了整個(gè)濱河市涧至，隨后出現(xiàn)的幾起案子腹躁，更是在濱河造成了極大的恐慌，老刑警劉巖南蓬，帶你破解...
    沈念sama閱讀 206,126評(píng)論 6贊 481
  • 死咒
    序言：濱河連續(xù)發(fā)生了三起死亡事件纺非，死亡現(xiàn)場(chǎng)離奇詭異，居然都是意外死亡赘方，警方通過查閱死者的電腦和手機(jī)烧颖，發(fā)現(xiàn)死者居然都...
    沈念sama閱讀 88,254評(píng)論 2贊 382
  • 救了他兩次的神仙讓他今天三更去死
    文/潘曉璐 我一進(jìn)店門，熙熙樓的掌柜王于貴愁眉苦臉地迎上來窄陡，“玉大人炕淮，你說我怎么就攤上這事√玻” “怎么了涂圆？”我有些...
    開封第一講書人閱讀 152,445評(píng)論 0贊 341
  • 道士緝兇錄：失蹤的賣姜人
    文/不壞的土叔 我叫張陵们镜，是天一觀的道長(zhǎng)。 經(jīng)常有香客問我润歉，道長(zhǎng)模狭，這世上最難降的妖魔是什么？ 我笑而不...
    開封第一講書人閱讀 55,185評(píng)論 1贊 278
  • ?港島之戀（遺憾婚禮）
    正文 為了忘掉前任踩衩，我火速辦了婚禮嚼鹉，結(jié)果婚禮上，老公的妹妹穿的比我還像新娘驱富。我一直安慰自己锚赤，他們只是感情好，可當(dāng)我...
    茶點(diǎn)故事閱讀 64,178評(píng)論 5贊 371
  • 惡毒庶女頂嫁案：這布局不是一般人想出來的
    文/花漫 我一把揭開白布萌朱。 她就那樣靜靜地躺著宴树，像睡著了一般。 火紅的嫁衣襯著肌膚如雪晶疼。 梳的紋絲不亂的頭發(fā)上酒贬，一...
    開封第一講書人閱讀 48,970評(píng)論 1贊 284
  • 城市分裂傳說
    那天，我揣著相機(jī)與錄音翠霍，去河邊找鬼锭吨。 笑死，一個(gè)胖子當(dāng)著我的面吹牛寒匙，可吹牛的內(nèi)容都是我干的零如。 我是一名探鬼主播，決...
    沈念sama閱讀 38,276評(píng)論 3贊 399
  • 雙鴛鴦連環(huán)套：你想象不到人心有多黑
    文/蒼蘭香墨 我猛地睜開眼锄弱，長(zhǎng)吁一口氣：“原來是場(chǎng)噩夢(mèng)啊……” “哼考蕾！你這毒婦竟也來了？” 一聲冷哼從身側(cè)響起会宪，我...
    開封第一講書人閱讀 36,927評(píng)論 0贊 259
  • 萬榮殺人案實(shí)錄
    序言：老撾萬榮一對(duì)情侶失蹤肖卧，失蹤者是張志新（化名）和其女友劉穎，沒想到半個(gè)月后掸鹅，有當(dāng)?shù)厝嗽跇淞掷锇l(fā)現(xiàn)了一具尸體塞帐，經(jīng)...
    沈念sama閱讀 43,400評(píng)論 1贊 300
  • ?護(hù)林員之死
    正文 獨(dú)居荒郊野嶺守林人離奇死亡，尸身上長(zhǎng)有42處帶血的膿包…… 初始之章·張勛 以下內(nèi)容為張勛視角 年9月15日...
    茶點(diǎn)故事閱讀 35,883評(píng)論 2贊 323
  • ?白月光啟示錄
    正文 我和宋清朗相戀三年巍沙，在試婚紗的時(shí)候發(fā)現(xiàn)自己被綠了葵姥。 大學(xué)時(shí)的朋友給我發(fā)了我未婚夫和他白月光在一起吃飯的照片。...
    茶點(diǎn)故事閱讀 37,997評(píng)論 1贊 333
  • 活死人
    序言：一個(gè)原本活蹦亂跳的男人離奇死亡句携，死狀恐怖榔幸，靈堂內(nèi)的尸體忽然破棺而出，到底是詐尸還是另有隱情，我是刑警寧澤削咆，帶...
    沈念sama閱讀 33,646評(píng)論 4贊 322
  • ?日本核電站爆炸內(nèi)幕
    正文 年R本政府宣布喳篇，位于F島的核電站，受9級(jí)特大地震影響态辛，放射性物質(zhì)發(fā)生泄漏。R本人自食惡果不足惜挺尿，卻給世界環(huán)境...
    茶點(diǎn)故事閱讀 39,213評(píng)論 3贊 307
  • 男人毒藥：我在死后第九天來索命
    文/蒙蒙 一奏黑、第九天 我趴在偏房一處隱蔽的房頂上張望。 院中可真熱鬧编矾，春花似錦熟史、人聲如沸。這莊子的主人今日做“春日...
    開封第一講書人閱讀 30,204評(píng)論 0贊 19
  • 一樁弒父案蹂匹，背后竟有這般陰謀
    文/蒼蘭香墨 我抬頭看了看天上的太陽。三九已至凹蜈，卻和暖如春限寞，著一層夾襖步出監(jiān)牢的瞬間，已是汗流浹背仰坦。 一陣腳步聲響...
    開封第一講書人閱讀 31,423評(píng)論 1贊 260
  • 情欲美人皮
    我被黑心中介騙來泰國(guó)打工履植， 沒想到剛下飛機(jī)就差點(diǎn)兒被人妖公主榨干…… 1. 我叫王不留，地道東北人悄晃。 一個(gè)月前我還...
    沈念sama閱讀 45,423評(píng)論 2贊 352
  • 代替公主和親
    正文 我出身青樓玫霎，卻偏偏與公主長(zhǎng)得像，于是被迫代替她去往敵國(guó)和親妈橄。 傳聞我的和親對(duì)象是個(gè)殘疾皇子庶近，可洞房花燭夜當(dāng)晚...
    茶點(diǎn)故事閱讀 42,722評(píng)論 2贊 345

推薦閱讀更多精彩內(nèi)容

  • Spring Cloud為開發(fā)人員提供了快速構(gòu)建分布式系統(tǒng)中一些常見模式的工具（例如配置管理，服務(wù)發(fā)現(xiàn)眷蚓，斷路器鼻种，智...
    卡卡羅2017閱讀 134,599評(píng)論 18贊 139
  • 問題：1.job的本質(zhì)是什么？ 2.任務(wù)的本質(zhì)是什么溪椎？ 3.文件系統(tǒng)的Namespace由誰來管理普舆，Namespa...
    時(shí)待吾閱讀 2,277評(píng)論 0贊 0
  • Hadoop部署方式 本地模式 偽分布模式(在一臺(tái)機(jī)器中模擬，讓所有進(jìn)程在一臺(tái)機(jī)器上運(yùn)行) 集群模式 服務(wù)器只是一...
    陳半仙兒閱讀 1,601評(píng)論 0贊 9
  • Spring Boot 參考指南 介紹 轉(zhuǎn)載自:https://www.gitbook.com/book/qbgb...
    毛宇鵬閱讀 46,748評(píng)論 6贊 342
  • 一呼三應(yīng)校读，遠(yuǎn)山行沼侣。白盤珠，東進(jìn)西出歉秫，綠鏡映百里妖嬈蛾洛。 秀水青山，涼風(fēng)盈。驕陽暖轧膘，金秋送爽钞螟，愜意隨汗水飛揚(yáng)。 革命老...
    panjw閱讀 157評(píng)論 0贊 1