如何使用Vert.x实现非阻塞REST web服务

Question

我是新进入Vert. x的。我遵循了Vert. x文档和一些教程。但是我混淆了使用Vert. x实现非阻塞REST Web服务的正确方法是什么。我在Java中找到了这篇文章开发非阻塞Web应用程序，其中包含一个使用Vert. x实现非阻塞Web应用程序的示例。

此代码块包含向另一个Vertical（“todoService”：TodoServiceVerticle）发送消息。

JsonObject command = new JsonObject();

command.putString("action","findOne").
putNumber("id",Long.valueOf(request.params().get("id")));

String address = "todoService";

vertx.eventBus().send(address, command, (Message<JsonObject> message)-> {
    JsonObject item = message.body();
    String payload = item.encode();
    request.response()
       .putHeader("content-type", "application/json")
       .end(item);
});

这是“todoService”：TodoServiceVer的垂直。

public class TodoServiceVerticle extends Verticle{

    /** Initializes the verticle at the start-up */
    @Override public void start() {   
        // Initialize the verticle
        vertx.eventBus().registerHandler("todoService", this::onMessage);
    }

    private void onMessage(Message<JsonObject> message) {
        JsonObject command = message.body();           
        // Only "findOne" is supported in this example 
        assert ("findOne".equals(command.getString("action")));         
        Long id = command.getLong("id");
        Todo item = findOneById(id);
        JsonObject payload = toJson(item);
        message.reply(payload);
    }
}

在这个例子中，服务器运行在一个线程上。所有的http请求都到达同一个线程。TodoServiceVerticle正在不同的线程中运行。

现在我的问题是如果TodoServiceVerticle。onMessage（）函数包含耗时的任务（例如：-DB Operation、Reading a Large File…），它将阻止进程。同时假设另一个用户调用TodoServiceVerticle。onMessage（），但他还必须等待上一个用户完成任务。那么如何避免这种问题。谢谢。

Answer 1

请看这个博客系列:

• 第一篇文章描述了如何建立一个vert。x应用程序，并执行单元测试
• 第二篇文章描述了如何配置此应用程序
• 第三篇文章介绍了vertx web，并开发了一个小型收藏管理应用程序。此应用程序提供HTML/JavaScript前端使用的REST API
• 第四篇文章介绍了如何运行集成测试以确保应用程序的行为
• 第五篇文章介绍了如何使用vertxjdbc客户端与JDBC数据库交互
• 最近一篇文章介绍了如何与MongoDB交互