Vertx 将处理程序添加到 Spring 数据 API

Question

在vertx中，如果我们要执行jdbc操作，不会阻塞主循环，我们使用以下代码，

client.getConnection(res -> {
  if (res.succeeded()) {

    SQLConnection connection = res.result();

    connection.query("SELECT * FROM some_table", res2 -> {
      if (res2.succeeded()) {

        ResultSet rs = res2.result();
        // Do something with results
      }
    });
  } else {
    // Failed to get connection - deal with it
  }
});

在这里，我们添加了将在我们的操作完成时执行的处理程序。

现在我想使用Spring Data API，但是和上面的方法一样吗

现在我按如下方式使用它

@Override
public void start() throws Exception {
    final EventBus eventBus = this.vertx.eventBus();
    eventBus.<String>consumer(Addresses.BEGIN_MATCH.asString(), handler-> {
        this.vertx.executeBlocking(()-> {
            final String body = handler.body();
            final JsonObject resJO = this.json.asJson(body);
            final int matchId = Integer.parseInt(resJO.getString("matchid"));
            this.matchService.beginMatch(matchId);//this service call method of crudrepository
            log.info("Match [{}] is started",matchId);
         }
    },
    handler->{});
}

这里我使用了执行阻塞，但它使用工作池中的线程，是否可以替代包装阻塞代码？

Answer 1

回答这个问题：如果：

• 您在单独的 pid 中运行多个 verticle 实例（使用 systemd 或 docker 或任何允许您在恢复模式下安全运行独立 java 进程的工具）并在集群模式下监听相同的 eventbus 通道（例如使用 hazelcast）。
• 按照 tsegismont 在对此答案的评论中的建议，您将 verticle 的多个实例作为工作 verticles 运行。

另外，它与问题无关，这确实是个人意见，但我还是给出了它：我认为在 vert.x 应用程序中使用 Spring 依赖项是个坏主意。 Spring 与至少使用 Spring Core 的基于 Servlet 的应用程序相关。我的意思是，这与在完全基于 Spring 的生态系统中使用相关。否则，您会将许多未使用的大依赖项带回您的 jar 文件中。

几乎每个 Spring 模块都有具有相同目的的小型、轻量级和独立库。例如，对于 IoC，您有 guice、hk2、weld...

如果我需要使用基于 SQL 的数据库，我个人会受到 Spring 的 JdbcTemplate 和 RowMapper 模型的启发，而无需使用任何 Spring 依赖项。用这样一个简单的界面来重现它非常简单：

import java.io.Serializable;
import java.sql.ResultSet;
import java.sql.SQLException;

public interface RowMapper<T extends Serializable> {
    T map(ResultSet rs) throws SQLException;
}

另外一个接口DatabaseProcessor 有这样的方法：

<T extends Serializable> List<T> execute(String query, List<QueryParam> params, RowMapper<T> rowMapper) throws SQLException;

还有一个 QueryParam 类，其中包含查询参数的值、顺序和名称（以避免 SQL 注入漏洞）。