在vertx上的最佳实践设计。用于存储库的Eventbus或Singleton

Question

我正在使用vertx3

我需要使用redis来设置和获取值。(Redis将来可能会改为其他东西)。

我正在为我的实现寻找最佳实践设计。

我正在开发vertx集群，我需要通过事件总线检索消息，提取消息并插入Redis。

另一方面，我可以通过网络获取请求，也可以提取消息并将它们插入redis中。

有两种选择：

1. 我应该有一个“红线-垂直线”，通过公共汽车获取信息并写出它们。
2. 我是否应该创建一个“侦听器垂直线”来保存DAO，它将包含RedisRepo对象，后者将编写它们。 我还将能够处理web调用并保存这个DAO对象。

如果我在spring上，我会创建一个包含RedisRepo的DAO，并将它注入到我的服务层，但是这里我们得到了事件总线，所以我不确定。

(顺便说一句，红色的数据源让我变成其他的东西，所以我得考虑一下通用包装器)

1. 

public class RedisRepoVerticle extends AbstractVerticle {

...
 public void start() {
 client = new RedisClient("localhost", 6379);
                 connection = client.connect();
...

vertx.eventBus().consumer("redis-operation", (handler) -> {
            {
                JsonObject msg = new JsonObject(handler.body().toString());
               //write straight to Redis 

            }
        });

}






2. 

     public class RedisMessageListener extends AbstractVerticle {
        DatasourceDAO datasource
        ...
         public void start() {
         client = new RedisClient("localhost", 6379);
                         connection = client.connect();
    ...

    vertx.eventBus().consumer("redis-operation", (handler) -> {
                {
                    JsonObject msg = new JsonObject(handler.body().toString());
                   datasourceDAO.writeToRedis(..); 

                }
            });

    }

//datasourceDAO will hold RedisRepo object

如果我选择第二种选择，我是否应该开始维持单身人士？我不想复制我的daos，这会复制我的redisrepo类

Answer 1

我认为最好是实现第二种情况，创建一个独立的垂直线，它将容纳一个redis客户端和一个独立的垂直线，它将接受、处理并将请求传递给redis。每个垂直线应该有单独的连接池，将来在创建从每个顶点到redis的独立连接时，您可能会遇到维护多个连接池的问题。

DAO-s的复制不应该是这里的情况。我建议你看看https://github.com/vert-x3/vertx-service-proxy。这是一个vert.x子项目，它可以帮助您理解垂直线本身是什么。您应该将提供一组方法的垂直线作为服务(特别是DAO)来处理。它的行为就像一个单例，也就是说，您不创建按需垂直的新实例，但是根据配置(instances)，它可以有多个实例。