springboot整合redis集群（三种方式）源码

package com.yang.rediscluster.demo; import io.lettuce.core.RedisClient; import io.lettuce.core.RedisURI; import io.lettuce.core.SortArgs; import io.lettuce.core.api.StatefulRedisConnection; import io.lettuce.core.api.sync.RedisCommands; import java.util.HashMap; import java.util.List; import java.util.Map; import java.util.Set; public class lettuceDemo { public static void main(String[] args) { //使用构建器链式编程来builder我们redisURI RedisURI uri = RedisURI.builder().redis("192.168.10.129") .withPort(6382) .withAuthentication("default", "123456") .build(); //创建连接客户端 RedisClient redisClient = RedisClient.create(uri); StatefulRedisConnection<String, String> conn = redisClient.connect(); //通过conn创建操作的command RedisCommands<String, String> commands = conn.sync(); //===========biz============== // keys List<String> keys = commands.keys("*"); System.out.println(keys); // string commands.set("k5","hello-lettuce"); System.out.println(commands.get("k5")); // list commands.lpush("myList2","v1","v2","v3"); List<String> myList2 = commands.lrange("myList2", 0, -1); for (String s : myList2) { System.out.println(s); } //set commands.sadd("mySet2", "v1", "v2", "v3"); Set<String> mySet2 = commands.smembers("mySet2"); for (String s : mySet2) { System.out.println(s); } //hash HashMap<String, String> map = new HashMap<>(); map.put("telphone", "123456123"); map.put("address", "zhongshan"); map.put("email", "1233456@qq.com"); commands.hmset("myHash2", map); Map<String, String> retMap = commands.hgetall("myHash2"); for (String k : retMap.keySet()) { System.out.println("k=" + k + "===============" + "v=" + retMap.get(k)); } // zset commands.zadd("myZset2", 100.0, "s1", 200.0, "s2", 90.0, "s3"); List<String> myZset2 = commands.zrange("myZset2", 0, 10); for (String s : myZset2) { System.out.println(s); } //sort SortArgs sortArgs = new SortArgs(); sortArgs.alpha(); sortArgs.desc(); List<String> myList3 = commands.sort("myList3", sortArgs); for (String s : myList3) { System.out.println(s); } //===========biz============== //各种关闭释放资源 conn.close(); redisClient.shutdown(); } }