? 在elastic-Job作業(yè)啟動的時候文留，首先會去持久化LiteJob的配置信息，持久化保存之前先去會檢查job存不存在竭沫，讀取zk上的原有配置的job信息燥翅，如果節(jié)點不存在，或者需要重寫的時候蜕提，去注冊中心寫節(jié)點或者是修改節(jié)點數據森书。
//SchedulerFacade.java
/**
* 更新作業(yè)配置.
*
* @param liteJobConfig 作業(yè)配置
* @return 更新后的作業(yè)配置
*/
public LiteJobConfiguration updateJobConfiguration(final LiteJobConfiguration liteJobConfig) {
//持久化LiteJob配置
configService.persist(liteJobConfig);
return configService.load(false);
}
//ConfigurationService.java
/**
* 持久化分布式作業(yè)配置信息.
*
* @param liteJobConfig 作業(yè)配置
*/
public void persist(final LiteJobConfiguration liteJobConfig) {
//檢查沖突作業(yè)
checkConflictJob(liteJobConfig);
if (!jobNodeStorage.isJobNodeExisted(ConfigurationNode.ROOT) || liteJobConfig.isOverwrite()) {
jobNodeStorage.replaceJobNode(ConfigurationNode.ROOT, LiteJobConfigurationGsonFactory.toJson(liteJobConfig));
}
}
//檢查沖突作業(yè)
private void checkConflictJob(final LiteJobConfiguration liteJobConfig) {
//查從注冊中心獲取舊的配置
Optional<LiteJobConfiguration> liteJobConfigFromZk = find();
//返回Optional是啥這個Optional是啥？谎势？.isPresent是啥方法凛膏，百思不得其解
if (liteJobConfigFromZk.isPresent() && !liteJobConfigFromZk.get().getTypeConfig().getJobClass().equals(liteJobConfig.getTypeConfig().getJobClass())) {
throw new JobConfigurationException("Job conflict with register center. The job '%s' in register center's class is '%s', your job class is '%s'",
liteJobConfig.getJobName(), liteJobConfigFromZk.get().getTypeConfig().getJobClass(), liteJobConfig.getTypeConfig().getJobClass());
}
}
//返回值是optional，這個是什么東東脏榆？猖毫？
private Optional<LiteJobConfiguration> find() {
if (!jobNodeStorage.isJobNodeExisted(ConfigurationNode.ROOT)) {
return Optional.absent();
}
LiteJobConfiguration result = LiteJobConfigurationGsonFactory.fromJson(jobNodeStorage.getJobNodeDataDirectly(ConfigurationNode.ROOT));
if (null == result) {
// TODO 應該刪除整個job node,并非僅僅刪除config node
jobNodeStorage.removeJobNodeIfExisted(ConfigurationNode.ROOT);
}
//這里還是一臉懵逼 optional是干嘛的？须喂？
return Optional.fromNullable(result);
}
? 根據邏輯吁断，應該是在配置中心獲取舊的配置，檢查舊配置是否存在坞生，判斷是不是null仔役，然后再判斷要不要重寫， Optional<LiteJobConfiguration> liteJobConfigFromZk = find(); 那這里應該是返回LiteJobConfiguration才對是己，Optional是個什么東東又兵？？打開這個Optional看了一下類結構卒废，在guava包里沛厨，依賴如下：
<dependency>
<groupId>com.google.guava</groupId>
<artifactId>guava</artifactId>
<version>18.0</version>
</dependency>
? 原來是鼎鼎大名的guava，膜拜膜拜摔认。那么這個Optional到底是啥俄烁？？看業(yè)務邏輯liteJobConfigFromZk.isPresent()應該是不為null的意思级野，看到不懂得地方页屠，趕快去總結總結Optional的用法和API：
-
構造方法：該Optional接口實現類有兩個，一個為Absent蓖柔，一個為Present辰企，中文意思為缺席的，出席的况鸣，然后個人理解牢贸，Present為存在的，Absent為不存在的镐捧。
-
absent()
- 返回absent對象
-
of(T t)
- t不能為null潜索，否則拋異常
-
fromNullable(T t)
- 可以為null臭增，為null時，構造absent對象竹习，否則構造Present
-
absent()
-
isPresent()
- 是否是present誊抛，不是則為absent。
-
get()
- 返回Optional包含的T實例整陌，若為null拗窃，拋異常
-
or(T)
- 若Option包含了值，返回Optional包含的T泌辫，否則返回輸入的T實例作為默認值
-
orNull()
- 返回Optional實例中包含的非空T實例随夸，如果Optional中包含的是空值，返回null;
在elasticJob中震放，節(jié)點不存在或者節(jié)點配置job的信息為null宾毒，返回Absent，否則返回Present殿遂。如果Job配置是present的狀態(tài)且作業(yè)監(jiān)聽類不一致诈铛，拋異常，檢查失敗勉躺。
這里是使用Optional代替了null值得判斷，具體帶來的好處觅丰，相信搜索一有很多鏈接都寫得很好饵溅。
Guava學習筆記：Optional優(yōu)雅的使用null
使用google guava的Optional接口來避免空指針錯誤
