diff --git a/net/src/main/java/com/zfoo/net/config/ConfigManager.java b/net/src/main/java/com/zfoo/net/config/ConfigManager.java index e3509e0b..18689ad8 100644 --- a/net/src/main/java/com/zfoo/net/config/ConfigManager.java +++ b/net/src/main/java/com/zfoo/net/config/ConfigManager.java @@ -85,17 +85,18 @@ public class ConfigManager implements IConfigManager { // 接下来就是通过注册中心,把生产者和消费者关联起来 try { var registryConfig = NetContext.getConfigManager().getLocalConfig().getRegistry(); - String driverClassName = registryConfig.getDriverClassName(); - if (driverClassName == null || driverClassName.isBlank()){ - registry = new ZookeeperRegistry(); - } else { - registry = (IRegistry) Class.forName(driverClassName).getDeclaredConstructor().newInstance(); + if (registryConfig != null) { + String driverClassName = registryConfig.getDriverClassName(); + if (driverClassName == null || driverClassName.isBlank()){ + registry = new ZookeeperRegistry(); + } else { + registry = (IRegistry) Class.forName(driverClassName).getDeclaredConstructor().newInstance(); + } + registry.start(); } } catch (Exception e) { throw new RuntimeException("registry instance err", e); } - - registry.start(); } @Override