(資料圖)
步驟4：創建Hystrix請求合并器執行器
接下來，我們將創建一個名為“GetDataCollapserExecutor”的類，該類用于執行Hystrix請求合并器：
@Servicepublic class GetDataCollapserExecutor { private final ExternalService externalService; @Autowired public GetDataCollapserExecutor(ExternalService externalService) { this.externalService = externalService; } @HystrixCollapser(batchMethod = "execute", collapserProperties = { @HystrixProperty(name = "timerDelayInMilliseconds", value = "100") }) public Future> getData(String key) { GetDataCollapser getDataCollapser = new GetDataCollapser(externalService, key); return getDataCollapser.queue(); } @HystrixCommand public Map execute(List keys) { Map resultMap = new HashMap<>(); for (String key : keys) { GetDataCollapser getDataCollapser = new GetDataCollapser(externalService, key); resultMap.putAll(getDataCollapser.execute()); } return resultMap; }} 如上所述，我們的GetDataCollapserExecutor類包含以下內容：
構造函數：該函數用于注入ExternalService實例。getData()方法：該方法使用@HystrixCollapser注解進行注釋，該注解指定了一個名為“execute”的批量執行方法。在此示例中，我們將timerDelayInMilliseconds屬性設置為100毫秒，這意味著如果100毫秒內有多個請求，則它們將被合并為單個請求。execute()方法：該方法使用@HystrixCommand注解進行注釋，該注解指定了Hystrix請求合并器執行邏輯。在此示例中，我們遍歷請求參數列表，并為每個請求創建一個GetDataCollapser實例。最后，我們將所有結果合并到一個HashMap中，并將其返回。步驟5：測試Hystrix請求合并器
現在，我們可以測試Hystrix請求合并器是否按預期工作。我們將創建一個名為“DataController”的類，并將其用于向客戶端公開API：
@RestControllerpublic class DataController { private final GetDataCollapserExecutor getDataCollapserExecutor; @Autowired public DataController(GetDataCollapserExecutor getDataCollapserExecutor) { this.getDataCollapserExecutor = getDataCollapserExecutor; } @GetMapping("/data") public Map getData(@RequestParam List keys) throws ExecutionException, InterruptedException { List>> futures = new ArrayList<>(); for (String key : keys) { futures.add(getDataCollapserExecutor.getData(key)); } Map resultMap = new HashMap<>(); for (Future> future : futures) { resultMap.putAll(future.get()); } return resultMap; }} 如上所述，我們的DataController類包含以下內容：
構造函數：該函數用于注入GetDataCollapserExecutor實例。getData()方法：該方法使用@GetMapping注解進行注釋，該注解指定了API的URL路徑和請求方法。在此示例中，我們使用@RequestParam注解將請求參數列表注入方法參數，并使用Future和get()方法來獲取Hystrix請求合并器的返回值。現在，我們可以使用Postman或類似的工具向API發送HTTP請求，并檢查是否成功合并了多個請求。例如，我們可以向http://localhost:8080/data發送具有以下查詢參數的GET請求：
?keys=key1&keys=key2&keys=key3這將使用Hystrix請求合并器執行三個請求，并將其結果合并到單個響應中。
步驟6：啟動應用程序并測試
現在，我們可以啟動應用程序并測試它是否按預期工作。我們可以通過運行以下命令來啟動應用程序：
mvn spring-boot:run應用程序啟動后，我們可以使用Postman或類似的工具向API發送HTTP請求，并檢查是否已成功使用Hystrix請求合并器合并了多個請求。例如，我們可以向http://localhost:8080/data發送具有以下查詢參數的GET請求：
?keys=key1&keys=key2&keys=key3如果一切正常，我們將看到以下響應：
{ "key1": "Data for key1", "key2": "Data for key2", "key3": "Data for key3"}這表明Hystrix請求合并器已成功執行三個請求并將其結果合并到單個響應中。
