胖胖的枫叶
主页
博客
产品设计
企业架构
全栈开发
效率工具
数据分析
项目管理
方法论
面试
  • openJdk-docs
  • spring-projects-docs
  • mysql-docs
  • redis-commands
  • redis-projects
  • apache-rocketmq
  • docker-docs
  • mybatis-docs
  • netty-docs
  • journaldev
  • geeksforgeeks
  • 后端进阶
  • 并发编程网
  • 英语肌肉记忆锻炼软件
  • 墨菲安全
  • Redisson-docs
  • jmh-Visual
  • 美团技术
  • MavenSearch
主页
博客
产品设计
企业架构
全栈开发
效率工具
数据分析
项目管理
方法论
面试
  • openJdk-docs
  • spring-projects-docs
  • mysql-docs
  • redis-commands
  • redis-projects
  • apache-rocketmq
  • docker-docs
  • mybatis-docs
  • netty-docs
  • journaldev
  • geeksforgeeks
  • 后端进阶
  • 并发编程网
  • 英语肌肉记忆锻炼软件
  • 墨菲安全
  • Redisson-docs
  • jmh-Visual
  • 美团技术
  • MavenSearch
  • 标签索引
  • 2024年

    • 配置Mac环境
    • 业务知识会计管理
    • 业务知识会计基础
    • 业务知识什么是财务
  • 2023年

    • 项目 Boi
  • 2022年

    • 企业架构故障管理
    • 企业架构开发债务
  • 2021年

    • Python3.8 Matplotlib员工数据分析
    • Python3.8 Matplotlib IP折线图
    • Python3.8 词云 IP地址
    • Redis RediSearch
    • Rust第一个CLI程序
    • Rust所有权
    • Rust函数与控制流
    • Rust变量与数据类型
    • Rust入门
    • 企业架构分布式系统
    • 编程式权限设计
    • Java JVM优化
    • SpringBoot MyBatis 批量
    • SpringBoot 测试Mock
    • SpringBoot Redis布隆过滤器
    • CentOS7 Jenkins 部署
    • SpringBoot WebClient
    • Docker Drone 部署
    • SpringBoot MyBatis
    • SpringBoot Redisson
    • SpringBoot MyBatis 雪花算法
    • Java Netty
    • Redis 扫描
    • CentOS7 Jenkins本地部署分级
    • Mac 安装 Neo4j Jupyter
    • Mac OpenJDK11 JavaFX 环境
    • Mac 安装 Jenv
    • SpringBoot Redis 延时队列
    • SpringBoot MDC日志
    • SpringBoot 定时任务
    • CentOS7 Nginx GoAccess
    • SpringBoot MyBatis 分析
    • SpringBoot Lucene
    • 企业架构分布式锁
    • 学习技巧减少学习排斥心理
    • SpringBoot 动态数据源
    • Docker Compose SpringBoot MySQL Redis
    • SpringBoot 阻塞队列
    • Docker Compose Redis 哨兵
    • Docker Compose Redis 主从
    • 网络通信
  • 2020年

    • SpringBoot 延时队列
    • MySQL基础(四)
    • Java 雪花算法
    • Redis Geo
    • 网络通信 Tcpdump
    • Spring SPI
    • Java Zookeeper
    • SpringBoot JMH
    • 网络通信 Wireshark
    • Docker Compose Redis MySQL
    • CentOS7 Docker 部署
    • Netty 源码环境搭建
    • MySQL基础(三)
    • CentOS7 Selenium运行环境
    • CentOS7 Nginx HTTPS
    • Java JMH
    • SpringBoot 修改Tomcat版本
    • Java Eureka 钉钉通知
    • SpringBoot 错误钉钉通知
    • Java JVM
    • Git 合并提交
    • CentOS7 OpenResty 部署
  • 2019年

    • Redis CLI
    • CentOS7 Nginx 日志
    • 编程式代码风格
    • IDEA 插件
    • Skywalking 源码环境搭建
    • SpringBoot Redis 超时错误
    • 编程式 gRPC
    • Java Arthas
    • Docker Compose Redis 缓存击穿
    • Docker ElasticSearch5.6.8 部署
    • Docker Mysql5.7 部署
    • Spring Redis 字符串
    • Docker Zookeeper 部署
    • Docker Redis 部署
    • SpringBoot Dubbo
    • CentOS7 CMake 部署
    • 应用程序性能指标
    • Java Code 递归
    • CentOS7 ELK 部署
    • CentOS7 Sonarqube 部署
    • Java Selenium
    • Java JJWT JUnit4
    • Spring 源码环境搭建
    • Java JUnit4
    • Java Web JSON Token
    • 编程式 FastDFS
    • Java XPath
    • Redis基础(二)
    • Redis基础(一)
    • Java MyBatis JUnit4
    • Java MyBatis H2 JUnit4
    • MyBatis 源码环境搭建
    • Git 配置
    • Java 核心
    • Java Dubbo
    • Java JavaCollecionsFramework
    • Java Maven
    • Java MyBatis
    • Java Spring
    • Java SpringMVC
    • MySQL
    • Redis
  • 2018年

    • Java HashMap
    • Java HashSet
    • Java Code 交换值
    • Spring Upgrade SpringBoot
    • Mac 编程环境
    • Java Log4j
    • 网络通信 Modbus
    • MySQL基础(二)
    • MySQL基础(一)
    • Java Stack
    • Java Vector
    • CentOS7 RabbitMQ 部署
    • CentOS7 Redis 部署
    • CentOS7 MongoDB 部署
    • CentOS7 基础命令
    • Java Eureka Zookeeper
    • CentOS7 MySQL 部署
    • Git 分支
    • CentOS7 Java环境配置
    • Java LinkedList
    • Java ArrayList
    • Spring Annotation Aop

Redis基础(二)

本章是整理知识内容,为强化知识长期更新。

set扩展

  • 分布式锁的简单实现
    • 在日常开发中,redis主要用在缓存处理。为保证缓存所以会使用集群的方式,避免缓存雪崩。都使用集群了应用层也不太可能是单应用。在分布式的情况下就会涉及分布式锁。a应用和b应用一起对某条缓存记录操作,a查完数据在内存修改,在放回去。如果这个操作两个应用同时进行就会出现并发问题。为了保证操作的原子性,所以就要使用锁来保证操作执行的顺序。
# 使用set的扩展命令 一次把expire和 setnx的特性带上。下面这条命令就是 过期时间5s 并且不可以重复添加。只能删除或者到期。
192.168.31.7:6379> set lock:redis true ex 5 nx
OK
192.168.31.7:6379> set lock:redis true ex 5 nx  # 第二次在设置就失败了。
(nil)

  • 但是这种分布式锁并不能完美解决问题,因为锁有过期时间,如果时间过期了但是操作依然未执行完成,后面的操作进来就可能会造成不可控影响。

异步消息列队

Redis list这个数据类型,非常适合做列队。使用rpush / lpush 操作入列,使用 lpop 和 rpop来出列队。

192.168.31.7:6379> rpush queue a b c d 
(integer) 4
192.168.31.7:6379> llen queue
(integer) 4
# rpop 压栈
192.168.31.7:6379> lpop queue
"a"
192.168.31.7:6379> lpop queue
"b"
192.168.31.7:6379> lpop queue
"c"
192.168.31.7:6379> lpop queue
"d"
# lpop 列队
192.168.31.7:6379> lpop queue
"a"
192.168.31.7:6379> lpop queue
"b"
192.168.31.7:6379> lpop queue
"c"
192.168.31.7:6379> lpop queue
"d"
  • 但是,redis的list一旦被消费完就会被删除,为了避免客户端一直读取。建议使用阻塞列队blpop\brpop的方式
# 使用blocking 阻塞读,1就是阻塞时间。这样可以避免不断的读。
192.168.31.7:6379> rpush queue a b c d 
(integer) 4
192.168.31.7:6379> blpop queue 1
1) "queue"
2) "a"
192.168.31.7:6379> blpop queue 1
1) "queue"
2) "b"
192.168.31.7:6379> blpop queue 1
1) "queue"
2) "c"
192.168.31.7:6379> blpop queue 1
1) "queue"
2) "d"
192.168.31.7:6379> blpop queue 1 # 最后一次 list已经空了。
(nil)
(1.08s)  # 阻塞了一秒

key查询

  • 虽然redis已经有keys,并不能像mysql一个提供limit这种,导致读取的太多了。Redis是一个单线程,数据太多会阻塞。scan提供了三个参数 cursor key limit 分别是
192.168.31.7:6379> set key1 1
OK
192.168.31.7:6379> set key2 1
OK
192.168.31.7:6379> set key3 1
OK
192.168.31.7:6379> set key4 1
OK
192.168.31.7:6379> set key5 1
OK
192.168.31.7:6379> scan 0 match key* count 10
1) "0"
2) 1) "key4"
   2) "key3"
   3) "key2"
   4) "key5"
   5) "key1"

Redis事务

Redis事物分别是multi/exec/discard 对应的就是begin/commit/rollback。Redis在收到exec的指令才会执行事务列队,执行完毕后一次返回指令运行结果。但是Redis仅仅是保证了个隔离性。在使用事物的时候建议使用管道pipe,这样可以减少网络请求。

# 简单的演示事务
192.168.31.7:6379> multi
OK
192.168.31.7:6379> set name wang
QUEUED
192.168.31.7:6379> set name zhang
QUEUED
192.168.31.7:6379> exec
1) OK
2) OK
  • 事务丢弃 discard
# 创建一个字符串并对value进行累加。
192.168.31.7:6379> set count 1
OK
192.168.31.7:6379> get count
"1"
192.168.31.7:6379> multi # 开启事物
OK
192.168.31.7:6379> incr count
QUEUED
192.168.31.7:6379> incr count
QUEUED
192.168.31.7:6379> discard # 丢弃事物
OK
192.168.31.7:6379> get count #检查数据。
"1"

Watch

上面的分布式锁其实是一个悲观锁,实际上可以使用watch实现乐观锁。watch会在事务开始之前,监听一个或者多个参数,当执行exec的时候redis会检查被监听的参数是否改变,如果改变了事务执行失败。这里需要注意的是watch必须在事务之前开启。

# 监听count
192.168.31.7:6379> watch count 
OK
192.168.31.7:6379> incr count # 自增count的value。
(integer) 2
192.168.31.7:6379> multi #开启事物
OK
192.168.31.7:6379> incr count 
QUEUED
192.168.31.7:6379> exec  
(nil) #事务执行失败。

END

最近更新: 2025/12/27 16:03
Contributors: 庆峰
Prev
Java XPath
Next
Redis基础(一)