Java免费获取汇率工具实现

汇率获取工具实现解析

一、工具概述

本汇率获取工具基于Java 11+的HTTP Client实现，提供同步和异步两种请求方式，支持从开放汇率API获取实时汇率数据。核心功能包括：

支持获取美元兑其他货币的完整汇率表
提供特定货币汇率查询接口
完善的错误处理与日志记录机制
异步非阻塞式请求处理

二、核心功能解析

（代码结构示意图）

1. 异步请求实现

  public static CompletableFuture<Map<String, Double>> fetchExchangeRatesAsync() {HttpRequest request = HttpRequest.newBuilder().uri(URI.create("https://open.er-api.com/v6/latest/USD")).timeout(Duration.ofSeconds(15)).header("Accept", "application/json").GET().build();return httpClient.sendAsync(request, HttpResponse.BodyHandlers.ofString()).thenApplyAsync(response -> {if (response.statusCode() != 200) {logger.error("API请求失败，状态码: {}", response.statusCode());throw new RuntimeException("API请求失败，状态码: " + response.statusCode());}return parseResponse(response.body());}).exceptionally(ex -> {logger.error("获取汇率数据时发生异常: {}", ex.getMessage(), ex);return Map.of(); // 返回空Map});}

实现特点：

使用HttpClient.sendAsync()发起异步请求
通过thenApplyAsync实现响应处理管道
exceptionally处理请求链中的异常

2. 同步请求实现

public static Map<String, Double> fetchExchangeRatesSync() {try {HttpRequest request = HttpRequest.newBuilder().uri(URI.create("https://open.er-api.com/v6/latest/USD")).timeout(Duration.ofSeconds(15)).header("Accept", "application/json").GET().build();HttpResponse<String> response = httpClient.send(request, HttpResponse.BodyHandlers.ofString());if (response.statusCode() != 200) {logger.error("API请求失败，状态码: {}", response.statusCode());return Map.of();}return parseResponse(response.body());} catch (Exception e) {logger.error("获取汇率数据时发生异常: {}", e.getMessage(), e);return Map.of();}}

关键点：

阻塞式请求适用于简单场景
统一使用相同的响应解析逻辑
同步异常捕获处理

三、关键技术实现

1. JSON响应解析

private static Map<String, Double> parseResponse(String jsonBody) {JsonNode root = objectMapper.readTree(jsonBody);if (!"success".equals(root.path("result").asText())) {// 错误结果处理}JsonNode ratesNode = root.path("rates");ratesNode.fields().forEachRemaining(entry ->rates.put(entry.getKey(), entry.getValue().asDouble()));
}

解析流程：

使用Jackson的ObjectMapper解析JSON
验证API返回状态
遍历rates节点构建汇率映射

2. 错误处理机制

HTTP状态码检查（非200状态）
JSON解析异常捕获
异步请求异常传递
空结果容错处理（返回空Map）
多级日志记录（ERROR/WARN/INFO）

四、使用示例

1. 同步获取汇率

Map<String, Double> rates = ExchangeRateFetcher.fetchExchangeRatesSync();
System.out.println("USD/CNY: " + rates.get("CNY"));

2. 异步处理汇率

ExchangeRateFetcher.fetchExchangeRatesAsync().thenAccept(rates -> {System.out.println("USD/EUR: " + rates.get("EUR"));});

3. 特定货币查询

/*** 获取指定货币的汇率* @param currencyCode 货币代码 (如 CNY, EUR)* @return 汇率值，如果获取失败返回 -1*/public static double getSpecificRate(String currencyCode) {Map<String, Double> rates = fetchExchangeRatesSync();if (rates.containsKey(currencyCode)) {return rates.get(currencyCode);}logger.warn("未找到货币代码: {} 的汇率", currencyCode);return -1;}