本文目录导读：
这是一个非常核心的架构问题,在分布式系统中，API 的可用性不仅仅指接口“能通”（服务不宕机），更关键的是数据的一致性、完整性和可访问性。
要保证 Java 分布式数据的可用性 API，通常需要从客户端（API 网关/应用层）、中间件（缓存/消息队列） 和存储层（数据库/分布式存储） 三个层面协同设计。
以下是具体的保证策略和技术实现：
服务层：熔断、降级与重试（防御性编程）
这是 API 本身的第一道防线，防止一个服务实例挂掉拖垮整个链路。
- 熔断（Circuit Breaker）：
- 工具：Hystrix（已停维）、Resilience4j（推荐）。
- 逻辑：当一个后端数据源（如数据库、Redis、另一个微服务）连续失败达到阈值（如 5 秒内 50% 请求失败），熔断器打开，后续请求直接返回 fallback（降级响应），不再尝试调用失败的数据源，这给数据源（如数据库）恢复的时间。
- 降级（Degrade）：
- 当熔断触发或系统负载过高时,API 返回一个有损但可用的响应，查询用户订单列表失败，API 降级返回“订单服务暂时不可用，请稍后重试”或从本地缓存（如 Ehcache）返回过期的历史数据。
- 重试（Retry）：
- 工具：Spring Retry、Resilience4j Retry。
- 场景：针对网络抖动导致的数据读取失败（如 SQL 超时、Redis 连接池满）。
- 关键：必须配合幂等性，如果写操作（如扣库存）被重试，必须保证多次执行结果一致（使用唯一请求 ID 去重）。
缓存层：多级缓存与缓存穿透保护
缓存是消除数据库压力、提高 API 读可用性的关键，但缓存本身如果挂了，会导致雪崩。
- 多级缓存策略：
本地缓存（Caffeine/Ehcache） -> 分布式缓存（Redis/Redis-Cluster） -> 数据库。
- 缓存雪崩预防：
- 随机过期时间：在设置 TTL 时，增加一个随机值（如 base TTL + 1-5分钟随机值），防止大量数据同时过期导致集体击穿数据库。
- 互斥锁（Mutex Key）：当缓存失效（如商品详情），只允许一个线程去数据库查询并回写缓存，其他线程等待（自旋或阻塞）。
- 缓存击穿预防：
- 对热点数据（如秒杀商品、大 V 信息）设置永不过期 + 异步更新（后台定时任务刷新，而不是查不到才触发）。
- 缓存穿透保护：
- Bloom Filter（布隆过滤器）：在 API 请求到达 Redis 前，先判断请求的 Key 是否一定不存在（如不存在的用户 ID），如果布隆过滤器判定不存在，直接返回 404，避免打到数据库。
- 缓存空对象：如果数据库查不到数据，也对 Key 设置一个较短的 TTL（如 30秒）的空值缓存。
数据存储层：读写分离与分库分表
这是数据库层面的可用性保障。
- 读写分离：
- JDBC 层面（如 ShardingSphere，MyCat）或 ORM 层面（Spring 动态数据源）。
- 主库（Master）：处理写操作（Insert/Update/Delete）。
- 从库（Slave）：处理读操作（Select），从库可以是多个。
- 保障点：当从库挂了，API 需要自动将读流量切换到主库（降级模式），保持写可用（虽然读性能下降，但整体可用）。
- 分库分表：
- 当单库扛不住时,使用 ShardingSphere 或 Vitess 进行水平拆分。
- 可用性挑战：跨库的 Join、排序或分页查询会很复杂，通常需通过全局表 + 索引表 + ES 来处理查询的可用性。
- 柔性事务（TCC / Saga）：
- 对于跨多个数据库的写操作（如支付：订单库 + 账户库 + 库存库），放弃强一致的 XA 事务（性能差），使用 TCC（Try-Confirm-Cancel）或基于消息的最终一致性（Saga）。
- 保证点：最终一定一致，如果中间失败（如扣款成功、出库失败），由补偿任务（定时 Job 或 MQ）进行回滚。
数据复制与同步
- 主从复制 vs 多主复制：
- 利用 MySQL 的 binlog 或 PostgreSQL 的 WAL 日志进行异步（或半同步）复制。
- 问题：主库挂了，从库可能缺少最新数据（数据同步延迟），API 可能读到旧数据。
- 妥协方案：对于强一致性要求（如余额、股票），API 必须强制读主库（再小的宕机也要优先保证一致性）；对于弱一致性（如浏览次数、用户昵称），可以接受读从库的延迟数据。
- 分布式共识算法：
- ZooKeeper / etcd（ZAB / Raft）：保证配置数据（如服务发现、分布式锁）的强一致性，API 在获取配置或锁时，总是能拿到最新的正确数据。
- RAFT：对于一些超高性能场景，有的团队会用 Raft 协议实现自己的 KV 存储（如 TiKV、etcd），牺牲一点性能换取数据的强一致性。
幂等性与最终一致
这是保证数据写操作不丢失、不重复的关键。
- 幂等（Idempotent）：
- Token 机制：客户端在请求写 API 前，先获取一个全局唯一的 Token，每次写操作必须携带该 Token，服务端使用 Redis 或数据库唯一索引去重，这是最常用的做法。
- 最终一致性：
- MQ（消息队列）：RabbitMQ / Kafka。
- 写操作（如异步更新用户积分）先写数据库，发送一条消息到 MQ，消费端处理积分逻辑，如果消费失败，MQ 会一直重试直到成功（手动 ACK + 死信队列）。
核心实战配置（示例）
假设你有一个商品详情 API，需要保证高可用：
// 1. 熔断+降级 (Resilience4j)
@CircuitBreaker(name = "productDetail", fallbackMethod = "fallbackDetail")
@Retry(name = "productDetailRetry")
public ProductDetail getProductDetail(Long productId) {
// 2. 多级缓存读取
// 先查本地Caffeine
ProductDetail detail = caffeineCache.get(productId);
if (detail != null) return detail;
// 再查Redis (使用BloomFilter拦截不存在ID)
if (!bloomFilter.mightContain(productId)) {
return ProductDetail.EMPTY;
}
detail = redisTemplate.opsForValue().get(productId);
if (detail != null) {
// 异步回写本地缓存
caffeineCache.put(productId, detail);
return detail;
}
// 3. 查数据库 (读写分离, 强制读主库用于强一致性)
detail = productMapper.selectById(productId);
if (detail == null) {
// 缓存空对象, 防穿透
redisTemplate.opsForValue().set(productId, ProductDetail.EMPTY, 5, TimeUnit.MINUTES);
return null;
}
// 4. 设置随机过期时间, 防雪崩
int ttl = 1800 + ThreadLocalRandom.current().nextInt(1800); // 30-60分钟
redisTemplate.opsForValue().set(productId, detail, ttl, TimeUnit.SECONDS);
caffeineCache.put(productId, detail);
return detail;
}
public ProductDetail fallbackDetail(Long productId, Throwable t) {
// 降级：返回本地Caffeine中的过期数据 (允许丢准，但不允许不可用)
return caffeineCache.getIfPresent(productId);
}
可用性不是银弹
保证 Java 分布式数据可用性 API 的核心是分层容忍与权衡：
- 高可用策略：熔断 > 降级 > 重试。
- 读优化：本地缓存（快）+ 分布式缓存（统一）+ Bloom Filter（防穿透）+ 读从库（分担压力）。
- 写优化：强一致性读主库，弱一致性读从库；用 MQ 保证最终一致。
- 终极方案：如果对数据一致性要求极高（如金融），方案可能是：Redis 缓存（提高性能）+ Zookeeper（强一致协调）+ 读写全部走主库，牺牲横向扩展能力来保证绝对正确。
真正的挑战在于：如何判断某个数据源是不可用（异常）还是仅仅是慢？ 如果判断错误（误判），会导致熔断早开，降低可用性；如果判断太晚，会引发雪崩，通常需要结合慢阈值、错误比例和滑动窗口（如 Sentinel 或者 Resilience4j 的滑动窗口统计）来综合决策。
