如何利用 Java Properties 实现配置热更新

在 Java 中，可以使用 java.util.Properties 类来存储和管理应用程序的配置信息。要实现配置热更新，即在不重启应用程序的情况下更新配置信息，可以采用以下几种方法：

方法一：使用文件监听器

通过监听配置文件的变化，当文件发生变化时，重新加载配置信息。

1. 创建一个配置类：

   import java.io.FileInputStream;
   import java.io.IOException;
   import java.util.Properties;
   
   public class ConfigManager {
       private static Properties properties;
       private static long lastModifiedTime;
   
       static {
           loadConfig();
           startFileWatcher();
       }
   
       public static void main(String[] args) {
           System.out.println(ConfigManager.getProperty("database.url"));
       }
   
       public static String getProperty(String key) {
           return properties.getProperty(key);
       }
   
       private static void loadConfig() {
           properties = new Properties();
           try (FileInputStream fis = new FileInputStream("config.properties")) {
               properties.load(fis);
               lastModifiedTime = fis.getChannel().position();
           } catch (IOException e) {
               e.printStackTrace();
           }
       }
   
       private static void startFileWatcher() {
           new Thread(() -> {
               while (true) {
                   try {
                       long currentTime = System.currentTimeMillis();
                       if (currentTime - lastModifiedTime > 1000) { // 每秒检查一次
                           loadConfig();
                           lastModifiedTime = currentTime;
                       }
                       Thread.sleep(1000);
                   } catch (InterruptedException e) {
                       e.printStackTrace();
                   }
               }
           }).start();
       }
   }
   

2. 配置文件 config.properties：

   database.url=jdbc:mysql://localhost:3306/mydb
   database.username=root
   database.password=secret
   

方法二：使用 Java NIO

Java NIO 提供了更高效的文件监听机制。

1. 创建一个配置类：

   import java.io.IOException;
   import java.nio.file.*;
   import java.util.Properties;
   
   public class ConfigManager {
       private static Properties properties;
   
       static {
           loadConfig();
           startFileWatcher();
       }
   
       public static void main(String[] args) {
           System.out.println(ConfigManager.getProperty("database.url"));
       }
   
       public static String getProperty(String key) {
           return properties.getProperty(key);
       }
   
       private static void loadConfig() {
           properties = new Properties();
           Path configPath = Paths.get("config.properties");
           try {
               if (Files.exists(configPath)) {
                   properties.load(Files.newInputStream(configPath));
               }
           } catch (IOException e) {
               e.printStackTrace();
           }
       }
   
       private static void startFileWatcher() {
           WatchService watchService = FileSystems.getDefault().newWatchService();
           Path configPath = Paths.get("config.properties");
           configPath.getParent().register(watchService, StandardWatchEventKinds.ENTRY_MODIFY);
   
           new Thread(() -> {
               while (true) {
                   try {
                       WatchKey watchKey = watchService.take();
                       for (WatchEvent<?> event : watchKey.pollEvents()) {
                           if (event.context().toString().equals("config.properties")) {
                               loadConfig();
                           }
                       }
                       watchKey.reset();
                   } catch (InterruptedException e) {
                       e.printStackTrace();
                   }
               }
           }).start();
       }
   }
   

2. 配置文件 config.properties：

   database.url=jdbc:mysql://localhost:3306/mydb
   database.username=root
   database.password=secret
   

方法三：使用 Spring Boot 的 @PropertySource 注解

如果你使用的是 Spring Boot，可以利用其提供的 @PropertySource 注解来实现配置热更新。

1. 创建一个配置类：

   import org.springframework.context.annotation.Configuration;
   import org.springframework.context.annotation.PropertySource;
   
   @Configuration
   @PropertySource("classpath:config.properties")
   public class AppConfig {
   }
   

2. 配置文件 config.properties：

   database.url=jdbc:mysql://localhost:3306/mydb
   database.username=root
   database.password=secret
   

3. 启用配置热更新： 在 application.properties 中添加以下配置：

   spring.cloud.config.server.monitor.enabled=true
   spring.cloud.config.server.monitor.file=config.properties
   

通过以上方法，可以实现 Java 应用程序的配置热更新。选择哪种方法取决于你的具体需求和项目结构。