Vert.x（vertx）操作Redis

川长思鸟来 2023-10-09 04:15 16阅读 0赞

Redis是一个基于Key-Value的非关系型数据库，在项目中经常用来做缓存、分布式锁等。关于Redis的基础知识，这里就不多说了，读者如果对这块内容不熟悉，可以先找些Redis相关的资料来学习。下面我主要来介绍下在Vertx中如何使用Redis，以及底层的实现原理。

## **基本操作** ##

1.使用Redis和使用数据库一样，只需要导入相关的包，就可以了。这里只需要引入vertx-redis-client

<dependency>
        <groupId>io.vertx</groupId>
        <artifactId>vertx-redis-client</artifactId>
        <version>3.8.1</version>
    </dependency>

2.使用RedisClient操作redis。Vertx的每一个组件都有一个相同的设计原则，就是对外提供一个接口，这个接口包含组件对外提供的所有服务，并且在这个接口中提供一个静态方法用于获得该接口的实例。你在使用Vertx的过程中，会对这个设计印象非常深刻。这样的设计方式，让开发者能够非常快速的上手，也让Vertx代码维护者在对系统进行升级的时候又能非常容易的做到向下兼容。所以在Vertx中集成Redis，我们只需要记住RedisClient就可以了。这也体现了面向对象设计原则中的：封装。

package stu.vertx.redis;
    
    import io.vertx.core.AbstractVerticle;
    import io.vertx.core.Vertx;
    import io.vertx.redis.RedisClient;
    import io.vertx.redis.RedisOptions;
    
    public class RedisDemo1 extends AbstractVerticle {
    
        @Override
        public void start() throws Exception {
    
            // 连接Redis的参数
            RedisOptions redisOptions = new RedisOptions()
                    .setHost("127.0.0.1")
                    .setPort(6379)
                    .setAuth("");
    
            // 获取到Redis客户端
            RedisClient redisClient = RedisClient.create(vertx,redisOptions);
    
            // 执行Redis操作
            redisClient.set("hello", "world", res -> {
                if (res.succeeded()) {
                    System.out.println("保存redis成功");
                }
            });
        }
    
        public static void main(String[] args) {
            Vertx vertx = Vertx.vertx();
            vertx.deployVerticle(new RedisDemo1());
        }
    }

3.每个组件中如果需要连接Redis都需要指定连接信息，并创建RedisClient比较麻烦，重复造轮子。可以抽取出一个公共的工具类，用来读取配置文件，并创建RedisClient。

package stu.vertx.redis;
    
    import io.vertx.core.Vertx;
    import io.vertx.redis.RedisClient;
    import io.vertx.redis.RedisOptions;
    
    import java.util.Properties;
    
    public class RedisUtils {
    
        private static final RedisOptions options = new RedisOptions();
        private static final Properties config = new Properties();
    
        static {
    
            try {
                config.load(RedisUtils.class.getClassLoader().getResourceAsStream("redis.properties"));
    
                options.setHost(config.getProperty("host"))
                        .setPort(Integer.parseInt(config.getProperty("port")))
                        .setAuth(config.getProperty("auth"));
    
            } catch (Exception e) {
                e.printStackTrace();
            }
        }
    
        public static RedisClient getRedisClient(Vertx vertx) {
            RedisClient redisClient = RedisClient.create(vertx, options);
            return redisClient;
        }
    
    }

4.Redis为了防止单点故障以及为了解决单点的容量问题，提供了哨兵和集群的模式。在Vertx早期版本是不支持集群模式的，如果想要使用集群模式，需要自己来集成AbstractRedisClient来实现集群的操作，在3.8.1这个版本已经对集群提供了支持。因此要想使用哨兵或者集群，只需要在RedisOptions中进行配置就可以了。

（1）哨兵的配置如下

new io.vertx.redis.client.RedisOptions()
            .setType(RedisClientType.SENTINEL)
            .addEndpoint(SocketAddress.inetSocketAddress(5000, "127.0.0.1"))
            .addEndpoint(SocketAddress.inetSocketAddress(5001, "127.0.0.1"))
            .addEndpoint(SocketAddress.inetSocketAddress(5002, "127.0.0.1"))
            .setMasterName("sentinel7000")
            .setRole(RedisRole.MASTER);

（2）集群的配置如下

new io.vertx.redis.client.RedisOptions()
            .addEndpoint(SocketAddress.inetSocketAddress(7000, "127.0.0.1"))
            .addEndpoint(SocketAddress.inetSocketAddress(7001, "127.0.0.1"))
            .addEndpoint(SocketAddress.inetSocketAddress(7002, "127.0.0.1"))
            .addEndpoint(SocketAddress.inetSocketAddress(7003, "127.0.0.1"))
            .addEndpoint(SocketAddress.inetSocketAddress(7004, "127.0.0.1"))
            .addEndpoint(SocketAddress.inetSocketAddress(7005, "127.0.0.1"))

到这里，对于Redis的基本操作就完成了，其实Vertx对于扩展功能的封装还是非常统一的，找清楚Vertx设计规则，在使用Vertx的API时会感觉非常简单、清晰。

## 源码分析 ##