首页 > 数据库 >Redis整合Springboot

Redis整合Springboot

时间：2024-03-04 22:33:32浏览次数：27  
标签：Springboot TX 0.1 Redis 6379 整合 序列化 class template

六.巅峰

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进行连接

image-20240304093503705

在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

 

标签：Springboot,TX,0.1,Redis,6379,整合,序列化,class,template
From： https://www.cnblogs.com/1764782550-rzs/p/18052889

相关文章

  • springboot四大特性
    "SpringBoot是一个基于Spring框架的开源框架，具有以下四大特性：简化配置：SpringBoot提供了自动化的配置机制，通过约定大于配置的方式，减少了开发人员的配置工作。它通过Starter模块来管理依赖，简化了项目的构建和管理。内嵌容器：SpringBoot支持内嵌Servlet容器（如Tomcat、Je......
  • Redis在游戏开发中的几种应用场景
    Redis特点1.内存数据库Redis数据主要存储在内存，综合性能标准100k+QPS。需要说明下，十万QPS只是个综合参考，实际性能跟CPU性能、操作的命令复杂度有较大关系，对于简单的set/get操作50万QPS也没问题。2.丰富的数据结构所有Redis的数据都是以key-value键值对的形式存在......
  • 【Redis】Redis如何保证和MySQL数据库的数据一致性
    保障MySQL和Redis数据一致性需要使用不同的策略和技术，因为两者是不同的数据存储系统。以下是一些常见的方法：1.数据同步MySQL数据同步至Redis使用事件驱动机制：当MySQL中的数据更新时，通过触发器或者其他事件驱动的机制，将数据同步至Redis。定时任务：定期轮询MySQL数据......
  • springboot3+vue3（三）接口参数校验Spring Validation框架
    1、引入Validation依赖<!--参数校验依赖validation--><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-validation</artifactId></dependency>va......
  • laravel8 + redis 队列
      执行命令生成job： phpartisanmake:job自定义名称修改queue.php配置文件'redis'=>['driver'=>'redis','connection'=>'queue',【databases.php中单独配置一个redis的链接名为queue】'queue'=>en......
  • springboot3+vue3（二）注册接口
     为了方便实体类操作，这里添加一下lombok的依赖，添加好以后右键重新加载mavenlombok注解含义大全：https://www.jianshu.com/p/41c4a226e955<!--lombok依赖--><dependency><groupId>org.projectlombok</groupId><artifactId>lombok</artifa......
  • redis自学（10）Set
    Set是Redis中的单列集合，满足下列特点：不保证有序性保证元素唯一（可以判断元素是否存在）求交集、并集、差集  以上操作，都需要判断元素是否存在，因此可以看出，Set对查询元素的效率要求非常高 Set是Redis中的集合，不一定确保元素有序，可以满足元素唯一、查询效率要求极高。为了......
  • Redis技术论点
    Redis单线程&&多线程问题redis是单线程还是多线程在redis4.X之前的版本，redis是单线程；redis4.X版本之后，陆续开始支持多线程，比如持久化过程，但是核心工作线程仍然是单线程；redis6.X之后，redis针对部分设计大量数据操作，存在阻塞线程风险的命令提供了异步操作，如：zrange、ZRANK、flusdb等......
  • springboot3+vue3大事件（一）项目准备工作
     1、执行sql脚本，准备数据库表--创建数据库createdatabasedev;--使用数据库usedev;--用户表createtableuser(idintunsignedprimarykeyauto_incrementcomment'ID',usernamevarchar(20)notnullunique......
  • SSM整合之使用配置类替换xml配置文件(2)
    SSM整合就是将MVC三层架构和框架核心API组件交给SpringIoC容器管理！一般需要配置两个IoC容器进行三层架构组件管理。容器名盛放组件web容器web相关组件（controller,springmvc核心组件）root容器业务和持久层相关组件（service,aop,tx,dataSource,mybatis,mapper等）w......

赞助商

阅读排行

网站主页关于我们联系我们网站地图

本网站内容转载自其他媒体，侵权联系[admin##ips99.com]。

Copyright © 2020-2023 IPS99 版权所有 IPS99