如何处理vertx消费者异常？

Question

我有代码：

SqlTemplate
    .forQuery(client, "SELECT * FROM user WHERE id=#{id}")
    .execute(parameters)
    .onSuccess(users -> {
      users.forEach(row -> {
        // exception here
        System.out.println(row.get(UUID.class, "id1") + " " + row.getString("title"));
      });
    })

处理消费者异常的最佳方法是什么？现在，如果异常引发，它将被吞没。。。

Answer 1

假设希望在引发异常时使流失败，最好使用compose遍历用户并处理。onSuccess（）和。onFailure（）分别显示。

您可以使用CompositeFuture来实现这一点。您可以有一个Future列表，并将成功的Future/失败的Future（在异常的情况下）添加到foreach循环中的列表中。

SqlTemplate
    .forQuery(client, "SELECT * FROM user WHERE id=#{id}")
    .execute(parameters)
    .compose(users -> {
      List<Future> usersFuture = new ArrayList<>();
      users.forEach(row -> {
        try {
          // exception here
          System.out.println(row.get(UUID.class, "id1") + " " + row.getString("title"));
          usersFuture.add(Future.succeededFuture());
        } catch (Exception e) {
          usersFuture.add(Future.failedFuture(e));
        }
      });
      return CompositeFuture.all(usersFuture).mapEmpty();
    })
    .onSuccess(res -> { 
        // end the flow with success
    })
    .onFailure(e -> { 
        // Add error message and fail the flow
    });

一般来说，我对这里可以抛出的异常感到好奇。由于这是您在验证后写入db的数据，因此您应该知道可能的错误场景，并相应地处理它们，而不会使流失败。