自拍偷在线精品自拍偷,亚洲欧美中文日韩v在线观看不卡

設(shè)計(jì)模式在業(yè)務(wù)系統(tǒng)中的應(yīng)用

開發(fā) 前端
本文的重點(diǎn)在于說明工作中所使用的設(shè)計(jì)模式,為了能夠更好的理解設(shè)計(jì)模式,首先簡單介紹一下業(yè)務(wù)場景。

 [[413691]]

本文的重點(diǎn)在于說明工作中所使用的設(shè)計(jì)模式,為了能夠更好的理解設(shè)計(jì)模式,首先簡單介紹一下業(yè)務(wù)場景。使用設(shè)計(jì)模式,可以簡化代碼、提高擴(kuò)展性、可維護(hù)性和復(fù)用性。有哪些設(shè)計(jì)模式,這里就不再介紹了,網(wǎng)上很多,本文只介紹所用到設(shè)計(jì)模式。

一  線路檢查工具

1  意義

為什么需要線路檢查工具呢,有以下幾個(gè)方面的原因:

  • 每逢大促都需要進(jìn)行各網(wǎng)絡(luò)和各行業(yè)的線路調(diào)整,調(diào)整完成之后,是否得到期望狀態(tài),需要檢查確認(rèn)。

  • 上下游應(yīng)用之間數(shù)據(jù)的一致性檢查,如果存在不一致,可能會在訂單履行時(shí)造成卡單。

  • 有些問題發(fā)生后,業(yè)務(wù)同學(xué)需要全面檢查一遍線路數(shù)據(jù),判斷是否符合預(yù)期。

  • 各領(lǐng)域之間的數(shù)據(jù)變更缺乏聯(lián)動(dòng)性,導(dǎo)致資源和線路出現(xiàn)不一致。

為什么要把線路檢查工具產(chǎn)品化呢,考慮如下:

  • 以前每次大促,都是技術(shù)同學(xué)現(xiàn)場編寫代碼撈數(shù)據(jù)給到業(yè)務(wù)同學(xué),而且因?yàn)槿藛T流動(dòng)性較大,代碼可復(fù)用性較低,導(dǎo)致重復(fù)勞動(dòng)。產(chǎn)品化后,可以方便地傳承下去,避免不必要的重復(fù)勞動(dòng)。

  • 每次因?yàn)闀r(shí)間緊急,現(xiàn)場寫的代碼都比較簡單,經(jīng)常是直接將數(shù)據(jù)打印到標(biāo)準(zhǔn)輸出,然后復(fù)制出來,人工拆分轉(zhuǎn)成Excel格式;這樣的過程要進(jìn)行多次,占用太多技術(shù)同學(xué)的時(shí)間。產(chǎn)品化后,解放了技術(shù)同學(xué),業(yè)務(wù)同學(xué)可以自己在頁面操作。

  • 很多數(shù)據(jù)檢查,是每次大促都會進(jìn)行的,業(yè)務(wù)同學(xué)與技術(shù)同學(xué)之間來回溝通的成本較高。產(chǎn)品化后,可以避免這些耗時(shí)耗力的溝通,大家可以把更多的時(shí)間放在其他的大促保障工作上。

2  檢查項(xiàng)

根據(jù)2020年D11進(jìn)行的數(shù)據(jù)檢查,本次共實(shí)現(xiàn)8項(xiàng),下面列舉了4項(xiàng),如下:

  • 時(shí)效對齊檢查:確保履行分單正常。

  • 弱控線路與表達(dá)網(wǎng)絡(luò)一致性:確保履行和路由不會因?yàn)榫€路缺失而卡單。

  • 資源映射和編碼映射一致:前者是表達(dá)線路時(shí)所用,后者是訂單履約時(shí)所用,確保表達(dá)和履約能夠一致。

  • 檢查線路數(shù)量:統(tǒng)計(jì)現(xiàn)存線路的情況。

好了,了解了背景知識,下面開始介紹所用到的設(shè)計(jì)模式,以及為什么要用、怎么用。

二  設(shè)計(jì)模式

1  模板方法模式+泛型

上述8項(xiàng)數(shù)據(jù)檢查工具,大致的處理流程是類似的,如下:

針對不同的檢查工具,只有“線路數(shù)據(jù)檢查”這一步是不一樣的邏輯,其他步驟都是相同的,如果每個(gè)檢查工具都實(shí)現(xiàn)這么一套邏輯,必定造成大量的重復(fù)代碼,維護(hù)性較差。

模板方法模式能夠很好地解決這個(gè)問題。模板方法設(shè)計(jì)模式包含模板方法和基本方法,模板方法包含了主要流程;基本方法是流程中共用的邏輯,如創(chuàng)建檢查任務(wù),結(jié)果輸出等等。

下圖是所 實(shí)現(xiàn)的模板方法模式的類繼承關(guān)系:

分析如下:

1)DataCheckProductService接口為對外提供的服務(wù),dataCheck方法為統(tǒng)一的數(shù)據(jù)檢查接口。

2)AbstractDataCheckProductService是一個(gè)抽象類,設(shè)定模板,即在dataCheck方法中設(shè)定好流程,包括如下:

  • commonParamCheck方法:進(jìn)行參數(shù)合法性檢查,不合法的情況下,直接返回 。

  • createFileName方法:創(chuàng)建文件名稱 。

  • createTaskRecord方法:創(chuàng)建檢查任務(wù) 。

  • runDataCheck方法:進(jìn)行數(shù)據(jù)檢查,這是一個(gè)抽象方法,所有檢查工具都要實(shí)現(xiàn)此方法,以實(shí)現(xiàn)自己的邏輯 。

  • uploadToOSS方法:將檢查結(jié)果上傳到OSS,便于下載。

  • updateRouteTask方法:結(jié)束時(shí)更新任務(wù)為完成。

dataCheck方法為模板方法,runDataCheck方法由各個(gè)子類去實(shí)現(xiàn),其他方法是基本方法。還有一些其他方法,是各個(gè)檢查工具都需要使用的,所以就放在了父類中。

3) CheckSupplierAndCodeMappingService類、CheckLandingCoverAreaService類和CheckAncPathNoServiceService類為具體的檢查工具子類,必須實(shí)現(xiàn)runDataCheck方法。

因?yàn)椴煌瑱z查項(xiàng)檢的查結(jié)果的格式是不一樣的,所以使用了泛型,使得可以兼容不同的檢查結(jié)果。

簡化的代碼如下:

  1. /** 
  2.  * 數(shù)據(jù)檢查工具產(chǎn)品化對外服務(wù)接口 
  3.  * @author xxx 
  4.  * @since xxx 
  5.  * */ 
  6. public interface DataCheckProductService { 
  7.     /** 
  8.      * 數(shù)據(jù)檢查 
  9.      * @param requestDTO 請求參數(shù) 
  10.      * */ 
  11.   <T> BaseResult<Long> dataCheck(DataCheckRequestDTO requestDTO); 
  12.  
  13.  
  14. /** 
  15.  * 數(shù)據(jù)檢查工具產(chǎn)品化服務(wù) 
  16.  * 
  17.  * @author xxx 
  18.  * @since xxx 
  19.  * */ 
  20. public abstract class AbstractDataCheckProductService implements DataCheckProductService { 
  21.     /** 
  22.      * 數(shù)據(jù)檢查 
  23.      * @param requestDTO 請求參數(shù) 
  24.      * @return 
  25.      * */ 
  26.     @Override 
  27.     public <T> BaseResult<Long> dataCheck(DataCheckRequestDTO requestDTO){ 
  28.         try
  29.             //1. 參數(shù)合法性檢查 
  30.             Pair<Boolean,String> paramCheckResult = commonParamCheck(requestDTO); 
  31.             if(!paramCheckResult.getLeft()){ 
  32.                 return BaseResult.ofFail(paramCheckResult.getRight()); 
  33.             } 
  34.              
  35.             //2. 創(chuàng)建導(dǎo)出任務(wù) 
  36.             String fileName = createFileName(requestDTO); 
  37.             RouteTaskRecordDO taskRecordDO = createTaskRecord(fileName, requestDTO.getUserName()); 
  38.  
  39.  
  40.             //3. 進(jìn)行數(shù)據(jù)檢查 
  41.             List<T> resultList = Collections.synchronizedList(new ArrayList<>()); 
  42.             runDataCheck(resultList, requestDTO); 
  43.  
  44.  
  45.             //4. 寫入文件 
  46.             String ossUrl = uploadToOSS(fileName,resultList); 
  47.             //5. 更新任務(wù)為完成狀態(tài) 
  48.             updateRouteTask(taskRecordDO.getId(),DDportTaskStatus.FINISHED.intValue(), resultList.size()-1,"",ossUrl); 
  49.  
  50.  
  51.             return BaseResult.ofSuccess(taskRecordDO.getId()); 
  52.         }catch (Exception e){ 
  53.             LogPrinter.errorLog("dataCheck-error, beanName="+getBeanName(),e); 
  54.             return BaseResult.ofFail(e.getMessage()); 
  55.         } 
  56.     } 
  57.  
  58.  
  59.      /** 
  60.      * 進(jìn)行數(shù)據(jù)檢查 
  61.      * @param resultList 存放檢查結(jié)果 
  62.      * @param requestDTO 請求參數(shù) 
  63.      * @return 
  64.      * */ 
  65.     public abstract <T> void runDataCheck(List<T> resultList, DataCheckRequestDTO requestDTO); 
  66.  
  67.  
  68. /** 
  69.  * 檢查資源映射和編碼映射一致 
  70.  * @author xxx 
  71.  * @since xxx 
  72.  * */ 
  73. public class CheckSupplierAndCodeMappingService extends AbstractDataCheckProductService{ 
  74.     @Override 
  75.     public <T> void runDataCheck(List<T> resultList, DataCheckRequestDTO requestDTO){ 
  76.         //自己的檢查邏輯 
  77.     } 
  78.  
  79.  
  80. /** 
  81.  * 檢查區(qū)域內(nèi)落地配必須三級全覆蓋 
  82.  * @author xxx 
  83.  * @since xxx 
  84.  * */ 
  85. public class CheckLandingCoverAreaService extends AbstractDataCheckProductService{ 
  86.     @Override 
  87.     public <T> void runDataCheck(List<T> resultList, DataCheckRequestDTO requestDTO){ 
  88.         //自己的檢查邏輯 
  89.     } 
  90.  
  91.  
  92. /** 
  93.  * 檢查資源映射和編碼映射一致 
  94.  * @author xxx 
  95.  * @since xxx 
  96.  * */ 
  97. public class CheckAncPathNoServiceService extends AbstractDataCheckProductService{ 
  98.     @Override 
  99.     public <T> void runDataCheck(List<T> resultList, DataCheckRequestDTO requestDTO){ 
  100.         //自己的檢查邏輯 
  101.     } 

使用模板方法模式的好處是:

  • 簡化了代碼,每個(gè)工具只需要關(guān)心自己的核心檢查邏輯,不需要關(guān)注前置和后置操作。

  • 提高了擴(kuò)展性,可以方便地增加新的檢查工具。

  • 統(tǒng)一的異常捕獲和處理邏輯,子類有異常,盡管往外拋出。

2  策略模式

之所以會用到策略模式,是因?yàn)橐恍z查工具寫完之后,發(fā)現(xiàn)跑出來的結(jié)果數(shù)據(jù)太多,有幾萬、幾十萬等等,一方面,檢查比較耗時(shí),結(jié)果文件會很大,下載耗時(shí);另一方面,這么多數(shù)據(jù)給到業(yè)務(wù)同學(xué),他們也很難處理和分析,也許他們只是想看一下總體情況,并不想看具體的到哪個(gè)地方的線路。為此,在原先方案設(shè)計(jì)的基礎(chǔ)上,增加了“統(tǒng)計(jì)信息”的選項(xiàng),讓用戶可以自行選擇“詳細(xì)信息”還是“統(tǒng)計(jì)信息”,對應(yīng)到頁面上就是一個(gè)單選框,如下:

現(xiàn)在增加了一種檢查方式,今后是否還會有其他的檢查方式?完全有可能的。所以得考慮到擴(kuò)展性,便于后面同學(xué)增加新的檢查方式。

此外,還有一種場景也可以使用策略模式,那就是業(yè)務(wù)系統(tǒng)中有很多業(yè)務(wù)網(wǎng)絡(luò),不同網(wǎng)絡(luò)之間有一些差異;本次所實(shí)現(xiàn)的檢查工具,有幾個(gè)涉及到多個(gè)網(wǎng)絡(luò),今后可能會涉及到所有網(wǎng)絡(luò)。

綜合以上兩種場景,最合適的就是策略模式了。“詳細(xì)信息”和“統(tǒng)計(jì)信息”各采用一種策略,不同網(wǎng)絡(luò)使用不同的策略,既便于代碼理解,又便于后續(xù)擴(kuò)展。

“詳細(xì)信息”和“統(tǒng)計(jì)信息”兩種檢查結(jié)果的策略類圖如下:

解析:

  • CompareModeStrategy對外提供統(tǒng)一的結(jié)果處理接口doHandle,策略子類必須實(shí)現(xiàn)此接口。

  • SupplierAndCodeMappingStatisticsStrategy和SupplierAndCodeMappingDetailStrategy是檢查配送資源和編碼映射一致性的兩種結(jié)果信息方式,前者為統(tǒng)計(jì)方式,后者為詳細(xì)方式。

  • LandingCoverAreaStatisticsStrategy和LandingCoverAreaDetailStrategy是檢查落地配覆蓋范圍的兩種結(jié)果信息方式,前者為統(tǒng)計(jì)方式,后者為詳細(xì)方式。

  • 那AbstractCompareModeStrategy是干什么用的?它是一個(gè)抽象類,負(fù)責(zé)承接所有策略子類共用的一些方法。

簡化的代碼如下:

  1. /** 
  2.  * 檢查結(jié)果策略對外接口 
  3.  * @author xxx 
  4.  * @since xxx 
  5.  * */ 
  6. public interface CompareModeStrategy { 
  7.     /** 
  8.      * 具體操作 
  9.      * 
  10.      * @param list 
  11.      * @param requestDTO 
  12.      * @return 結(jié)果集 
  13.      * */ 
  14.     <T> List<T> doHandle(List<CompareBO> list, DataCheckRequestDTO requestDTO); 
  15.  
  16.  
  17. /** 
  18.  * 策略公共父類 
  19.  * 
  20.  * @author xxx 
  21.  * @since xxx 
  22.  * @apiNote 主要是將子類共用方法和成員抽離出來 
  23.  * */ 
  24. public abstract class AbstractCompareModeStrategy implements CompareModeStrategy { 
  25.     //子類的共用方法,可以放在此類中 
  26.  
  27.  
  28. /** 
  29.  * 檢查落地配覆蓋范圍 詳細(xì)信息 策略類 
  30.  * @author xxx 
  31.  * @since xxx 
  32.  * */ 
  33. public class LandingCoverAreaDetailStrategy extends AbstractCompareModeStrategy{ 
  34.     @Override 
  35.     public <T> List<T> doHandle(List<CompareBO> list, DataCheckRequestDTO requestDTO){ 
  36.         List<T> resultList = new ArrayList<>(); 
  37.     //檢查結(jié)果處理邏輯 
  38.         return resultList; 
  39.     } 
  40.  
  41.  
  42. /** 
  43.  * 檢查落地配覆蓋范圍 統(tǒng)計(jì)信息 策略類 
  44.  * @author xxx 
  45.  * @since xxx 
  46.  * */ 
  47. public class LandingCoverAreaStatisticsStrategy extends AbstractCompareModeStrategy{ 
  48.     @Override 
  49.     public <T> List<T> doHandle(List<CompareBO> list, DataCheckRequestDTO requestDTO){ 
  50.         List<T> resultList = new ArrayList<>(); 
  51.     //檢查結(jié)果處理邏輯 
  52.         return resultList; 
  53.     } 
  54.  
  55.  
  56. /** 
  57.  * 檢查配送資源和編碼映射一致 詳細(xì)信息 策略類 
  58.  * @author xxx 
  59.  * @since xxx 
  60.  * */ 
  61. public class SupplierAndCodeMappingDetailStrategy extends AbstractCompareModeStrategy{ 
  62.     @Override 
  63.     public <T> List<T> doHandle(List<CompareBO> list, DataCheckRequestDTO requestDTO){ 
  64.         List<T> resultList = new ArrayList<>(); 
  65.     //檢查結(jié)果處理邏輯 
  66.         return resultList; 
  67.     } 
  68.  
  69.  
  70. /** 
  71.  * 檢查配送資源和編碼映射一致 統(tǒng)計(jì)信息 策略類 
  72.  * @author xxx 
  73.  * @since xxx 
  74.  * */ 
  75. public class SupplierAndCodeMappingStatisticsStrategy extends AbstractCompareModeStrategy{ 
  76.     @Override 
  77.     public <T> List<T> doHandle(List<CompareBO> list, DataCheckRequestDTO requestDTO){ 
  78.         List<T> resultList = new ArrayList<>(); 
  79.     //檢查結(jié)果處理邏輯 
  80.         return resultList; 
  81.     } 

同樣,不同網(wǎng)絡(luò)的處理策略類圖如下:

代碼與上面類似,就不展示了。

使用策略模式的好處是:

  • 提高代碼擴(kuò)展性,后續(xù)增加別的結(jié)果格式或別的網(wǎng)絡(luò)處理邏輯,可以在不修改其他策略的情況下直接新增。

  • 提高代碼可讀性,取代了if...else,條理清晰。

  • 不同系列采用不同的策略,策略與策略之間可以嵌套使用,形成策略的疊加效用。

3  工廠模式

工廠模式解決的是bean的生產(chǎn)問題,簡單工廠模式根據(jù)入?yún)⑸a(chǎn)不同的bean,普通工廠模式針對每個(gè)bean都構(gòu)建一個(gè)工廠,此兩者各有優(yōu)劣,看需要。本方案采用的是簡單工廠模式。

之所以使用工廠模式,是因?yàn)橛刑嗟腷ean需要構(gòu)造,如果在業(yè)務(wù)邏輯中構(gòu)造各種bean,則會顯得凌亂和分散,所以需要一個(gè)統(tǒng)一生成bean的地方,更好地管理和擴(kuò)展。

本方案中主要有三類bean需要工廠來生成:

  • 模板方法模式中所用到的子類。

  • 檢查結(jié)果格式策略中所用到的子類。

  • 不同網(wǎng)絡(luò)處理策略中所用到的子類。

所以,使用三個(gè)工廠分別構(gòu)造這三種類型的bean。另外,因?yàn)槊總€(gè)bean主要的功能都在方法中,不涉及類變量的使用,所以可以利用spring容器生成的bean,而不是我們自己new出來,這樣就使得bean可以重復(fù)使用。因此,這里的工廠只是bean的決策(根據(jù)參數(shù)決定使用哪個(gè)bean),不用自己new了。

三個(gè)工廠分別如下:

  • DataCheckProductFatory:由getDataCheckProductService方法根據(jù)輸入?yún)?shù)決策使用哪個(gè)數(shù)據(jù)檢查工具。

  • CompareModeStrategyFactory:用于決策使用哪種格式輸出,因?yàn)閷⑤敵霾呗苑譃榱?類(詳細(xì)信息和統(tǒng)計(jì)信息),所以需要傳入兩個(gè)參數(shù)才能決定使用哪種策略。

  • DataCheckNetworkStrategyFactory:用于決策使用哪種網(wǎng)絡(luò)處理策略,因?yàn)閷⒉呗苑譃榱?類(4PL網(wǎng)絡(luò)和其他網(wǎng)絡(luò)),所以需要傳入兩個(gè)參數(shù)才能決定使用哪種策略。

這三個(gè)工廠的代碼類似,這里就以CompareModeStrategyFactory為例,簡化的代碼如下:

  1. /** 
  2.  * 比對結(jié)果集方式 
  3.  * @author xxx 
  4.  * @since xxx 
  5.  * */ 
  6. @Service 
  7. public class CompareModeStrategyFactory { 
  8.  
  9.  
  10.     /************************ 詳細(xì)結(jié)果的bean  **************************/ 
  11.     @Resource 
  12.     private LandingCoverAreaDetailStrategy landingCoverAreaDetailStrategy; 
  13.     @Resource 
  14.     private SupplierAndCodeMappingDetailStrategy supplierAndCodeMappingDetailStrategy; 
  15.  
  16.  
  17.     /************************ 統(tǒng)計(jì)結(jié)果的bean  **************************/ 
  18.     @Resource 
  19.     private LandingCoverAreaStatisticsStrategy landingCoverAreaStatisticsStrategy; 
  20.     @Resource 
  21.     private SupplierAndCodeMappingStatisticsStrategy supplierAndCodeMappingStatisticsStrategy; 
  22.  
  23.  
  24.     /** 
  25.      * 獲取比對結(jié)果的策略 
  26.      * */ 
  27.     public CompareModeStrategy getCompareModeStrategy(DataCheckProductEnum productEnum, DataCompareModeEnum modeEnum){ 
  28.         CompareModeStrategy compareModeStrategy = null
  29.         switch (modeEnum){ 
  30.             case DETAIL_INFO: 
  31.                 compareModeStrategy = getDetailCompareModeStrategy(productEnum); 
  32.                 break
  33.             case STATISTICS_INFO : 
  34.                 compareModeStrategy = getStatisticsCompareModeStrategy(productEnum); 
  35.                 break
  36.             default:; 
  37.         } 
  38.         return compareModeStrategy; 
  39.     } 
  40.     /** 
  41.      * 獲取 信息信息 策略對象 
  42.      * */ 
  43.     private CompareModeStrategy getDetailCompareModeStrategy(DataCheckProductEnum productEnum){ 
  44.         CompareModeStrategy compareModeStrategy = null
  45.         switch (productEnum){ 
  46.             case CHECK_LANDING_COVER_AREA: 
  47.                 compareModeStrategy = landingCoverAreaDetailStrategy; 
  48.                 break
  49.             case CHECK_SUPPLIER_AND_CODE_MAPPING: 
  50.                 compareModeStrategy = supplierAndCodeMappingDetailStrategy; 
  51.                 break
  52.             default:; 
  53.         } 
  54.         return compareModeStrategy; 
  55.     } 
  56.     /** 
  57.      * 獲取 統(tǒng)計(jì)信息 策略對象 
  58.      * */ 
  59.     private CompareModeStrategy getStatisticsCompareModeStrategy(DataCheckProductEnum productEnum){ 
  60.         CompareModeStrategy compareModeStrategy = null
  61.         switch (productEnum){ 
  62.             case CHECK_LANDING_COVER_AREA: 
  63.                 compareModeStrategy = landingCoverAreaStatisticsStrategy; 
  64.                 break
  65.             case CHECK_SUPPLIER_AND_CODE_MAPPING: 
  66.                 compareModeStrategy = supplierAndCodeMappingStatisticsStrategy; 
  67.                 break
  68.             default:; 
  69.         } 
  70.         return compareModeStrategy; 
  71.     } 

使用工廠模式的好處是:

  • 便于bean的管理,所有的bean都在一處創(chuàng)建(或決策)。

  • 條理清晰,便于閱讀和維護(hù)。

4  “代理模式”

這個(gè)代理模式是打著雙引號的,因?yàn)椴皇钦嬲拇砟J?,只是從?shí)現(xiàn)方式上來說,具有代理模式的意思。為什么需要用到代理模式?是因?yàn)轭愄嗔耍瑯I(yè)務(wù)邏輯分散在各個(gè)類中,有的在模板子類中,有的在網(wǎng)絡(luò)策略中,有的在結(jié)果輸出格式策略中,而這些業(yè)務(wù)邏輯都需要多線程執(zhí)行和異常捕獲。如果有個(gè)代理類,能夠收口這些處理邏輯,只需增加前置多線程處理和后置異常處理即可。

Java語言中的函數(shù)式編程,具備這種能力。所謂函數(shù)式編程,是指能夠?qū)⒎椒ó?dāng)做參數(shù)傳遞給方法,前面“方法”是業(yè)務(wù)邏輯,后面“方法”是代理,將業(yè)務(wù)邏輯傳遞給代理,就實(shí)現(xiàn)了統(tǒng)一收口的目的。

能夠?qū)崿F(xiàn)此功能的接口有四個(gè),分別是:Consumer、Supplier、Predicate與Function,怎么使用可以網(wǎng)上查詢。本方案使用的是Consumer,因?yàn)樗怯脕硐M(fèi)的,即需要傳入一個(gè)參數(shù),沒有返回值,符合本方案的設(shè)計(jì)。

簡化后的代碼如下:

  1. @Service 
  2. public class CheckLandingCoverAreaService extends AbstractDataCheckProductService { 
  3.     @Override 
  4.     public <T> void runDataCheck(List<T> resultList, DataCheckRequestDTO requestDTO){ 
  5.         dataCheckUtils.parallelCheckByFromResCodes(requestDTO,requestDTO.getFromResCodeList(),fromResCode->{ 
  6.             ExpressNetworkQuery query = new ExpressNetworkQuery(); 
  7.             query.setNs(NssEnum.PUB.getId()); 
  8.             query.setStatus(StatusEnum.ENABLE.getId()); 
  9.             query.setGroupNameList(requestDTO.getGroupNameList()); 
  10.             query.setBrandCodeList(requestDTO.getBrandCodeList()); 
  11.             query.setFromResCode(fromResCode); 
  12.             List<TmsMasterExpressNetworkDO> masterExpressNetworkDOS = tmsMasterExpressNetworkService.queryExpressNetworkTimeList(query); 
  13.             startCompareWithAnc(resultList,requestDTO,masterExpressNetworkDOS,fromResCode,solutionCodeMap); 
  14.         }); 
  15.     } 
  16.  
  17.  
  18. @Service 
  19. public class DataCheckUtils { 
  20.     /** 
  21.      * 并行處理每個(gè)倉 
  22.      * @param requestDTO 請求參數(shù) 
  23.      * @param fromResCodeList 需要檢查的倉列表 
  24.      * @param checkOperation 具體的業(yè)務(wù)處理邏輯 
  25.      * */ 
  26.     public <T> void parallelCheckByFromResCodes(DataCheckRequestDTO requestDTO, List<String> fromResCodeList, Consumer<String> checkOperation){ 
  27.         List<CompletableFuture> futureList = Collections.synchronizedList(new ArrayList<>()); 
  28.         fromResCodeList.forEach(fromResCode->{ 
  29.             CompletableFuture future = CompletableFuture.runAsync(() -> { 
  30.                 try
  31.                     checkOperation.accept(fromResCode); 
  32.                 }catch (Exception e){ 
  33.                     LogPrinter.errorLog("parallelCheckByFromResCodes-error, taskId="+requestDTO.getTaskId(),e); 
  34.                     recordErrorInfo(requestDTO.getTaskId(),e); 
  35.                 } 
  36.             }, DATA_CHECK_THREAD_POOL); 
  37.             futureList.add(future); 
  38.         }); 
  39.         //等待所有線程結(jié)束 
  40.         futureList.forEach(future->{ 
  41.             try
  42.                 future.get(); 
  43.             }catch (Exception e){ 
  44.                 LogPrinter.errorLog("parallelCheckByFromResCodes-future-get-error",e); 
  45.             } 
  46.         }); 
  47.     } 

可以看出,Consumer所代表的就是一個(gè)方法,將此方法作為parallelCheckByFromResCodes方法的一個(gè)參數(shù),在parallelCheckByFromResCodes中進(jìn)行多線程和異常處理,既能統(tǒng)一收口,又大大減少了重復(fù)代碼。

代理模式的好處是:

  • 統(tǒng)一收口多種不同的業(yè)務(wù)邏輯,統(tǒng)一做日志和異常處理。

  • 減少重復(fù)代碼,提高了代碼質(zhì)量。

  • 可維護(hù)性較強(qiáng)。

5  其他

像結(jié)果輸出格式策略模式那樣,雖然AbstractCompareModeStrategy沒有實(shí)際的業(yè)務(wù)邏輯,但仍然把它作為一個(gè)基類,目的是所有子類共用的邏輯或方法,能夠放在此類中,減少代碼量,提升維護(hù)性。

但是有的時(shí)候,不是繼承自同一個(gè)基類的子類們,仍然要共用一些邏輯或方法(如parallelCheckByFromResCodes方法),但Java語言限制一個(gè)類只能繼承一個(gè)基類,怎么辦呢?簡單的辦法就是把這些共用邏輯或方法放到一個(gè)工具類(如DataCheckUtils)中。

三  思考&感悟

在做這個(gè)項(xiàng)目的過程中,剛開始沒有很好的設(shè)計(jì),也沒有想的很全面,導(dǎo)致代碼改了又改,雖然耽誤點(diǎn)時(shí)間,但覺得是值得的??偨Y(jié)以下幾點(diǎn):

  • 將提升代碼可讀性、可擴(kuò)展性和可維護(hù)性的意識注入到平時(shí)的項(xiàng)目中,便于自己,利于他人。如果項(xiàng)目緊急沒時(shí)間考慮很多,希望之后有時(shí)間時(shí)能夠改善和優(yōu)化。

  • 工作不僅是為了完成任務(wù),更是提升自己的過程。能力要用將來進(jìn)行時(shí)。

 

 

 

責(zé)任編輯:張燕妮 來源: 阿里技術(shù)
相關(guān)推薦

2009-11-23 20:30:55

ibmdwSOA

2022-09-15 10:23:17

業(yè)務(wù)開發(fā)自我成長

2020-08-06 11:13:17

數(shù)據(jù)分析數(shù)據(jù)大數(shù)據(jù)

2009-06-25 15:54:18

設(shè)計(jì)模式EJB

2021-12-16 11:58:48

業(yè)務(wù)鏈路數(shù)據(jù)

2020-06-02 10:36:42

云計(jì)算軟件即服務(wù)IT

2024-02-21 12:18:15

2020-03-31 21:50:41

JavaScript前端技術(shù)

2022-08-16 13:48:55

暗數(shù)據(jù)IT領(lǐng)導(dǎo)者

2023-08-31 17:23:48

ChatGPT人工智能

2024-05-09 12:17:00

責(zé)任鏈設(shè)計(jì)模式

2021-09-15 10:15:38

人工智能AI情感

2013-03-28 13:08:15

Web緩存

2015-06-30 15:07:49

物聯(lián)網(wǎng)業(yè)務(wù)轉(zhuǎn)型

2012-08-30 09:07:33

設(shè)計(jì)模式

2023-03-17 07:13:43

2023-03-17 06:14:20

2023-11-07 12:00:05

分布式系統(tǒng)數(shù)據(jù)訪問

2021-04-18 21:07:32

門面模式設(shè)計(jì)

2024-07-31 08:12:33

點(diǎn)贊
收藏

51CTO技術(shù)棧公眾號