2

我有一个类ConfigFactory，它可以通过 vert.x conf 模块从 JSON 文件中给我一些配置。

public class ConfigFactory {
    private static JsonObject result = new JsonObject();
    static {
        ConfigStoreOptions fileStore = new ConfigStoreOptions()
                .setType("file")
                .setOptional(true)
                .setFormat("json")
                .setConfig(new JsonObject().put("path", "conf/config.json"));
        ConfigRetrieverOptions options = new ConfigRetrieverOptions().addStore(fileStore);
        ConfigRetriever retriever = ConfigRetriever.create(VertxSingleton.VERTX, options);
        retriever.getConfig(ar -> {
            if (ar.failed()) {
                throw new RuntimeException("Config get error! Something went wring during getting the config");
            } else {
                result.mergeIn(ar.result());
            }
        });
    }

    public static JsonObject getHttpConfig() {
        BiFunction<Integer, String, JsonObject> httpConfigFile = (port, host) -> new JsonObject()
                .put("port", port).put("host", host);
        if (!result.isEmpty()) {
            JsonObject http = result.getJsonObject("http");
            return httpConfigFile.apply(http.getInteger("port"), http.getString("host"));
        } else {
            throw new RuntimeException("HTTP Config get error! Something went wring during getting the config");
        }

    }
}

但是在 Verticle 中，我使用JsonObject httpConfig = ConfigFactory.getHttpConfig();，它会给我异常 HTTP Config get error! Something went wring during getting the config。此时，result是空的。

我发现静态方法getHttpConfig在静态代码块之前运行。大约一秒钟，静态代码块将运行。那个时候，result还不是空的。

你能帮助我吗？谢谢！

4

1 回答 1

3

与其说是与 vertX 相关的问题，不如说是设计问题。静态块在类加载器加载类时执行，它基本上会在类第一次引用时发生。如果您第一次引用它是在您使用时， ConfigFactory.getHttpConfig();则该类由类加载器加载，执行静态块并使用处理程序调用retrieveConfig。不幸的是，它没有阻止执行（处理程序等待结果）并且您立即调用该类。因此，为了使其正常工作，您应该在完成初始化后调用 getHttpConfig() 。

  • 使静态块同步的解决方案是使用 Future 选项。

例如：

Future<JsonObject> futureJson=ConfigRetriever.getConfigAsFuture(retriever);
JsonObject obj=futureJson.get();

当在静态块中调用 future.get() 时，它将等到检索到配置后再继续。这似乎是一个更容易理解的解决方案，但我不会使用它。它是异步的，我们不应该改变这种行为。

  • 另一个可能需要更多编码的解决方案是添加一个静态字段来显示它是否处于工作状态。

例如：

private static JsonObject result = new JsonObject();
private static boolean readyToGo;
    static {       
        retriever.getConfig(ar -> {
           ....
            if (ar.failed()) {
             ...
            } else {
                result.mergeIn(ar.result());
                ConfigFactory.readyToGo=true; //Now we are good to go
            }
        });
    }

然后 

   public static JsonObject getHttpConfig() {
      if (!readyToGo) throw Exception
    }

添加一个 isReady() 方法，当您调用 getHttpConfig() 方法时，您将首先调用 isReady()。就像是：

while(!ConfigFactory.isReady()){
//wait ;)
}
ConfigFactory.getHttpConfig(); //it will work here

我想你可以写得更好；）但是一般的想法是在对象是否准备好使用时保持状态。执行该静态配置并不能保证对象处于就绪状态，因此您应该自己管理该状态。

  • 简单的解决方案是在启动时调用一次类，以便它可以被初始化（类加载），然后稍后调用 getHttpConfig()。如果检索器花费太多时间或者即使它从未完成检索配置，它也不能保证 100% 的结果。
于 2018-08-24T08:10:58.390 回答