java - vertx 上的最佳实践设计。存储库的 Eventbus 或 Singleton

Question

我正在使用 vertx3

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

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

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

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

两种选择:

1. 我是否应该有一个“redis-verticle”来通过总线获取消息并写入它们。

2. 我是否应该创建一个“Listener verticle”来容纳 DAO，DAO 将容纳 RedisRepo 对象，而 RedisRepo 对象将写入它们。

   我还将能够处理网络调用并持有这个 DAO 对象

如果我在 spring-app 上，我会创建一个包含 RedisRepo 的 DAO，并将其注入(inject)我的服务层，但这里我们有事件总线，所以我不确定。

(顺便说一句，redis 数据源我要改成别的东西，所以我得考虑通用包装器)

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

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

DAO-s 复制不应该是这里的情况。我建议你看看 https://github.com/vert-x3/vertx-service-proxy .这是一个 vert.x 子项目，可以帮助您了解什么是 Verticle。您应该将 Verticle 视为提供一组方法的服务(或特别是 DAO)。它的行为类似于单例，即您不会按需创建 Verticle 的新实例，但根据配置 (http://vertx.io/docs/vertx-core/groovy/#_specifying_number_of_verticle_instances) 可以有多个实例。