配置中心设计与实现

/**
 * 传统配置方式的问题
 */
public class TraditionalConfigProblems {
    
    // 1. 配置文件散落各处
    /*
     * application.properties
     * application-dev.properties
     * application-prod.properties
     * 每个环境都要维护一套配置
     */
    
    // 2. 配置修改需要重启
    /*
     * 修改数据库连接
     * 修改 Redis 地址
     * 修改线程池参数
     * → 都需要重启应用
     */
    
    // 3. 配置安全性
    /*
     * 密码明文存储在代码库
     * 不同环境密码不同
     * 泄露风险高
     */
    
    // 4. 配置一致性
    /*
     * 多个服务使用相同配置
     * 修改时需要逐个同步
     * 容易遗漏导致不一致
     */
}

/**
 * 配置中心的核心价值
 */
public class ConfigCenterBenefits {
    
    // 1. 集中管理
    /*
     * 所有配置集中存储
     * 统一版本控制
     * 统一权限管理
     */
    
    // 2. 动态更新
    /*
     * 配置修改实时生效
     * 无需重启应用
     * 支持灰度发布
     */
    
    // 3. 环境隔离
    /*
     * 开发、测试、生产环境隔离
     * 相同应用不同环境不同配置
     */
    
    // 4. 配置加密
    /*
     * 敏感信息加密存储
     * 运行时解密
     * 审计日志
     */
}

/**
 * 配置中心对比
 */
public class ConfigCenterComparison {
    /*
     * | 特性           | Spring Cloud Config | Apollo | Nacos |
     * |----------------|---------------------|--------|-------|
     * | 配置存储        | Git/文件系统         | 数据库  | 数据库  |
     * | 动态刷新        | 需要 Bus            | 实时推送 | 实时推送 |
     * | 管理界面        | 无                  | 完善    | 完善    |
     * | 权限管理        | 弱                  | 强      | 中      |
     * | 多环境支持      | 支持                | 强      | 强      |
     * | 服务发现        | 无                  | 无      | 内置    |
     * | 学习成本        | 低                  | 中      | 低      |
     * | 社区活跃度      | 高                  | 中      | 高      |
     */
}

/**
 * 配置数据模型
 */
public class ConfigModel {
    
    // 配置项
    @Data
    public class ConfigItem {
        private String key;           // 配置键
        private String value;         // 配置值
        private String description;   // 描述
        private DataType type;        // 类型：STRING、NUMBER、BOOLEAN等
        private boolean encrypted;    // 是否加密
        private String defaultValue;  // 默认值
    }
    
    // 命名空间（Namespace）
    /*
     * 作用：逻辑隔离，如按应用、按模块划分
     * 示例：
     * - user-service: 用户服务配置
     * - order-service: 订单服务配置
     * - redis: Redis相关配置
     * - mysql: 数据库配置
     */
    
    // 配置集（Configuration Set）
    /*
     * 作用：物理隔离，如按环境划分
     * 示例：
     * - DEV: 开发环境
     * - TEST: 测试环境
     * - PROD: 生产环境
     */
    
    // 版本管理
    /*
     * 每次修改生成新版本
     * 支持版本回滚
     * 版本对比查看差异
     */
}

/**
 * 配置推送实现
 */
public class ConfigPushMechanism {
    
    // 推模式（Push）
    /*
     * 配置中心主动推送变更
     * 实现方式：长轮询、WebSocket
     * 优点：实时性高
     * 缺点：连接数多时压力大
     */
    public class PushModel {
        // 客户端长轮询
        public void longPolling() {
            while (true) {
                // 1. 客户端发起长轮询请求
                // 2. 服务端hold住连接
                // 3. 有配置变更时立即返回
                // 4. 无变更时超时返回
            }
        }
    }
    
    // 拉模式（Pull）
    /*
     * 客户端定时拉取配置
     * 实现方式：定时任务
     * 优点：实现简单
     * 缺点：有延迟
     */
    public class PullModel {
        @Scheduled(fixedDelay = 30000)  // 30秒拉取一次
        public void pullConfig() {
            // 拉取最新配置
            // 比较版本号
            // 有变更则更新本地配置
        }
    }
    
    // 推拉结合（推荐）
    /*
     * 长连接保持 + 定时检查
     * 兼顾实时性和可靠性
     */
}

/**
 * 配置中心高可用架构
 */
public class HighAvailability {
    
    // 集群部署
    /*
     * 配置中心本身集群化
     * 客户端配置多个地址
     * 失败自动切换
     */
    
    // 数据持久化
    /*
     * 配置数据持久化到数据库
     * 定期备份
     * 容灾恢复
     */
    
    // 客户端容错
    /*
     * 本地缓存配置
     * 服务端不可用时使用本地配置
     * 重试机制
     */
    
    // 配置回退
    /*
     * 新配置有问题时快速回滚
     * 版本管理支持回退
     */
}

@SpringBootApplication
@EnableConfigServer  // 启用配置中心服务端
public class ConfigServerApplication {
    public static void main(String[] args) {
        SpringApplication.run(ConfigServerApplication.class, args);
    }
}

@SpringBootApplication
@RestController
@RefreshScope  // 支持动态刷新
public class ConfigClientApplication {
    
    @Value("${app.name}")
    private String appName;
    
    @Value("${database.url}")
    private String dbUrl;
    
    @GetMapping("/config")
    public Map<String, String> getConfig() {
        return Map.of(
            "appName", appName,
            "dbUrl", dbUrl
        );
    }
    
    public static void main(String[] args) {
        SpringApplication.run(ConfigClientApplication.class, args);
    }
}

/**
 * 配置动态刷新机制
 */
public class ConfigRefresh {
    
    // 方式1：/actuator/refresh端点
    /*
     * POST /actuator/refresh
     * 手动触发配置刷新
     * 返回变更的配置项
     */
    
    // 方式2：Spring Cloud Bus（自动刷新）
    /*
     * 配置中心更新配置
     * 发送消息到消息队列
     * 所有客户端监听并刷新
     */
    
    // 方式3：@RefreshScope注解
    /*
     * 标注需要刷新的Bean
     * 配置变更时重新创建Bean
     */
    @Component
    @RefreshScope
    public class DynamicConfigBean {
        @Value("${dynamic.config}")
        private String dynamicValue;
    }
}

/**
 * Apollo 核心概念
 */
public class ApolloConcepts {
    
    // 1. 应用（Application）
    /*
     * 每个微服务对应一个应用
     * 如：user-service、order-service
     */
    
    // 2. 集群（Cluster）
    /*
     * 应用的不同部署集群
     * 如：default、shanghai、beijing
     */
    
    // 3. 命名空间（Namespace）
    /*
     * 配置的逻辑分组
     * 类型：
     * - 私有命名空间：应用独享
     * - 公共命名空间：多个应用共享
     */
    
    // 4. 配置发布
    /*
     * 灰度发布：先发布到部分实例
     * 全量发布：所有实例生效
     * 回滚：快速回退到上一版本
     */
}

@Configuration
public class ApolloConfig {
    
    // 1. 监听配置变更
    @ApolloConfigChangeListener
    private void onChange(ConfigChangeEvent changeEvent) {
        for (String key : changeEvent.changedKeys()) {
            ConfigChange change = changeEvent.getChange(key);
            log.info("配置变更: {} = {} -> {}", 
                key, change.getOldValue(), change.getNewValue());
            
            // 根据变更类型处理
            if (change.getChangeType() == PropertyChangeType.ADDED) {
                // 新增配置
            } else if (change.getChangeType() == PropertyChangeType.MODIFIED) {
                // 修改配置
                if ("redis.host".equals(key)) {
                    redisTemplate.resetConnection();  // 重建Redis连接
                }
            }
        }
    }
    
    // 2. 获取配置
    @ApolloConfig("redis")
    private Config redisConfig;
    
    public String getRedisHost() {
        return redisConfig.getProperty("host", "localhost");
    }
    
    // 3. 注入配置
    @Value("${server.port}")
    private int serverPort;
}

/**
 * 敏感信息加密
 */
public class ConfigEncryption {
    
    // Jasypt 加密
    /*
     * 配置：ENC(加密内容)
     * 加密：java -cp jasypt-1.9.3.jar org.jasypt.intf.cli.JasyptPBEStringEncryptionCLI input="secret" password=masterKey algorithm=PBEWithMD5AndDES
     */
    
    // Spring Cloud Config 加密
    /*
     * POST /encrypt
     * 请求体：明文
     * 返回：密文
     * 
     * 使用：{cipher}密文
     */
    
    // Apollo 加密
    /*
     * 管理界面支持加密
     * 自动识别{cipher}前缀
     * 客户端自动解密
     */
}