最详细Redis学习资料（源码）

package com.tong.test; import cn.hutool.bloomfilter.BitMapBloomFilter; import org.junit.After; import org.junit.Before; import org.junit.Test; import redis.clients.jedis.*; import java.util.HashSet; import java.util.List; import java.util.Set; /*** * jedis测试用例 */ public class JedisTest { Jedis jedis; /** * 初始化jedis实列 */ @Before public void init() { // 创建redis连接实列 jedis = new Jedis("192.168.66.100", 6379); } /** * string操作 */ @Test public void stringTest() { // 设置一个key // jedis.set("k1","k2"); // 获取key的值 String k1 = jedis.get("k1"); System.out.println(k1); //设置key过期时间为10 jedis.setex("k2", 10, "v2"); } /** * list操作 */ @Test public void listTest() { // 添加元素 lpush rpush jedis.lpush("list1", "v1", "v2"); jedis.rpush("list1", "v3", "v4"); // 获取所有元素 List<String> list1 = jedis.lrange("list1", 0, -1); // 遍历元素 for (String s : list1) { System.out.println(s); } } /** * set操作 */ @Test public void setTest() { // 添加元素 jedis.sadd("set1", "v1", "v2", "v2", "v2", "v3"); // 获取元素 Set<String> set1 = jedis.smembers("set1"); //遍历所有元素 for (String s : set1) { System.out.println(s); } } /** * hash操作 */ @Test public void hashTest() { // 设置hash jedis.hset("user", "age", "26"); jedis.hset("user", "name", "xiaotong"); // 获取所有key的value的值 List<String> user = jedis.hvals("user"); // 遍历所有元素s for (String s : user) { System.out.println(s); } } /** * zset操作 */ @Test public void zsetTest() { // 添加元素 jedis.zadd("zset", 100, "java"); jedis.zadd("zset", 200, "python"); jedis.zadd("zset", 300, "c++"); jedis.zadd("zset", 400, "c"); // 获取所有值 Set<String> zset = jedis.zrange("zset", 0, -1); // 遍历数据 for (String s : zset) { System.out.println(s); } } /** * bitmaps数据类型 */ @Test public void bitmapsTest() { // 给张三添加上班打卡记录 jedis.setbit("zhangsan:2", 0, "1"); jedis.setbit("zhangsan:2", 1, "1"); jedis.setbit("zhangsan:2", 2, "0"); jedis.setbit("zhangsan:2", 3, "1"); // 获取张三 第 3天上班记录 Boolean getbit = jedis.getbit("zhangsan:2", 2); // 如果是1 true 0 false System.out.println(getbit); } /** * geo操作 */ @Test public void geoTest() { // 添加地理信息 jedis.geoadd("china", 130, 30, "beijing"); // 获取地理信息 List<GeoCoordinate> geopos = jedis.geopos("china", "beijing"); // 遍历位置信息 for (GeoCoordinate geopo : geopos) { System.out.println(geopo.toString()); } } /** * hyperloglog操作 */ @Test public void hyperloglogTest() { // 添加元素 jedis.pfadd("book", "uid1", "uid3", "uid3", "uid2"); // 获取书籍数量 long bookCount = jedis.pfcount("book"); System.out.println(bookCount); } /** * 没有pipelibne * 耗时 ： 3037毫秒 */ @Test public void pipelineTest() { // 开始时间 long startTime = System.currentTimeMillis(); // 添加hash元素 for (int i = 0; i < 10000; i++) { jedis.hset("hashkey:" + i, "field" + i, "value" + i); } // 结束时间 long endTimt = System.currentTimeMillis(); System.out.println(endTimt - startTime); } /** * pipeline * 耗时： 83毫秒 */ @Test public void pepeline() { // 开始时间 long startTime = System.currentTimeMillis(); for (int i = 0; i < 100; i++) { Pipeline pipelined = jedis.pipelined(); for (int j = i * 100; j < (i + 1) * 100; j++) { pipelined.hset("hashkey:" + j, "field" + j, "value" + j); } pipelined.syncAndReturnAll(); } // 结束时间 long endTimt = System.currentTimeMillis(); System.out.println(endTimt - startTime); } @Test public void clusterTest() { //构建set集合保存redis node Set<HostAndPort> redisNodes = new HashSet<>(); redisNodes.add(new HostAndPort("192.168.66.101", 8001)); redisNodes.add(new HostAndPort("192.168.66.102", 8001)); redisNodes.add(new HostAndPort("192.168.66.103", 8001)); redisNodes.add(new HostAndPort("192.168.66.101", 8002)); redisNodes.add(new HostAndPort("192.168.66.102", 8002)); redisNodes.add(new HostAndPort("192.168.66.103", 8002)); // 构建Jediscluster 建立连接 JedisCluster jedisCluster = new JedisCluster(redisNodes); // 添加元素 String name = jedisCluster.get("name"); System.out.println(name); } @After public void close() { //关闭jedis连接 jedis.close(); } /** * 布隆过滤器 */ @Test public void FileterTest() { // 初始化 BitMapBloomFilter bitMapBloomFilter = new BitMapBloomFilter(10); // 添加元素 bitMapBloomFilter.add("abc"); bitMapBloomFilter.add("123"); bitMapBloomFilter.add("qwe"); bitMapBloomFilter.add("xiaotong"); System.out.println(bitMapBloomFilter.contains("abc")); } /** * 互斥锁解决缓存击穿 * * @param key 商品key */ @Test public void lock(String key) throws InterruptedException { // 获取key的值 String value = jedis.get(key); // 判断缓存是否过期 if (value == null) { // 设置3分钟超时。只有key不存在的时候才能创建 Long setnx = jedis.setnx(key + "_mutex", "1"); // 设置过期实践 jedis.pexpire(key + "_mutex", 3 * 60); // 设置成功 if (setnx == 1) { // DB操作 数据库操作 value = "db"; //保存缓存 jedis.setex(key, 3 * 60, value); jedis.del(key + "_mutex"); } else { Thread.sleep(5000); lock(key); } } } /** * 通过加锁 解决缓存雪崩 * * @param key 商品key */ public Object saveLock(String key) { // 加锁key String lockKey = key; // 获取key的值 String value = jedis.get(key); // 判断是否过期 if (value == null) { synchronized (lockKey) { // 获取key的value的值 String s = jedis.get(key); if (s != null) { return s; } else { // DB 一般这里就是sql查询 value = "value"; jedis.set(key, value); } } } return lockKey; } }