我在工作中遇到了一個(gè)非常有趣的情況，我想在這里分享解決方案。

想象一下您需要處理一組數(shù)據(jù)。為了處理這組數(shù)據(jù)，您有幾種不同的策略。例如，我需要?jiǎng)?chuàng)建如何從 S3 獲取數(shù)據(jù)集合、本地存儲(chǔ)庫(kù)中的示例或作為輸入傳遞的策略。

決定這一策略的人就是提出請(qǐng)求的人：

我想獲取S3中的數(shù)據(jù)。取 X 天 H1 和 H2 之間生成的數(shù)據(jù)，該數(shù)據(jù)來自 Abóbora 客戶端。獲取最近3000條符合此條件的數(shù)據(jù)。

或者：

拿你那里的示例數(shù)據(jù)，復(fù)制10000次來進(jìn)行壓力測(cè)試。

或者甚至：

我有這個(gè)目錄，你也可以訪問它。獲取該目錄中的所有內(nèi)容并遞歸到子目錄中。

最后：

獲取輸入中的這個(gè)數(shù)據(jù)單元并使用它。

如何實(shí)施？

我的第一個(gè)想法是：“如何在 Java 中定義輸入的形狀？”

我得出了第一個(gè)結(jié)論，這對(duì)于該項(xiàng)目非常重要：“你知道嗎？我不會(huì)定義形狀。添加一個(gè)可以處理它的 Map?！?/string>

最重要的是，由于我沒有在 DTO 中放置任何形狀，因此我可以完全自由地嘗試輸入。

因此，在建立概念驗(yàn)證后，我們遇到了這樣的情況：我們需要擺脫 POC 壓力，轉(zhuǎn)向接近實(shí)際使用的東西。

我所做的服務(wù)是驗(yàn)證規(guī)則?；旧希?dāng)更改規(guī)則時(shí)，我需要采用該規(guī)則并將其與生產(chǎn)應(yīng)用程序中發(fā)生的事件進(jìn)行匹配。或者，如果應(yīng)用程序發(fā)生更改并且沒有錯(cuò)誤，則期望對(duì)相同數(shù)據(jù)的相同規(guī)則的決策將保持相同；現(xiàn)在，如果使用相同數(shù)據(jù)集的相同規(guī)則的決策發(fā)生了變化……那么，這就是潛在的麻煩。

所以，我需要這個(gè)應(yīng)用程序來運(yùn)行規(guī)則的回測(cè)。我需要點(diǎn)擊真實(shí)的應(yīng)用程序發(fā)送數(shù)據(jù)以進(jìn)行評(píng)估和相關(guān)規(guī)則。它的用途相當(dāng)多樣：

• 驗(yàn)證更新應(yīng)用程序時(shí)的潛在偏差
• 驗(yàn)證更改后的規(guī)則是否保持相同的行為
  • 例如，優(yōu)化規(guī)則執(zhí)行時(shí)間
• 檢查規(guī)則的變化是否產(chǎn)生了預(yù)期的決策變化
• 驗(yàn)證應(yīng)用程序中的更改確實(shí)提高了效率
  • 例如，在啟用 JVMCI 的情況下使用新版本的 GraalVM 會(huì)增加我可以發(fā)出的請(qǐng)求數(shù)量嗎？

因此，為此，我需要一些關(guān)于事件起源的策略：

• 從S3獲取真實(shí)數(shù)據(jù)
• 獲取存儲(chǔ)庫(kù)中作為樣本的數(shù)據(jù)并復(fù)制多次
• 從本地計(jì)算機(jī)上的特定位置獲取數(shù)據(jù)

而且我還需要與我的規(guī)則不同的策略：

• 通過輸入傳遞
• 使用快速運(yùn)行的存根
• 使用基于生產(chǎn)規(guī)則的樣本
• 在我的機(jī)器上使用此路徑

如何處理這個(gè)問題？好吧，讓用戶提供數(shù)據(jù)吧！

策略 API

你知道關(guān)于 json-schema 的一些總是引起我注意的事情嗎？這里：

{
    "$schema": "https://json-schema.org/draft/2020-12/schema",
    "$id": "https://json-schema.org/draft/2020-12/schema",
    "$vocabulary": {
        //...
    }
}

這些字段以 $ 開頭。在我看來，它們是用來表示元數(shù)據(jù)的。那么為什么不在數(shù)據(jù)輸入中使用它來指示正在使用哪種策略的元數(shù)據(jù)呢？

{
    "dados": {
        "$strategy": "sample",
        "copias": 15000
    },
    //...
}

例如，我可以訂購(gòu) 15000 份我擁有的數(shù)據(jù)作為樣本?；蛘邚?S3 請(qǐng)求一些東西，在 Athena 中進(jìn)行查詢：

{
    "dados": {
        "$strategy": "athena-query",
        "limit": 15000,
        "inicio": "2024-11-25",
        "fim": "2024-11-26",
        "cliente": "Abóbora"
    },
    //...
}

或者在本地路徑中？

{
    "dados": {
        "$strategy": "localpath",
        "cwd": "/home/jeffque/random-project-file",
        "dir": "../payloads/esses-daqui/top10-hard/"
    },
    //...
}

這樣我就可以委托選擇未來的策略。

代碼審查和外觀

我處理策略的第一個(gè)方法是：

public DataLoader getDataLoader(Map<String, Object> inputDados) {
    final var strategy = (String) inputDados.get("$strategy");
    return switch (strategy) {
        case "localpath" -> new LocalpathDataLoader();
        case "sample" -> new SampleDataLoader(resourcePatternResolver_spring);
        case "athena-query" -> new AthenaQueryDataLoader(athenaClient, s3Client);
        default -> new AthenaQueryDataLoader(athenaClient, s3Client);
    }
}

所以我的架構(gòu)師在代碼審查期間問了兩個(gè)問題：

• “為什么你實(shí)例化所有東西而不讓 Spring 為你工作？”
• 他在代碼中創(chuàng)建了一個(gè)DataLoaderFacade并放棄了它半成品

從中我明白了什么？使用外觀將處理委托給正確的角落并......放棄手動(dòng)控制是一個(gè)好主意？

嗯，很多魔法都是因?yàn)榇禾於l(fā)生的。既然我們?cè)谝粋€(gè)擁有 Java 專業(yè)知識(shí)的 Java 之家，為什么不使用慣用的 Java/Spring，對(duì)吧？?jī)H僅因?yàn)?em>我作為一個(gè)個(gè)體覺得有些事情難以理解并不一定意味著它們很復(fù)雜。那么，讓我們擁抱 Java 依賴注入魔法的世界。

創(chuàng)建 fa?ade 對(duì)象

曾經(jīng)是：

final var dataLoader = getDataLoader(inputDados)
dataLoader.loadData(inputDados, workingPath);

變成：

{
    "$schema": "https://json-schema.org/draft/2020-12/schema",
    "$id": "https://json-schema.org/draft/2020-12/schema",
    "$vocabulary": {
        //...
    }
}

所以我的控制器層不需要管理這個(gè)。把它留給門面。

那么，我們要如何做立面呢？好吧，首先，我需要將所有對(duì)象注入其中：

{
    "dados": {
        "$strategy": "sample",
        "copias": 15000
    },
    //...
}

好的，對(duì)于主 DataLoader，除了 @Service 之外，我還將其寫為 @Primary。剩下的我就用@Service寫下來。

在這里測(cè)試一下，設(shè)置 getDataLoader 返回 null 只是為了嘗試 Spring 如何調(diào)用構(gòu)造函數(shù)......它起作用了。現(xiàn)在我需要記下和元數(shù)據(jù)每個(gè)服務(wù)他們使用什么策略...

如何做到這一點(diǎn)...

嗯，看！在 Java 中，我們有注釋！我可以創(chuàng)建一個(gè) runtime 注釋，其中包含該組件使用的策略！

所以我可以在 AthenaQueryDataLoader 中擁有類似的東西：

{
    "dados": {
        "$strategy": "athena-query",
        "limit": 15000,
        "inicio": "2024-11-25",
        "fim": "2024-11-26",
        "cliente": "Abóbora"
    },
    //...
}

我也可以有別名，為什么不呢？

{
    "dados": {
        "$strategy": "localpath",
        "cwd": "/home/jeffque/random-project-file",
        "dir": "../payloads/esses-daqui/top10-hard/"
    },
    //...
}

并展示！

但是如何創(chuàng)建這個(gè)注釋呢？好吧，我需要它有一個(gè)字符串向量的屬性（Java 編譯器已經(jīng)處理提供一個(gè)單獨(dú)的字符串并將其轉(zhuǎn)換為具有 1 個(gè)位置的向量）。默認(rèn)值為值。看起來像這樣：

public DataLoader getDataLoader(Map<String, Object> inputDados) {
    final var strategy = (String) inputDados.get("$strategy");
    return switch (strategy) {
        case "localpath" -> new LocalpathDataLoader();
        case "sample" -> new SampleDataLoader(resourcePatternResolver_spring);
        case "athena-query" -> new AthenaQueryDataLoader(athenaClient, s3Client);
        default -> new AthenaQueryDataLoader(athenaClient, s3Client);
    }
}

如果注釋字段沒有值，我需要將其明確化，這看起來很難看，如 EstrategiaFeia 注釋中所示：

final var dataLoader = getDataLoader(inputDados)
dataLoader.loadData(inputDados, workingPath);

我認(rèn)為這聽起來不太自然。

好吧，鑒于此，我們?nèi)匀恍枰?/p>

• 從傳遞的對(duì)象中提取類注釋
• 創(chuàng)建字符串映射 $\to$→ 數(shù)據(jù)加載器（或字符串 $\to$→ T）

提取注釋并組裝地圖

要提取注釋，我需要訪問對(duì)象類：

dataLoaderFacade.loadData(inputDados, workingPath);

除此之外，我可以問一下這個(gè)類是否帶有像Strategy這樣的注解：

@Service // para o Spring gerenciar esse componente como um servi?o
public class DataLoaderFacade implements DataLoader {

    public DataLoaderFacade(DataLoader primaryDataLoader,
                            List<DataLoader> dataLoaderWithStrategies) {
        // armazena de algum modo
    }

    @Override
    public CompletableFuture<Void> loadData(Map<String, Object> input, Path workingPath) {
        return getDataLoader(input).loadData(input, workingPath);
    }

    private DataLoader getDataLoader(Map<String, Object> input) {
        final var strategy = input.get("$strategy");
        // magia...
    }
}

你還記得它有values字段嗎？好吧，這個(gè)字段返回一個(gè)字符串向量：

@Service
@Primary
@Estrategia("athena-query")
public class AthenaQueryDataLoader implements DataLoader {
    // ...
}

表演！但我有一個(gè)挑戰(zhàn)，因?yàn)橹拔矣幸粋€(gè) T 類型的對(duì)象，現(xiàn)在我想將同一對(duì)象映射到 (T, String)[]。在流中，執(zhí)行此操作的經(jīng)典操作是 flatMap。 Java 也不允許我突然返回這樣的元組，但我可以用它創(chuàng)建一條記錄。

它看起來像這樣：

{
    "$schema": "https://json-schema.org/draft/2020-12/schema",
    "$id": "https://json-schema.org/draft/2020-12/schema",
    "$vocabulary": {
        //...
    }
}

如果有一個(gè)對(duì)象沒有標(biāo)注策略怎么辦？會(huì)給NPE嗎？最好不要，我們?cè)?NPE 之前過濾掉它：

{
    "dados": {
        "$strategy": "sample",
        "copias": 15000
    },
    //...
}

鑒于此，我還需要整理一張地圖。而且，好吧，看：Java 已經(jīng)為此提供了一個(gè)收集器！ Collector.toMap(keyMapper, valueMapper)

{
    "dados": {
        "$strategy": "athena-query",
        "limit": 15000,
        "inicio": "2024-11-25",
        "fim": "2024-11-26",
        "cliente": "Abóbora"
    },
    //...
}

到目前為止，還好。但 flatMap 特別困擾我。有一個(gè)名為 mapMulti 的新 Java API，它具有倍增的潛力：

{
    "dados": {
        "$strategy": "localpath",
        "cwd": "/home/jeffque/random-project-file",
        "dir": "../payloads/esses-daqui/top10-hard/"
    },
    //...
}

美麗。我為 DataLoader 獲取了它，但我還需要為 RuleLoader 做同樣的事情。或者也許不是？如果您注意到，此代碼中沒有任何特定于 DataLoader 的內(nèi)容。我們可以抽象這段代碼！！

public DataLoader getDataLoader(Map<String, Object> inputDados) {
    final var strategy = (String) inputDados.get("$strategy");
    return switch (strategy) {
        case "localpath" -> new LocalpathDataLoader();
        case "sample" -> new SampleDataLoader(resourcePatternResolver_spring);
        case "athena-query" -> new AthenaQueryDataLoader(athenaClient, s3Client);
        default -> new AthenaQueryDataLoader(athenaClient, s3Client);
    }
}

立面之下

純粹出于功利的原因，我將這個(gè)算法放在注釋中：

final var dataLoader = getDataLoader(inputDados)
dataLoader.loadData(inputDados, workingPath);

立面呢？好吧，工作也這么說。我決定抽象一下：

dataLoaderFacade.loadData(inputDados, workingPath);

立面看起來像這樣：

@Service // para o Spring gerenciar esse componente como um servi?o
public class DataLoaderFacade implements DataLoader {

    public DataLoaderFacade(DataLoader primaryDataLoader,
                            List<DataLoader> dataLoaderWithStrategies) {
        // armazena de algum modo
    }

    @Override
    public CompletableFuture<Void> loadData(Map<String, Object> input, Path workingPath) {
        return getDataLoader(input).loadData(input, workingPath);
    }

    private DataLoader getDataLoader(Map<String, Object> input) {
        final var strategy = input.get("$strategy");
        // magia...
    }
}

以上是在Java中使用注解來制定策略的詳細(xì)內(nèi)容。更多信息請(qǐng)關(guān)注PHP中文網(wǎng)其他相關(guān)文章！