如何在VertX应用的HTTP请求中修改config.json配置字段？

当然可以实现，核心思路是在HTTP请求处理逻辑中修改内存中的配置对象，再将其写回config.json文件，同时要注意多线程环境下的并发安全问题。

具体实现步骤 #

1. 定位并修改内存中的配置属性
   根据需求找到dataFilter中name为xxx的对象，更新其values数组：

   // 从requestDto中获取新的values列表，需根据实际DTO结构调整方法名
   List<Integer> newValues = requestDto.getNewValues();
   
   // 遍历dataFilter数组定位目标对象
   JsonArray dataFilter = config.getJsonObject("REQUEST_OPTIONS").getJsonArray("dataFilter");
   for (int i = 0; i < dataFilter.size(); i++) {
       JsonObject filter = dataFilter.getJsonObject(i);
       if ("xxx".equals(filter.getString("name"))) {
           filter.put("values", new JsonArray(newValues));
           break;
       }
   }
   

2. 将修改后的配置写回文件
   使用VertX的异步文件系统API写入，避免阻塞事件循环：

   // 替换为实际的config.json路径
   vertx.fileSystem().writeFile("config.json", Buffer.buffer(config.encodePrettily()), ar -> {
       if (ar.failed()) {
           log.error("写入配置文件失败", ar.cause());
           throw new RuntimeException("配置更新失败", ar.cause());
       }
   });
   

3. 更新请求处理方法
   整合逻辑后的performAction方法：

   private Handler<RoutingContext> performAction(JsonObject config, Vertx vertx) {
       return routingContext -> Try.of(() -> Json.decodeValue(routingContext.getBody(), RequestDto.class))
               .onFailure(ex -> log.warn("解析RequestDto失败: ", ex))
               .andThen(requestDto -> {
                   // 修改内存配置
                   List<Integer> newValues = requestDto.getNewValues();
                   JsonArray dataFilter = config.getJsonObject("REQUEST_OPTIONS").getJsonArray("dataFilter");
                   for (int i = 0; i < dataFilter.size(); i++) {
                       JsonObject filter = dataFilter.getJsonObject(i);
                       if ("xxx".equals(filter.getString("name"))) {
                           filter.put("values", new JsonArray(newValues));
                           break;
                       }
                   }
                   // 异步写回文件
                   vertx.fileSystem().writeFile("config.json", Buffer.buffer(config.encodePrettily()), ar -> {
                       if (ar.failed()) throw new RuntimeException("写入配置文件失败", ar.cause());
                   });
               })
               .onFailure(ex -> {
                   log.warn("保存请求失败: ", ex);
                   routingContext.response().setStatusCode(HttpResponseStatus.INTERNAL_SERVER_ERROR.code()).end();
               })
               .onSuccess(handler -> routingContext.response().setStatusCode(HttpResponseStatus.OK.code()).end());
   }
   

关键注意事项 #

• 并发安全：多个请求同时修改配置时，需用VertX的SharedData锁避免冲突。
• 配置同步：若其他Verticle依赖该配置，修改内存中的config对象后，后续访问会自动获取最新值；如需立即通知其他Verticle，可通过事件总线发送更新消息。
• 路径准确性：确保config.json的路径正确，建议使用绝对路径或从环境变量读取。

原问题相关代码 #

配置文件（config.json） #

{
  "REQUEST_OPTIONS": {
    "dataFilter": [
      {
        "name": "xxx",
        "values": [1, 2, 3] // 待修改的目标字段
      },
      {
        "name": "yyy",
        "values": [4, 5, 6]
      }
    ]
  }
}

启动方法代码 #

@Override
public void start(Promise<Void> startPromise) {
    CompositeFuture.all(
            // 其他Future操作
            Future.future(ConfigRetriever.create(vertx)::getConfig)
                    .flatMap(config -> storeData(config)
                            .compose(maybeStoreData -> CompositeFuture.all(
                                    matcherVerticle(subject).apply(maybeStoreData),
                                    http(sharedData, maybeStoreData).apply(config)
                            )))
            .<Void>mapEmpty()
            .onComplete(startPromise);
}

路由配置代码 #

router.get("/api/action").handler(performAction(configJson));

请求处理方法代码 #

private Handler<RoutingContext> performAction(JsonObject config) {
    return routingContext -> Try.of(() -> Json.decodeValue(routingContext.getBody(), RequestDto.class))
            .onFailure(ex -> log.warn("解析RequestDto失败: ", ex))
            .andThen(requestDto -> ???根据requestDto更新配置文件？??)
            .onFailure(ex -> log.warn("保存请求失败: ", ex))
            .onFailure(ex -> routingContext.response().setStatusCode(HttpResponseStatus.INTERNAL_SERVER_ERROR.code()))
            .onSuccess(handler -> routingContext.response().setStatusCode(HttpResponseStatus.OK.code()));
}

内容的提问来源于stack exchange，提问作者Leah