Spring Boot Redis客户端远程操作实现过程解析

//构造一个jedis对象
Jedis jedis=new Jedis("127.0.0.1")；
//有密码的话要认证
jedis.auth("root");
//测试是否连接成功
String ping =jedis.ping();
//返回pong表示成功
System.out.println(ping);

//1.构造一个jedis连接池
JedisPool pool=new JedisPool("127.0.0.1"，6379)；
//2.从连接池中获取一个jedis连接
Jedis jedis=pool.getResource();
//3.测试是否连接成功
String ping =jedis.ping();
//返回pong表示成功
System.out.println(ping);
//4.归还连接
jedis.close();

public interface CallJedis {
  void call(Jedis jedis);
}

public class Redis {
  private JedisPool pool;
  public Redis() {
    GenericObjectPoolConfig config = new GenericObjectPoolConfig();
    //连接池最大空闲数
    config.setMaxIdle(300);
    //最大连接数
    config.setMaxTotal(1000);
    //连接最大等待时间，如果是 -1 表示没有限制
    config.setMaxWaitMillis(30000);
    //在空闲时检查有效性
    config.setTestOnBorrow(true);
    /**
     * 1. Redis 地址
     * 2. Redis 端口
     * 3. 连接超时时间
     * 4. 密码
     */
    pool = new JedisPool(config, "192.168.91.128", 6379, 30000, "root");
  }
  public void execute(CallJedis callJedis) {
    try (Jedis jedis = pool.getResource()) {
      callJedis.call(jedis);
    }
  }
}

Redis redis = new Redis();
redis.execute(jedis -> {
  System.out.println(jedis.ping());
});

//创建连接root是密码，127.0.0.1是服务端地址
   RedisClient redisClient =RedisClient.create("redis://root@127.0.0.1");
   //创建连接通道
   StatefulRedisConnection<String, String> connect = redisClient.connect();
   //获取同步调用对象
   RedisCommands<String, String> sync = connect.sync();
   //赋值
   sync.set("name", "zl");
   //取值
    String name = sync.get("name");
   //测试
    System.out.println(name);
  }