编写对文件执行CRUD操作的顶点

Question

我是Vert的新手。我正在尝试实现一个小型REST API，它将数据存储在本地文件系统的JSON文件中。

到目前为止，我设法实现了REST API，因为Vertx在这方面有很好的文档记录。

我目前正在寻找的是如何在Vert. x中构建数据访问对象的示例。我怎样才能实现一个可以对包含JSON的文本文件执行粗鲁操作的版本？

你能给我举些例子吗？有什么提示吗？

更新1：

通过对文件进行CRUD操作，我想到了以下内容。想象一下，在路径/api/v1/user/： userid/记录/上有一个名为Records的REST资源。

在启动HTTP服务器的垂直通道中，我有以下路径。

router.get('/api/user/:userid/records').handler(this.&handleGetRecords)
router.post('/api/user/:userid/records').handler(this.&handleNewRecord)

处理程序方法handleGetRecords和handleNewRecord使用Vertx事件总线发送消息。

request.bodyHandler({ b ->

   def userid = request.getParam('userid')

   logger.info "Reading record for user {}", userid
            vertx.eventBus().send(GET_TIME_ENTRIES.name(), "read time records", [headers: [userId: userid]], { reply ->

   // This handler will be called for every request
   def response = routingContext.response()

   if (reply.succeeded()) {
      response.putHeader("content-type", "text/json")
      // Write to the response and end it
                    response.end(reply.result().body())
   } else {

      logger.warn("Reply failed {}", reply.failed())
      response.statusCode = 500
      response.putHeader("content-type", "text/plain")

      response.end('That did not work out well')
   }
  })
})

然后还有另一个顶点消耗这些消息GET_TIME_ENTRIES或CREATE_TIME_ENTRY。我认为这个消费者顶点是记录的数据访问对象。这个顶点可以读取包含所有用户记录的给定： userid的文件。顶点能够

• 添加一条记录
• 读取所有记录
• 读取特定记录
• 更新一条记录
• 删除一条或全部记录

这里是读取所有记录的例子。

vertx.eventBus().consumer(GET_TIME_ENTRIES.name(), { message ->

    String userId = message.headers().get('userId')
    String absPath = "${this.source}/${userId}.json" as String

    vertx.fileSystem().readFile(absPath, { result ->

        if (result.succeeded()) {
            logger.info("About to read from user file {}", absPath)
            def jsonObject = new JsonObject(result.result().toString())
            message.reply(jsonObject.getJsonArray('records').toString())
        } else {
            logger.warn("User file {} does not exist", absPath)
            message.fail(404, "user ${userId} does not exist")
        }
    })
})

我试图实现的是像上面那样读取文件，并将JSON反序列化为POJO（例如列表）




Answer 1

我想下面的链接会帮助你，这是Vertx crud操作的一个很好的例子。

使用hikari的Vertx学生积垢操作

Answer 2

首先，在我看来，您使用EventBus的方法很好。它可能会慢一点，因为EventBus将序列化/反序列化对象，但它提供了一个非常好的解耦。

您可以在这里看到另一种方法的示例：
https://github.com/aesteve/vertx-feeds/blob/master/src/main/java/io/vertx/examples/feeds/dao/RedisDAO.java

请注意每个方法如何接收处理程序作为其最后一个参数：

public void getMaxDate(String feedHash, Handler<Date> handler) {

耦合度更高，但效率也更高。

对于更经典、更直接的方法，您可以看到官方示例：

https://github.com/aokolnychyi/vertx-example/blob/master/src/main/java/com/aokolnychyi/vertx/example/dao/MongoDbTodoDaoImpl.java

您可以看到，这里的DAO基本上是同步的，但是由于处理程序仍然是异步的，所以它还是可以的。