Redis：学习笔记-02
该部分内容，参考了 bilibili 上讲解 Redis 中，观看数最多的课程 Redis最新超详细版教程通俗易懂，来自 UP主 遇见狂神说
4. 事物
Redis 事务本质：一组命令的集合；一个事务中的所有命令都会被序列化，在事务执行的过程中，会按照顺序执行。
一次性、顺序性、排他性的执行一系列命令。
------ 队列 set set set 执行------
Redis 事务没有没有隔离级别的概念。
所有的命令在事务中，并没有直接被执行，只有发起执行命令 exec 的时候才会执行。
Redis单条命令式保存原子性的，但是事务不保证原子性
redis的事务：
- 开启事务（multi）
- 命令入队（......）
- 执行事务（exec）
4.1 正常执行事物
127.0.0.1:6379> multi # 开启事务
OK
127.0.0.1:6379> set k1 v1
QUEUED
127.0.0.1:6379> set k2 v2
QUEUED
127.0.0.1:6379> get k1
QUEUED
127.0.0.1:6379> set k3 v3
QUEUED
127.0.0.1:6379> exec # 执行事务
1) OK
2) OK
3) "v1"
4) OK
4.2 放弃事物
127.0.0.1:6379> multi # 开启事务
OK
127.0.0.1:6379> set k1 v1
QUEUED
127.0.0.1:6379> set k2 v2
QUEUED
127.0.0.1:6379> set k4 v4
QUEUED
127.0.0.1:6379> discard # 取消事务
OK
127.0.0.1:6379> get k4 # 事务队列中命令都不会被执行
(nil)
4.3 编译型异常
编译型异常（代码有问题，命令有错） ，事务中所有的命令都不会被执行
127.0.0.1:6379> multi
OK
127.0.0.1:6379> set k1 v1
QUEUED
127.0.0.1:6379> set k2 v2
QUEUED
127.0.0.1:6379> set k3 v3
QUEUED
127.0.0.1:6379> getset k3 # 错误的命令
(error) ERR wrong number of arguments for 'getset' command
127.0.0.1:6379> set k4 v4
QUEUED
127.0.0.1:6379> exec # 执行事务报错
(error) EXECABORT Transaction discarded because of previous errors.
127.0.0.1:6379> get k4 # 所有的命令都不会被执行
(nil)
4.4 运行时异常
运行时异常（如：1/0）， 如果事务队列中存在语法性，那么执行命令的时候，其他命令是可以正常执行的，错误命令抛出异常。
127.0.0.1:6379> get k1
"v1"
127.0.0.1:6379> multi
OK
127.0.0.1:6379> incr k1 # 会执行的时候失败
QUEUED
127.0.0.1:6379> set k4 v4
QUEUED
127.0.0.1:6379> get k4
QUEUED
127.0.0.1:6379> exec
1) (error) ERR value is not an integer or out of range # 虽然第一条命令报错了，但是依旧正常执行成功了
2) OK
3) "v4"
4.5 监控
悲观锁：很悲观，认为什么时候都会出问题，无论做什么都会加锁
乐观锁：很乐观，认为什么时候都不会出问题，所以不会上锁；更新数据的时候去判断一下，在此期间是否有人修改过这个数据，获取version更新的时候比较 version
示例：
- 正常执行成功
127.0.0.1:6379> set money 100
OK
127.0.0.1:6379> set out 0
OK
127.0.0.1:6379> watch money # 监视 money 对象
OK
127.0.0.1:6379> multi # 事务正常结束，数据期间没有发生变动，这个时候就正常执行成功
OK
127.0.0.1:6379> decrby money 20
QUEUED
127.0.0.1:6379> incrby out 20
QUEUED
127.0.0.1:6379> exec
1) (integer) 80
2) (integer) 20
测试多线程修改值 , 使用watch 可以当做Redis的乐观锁操作
127.0.0.1:6379> watch money # 监视 money
OK
127.0.0.1:6379> multi
OK
127.0.0.1:6379> decrby money 50
QUEUED
127.0.0.1:6379> incrby out 50
QUEUED
# -----
# 此时打开另一个client对money进行修改：set money 1000
# -----
127.0.0.1:6379> exec # 执行之前，另外一个线程，修改了我们的值，这个时候，就会导致事务执行失败
(nil)
127.0.0.1:6379> get money # 可以看到上方事物执行失败，而money的值已经在另一个线程中被修改了
"1000"
如果修改失败，获取最新的值就好
127.0.0.1:6379> unwatch # 如果发现事物执行失败，就先解锁
OK
127.0.0.1:6379> watch money # 获取最新的值，再次监视
OK
127.0.0.1:6379> multi
OK
127.0.0.1:6379> decrby money 50
QUEUED
127.0.0.1:6379> incrby out 50
QUEUED
127.0.0.1:6379> exec # 比对监视的值是否发生了变化，若没有变化，则执行成功，如果变化则执行失败
1) (integer) 950
2) (integer) 70
5. Jedis
5.1 连接测试
我们要使用 Java 来操作 Redis
Jedis 是 Redis 官方推荐的 Java 连接开发工具，使用 Java 操作 Redis 中间件，如果你要使用 Java 操作Redis，那么一定要对 Jedis 十分的熟悉
-
创建Maven项目并导入相关依赖：
<dependencies>
<dependency>
<groupId>redis.clients</groupId>
<artifactId>jedis</artifactId>
<version>3.2.0</version>
</dependency> <dependency>
<groupId>com.alibaba</groupId>
<artifactId>fastjson</artifactId>
<version>1.2.62</version>
</dependency> <dependency>
<groupId>junit</groupId>
<artifactId>junit</artifactId>
<version>4.12</version>
</dependency>
</dependencies> -
编码测试：
- 连接数据库
- 操作命令
- 断开连接
@Test
public void test(){
// new Jedis 对象即可
Jedis jedis = new Jedis("127.0.0.1", 6379);
System.out.println(jedis.ping());
}输出：
PONG
5.2 常用API
key测试：
@Test
public void testKey(){
Jedis jedis = new Jedis("127.0.0.1", 6379);
System.out.println("清空数据："+jedis.flushDB()); // OK
System.out.println("判断某个键是否存在："+jedis.exists("username")); // false
System.out.println("新增<'username','kuangshen'>的键值对："+jedis.set("username", "kuangshen")); // OK
System.out.println("新增<'password','password'>的键值对："+jedis.set("password", "password")); // OK
System.out.print("系统中所有的键如下：");
Set<String> keys = jedis.keys("*");
System.out.println(keys); // [password, username]
System.out.println("删除键password:"+jedis.del("password")); // 1
System.out.println("判断键password是否存在："+jedis.exists("password")); // false
System.out.println("查看键username所存储的值的类型："+jedis.type("username")); // string
System.out.println("随机返回key空间的一个："+jedis.randomKey()); // username
System.out.println("重命名key："+jedis.rename("username","name")); // OK
System.out.println("取出改后的name："+jedis.get("name")); // kuangshen
System.out.println("按索引查询："+jedis.select(0)); // OK
System.out.println("删除当前选择数据库中的所有key："+jedis.flushDB()); // OK
System.out.println("返回当前数据库中key的数目："+jedis.dbSize()); // 0
System.out.println("删除所有数据库中的所有key："+jedis.flushAll()); // OK
}
String测试：
@Test
public void testString(){
Jedis jedis = new Jedis("127.0.0.1", 6379);
jedis.flushDB();
System.out.println("===========增加数据===========");
System.out.println(jedis.set("key1","value1")); // OK
System.out.println(jedis.set("key2","value2")); // OK
System.out.println(jedis.set("key3", "value3")); // OK
System.out.println("删除键key2:"+jedis.del("key2")); // 1
System.out.println("获取键key2:"+jedis.get("key2")); // null
System.out.println("修改key1:"+jedis.set("key1", "value1Changed")); // ok
System.out.println("获取key1的值："+jedis.get("key1")); // value1Changed
System.out.println("在key3后面加入值："+jedis.append("key3", "End")); // 9
System.out.println("key3的值："+jedis.get("key3")); // value3End
System.out.println("增加多个键值对："+jedis.mset("key01","value01","key02","value02","key03","value03")); // OK
System.out.println("获取多个键值对："+jedis.mget("key01","key02","key03")); // [value01, value02, value03]
System.out.println("获取多个键值对："+jedis.mget("key01","key02","key03","key04")); // [value01, value02, value03, null]
System.out.println("删除多个键值对："+jedis.del("key01","key02")); // 2
System.out.println("获取多个键值对："+jedis.mget("key01","key02","key03")); // [null, null, value03]
jedis.flushDB();
System.out.println("===========新增键值对防止覆盖原先值==============");
System.out.println(jedis.setnx("key1", "value1")); // 1
System.out.println(jedis.setnx("key2", "value2")); // 1
System.out.println(jedis.setnx("key2", "value2-new")); // 0
System.out.println(jedis.get("key1")); // value1
System.out.println(jedis.get("key2")); // value2
System.out.println("===========新增键值对并设置有效时间=============");
System.out.println(jedis.setex("key3", 2, "value3")); // OK
System.out.println(jedis.get("key3")); // value3
try {
TimeUnit.SECONDS.sleep(3);
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println(jedis.get("key3")); // null
System.out.println("===========获取原值，更新为新值==========");
System.out.println(jedis.getSet("key2", "key2GetSet")); // value2
System.out.println(jedis.get("key2")); // key2GetSet
System.out.println("获得key2的值的字串："+jedis.getrange("key2", 2, 4)); // y2G
}
List测试：
@Test
public void testList(){
Jedis jedis = new Jedis("127.0.0.1", 6379);
jedis.flushDB();
System.out.println("===========添加一个list===========");
jedis.lpush("collections", "ArrayList", "Vector", "Stack", "HashMap", "WeakHashMap", "LinkedHashMap");
jedis.lpush("collections", "HashSet");
jedis.lpush("collections", "TreeSet");
jedis.lpush("collections", "TreeMap");
System.out.println("collections的内容："+jedis.lrange("collections", 0, -1));//-1代表倒数第一个元素，-2代表倒数第二个元素,end为-1表示查询全部
// 输出：[TreeMap, TreeSet, HashSet, LinkedHashMap, WeakHashMap, HashMap, Stack, Vector, ArrayList]
System.out.println("collections区间0-3的元素："+jedis.lrange("collections",0,3)); // [TreeMap, TreeSet, HashSet, LinkedHashMap]
System.out.println("===============================");
// 删除列表指定的值 ，第二个参数为删除的个数（有重复时），后add进去的值先被删，类似于出栈
System.out.println("删除指定元素个数："+jedis.lrem("collections", 2, "HashMap")); // 1
System.out.println("collections的内容："+jedis.lrange("collections", 0, -1)); // [TreeMap, TreeSet, HashSet, LinkedHashMap, WeakHashMap, Stack, Vector, ArrayList]
System.out.println("删除下表0-3区间之外的元素："+jedis.ltrim("collections", 0, 3)); // OK
System.out.println("collections的内容："+jedis.lrange("collections", 0, -1)); // [TreeMap, TreeSet, HashSet, LinkedHashMap]
System.out.println("collections列表出栈（左端）："+jedis.lpop("collections")); // TreeMap
System.out.println("collections的内容："+jedis.lrange("collections", 0, -1)); // [TreeSet, HashSet, LinkedHashMap]
System.out.println("collections添加元素，从列表右端，与lpush相对应："+jedis.rpush("collections", "EnumMap")); // 4
System.out.println("collections的内容："+jedis.lrange("collections", 0, -1)); // [TreeSet, HashSet, LinkedHashMap, EnumMap]
System.out.println("collections列表出栈（右端）："+jedis.rpop("collections")); // EnumMap
System.out.println("collections的内容："+jedis.lrange("collections", 0, -1)); // [TreeSet, HashSet, LinkedHashMap]
System.out.println("修改collections指定下标1的内容："+jedis.lset("collections", 1, "LinkedArrayList")); // OK
System.out.println("collections的内容："+jedis.lrange("collections", 0, -1)); // [TreeSet, LinkedArrayList, LinkedHashMap]
System.out.println("===============================");
System.out.println("collections的长度："+jedis.llen("collections")); // 3
System.out.println("获取collections下标为2的元素："+jedis.lindex("collections", 2)); // LinkedHashMap
System.out.println("===============================");
jedis.lpush("sortedList", "3","6","2","0","7","4");
System.out.println("sortedList排序前："+jedis.lrange("sortedList", 0, -1)); // [4, 7, 0, 2, 6, 3]
System.out.println(jedis.sort("sortedList")); // [0, 2, 3, 4, 6, 7]
System.out.println("sortedList排序后："+jedis.lrange("sortedList", 0, -1)); // [4, 7, 0, 2, 6, 3]
}
set测试：
@Test
public void testSet(){
Jedis jedis = new Jedis("127.0.0.1", 6379);
jedis.flushDB();
System.out.println("============向集合中添加元素（不重复）============");
System.out.println(jedis.sadd("eleSet", "e1","e2","e4","e3","e0","e8","e7","e5")); // 8
System.out.println(jedis.sadd("eleSet", "e6")); // 1
System.out.println(jedis.sadd("eleSet", "e6")); // 0
System.out.println("eleSet的所有元素为："+jedis.smembers("eleSet")); // [e4, e2, e0, e5, e3, e8, e1, e7, e6]
System.out.println("删除一个元素e0："+jedis.srem("eleSet", "e0")); // 1
System.out.println("eleSet的所有元素为："+jedis.smembers("eleSet")); // [e2, e5, e3, e8, e1, e7, e6, e4]
System.out.println("删除两个元素e7和e6："+jedis.srem("eleSet", "e7","e6")); // 2
System.out.println("eleSet的所有元素为："+jedis.smembers("eleSet")); // [e3, e8, e1, e4, e2, e5]
System.out.println("随机的移除集合中的一个元素："+jedis.spop("eleSet")); // e4
System.out.println("随机的移除集合中的一个元素："+jedis.spop("eleSet")); // e2
System.out.println("eleSet的所有元素为："+jedis.smembers("eleSet")); // [e8, e1, e5, e3]
System.out.println("eleSet中包含元素的个数："+jedis.scard("eleSet")); // 4
System.out.println("e3是否在eleSet中："+jedis.sismember("eleSet", "e3")); // true
System.out.println("e1是否在eleSet中："+jedis.sismember("eleSet", "e1")); // true
System.out.println("e1是否在eleSet中："+jedis.sismember("eleSet", "e5")); // true
System.out.println("=================================");
System.out.println(jedis.sadd("eleSet1", "e1","e2","e4","e3","e0","e8","e7","e5")); // 8
System.out.println(jedis.sadd("eleSet2", "e1","e2","e4","e3","e0","e8")); // 6
System.out.println("将eleSet1中删除e1并存入eleSet3中："+jedis.smove("eleSet1", "eleSet3", "e1")); //移到集合元素:1
System.out.println("将eleSet1中删除e2并存入eleSet3中："+jedis.smove("eleSet1", "eleSet3", "e2")); // 1
System.out.println("eleSet1中的元素："+jedis.smembers("eleSet1")); // [e7, e8, e4, e0, e5, e3]
System.out.println("eleSet3中的元素："+jedis.smembers("eleSet3")); // [e2, e1]
System.out.println("============集合运算=================");
System.out.println("eleSet1中的元素："+jedis.smembers("eleSet1")); // [e7, e8, e4, e0, e5, e3]
System.out.println("eleSet2中的元素："+jedis.smembers("eleSet2")); // [e2, e3, e1, e8, e4, e0]
System.out.println("eleSet1和eleSet2的交集:"+jedis.sinter("eleSet1","eleSet2")); // [e3, e8, e4, e0]
System.out.println("eleSet1和eleSet2的并集:"+jedis.sunion("eleSet1","eleSet2")); // [e2, e0, e5, e3, e8, e1, e7, e4]
System.out.println("eleSet1和eleSet2的差集:"+jedis.sdiff("eleSet1","eleSet2")); // [e5, e7]
jedis.sinterstore("eleSet4","eleSet1","eleSet2"); // 求交集并将交集保存到dstkey的集合
System.out.println("eleSet4中的元素："+jedis.smembers("eleSet4")); // [e4, e0, e3, e8]
}
hash测试：
@Test
public void testHash(){
Jedis jedis = new Jedis("127.0.0.1", 6379);
jedis.flushDB();
Map<String,String> map = new HashMap<String,String>();
map.put("key1","value1");
map.put("key2","value2");
map.put("key3","value3");
map.put("key4","value4");
// 添加名称为hash（key）的hash元素
jedis.hmset("hash",map);
// 向名称为hash的hash中添加key为key5，value为value5元素
jedis.hset("hash", "key5", "value5");
System.out.println("散列hash的所有键值对为："+jedis.hgetAll("hash"));// {key1=value1, key2=value2, key5=value5, key3=value3, key4=value4}
System.out.println("散列hash的所有键为："+jedis.hkeys("hash"));// [key1, key2, key5, key3, key4]
System.out.println("散列hash的所有值为："+jedis.hvals("hash"));// [value3, value1, value2, value4, value5]
System.out.println("将key6保存的值加上一个整数，如果key6不存在则添加key6："+jedis.hincrBy("hash", "key6", 6)); // 6
System.out.println("散列hash的所有键值对为："+jedis.hgetAll("hash")); // {key1=value1, key2=value2, key5=value5, key6=6, key3=value3, key4=value4}
System.out.println("将key6保存的值加上一个整数，如果key6不存在则添加key6："+jedis.hincrBy("hash", "key6", 3)); // 9
System.out.println("散列hash的所有键值对为："+jedis.hgetAll("hash")); // {key1=value1, key2=value2, key5=value5, key6=9, key3=value3, key4=value4}
System.out.println("删除一个或者多个键值对："+jedis.hdel("hash", "key2")); // 1
System.out.println("散列hash的所有键值对为："+jedis.hgetAll("hash")); // {key1=value1, key5=value5, key6=9, key3=value3, key4=value4}
System.out.println("散列hash中键值对的个数："+jedis.hlen("hash")); // 5
System.out.println("判断hash中是否存在key2："+jedis.hexists("hash","key2")); // false
System.out.println("判断hash中是否存在key3："+jedis.hexists("hash","key3")); // true
System.out.println("获取hash中的值："+jedis.hmget("hash","key3")); // [value3]
System.out.println("获取hash中的值："+jedis.hmget("hash","key3","key4")); // [value3, value4]
}
5.3 事物操作
@Test
public void test(){
Jedis jedis = new Jedis("127.0.0.1", 6379);
jedis.flushDB();
JSONObject jsonObject = new JSONObject();
jsonObject.put("hello", "world");
jsonObject.put("hi", "redis");
// 开启事务
Transaction multi = jedis.multi();
String result = jsonObject.toJSONString();
try {
multi.set("user1", result);
multi.set("user2", result);
int i = 1/0; // 代码抛出异常事务，执行失败
multi.exec(); // 执行事务
}catch (Exception e){
multi.discard(); // 放弃事务
e.printStackTrace();
}finally {
System.out.println(jedis.get("user1"));
System.out.println(jedis.get("user2"));
jedis.close(); // 关闭连接
}
}
- 当未出现异常时，输出：
{"hi":"redis","hello":"world"}
{"hi":"redis","hello":"world"}
- 当出现异常时，输出：
java.lang.ArithmeticException: / by zero
at cn.xyc.JedisTx.test(JedisTx.java:26)
null
null
6. SpringBoot 整合
6.1 概述
SpringBoot 操作数据：spring-data：jpa、jdbc、mongodb、Redis
SpringData 也是和 SpringBoot 齐名的项目
说明： 在 SpringBoot2.x 之后，原来使用的 jedis 被替换为了 lettuce
jedis : 采用的直连，多个线程操作的话，是不安全的，如果想要避免不安全的，使用 jedis pool 连接池，更像 BIO 模式
lettuce : 采用 netty，实例可以在多个线程中进行共享，不存在线程不安全的情况，可以减少线程数据了，更像 NIO 模式
通过 springboot 对 redis 进行整合：
- 导入依赖：
<!-- 操作redis -->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-redis</artifactId>
</dependency>
- 连接配置
# 配置redis：其实都是默认的
spring.redis.host=127.0.0.1
spring.redis.port=6379
- 测试
@SpringBootTest
public class SpringbootRedisApplicattionTests {
@Autowired
// private RedisTemplate<String, String> redisTemplate;
private RedisTemplate redisTemplate;
@Test
void contextLoads(){
// redisTemplate 操作不同的数据类型，api和我们的指令是一样的
// opsForValue 操作字符串 类似String
// opsForList 操作List 类似List
// opsForSet 操作Set
// opsForHash 操作Hash
// opsForZSet 操作zset
// opsForGeo 操作geospatial
// opsForHyperLogLog 操作HyperLogLog
redisTemplate.opsForValue().set("name", "zhangsan");
System.out.println(redisTemplate.opsForValue().get("name"));
}
@Test
void test(){
// 除了基本的操作，我们常用的方法都可以直接通过redisTemplate操作，比如事务，和基本的CRUD
RedisConnection connection = redisTemplate.getConnectionFactory().getConnection();
connection.flushDb();
connection.close();
}
}
6.2 源码分析
也是通过 RedisAutoConfiguration 进行了自动配置
@Configuration(proxyBeanMethods = false)
@ConditionalOnClass(RedisOperations.class)
// 在RedisProperties.class中定义的相关的属性
@EnableConfigurationProperties(RedisProperties.class)
@Import({ LettuceConnectionConfiguration.class, JedisConnectionConfiguration.class })
public class RedisAutoConfiguration {
@Bean
@ConditionalOnMissingBean(name = "redisTemplate") // 通过自己定义redisTemplate可以覆盖该类的创建
public RedisTemplate<Object, Object> redisTemplate(RedisConnectionFactory redisConnectionFactory)
throws UnknownHostException {
// 默认的 RedisTemplate 没有过多的设置，redis 对象都是需要序列化
// 两个泛型都是 Object, Object 的类型，我们使用需要强制转换 <String, Object>
RedisTemplate<Object, Object> template = new RedisTemplate<>();
template.setConnectionFactory(redisConnectionFactory);
return template;
}
@Bean
@ConditionalOnMissingBean
// 由于 String 是redis中最常使用的类型，所以说单独提出来了一个bean
public StringRedisTemplate stringRedisTemplate(RedisConnectionFactory redisConnectionFactory)
throws UnknownHostException {
StringRedisTemplate template = new StringRedisTemplate();
template.setConnectionFactory(redisConnectionFactory);
return template;
}
}
查看RedisTemplate类：
public class RedisTemplate<K, V> extends RedisAccessor implements RedisOperations<K, V>, BeanClassLoaderAware {
private boolean enableTransactionSupport = false;
private boolean exposeConnection = false;
private boolean initialized = false;
private boolean enableDefaultSerializer = true;
private @Nullable RedisSerializer<?> defaultSerializer;
private @Nullable ClassLoader classLoader;
// 有关序列化的配置
@SuppressWarnings("rawtypes") private @Nullable RedisSerializer keySerializer = null;
@SuppressWarnings("rawtypes") private @Nullable RedisSerializer valueSerializer = null;
@SuppressWarnings("rawtypes") private @Nullable RedisSerializer hashKeySerializer = null;
@SuppressWarnings("rawtypes") private @Nullable RedisSerializer hashValueSerializer = null;
private RedisSerializer<String> stringSerializer = RedisSerializer.string();
@Override
public void afterPropertiesSet() {
super.afterPropertiesSet();
boolean defaultUsed = false;
if (defaultSerializer == null) {
// 默认的序列化方式就是使用jdk序列化
defaultSerializer = new JdkSerializationRedisSerializer(
classLoader != null ? classLoader : this.getClass().getClassLoader());
}
if (enableDefaultSerializer) {
if (keySerializer == null) {
keySerializer = defaultSerializer;
defaultUsed = true;
}
if (valueSerializer == null) {
valueSerializer = defaultSerializer;
defaultUsed = true;
}
if (hashKeySerializer == null) {
hashKeySerializer = defaultSerializer;
defaultUsed = true;
}
if (hashValueSerializer == null) {
hashValueSerializer = defaultSerializer;
defaultUsed = true;
}
}
if (enableDefaultSerializer && defaultUsed) {
Assert.notNull(defaultSerializer, "default serializer null and not all serializers initialized");
}
if (scriptExecutor == null) {
this.scriptExecutor = new DefaultScriptExecutor<>(this);
}
initialized = true;
}
}
使用默认的JDK编码方式进行对象的保存：
创建对象：
public class User implements Serializable{ // 想要保存对象必须实现Serializable接口
private String name;
private Integer age;
}
@Test
void testJdkSerializer(){
User user = new User("zhangsan", 18);
redisTemplate.opsForValue().set("user", user);
System.out.println(redisTemplate.opsForValue().get("user"));
}
输出：
控制台输出：User{name='zhangsan', age=18}
通过redis命令控制终端查询：
127.0.0.1:6379> keys *
1) "\xac\xed\x00\x05t\x00\x04user"
127.0.0.1:6379> get "\xac\xed\x00\x05t\x00\x04user"
"\xac\xed\x00\x05sr\x00\"cn.xyc.springbootredis.domain.User\xaak\x8a\xca\xa1\a\xf1\n\x02\x00\x02L\x00\x03aget\x00\x13Ljava/lang/Integer;L\x00\x04namet\x00\x12Ljava/lang/String;xpsr\x00\x11java.lang.Integer\x12\xe2\xa0\xa4\xf7\x81\x878\x02\x00\x01I\x00\x05valuexr\x00\x10java.lang.Number\x86\xac\x95\x1d\x0b\x94\xe0\x8b\x02\x00\x00xp\x00\x00\x00\x12t\x00\bzhangsan"
通过自定义一个 RedisTemplete，使用 json 的方式进行序列化对象
@Configuration
public class RedisConfig {
@Bean
@SuppressWarnings("all")
public RedisTemplate<String, Object> redisTemplate(RedisConnectionFactory factory){
// 我们为了自己开发方便，一般直接使用 <String, Object>
RedisTemplate<String, Object> template = new RedisTemplate<>();
template.setConnectionFactory(factory);
// Json序列化配置
Jackson2JsonRedisSerializer jackson2JsonRedisSerializer = new Jackson2JsonRedisSerializer(Object.class);
ObjectMapper objectMapper = new ObjectMapper();
objectMapper.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);
objectMapper.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL);
jackson2JsonRedisSerializer.setObjectMapper(objectMapper);
// String 的序列化
StringRedisSerializer stringRedisSerializer = new StringRedisSerializer();
// key采用String的序列化方式
template.setKeySerializer(stringRedisSerializer);
// hash的key也采用String的序列化方式
template.setHashKeySerializer(stringRedisSerializer);
// value序列化方式采用jackson
template.setValueSerializer(jackson2JsonRedisSerializer);
// hash的value序列化方式采用jackson
template.setHashValueSerializer(jackson2JsonRedisSerializer);
template.afterPropertiesSet();
return template;
}
}
输出：
控制台输出：User{name='zhangsan', age=18}
通过redis命令控制终端查询：
127.0.0.1:6379> get user
"[\"cn.xyc.springbootredis.domain.User\",{\"name\":\"zhangsan\",\"age\":18}]"
自定义工具类操作Redis：
package cn.xyc.springbootredis.utils; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.stereotype.Component;
import org.springframework.util.CollectionUtils; import java.util.List;
import java.util.Map;
import java.util.Set;
import java.util.concurrent.TimeUnit; @Component
public final class RedisUtil { @Autowired
private RedisTemplate<String, Object> redisTemplate; // =============================common============================
/**
* 指定缓存失效时间
* @param key 键
* @param time 时间(秒)
*/
public boolean expire(String key, long time) {
try {
if (time > 0) {
redisTemplate.expire(key, time, TimeUnit.SECONDS);
}
return true;
} catch (Exception e) {
e.printStackTrace();
return false;
}
} /**
* 根据key 获取过期时间
* @param key 键 不能为null
* @return 时间(秒) 返回0代表为永久有效
*/
public long getExpire(String key) {
return redisTemplate.getExpire(key, TimeUnit.SECONDS);
} /**
* 判断key是否存在
* @param key 键
* @return true 存在 false不存在
*/
public boolean hasKey(String key) {
try {
return redisTemplate.hasKey(key);
} catch (Exception e) {
e.printStackTrace();
return false;
}
} /**
* 删除缓存
* @param key 可以传一个值 或多个
*/
@SuppressWarnings("unchecked")
public void del(String... key) {
if (key != null && key.length > 0) {
if (key.length == 1) {
redisTemplate.delete(key[0]);
} else {
redisTemplate.delete(CollectionUtils.arrayToList(key));
}
}
} // ============================String============================= /**
* 普通缓存获取
* @param key 键
* @return 值
*/
public Object get(String key) {
return key == null ? null : redisTemplate.opsForValue().get(key);
} /**
* 普通缓存放入
* @param key 键
* @param value 值
* @return true成功 false失败
*/ public boolean set(String key, Object value) {
try {
redisTemplate.opsForValue().set(key, value);
return true;
} catch (Exception e) {
e.printStackTrace();
return false;
}
} /**
* 普通缓存放入并设置时间
* @param key 键
* @param value 值
* @param time 时间(秒) time要大于0 如果time小于等于0 将设置无限期
* @return true成功 false 失败
*/ public boolean set(String key, Object value, long time) {
try {
if (time > 0) {
redisTemplate.opsForValue().set(key, value, time, TimeUnit.SECONDS);
} else {
set(key, value);
}
return true;
} catch (Exception e) {
e.printStackTrace();
return false;
}
} /**
* 递增
* @param key 键
* @param delta 要增加几(大于0)
*/
public long incr(String key, long delta) {
if (delta < 0) {
throw new RuntimeException("递增因子必须大于0");
}
return redisTemplate.opsForValue().increment(key, delta);
} /**
* 递减
* @param key 键
* @param delta 要减少几(小于0)
*/
public long decr(String key, long delta) {
if (delta < 0) {
throw new RuntimeException("递减因子必须大于0");
}
return redisTemplate.opsForValue().increment(key, -delta);
} // ================================Map================================= /**
* HashGet
* @param key 键 不能为null
* @param item 项 不能为null
*/
public Object hget(String key, String item) {
return redisTemplate.opsForHash().get(key, item);
} /**
* 获取hashKey对应的所有键值
* @param key 键
* @return 对应的多个键值
*/
public Map<Object, Object> hmget(String key) {
return redisTemplate.opsForHash().entries(key);
} /**
* HashSet
* @param key 键
* @param map 对应多个键值
*/
public boolean hmset(String key, Map<String, Object> map) {
try {
redisTemplate.opsForHash().putAll(key, map);
return true;
} catch (Exception e) {
e.printStackTrace();
return false;
}
} /**
* HashSet 并设置时间
* @param key 键
* @param map 对应多个键值
* @param time 时间(秒)
* @return true成功 false失败
*/
public boolean hmset(String key, Map<String, Object> map, long time) {
try {
redisTemplate.opsForHash().putAll(key, map);
if (time > 0) {
expire(key, time);
}
return true;
} catch (Exception e) {
e.printStackTrace();
return false;
}
} /**
* 向一张hash表中放入数据,如果不存在将创建
*
* @param key 键
* @param item 项
* @param value 值
* @return true 成功 false失败
*/
public boolean hset(String key, String item, Object value) {
try {
redisTemplate.opsForHash().put(key, item, value);
return true;
} catch (Exception e) {
e.printStackTrace();
return false;
}
} /**
* 向一张hash表中放入数据,如果不存在将创建
*
* @param key 键
* @param item 项
* @param value 值
* @param time 时间(秒) 注意:如果已存在的hash表有时间,这里将会替换原有的时间
* @return true 成功 false失败
*/
public boolean hset(String key, String item, Object value, long time) {
try {
redisTemplate.opsForHash().put(key, item, value);
if (time > 0) {
expire(key, time);
}
return true;
} catch (Exception e) {
e.printStackTrace();
return false;
}
} /**
* 删除hash表中的值
*
* @param key 键 不能为null
* @param item 项 可以使多个 不能为null
*/
public void hdel(String key, Object... item) {
redisTemplate.opsForHash().delete(key, item);
} /**
* 判断hash表中是否有该项的值
*
* @param key 键 不能为null
* @param item 项 不能为null
* @return true 存在 false不存在
*/
public boolean hHasKey(String key, String item) {
return redisTemplate.opsForHash().hasKey(key, item);
} /**
* hash递增 如果不存在,就会创建一个 并把新增后的值返回
*
* @param key 键
* @param item 项
* @param by 要增加几(大于0)
*/
public double hincr(String key, String item, double by) {
return redisTemplate.opsForHash().increment(key, item, by);
} /**
* hash递减
*
* @param key 键
* @param item 项
* @param by 要减少记(小于0)
*/
public double hdecr(String key, String item, double by) {
return redisTemplate.opsForHash().increment(key, item, -by);
} // ============================set============================= /**
* 根据key获取Set中的所有值
* @param key 键
*/
public Set<Object> sGet(String key) {
try {
return redisTemplate.opsForSet().members(key);
} catch (Exception e) {
e.printStackTrace();
return null;
}
} /**
* 根据value从一个set中查询,是否存在
*
* @param key 键
* @param value 值
* @return true 存在 false不存在
*/
public boolean sHasKey(String key, Object value) {
try {
return redisTemplate.opsForSet().isMember(key, value);
} catch (Exception e) {
e.printStackTrace();
return false;
}
} /**
* 将数据放入set缓存
*
* @param key 键
* @param values 值 可以是多个
* @return 成功个数
*/
public long sSet(String key, Object... values) {
try {
return redisTemplate.opsForSet().add(key, values);
} catch (Exception e) {
e.printStackTrace();
return 0;
}
} /**
* 将set数据放入缓存
*
* @param key 键
* @param time 时间(秒)
* @param values 值 可以是多个
* @return 成功个数
*/
public long sSetAndTime(String key, long time, Object... values) {
try {
Long count = redisTemplate.opsForSet().add(key, values);
if (time > 0)
expire(key, time);
return count;
} catch (Exception e) {
e.printStackTrace();
return 0;
}
} /**
* 获取set缓存的长度
*
* @param key 键
*/
public long sGetSetSize(String key) {
try {
return redisTemplate.opsForSet().size(key);
} catch (Exception e) {
e.printStackTrace();
return 0;
}
} /**
* 移除值为value的
*
* @param key 键
* @param values 值 可以是多个
* @return 移除的个数
*/ public long setRemove(String key, Object... values) {
try {
Long count = redisTemplate.opsForSet().remove(key, values);
return count;
} catch (Exception e) {
e.printStackTrace();
return 0;
}
} // ===============================list================================= /**
* 获取list缓存的内容
*
* @param key 键
* @param start 开始
* @param end 结束 0 到 -1代表所有值
*/
public List<Object> lGet(String key, long start, long end) {
try {
return redisTemplate.opsForList().range(key, start, end);
} catch (Exception e) {
e.printStackTrace();
return null;
}
} /**
* 获取list缓存的长度
*
* @param key 键
*/
public long lGetListSize(String key) {
try {
return redisTemplate.opsForList().size(key);
} catch (Exception e) {
e.printStackTrace();
return 0;
}
} /**
* 通过索引 获取list中的值
*
* @param key 键
* @param index 索引 index>=0时， 0 表头，1 第二个元素，依次类推；index<0时，-1，表尾，-2倒数第二个元素，依次类推
*/
public Object lGetIndex(String key, long index) {
try {
return redisTemplate.opsForList().index(key, index);
} catch (Exception e) {
e.printStackTrace();
return null;
}
} /**
* 将list放入缓存
*
* @param key 键
* @param value 值
*/
public boolean lSet(String key, Object value) {
try {
redisTemplate.opsForList().rightPush(key, value);
return true;
} catch (Exception e) {
e.printStackTrace();
return false;
}
} /**
* 将list放入缓存
* @param key 键
* @param value 值
* @param time 时间(秒)
*/
public boolean lSet(String key, Object value, long time) {
try {
redisTemplate.opsForList().rightPush(key, value);
if (time > 0)
expire(key, time);
return true;
} catch (Exception e) {
e.printStackTrace();
return false;
} } /**
* 将list放入缓存
*
* @param key 键
* @param value 值
* @return
*/
public boolean lSet(String key, List<Object> value) {
try {
redisTemplate.opsForList().rightPushAll(key, value);
return true;
} catch (Exception e) {
e.printStackTrace();
return false;
} } /**
* 将list放入缓存
*
* @param key 键
* @param value 值
* @param time 时间(秒)
* @return
*/
public boolean lSet(String key, List<Object> value, long time) {
try {
redisTemplate.opsForList().rightPushAll(key, value);
if (time > 0)
expire(key, time);
return true;
} catch (Exception e) {
e.printStackTrace();
return false;
}
} /**
* 根据索引修改list中的某条数据
*
* @param key 键
* @param index 索引
* @param value 值
* @return
*/ public boolean lUpdateIndex(String key, long index, Object value) {
try {
redisTemplate.opsForList().set(key, index, value);
return true;
} catch (Exception e) {
e.printStackTrace();
return false;
}
} /**
* 移除N个值为value
*
* @param key 键
* @param count 移除多少个
* @param value 值
* @return 移除的个数
*/ public long lRemove(String key, long count, Object value) {
try {
Long remove = redisTemplate.opsForList().remove(key, count, value);
return remove;
} catch (Exception e) {
e.printStackTrace();
return 0;
}
}
}测试使用：
@Autowired
private RedisUtil redisUtil; @Test
void testUtils(){
redisUtil.lSet("list", 1);
redisUtil.lSet("list", 2);
redisUtil.lSet("list", Lists.list(3, 4));
List<Object> list = redisUtil.lGet("list", 0, -1);
System.out.println(list.toString()); // [1, 2, 3, 4]
}