redis学习笔记（四）

事务可以一次执行多个命令， 并且带有以下两个重要的保证：

• 事务是一个单独的隔离操作：事务中的所有命令都会序列化、按顺序地执行。事务在执行的过程中，不会被其他客户端发送来的命令请求所打断。

• 事务是一个原子操作：事务中的命令要么全部被执行，要么全部都不执行
  redis事务执行步骤：

• 开启事务（MULTI）

• 命令入队（…）

• 执行事务（EXEC）

生活中：锁在我们身边无处不在，比如我出门玩去了需要把门锁上，比如我需要把钱放到保险柜里面，必须上锁以保证我财产的安全。

代码中：比如多个线程需要同时操作修改共享变量，这时需要给变量上把锁（syncronized），保证变量值是对的。

数据库表：当多个用户修改表中同一数据时，我们可以给该行数据上锁（行锁）。

指的是对数据被外界（包括本系统当前的其他事务，以及来自外部系统的事务处理）修改持保守态度，因此，在整个数据处理过程中，将数据处于锁定状态。悲观锁的实现，往往依靠数据库提供的锁机制（也只有数据库层提供的锁机制才能真正保证数据访问的排他性，否则，即使在本系统中实现了加锁机制，也无法保证外部系统不会修改数据）。

乐观锁，大多是基于数据版本（ Version ）记录机制实现。何谓数据版本？即为数据增加一个版本标识，在基于数据库表的版本解决方案中，一般是通过为数据库表增加一个 “version” 字段来实现。读取出数据时，将此版本号一同读出，之后更新时，对此版本号加一。此时，将提交数据的版本数据与数据库表对应记录的当前版本信息进行比对，如果提交的数据版本号等于数据库表当前版本号，则予以更新，否则认为是过期数据。

标记所有指定的key 被监视起来，在事务中有条件的执行。
WATCH 命令可以为 Redis 事务提供 check-and-set （CAS）行为，实现乐观锁

127.0.0.1:6379> set money 100 # 存入100元
OK
127.0.0.1:6379> set out 0 # 支出0元
OK
127.0.0.1:6379> WATCH money # 监视对象
OK
127.0.0.1:6379> MULTI # 开始事务
OK
127.0.0.1:6379> DECRBY money 20 # 支出20 
QUEUED
127.0.0.1:6379> INCRBY out 20 # 记账
QUEUED
127.0.0.1:6379> EXEC # 结束事务
1) (integer) 80
2) (integer) 20

127.0.0.1:6379> set money 100
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

新开一个redis，修改money

127.0.0.1:6379> get money
"100"
127.0.0.1:6379> set money 1000
OK
127.0.0.1:6379>

执行事务（无论事务是否执行成功exec都会解除锁）

127.0.0.1:6379> EXEC
(nil) # 事务失败

正常成功返回的结果

1) (integer) 80
2) (integer) 20

UNWATCH放弃监视，解除乐观锁

127.0.0.1:6379> UNWATCH
OK

创建一个springboot项目并导入基本依赖

编辑配置文件，设置redis基本信息

进行测试

import org.junit.jupiter.api.Test;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.data.redis.core.RedisTemplate;

import javax.xml.ws.Action;

@SpringBootTest
class Redis02SpringbootApplicationTests {

	@Autowired
	private RedisTemplate redisTemplate;

	@Test
	void contextLoads() {
		redisTemplate.opsForValue().set("name","xiaoming");
		System.out.println(redisTemplate.opsForValue().get("name"));
	}

}

输出结果

xiaoming

• opsForValue 操作字符串
• opsForList 操作List集合
• opsForSet 操作Set集合
• opsForHash 操作Hash
• opsForZSet 操作Zset集合

基本操作

RedisConnection connection = redisTemplate.getConnectionFactory().getConnection();
connection.flushAll();
connection.flushDb();

自定义RedisTemplate

package com.ukir.config;

import com.fasterxml.jackson.annotation.JsonAutoDetect;
import com.fasterxml.jackson.annotation.JsonTypeInfo;
import com.fasterxml.jackson.annotation.PropertyAccessor;
import com.fasterxml.jackson.databind.ObjectMapper;
import com.fasterxml.jackson.databind.jsontype.impl.LaissezFaireSubTypeValidator;
import org.springframework.cache.annotation.CachingConfigurerSupport;
import org.springframework.cache.annotation.EnableCaching;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.data.redis.connection.RedisConnectionFactory;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.serializer.Jackson2JsonRedisSerializer;
import org.springframework.data.redis.serializer.RedisSerializer;
import org.springframework.data.redis.serializer.StringRedisSerializer;

@EnableCaching
@Configuration
public class RedisConfig extends CachingConfigurerSupport {

    @Bean
    public RedisTemplate redisTemplate(RedisConnectionFactory redisConnectionFactory) {
        RedisTemplate redisTemplate = new RedisTemplate<>();
        redisTemplate.setConnectionFactory(redisConnectionFactory);

        // 通过 Jackson 组件进行序列化
        RedisSerializer