#配置中心设计

// 配置模型
public class ConfigItem {
    private String namespace;     // 命名空间，如 "order-service"
    private String key;          // 配置key，如 "coupon.threshold"
    private String value;        // 配置值，如 "100"
    private String type;        // 类型：TEXT / JSON / YAML / PROPERTIES
    private long version;       // 版本号
    private long timestamp;      // 更新时间
    private String operator;     // 操作人
}

// 配置分组
public class ConfigGroup {
    private String namespace;    // 命名空间
    private String group;        // 分组，如 "dev" / "test" / "prod"
    private List<ConfigItem> configs;
}

public class ConfigClient {

    private static final long PULL_INTERVAL = 30000;  // 30秒拉取一次

    private volatile long currentVersion = 0;
    private ConfigCache localCache = new ConfigCache();

    // 长连接接收推送
    @Subscribe
    public void onConfigPush(ConfigPush push) {
        if (push.getVersion() > currentVersion) {
            applyConfig(push);
            currentVersion = push.getVersion();
        }
    }

    // 兜底：定时拉取
    @Scheduled(fixedDelay = PULL_INTERVAL)
    public void pullConfig() {
        try {
            ConfigSnapshot snapshot = configCenterClient.pull(
                namespace, group, currentVersion
            );
            if (snapshot.getVersion() > currentVersion) {
                applyConfig(snapshot);
                currentVersion = snapshot.getVersion();
            }
        } catch (Exception e) {
            log.warn("拉取配置失败，使用本地缓存", e);
            // 使用本地缓存兜底
        }
    }

    // 应用配置
    private void applyConfig(ConfigSnapshot snapshot) {
        for (ConfigItem item : snapshot.getConfigs()) {
            localCache.put(item.getKey(), item.getValue());
            notifyListeners(item);
        }
    }
}

public class ConfigGrayRelease {

    // 灰度百分比
    public static final Map<String, Integer> GRAY_PERCENT = Map.of(
        "first", 10,
        "second", 30,
        "third", 50,
        "full", 100
    );

    // 判断是否在灰度范围内
    public boolean isInGrayScope(String clientId, int grayPercent) {
        // 使用一致性哈希，相同的clientId总是落入同一范围
        int hash = Math.abs(clientId.hashCode() % 100);
        return hash < grayPercent;
    }

    // 灰度发布
    public void grayRelease(Long configId, int grayPercent) {
        Config config = configDAO.selectById(configId);

        // 标记为灰度状态
        config.setStatus(ConfigStatus.GRAY);
        config.setGrayPercent(grayPercent);
        config.setGrayStrategy("MACHINE");
        configDAO.update(config);

        // 只推送给灰度范围内的客户端
        List<String> grayClients = clientDAO.selectByGrayScope(grayPercent);
        pushToClients(config, grayClients);

        // 通知监控
        monitorService.alert("灰度发布", configId, grayPercent);
    }

    // 全量发布
    public void fullRelease(Long configId) {
        Config config = configDAO.selectById(configId);
        config.setStatus(ConfigStatus.RELEASED);
        config.setGrayPercent(100);
        configDAO.update(config);

        // 推送给所有客户端
        List<String> allClients = clientDAO.selectAll();
        pushToClients(config, allClients);
    }

    // 回滚
    public void rollback(Long configId) {
        Config config = configDAO.selectById(configId);
        Config previous = configHistoryDAO.selectPrevious(configId);

        // 恢复上一版本
        config.setConfigValue(previous.getConfigValue());
        config.setVersion(previous.getVersion());
        config.setStatus(ConfigStatus.ROLLED_BACK);
        configDAO.update(config);

        // 通知所有客户端
        pushToClients(config, clientDAO.selectAll());
    }
}