我有一个类ConfigFactory,它可以通过vert.xconf模块从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");
}
}
}但是在垂直,我使用JsonObject httpConfig = ConfigFactory.getHttpConfig();,它会给我例外HTTP Config get error! Something went wring during getting the config.In这次,result是空的。
我发现静态方法getHttpConfig在静态代码块之前运行。大约一秒,静态代码块将运行。当时,result并不是空的。
你能帮帮我吗?谢谢!
发布于 2018-08-24 08:10:58
与其说是vertX相关的问题,不如说是一个设计问题。静态块是在类加载器加载类时执行的,这基本上是在首次引用类时发生的。如果您第一次引用是在使用ConfigFactory.getHttpConfig();时,那么类加载器将加载该类,则执行静态块,并使用处理程序调用retrieveConfig。不幸的是,它没有阻塞执行(处理程序等待结果),您可以立即调用类。因此,为了使其正常工作,您应该在getHttpConfig()完成初始化之后调用它。
例如:
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我想您可以更好地编写它;)但是一般的想法是,如果对象准备使用或不使用,则保持状态。执行静态配置并不能保证对象处于就绪状态,因此您应该自己管理该状态。
https://stackoverflow.com/questions/51999544
复制相似问题