六.巅峰

1.事务

Redis单条命令保证原子性，但是事务不保证原子性

原子性：要么同时成功，要么同时失败

Redis的事物本质：一组命令的集合，一个事务中的所有命令都会被序列化，事务执行过程中，会按照顺序执行。具有一次性，顺序性，排他性（没有隔离级别的概念）

所有的命令在事务中，并没有直接执行，只有发起执行命令的时候才会执行

事务的三个阶段：

• 开启事务(multi)

• 命令入队(...)

• 执行事务(exec)

127.0.0.1:6379> multi //开启事务
OK
127.0.0.1:6379(TX)> set name ren
QUEUED
127.0.0.1:6379(TX)> set age 8
QUEUED
127.0.0.1:6379(TX)> get age
QUEUED
127.0.0.1:6379(TX)> get name
QUEUED
127.0.0.1:6379(TX)> exec //执行事务
1) OK
2) OK
3) "8"
4) "ren"
​
127.0.0.1:6379> multi
OK
127.0.0.1:6379(TX)> set lu 8
QUEUED
127.0.0.1:6379(TX)> discard //放弃事务discard
OK
127.0.0.1:6379> get lu
(nil)

编译型异常(代码有问题，命令有错)，事务中所有的命令都不会被执行

127.0.0.1:6379> multi
OK
127.0.0.1:6379(TX)> set sir 8
QUEUED
127.0.0.1:6379(TX)> setage 8 //代码有问题
(error) ERR unknown command 'setage', with args beginning with: '8' 
127.0.0.1:6379(TX)> get sir
QUEUED
127.0.0.1:6379(TX)> exec
(error) EXECABORT Transaction discarded because of previous errors.

运行时异常，如果事务队列中存在语法型错误，那么在执行过程中，其他命令是可以正常执行的

127.0.0.1:6379> multi
OK
127.0.0.1:6379(TX)> set name ren
QUEUED
127.0.0.1:6379(TX)> incr name //出现语法型错误
QUEUED
127.0.0.1:6379(TX)> get name
QUEUED
127.0.0.1:6379(TX)> exec
1) OK
2) (error) ERR value is not an integer or out of range 
3) "ren"

watch实现乐观锁

悲观锁：很悲观，认为什么时候都会出问题，无论做什么都加锁。

乐观锁：

• 很乐观，认为什么时候都不会出问题，所以不会上锁。

• 在更新数据的时候获取version进行判断。

• 对version进行比较，来查看此期间是否有人修改过数据。

Redis监听对象

//正常线程情况
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(TX)> decrby money 20
QUEUED
127.0.0.1:6379(TX)> incrby out 20
QUEUED
127.0.0.1:6379(TX)> exec
1) (integer) 80
2) (integer) 20
//测试多客户端修改完值，使用watch当做乐观锁操作
127.0.0.1:6379> watch money
OK
127.0.0.1:6379> multi
OK
127.0.0.1:6379(TX)> decrby money 20
QUEUED
127.0.0.1:6379(TX)> incrby out 20
QUEUED
127.0.0.1:6379(TX)> exec //执行之前，另外一个线程修改了money的值，此时事务失败
(nil)
127.0.0.1:6379> get money
"1000"
​
127.0.0.1:6379> unwatch //如果发现事务执行失败，就先解锁
OK
127.0.0.1:6379> watch money //获取最新的值watch money，再次进行监视
OK
127.0.0.1:6379> multi
OK
127.0.0.1:6379(TX)> decrby money 10
QUEUED
127.0.0.1:6379(TX)> incrby out 10 
QUEUED
127.0.0.1:6379(TX)> exec //比对监视的值是否发生变化，如果没有发生变化，那么执行成功，否则事务执行失败
1) (integer) 990
2) (integer) 30

2.Redis实现分布式锁

3.Jedis

<dependency>
    <groupId>redis.clients</groupId>
    <artifactId>jedis</artifactId>
    <version>5.1.0</version>
</dependency>
<dependency>
    <groupId>com.alibaba.fastjson2</groupId>
    <artifactId>fastjson2</artifactId>
    <version>2.0.46</version>
</dependency>
<dependency>
    <groupId>com.fasterxml.jackson.core</groupId>
    <artifactId>jackson-databind</artifactId>
    <version>2.16.1</version>
</dependency>

帮助我们使用Java来操作Redis

编码测试:

• 连接数据库

• 操作命令

• 断开连接

使用Jedis操作事务

​

4.SpringBoot整合

配置及理解

使用SpringData进行连接

在Springboot中，原来的jedis被替换成了lettuce，如果想要避免不安全，要使用jedis pool连接池

jedis:采用的直连，多个线程操作，是不安全的。

lettuce：使用netty,实例可以在多个线程进行共享，不存在线程不安全的情况，可以减少线程数据，更像NIO模式。

故选择lettuce

源码部分：

@AutoConfiguration
@ConditionalOnClass({RedisOperations.class})
@EnableConfigurationProperties({RedisProperties.class})
@Import({LettuceConnectionConfiguration.class, JedisConnectionConfiguration.class})
public class RedisAutoConfiguration {
    public RedisAutoConfiguration() {
    }
​
    @Bean
    @ConditionalOnMissingBean({RedisConnectionDetails.class})
    PropertiesRedisConnectionDetails redisConnectionDetails(RedisProperties properties) {
        return new PropertiesRedisConnectionDetails(properties);
    }
​
    @Bean
    @ConditionalOnMissingBean( //如果自己定义redisTemplate，则此段代码不生效
        name = {"redisTemplate"}
    )
    @ConditionalOnSingleCandidate(RedisConnectionFactory.class)
    public RedisTemplate<Object, Object> redisTemplate(RedisConnectionFactory redisConnectionFactory) {
        //两个泛型都是Object类型，我们需要强制转换<String,Object>
        RedisTemplate<Object, Object> template = new RedisTemplate();
        template.setConnectionFactory(redisConnectionFactory);
        return template;
    }
    @Bean
    @ConditionalOnMissingBean //由于String类型最常使用，所以说单独提出了一个bean
    @ConditionalOnSingleCandidate(RedisConnectionFactory.class)
    public StringRedisTemplate stringRedisTemplate(RedisConnectionFactory redisConnectionFactory) {
        return new StringRedisTemplate(redisConnectionFactory);
    }
}

整合测试

1. 导入依赖

2. 配置连接

3. 测试

@Test
    public void Test() throws JsonProcessingException {
        //真正的开发使用JSON来传递对象
        User user = new User("任子硕", 23);
        //需要进行序列化
        String jsonUser = new ObjectMapper().writeValueAsString(user);
        redisTemplate.opsForValue().set("user",jsonUser);
        //redisTemplate.opsForValue().set("user",user); 直接传对象会无法传输Cannot serialize
        System.out.println(redisTemplate.opsForValue().get("user"));
    }

序列化对象implements Serializable

在企业中，所有的pojo都需要进行序列化

@Component
@Data
@AllArgsConstructor
@NoArgsConstructor
public class User implements Serializable {
    //序列化对象
    private String name;
    private int age;
}

Redis的序列化配置

@Configuration
public class RedisConfig {
    @Bean
    @SuppressWarnings("all")
    public RedisTemplate<String, Object> redisTemplate(RedisConnectionFactory redisConnectionFactory) {
        //配置具体的序列化方式
        RedisTemplate<String, Object> template = new RedisTemplate<String, Object>();
        template.setConnectionFactory(redisConnectionFactory);
        //JSON序列化配置
        Jackson2JsonRedisSerializer jackson2JsonRedisSerializer = new Jackson2JsonRedisSerializer(Object.class);
        ObjectMapper om = new ObjectMapper();
        om.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);
        om.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL);
        om.activateDefaultTyping(LaissezFaireSubTypeValidator.instance, ObjectMapper.DefaultTyping.NON_FINAL);
        jackson2JsonRedisSerializer.setObjectMapper(om);
        //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;
    }
}

192.168.233.131:6379> keys *
1) "user"

5.Redis.conf详解

通过配置文件来启动Redis

1. 配置文件unit单位对大小写不敏感

2. bind127.0.0.1 绑定的ip

3. protected-mode yes 保护模式

4. port 6379 端口设置

5. daemonize yes 以守护进程的方式存在，默认是no

6. pidfile /var/run/redis_6379.pid 如果以后台方式运行，我们需要指定一个pid进程文件

7. loglevel notice （生产环境）日志

8. logfile "" 日志的文件位置名

9. databases 16 数据库的数量，默认是16个数据库

10. always-show-logo yes 是否总是显示loge