熟练使用 Elastic Job系列之作业分片策略(五)
自帶的分片策略
框架默認(rèn)提供了三種分片策略,所有的分片策略都是接口JobShardingStrategy的實(shí)現(xiàn)?
AverageAllocationJobShardingStrategy
全類路徑:?io.elasticjob.lite.api.strategy.impl.AverageAllocationJobShardingStrategy
策略說(shuō)明:
OdevitySortByNameJobShardingStrategy
全類路徑:?io.elasticjob.lite.api.strategy.impl.OdevitySortByNameJobShardingStrategy
策略說(shuō)明:
AverageAllocationJobShardingStrategy VS OdevitySortByNameJobShardingStrategy
AverageAllocationJobShardingStrategy的缺點(diǎn)是,一旦分片數(shù)小于作業(yè)服務(wù)器數(shù),作業(yè)將永遠(yuǎn)分配至IP地址靠前的服務(wù)器,導(dǎo)致IP地址靠后的服務(wù)器空閑。而OdevitySortByNameJobShardingStrategy則可以根據(jù)作業(yè)名稱重新分配服務(wù)器負(fù)載。如:
如果有3臺(tái)服務(wù)器,分成2片,作業(yè)名稱的哈希值為奇數(shù),則每臺(tái)服務(wù)器分到的分片是:1=[0], 2=[1], 3=[]
如果有3臺(tái)服務(wù)器,分成2片,作業(yè)名稱的哈希值為偶數(shù),則每臺(tái)服務(wù)器分到的分片是:3=[0], 2=[1], 1=[]
RotateServerByNameJobShardingStrategy
全類路徑:?io.elasticjob.lite.api.strategy.impl.RotateServerByNameJobShardingStrategy
策略說(shuō)明:
根據(jù)作業(yè)名的哈希值對(duì)服務(wù)器列表進(jìn)行輪轉(zhuǎn)的分片策略。
運(yùn)維平臺(tái)與分片
回到熟練使用 Elastic Job系列之入門(mén)Demo(三)?文章的實(shí)例demo, 在項(xiàng)目中有通過(guò)sharding-total-count=來(lái)設(shè)置作業(yè)分片數(shù), 如圖所示,??從配置中可以知道zookeeper注冊(cè)中心地址名稱空間, 以及作業(yè)的分片數(shù)目。在這里為了模擬多機(jī)器部署,先對(duì)工程進(jìn)行maven打包, 然后在本機(jī)啟動(dòng)項(xiàng)目,同時(shí)把打的jar包丟到虛擬機(jī)里執(zhí)行?
?不同的機(jī)器上啟動(dòng)了同一個(gè)作業(yè)服務(wù),打開(kāi)Elastic Job運(yùn)維平臺(tái),注冊(cè)中心配置內(nèi)容為之前applicationContext.xml的配置內(nèi)容,點(diǎn)擊連接進(jìn)入??此時(shí)可以看到具體的作業(yè)信息??還可以看到有幾個(gè)服務(wù)器在執(zhí)行這個(gè)作業(yè)??其中99.1是我的本地電腦, 102是我的虛擬機(jī)。
那么服務(wù)器和作業(yè)分片是什么樣的關(guān)系了, 回顧上下文可以了解到, 作業(yè)的分片數(shù)是3, 機(jī)器實(shí)例是2臺(tái),默認(rèn)的分片策略是AverageAllocationJobShardingStrategy,所以通過(guò)運(yùn)維平臺(tái)查看作業(yè)詳情如下, 和AverageAllocationJobShardingStrategy的策略描述是相符合的。?
自定義分片策略
實(shí)現(xiàn)JobShardingStrateg接口并實(shí)現(xiàn)sharding方法即可,可以根據(jù)需求定制化自己的分片策略。與配置通常的作業(yè)屬性相同,在spring命名空間或者JobConfiguration中配置jobShardingStrategyClass屬性,屬性值是作業(yè)分片策略類的全路徑。
??這里代碼的含義是吧所有的分片都分配給192.168.104.102這臺(tái)機(jī)器上。
同樣也是想把項(xiàng)目打成jar包, 分別為本地項(xiàng)目IDEA直接啟動(dòng),jar包在虛擬機(jī)啊里通過(guò)java -jar方式啟動(dòng)??可以發(fā)現(xiàn)控制臺(tái)打印輸出了自定義分片策略代碼中的日志,此時(shí)連接運(yùn)維平臺(tái)查看,這里配置有修改,稍后可以自行下載源碼查看調(diào)試。??
最后小編在學(xué)習(xí)過(guò)程中整理了一些學(xué)習(xí)資料,可以分享給做軟件測(cè)試工程師的朋友們,相互交流學(xué)習(xí),需要的可以加入我的學(xué)習(xí)交流群 323432957 或加微dingyu-002即可免費(fèi)獲取Python自動(dòng)化測(cè)開(kāi)及Java自動(dòng)化測(cè)開(kāi)學(xué)習(xí)資料(里面有功能測(cè)試、性能測(cè)試、python自動(dòng)化、java自動(dòng)化、測(cè)試開(kāi)發(fā)、接口測(cè)試、APP測(cè)試等多個(gè)知識(shí)點(diǎn)的架構(gòu)資料)
總結(jié)
以上是生活随笔為你收集整理的熟练使用 Elastic Job系列之作业分片策略(五)的全部?jī)?nèi)容,希望文章能夠幫你解決所遇到的問(wèn)題。
- 上一篇: 敏捷软件开发学习笔记(四)之结构型设计模
- 下一篇: start() 跟 run() 方法的区