深入学习 Redis - 基于 Jedis 通过 Java 客户端操作 Redis 和 Redis 集群

╰+攻爆jí腚メ 2024-03-22 22:44 69阅读 0赞

目录

一、Jedis 依赖

二、Java 客户端操控 redis

2.1、准备工作（ssh 隧道）

2.2、概要

2.2、string

2.3、hash

2.4、list

2.5、set

2.5、zset

三、访问集群

一、Jedis 依赖

自己去 中央仓库 上面找.

二、Java 客户端操控 redis

2.1、准备工作（ssh 隧道）

想要连接上云服务器上的 redis ，就需要开放 6379 端口，但是一旦开饭这个端口是十分危险的！！！（不出 3 天，你的服务器就会被黑客攻击）

我们有两种办法

  1. 将 java 程序打包成 jar 包，放到 linux 服务器上执行（过于麻烦，不推荐）;
  2. 匹配 ssh 端口转发，把云服务器的 redis 端口，映射到本地主机（推荐）.

因此我们来讲讲第二种办法~

我们在本地 windows 主机上，使用 xshell 连接远程服务器，主要就是通过 ssh 协议（默认走 22 端口）实现通信的，他有一个很重要的特性，就是支持端口转发！ 我们只需要配置 ssh 程序监听本地端口，映射到云服务器的端口，就可以实现通过 windows 主机，访问云服务器的 6379 端口.

具体的，我们只需要再 xshell 上配置连接信息即可：

3c16e73455a348b0b0b55ad78fa251ec.png

8eab57b55ca440f6baeee66132b3115b.png

Ps：当配置了端口准发后，一定要断开之前的连接，重新连接才能生效.

2.2、概要

基于前面对 redis 指令的学习，这里使用 jedis 这个库来操控 redis。

Ps：一个优秀的库，一定是非常容易上手的，因此接下来介绍的操作，不会覆盖到所有指令，会挑选出一些重要 / 代表性的命令，来进行演示~

使用 jedis 操控 redis 类似于 JDBC ，我们可以先创建 连接池，然后拿到连接，执行完操作后再释放连接，因此后续讲的所有操作，都是基于以下代码：

  1. public static void main(String[] args) {
  2.         //这里只是开发阶段这么写，要是部署到云服务器上，就需要根据实际情况来配置这个的 ip 和端口号.
  3.         JedisPool jedisPool = new JedisPool("tcp://127.0.0.1:8888");
  4.         //使用 try，出代码块时自动释放 jedis 连接(不是关闭，而是放回到连接池中)
  5.         try(Jedis jedis = jedisPool.getResource()) {
  6.             // 测试场景：
  7.             // ......
  8.             test1(jedis);
  9.         }
  10.     }

2.2、string

  1. public class JedisString {
  3.     private static void test1(Jedis jedis) {
  4.         System.out.println("------------------------------------");
  5.         System.out.println("mget 和 mset");
  6.         //这里为了演示效果，使用之前会先释放所有 key
  7.         jedis.flushAll();
  9.         jedis.mset("key1", "value1", "key2", "value2", "key3", "value3");
  11.         List<String> values = jedis.mget("key1", "key2", "key3", "key100");
  13.         System.out.println(values);
  14.     }
  16.     private static void test2(Jedis jedis) {
  17.         System.out.println("------------------------------------");
  18.         System.out.println("getrange 和 setrange");
  19.         jedis.flushAll();
  21.         jedis.set("key", "helloworld");
  23.         String value1 = jedis.getrange("key", 2, 5);
  24.         System.out.println("value1: " + value1);
  26.         jedis.setrange("key", 2, "cykkk");
  28.         String value2 = jedis.get("key");
  29.         System.out.println("value2: " + value2);
  30.     }
  32.     private static void test3(Jedis jedis) {
  33.         System.out.println("------------------------------------");
  34.         System.out.println("append");
  35.         jedis.flushAll();
  37.         jedis.set("key1", "hello");
  38.         jedis.append("key1", " world");
  40.         String value1 = jedis.get("key1");
  41.         System.out.println("value1: " + value1);
  42.     }
  44.     private static void test4(Jedis jedis) {
  45.         System.out.println("------------------------------------");
  46.         System.out.println("incr 和 decr");
  47.         jedis.flushAll();
  49.         jedis.set("key1", "10");
  50.         jedis.incr("key1");
  51.         System.out.println("inct key1: " + jedis.get("key1"));
  53.         jedis.set("key1", "10");
  54.         jedis.decr("key1");
  55.         System.out.println("decr key2: " + jedis.get("key1"));
  56.     }
  59.     public static void main(String[] args) {
  60.         //这里只是开发阶段这么写，要是部署到云服务器上，就需要根据实际情况来配置这个的 ip 和端口号.
  61.         JedisPool jedisPool = new JedisPool("tcp://127.0.0.1:8888");
  62.         //使用 try，出代码块时自动释放 jedis 连接(不是关闭，而是放回到连接池中)
  63.         try(Jedis jedis = jedisPool.getResource()) {
  64.             // 测试场景：
  65.             // ......
  66.             test1(jedis);
  67.             test2(jedis);
  68.             test3(jedis);
  69.             test4(jedis);
  70.         }
  71.     }
  73. }

810aad9eb86141ddad35331d08152609.png

2.3、hash

  1. public class JedisHash {
  3.     private static void test1(Jedis jedis) {
  4.         System.out.println("-----------------------------------");
  5.         System.out.println("hset 和 hget");
  6.         jedis.flushAll();
  8.         jedis.hset("key1", "f1", "v1");
  9.         String result = jedis.hget("key1", "f1");
  11.         System.out.println("result: " + result);
  13.         Map<String, String> map = new HashMap<>();
  14.         map.put("f1", "v1");
  15.         map.put("f2", "v2");
  16.         map.put("f3", "v3");
  18.         jedis.hset("key2", map);
  19.         System.out.println("key2: " + jedis.hgetAll("key2"));
  21.     }
  23.     private static void test2(Jedis jedis) {
  24.         System.out.println("-----------------------------------");
  25.         System.out.println("hexists");
  26.         jedis.flushAll();
  28.         jedis.hset("key1", "f1", "v1");
  30.         boolean result1 = jedis.hexists("key1", "f1");
  31.         boolean result2 = jedis.hexists("key1", "f2");
  32.         System.out.println("result1: " + result1);
  33.         System.out.println("result2: " + result2);
  34.     }
  36.     private static void test3(Jedis jedis) {
  37.         System.out.println("-----------------------------------");
  38.         System.out.println("hdel");
  39.         jedis.flushAll();
  41.         jedis.hset("key1", "f1", "v1");
  42.         jedis.hset("key1", "f2", "v2");
  43.         jedis.hset("key1", "f3", "v3");
  45.         long result = jedis.hdel("key1", "f1");
  46.         System.out.println("result: " + result);
  48.         System.out.println("f1: " + jedis.hget("key1", "f1"));
  49.         System.out.println("f2: " + jedis.hget("key1", "f2"));
  50.         System.out.println("f3: " + jedis.hget("key1", "f3"));
  51.     }
  53.     private static void test4(Jedis jedis) {
  54.         System.out.println("-----------------------------------");
  55.         System.out.println("hkeys 和 hvals");
  56.         jedis.flushAll();
  58.         Map<String, String> map = new HashMap<>();
  59.         map.put("f1", "v1");
  60.         map.put("f2", "v2");
  61.         map.put("f3", "v3");
  63.         jedis.hmset("key1", map);
  64.         Set<String> set = jedis.hkeys("key1");
  65.         List<String> list = jedis.hvals("key1");
  66.         System.out.println("key1 -> field:" + set);
  67.         System.out.println("key2 -> value:" + list);
  68.     }
  70.     public static void main(String[] args) {
  71.         JedisPool jedisPool = new JedisPool("tcp://127.0.0.1:8888");
  72.         try(Jedis jedis = jedisPool.getResource()) {
  73.             test1(jedis);
  74.             test2(jedis);
  75.             test3(jedis);
  76.             test4(jedis);
  77.         }
  78.     }
  80. }

c692b724294944c4b0b6f86d96bd111f.png

2.4、list

  1. public class JedisList {
  3.     private static void test1(Jedis jedis) {
  4.         System.out.println("---------------------------");
  5.         System.out.println("lpush 和 lrange");
  6.         jedis.flushAll();
  8.         jedis.lpush("key1", "value1", "value2", "value3");
  9.         List<String> result = jedis.lrange("key1", 0 ,-1);
  11.         System.out.println(result);
  12.     }
  14.     private static void test2(Jedis jedis) {
  15.         System.out.println("---------------------------");
  16.         System.out.println("rpush");
  17.         jedis.flushAll();
  19.         jedis.rpush("key1", "value1", "value2", "value3");
  20.         List<String> result = jedis.lrange("key1", 0 ,-1);
  22.         System.out.println(result);
  23.     }
  26.     private static void test3(Jedis jedis) throws InterruptedException {
  27.         System.out.println("---------------------------");
  28.         System.out.println("blpop");
  29.         jedis.flushAll();
  31.         List<String> result = jedis.blpop(100, "key1");
  32.         System.out.println(result.get(0));
  33.         System.out.println(result.get(1));
  34.     }
  38.     public static void main(String[] args) throws InterruptedException {
  39.         JedisPool jedisPool = new JedisPool("tcp://127.0.0.1:8888");
  40.         try(Jedis jedis = jedisPool.getResource()) {
  41.             test1(jedis);
  42.             test2(jedis);
  43.             test3(jedis);
  44.         }
  45.     }
  47. }

0164b43709554d968743e25e2d0c6e17.png

2.5、set

  1. public class JedisSet {
  3.     private static void test1(Jedis jedis) {
  4.         System.out.println("-------------------------");
  5.         System.out.println("sadd 和 smembers");
  6.         jedis.flushAll();
  8.         jedis.sadd("key1", "m1", "m2", "m3");
  9.         Set<String> set = jedis.smembers("key1");
  11.         System.out.println(set);
  12.     }
  14.     private static void test2(Jedis jedis) {
  15.         System.out.println("-------------------------");
  16.         System.out.println("sismember");
  17.         jedis.flushAll();
  19.         jedis.sadd("key1", "m1", "m2", "m3");
  20.         boolean result1 = jedis.sismember("key1", "m2");
  21.         boolean result2 = jedis.sismember("key1", "m100");
  23.         System.out.println("result1: " + result1);
  24.         System.out.println("result2: " + result2);
  25.     }
  27.     private static void test3(Jedis jedis) {
  28.         System.out.println("-------------------------");
  29.         System.out.println("scard");
  30.         jedis.flushAll();
  32.         jedis.sadd("key1", "m1", "m1", "m3");
  33.         long result = jedis.scard("key1");
  35.         System.out.println("result: " + result);
  36.     }
  38.     private static void test4(Jedis jedis) {
  39.         System.out.println("-------------------------");
  40.         System.out.println("spop");
  41.         jedis.flushAll();
  43.         jedis.sadd("key1", "m1", "m1", "m3");
  44.         String result = jedis.spop("key1");
  46.         System.out.println("result: " + result);
  47.     }
  49.     private static void test5(Jedis jedis) {
  50.         System.out.println("-------------------------");
  51.         System.out.println("sinter");
  52.         jedis.flushAll();
  54.         jedis.sadd("key1", "m1", "m2", "m3");
  55.         jedis.sadd("key2", "m2", "m3", "m4");
  56.         Set<String> set = jedis.sinter("key1", "key2");
  58.         System.out.println(set);
  59.     }
  61.     private static void test6(Jedis jedis) {
  62.         System.out.println("-------------------------");
  63.         System.out.println("sinter");
  64.         jedis.flushAll();
  66.         jedis.sadd("key1", "m1", "m2", "m3");
  67.         jedis.sadd("key2", "m2", "m3", "m4");
  68.         long len = jedis.sinterstore("keyStore", "key1", "key2");
  70.         System.out.println("len: " + len);
  71.         System.out.println("keyStore: " + jedis.smembers("keyStore"));
  72.     }
  75.     public static void main(String[] args) {
  76.         JedisPool jedisPool = new JedisPool("tcp://127.0.0.1:8888");
  77.         try(Jedis jedis = jedisPool.getResource()) {
  78.             test1(jedis);
  79.             test2(jedis);
  80.             test3(jedis);
  81.             test4(jedis);
  82.             test5(jedis);
  83.             test6(jedis);
  84.         }
  85.     }
  87. }

e2bc0074d8174248872c1ddb7214d3eb.png

2.5、zset

  1. public class JedisZset {
  3.     private static void test1(Jedis jedis) {
  4.         System.out.println("-----------------------------");
  5.         System.out.println("zadd 和 zrange");
  6.         jedis.flushAll();
  8.         jedis.zadd("key1", 10, "aaa");
  9.         Map<String, Double> map = new HashMap<>();
  10.         map.put("bbb", 20.0);
  11.         map.put("ccc", 30.0);
  12.         jedis.zadd("key1", map);
  14.         List<String> list = jedis.zrange("key1", 0 ,-1);
  15.         System.out.println(list);
  16.     }
  18.     private static void test2(Jedis jedis) {
  19.         System.out.println("-----------------------------");
  20.         System.out.println("zcard");
  21.         jedis.flushAll();
  23.         jedis.zadd("key1", 10, "aaa");
  24.         jedis.zadd("key1", 20, "bbb");
  25.         jedis.zadd("key1", 30, "ccc");
  27.         long len = jedis.zcard("key1");
  28.         System.out.println(len);
  29.     }
  31.     private static void test3(Jedis jedis) {
  32.         System.out.println("-----------------------------");
  33.         System.out.println("zrem");
  34.         jedis.flushAll();
  36.         jedis.zadd("key1", 10, "aaa");
  37.         jedis.zadd("key1", 20, "bbb");
  38.         jedis.zadd("key1", 30, "ccc");
  40.         long count = jedis.zrem("key1", "aaa", "bbb", "xxx");
  41.         System.out.println(count);
  42.     }
  44.     private static void test4(Jedis jedis) {
  45.         System.out.println("-----------------------------");
  46.         System.out.println("zscore 和 zrank");
  47.         jedis.flushAll();
  49.         jedis.zadd("key1", 10, "aaa");
  50.         jedis.zadd("key1", 20, "bbb");
  51.         jedis.zadd("key1", 30, "ccc");
  53.         Double score = jedis.zscore("key1", "bbb");
  54.         Long rank = jedis.zrank("key1", "bbb");
  56.         System.out.println("score: " + score);
  57.         System.out.println("rank: " + rank);
  58.     }
  60.     public static void main(String[] args) {
  61.         JedisPool jedisPool = new JedisPool("tcp://127.0.0.1:8888");
  62.         try(Jedis jedis = jedisPool.getResource()) {
  63.             test1(jedis);
  64.             test2(jedis);
  65.             test3(jedis);
  66.             test4(jedis);
  67.         }
  68.     }
  70. }

6a8fd7e49798447082fe6f62e741232c.png

三、访问集群

使⽤ JedisCluster 类代替 Jedis 类即可.

需要在创建实例的时候, 把多个节点的地址, 都设置进去.

JedisCluster 提供的⽅法和 Jedis 基本⼀致，都和 Redis 命令是对应的（上面已经演示过了，这里就不过多演示了）.

  1. public class JedisClusterDemo {
  3.     public static void main(String[] args) {
  4.         Set<HostAndPort> nodes = new HashSet<>();
  5.         nodes.add(new HostAndPort("172.30.0.101", 6379));
  6.         nodes.add(new HostAndPort("172.30.0.102", 6379));
  7.         nodes.add(new HostAndPort("172.30.0.103", 6379));
  8.         nodes.add(new HostAndPort("172.30.0.104", 6379));
  9.         nodes.add(new HostAndPort("172.30.0.105", 6379));
  10.         nodes.add(new HostAndPort("172.30.0.106", 6379));
  11.         nodes.add(new HostAndPort("172.30.0.107", 6379));
  12.         nodes.add(new HostAndPort("172.30.0.108", 6379));
  13.         nodes.add(new HostAndPort("172.30.0.109", 6379));
  15.         try (JedisCluster jedisCluster = new JedisCluster(nodes)) {
  16.             jedisCluster.set("k1", "111");
  17.             String val = jedisCluster.get("k1");
  18.             System.out.println("k1: " + val);
  19.         }
  21.     }
  23. }

注意！由于此处我们的代码是需要访问整个 redis 集群, 因此不能直接在 windows 上运⾏程序了. (上述 docker 容器的 ip 都是 windows 主机上⽆法直接访问的).

需要把整个程序打成 jar 包, 上传到 Linux 中, 并通过下列⽅式运⾏.

  1. java -jar [jar包名]

fa9a1caeccfe4ddd82b33a623e90b7a8.gif

发表评论

表情：
评论列表 （有 0 条评论，69人围观）

还没有评论，来说两句吧...

相关阅读