Redis事务处理的使用操作方法

一、简介

Redis采用了乐观锁方式进行事务控制，它使用watch命令监视给定的key，当exec（提交事务）的时候,如果监视的key从调用watch后发生过变化，则整个事务会失败。也可以调用watch多次监视多个key。注意watch的key是对整个连接有效的，如果连接断开，监视和事务都会被自动清除。当然exec，discard，unwatch命令都会清除连接中的所有监视。

Redis保证一个事务中的所有命令要么都执行，要么都不执行(原子性)。如果在发送EXEC命令前客户端断线了，则Redis会清空事务队列，事务中的所有命令都不会执行。而一旦客户端发送了EXEC命令，所有的命令就都会被执行，即使此后客户端断线也没关系，因为Redis中已经记录了所有要执行的命令。

常用指令：

  • multi 开启事务
  • exec 提交事务
  • discard 取消事务
  • watch 监控，如果监控的值发生变化，则提交事务时会失败
  • unwatch 去掉监控

二、模拟使用

模拟转账操作

开启事务后所有操作都会进入到一个队列中，提交时一起执行

模拟取消事务

redis事务太简单，没有回滚，而只有取消。

当队列中有语句出现错误时，事务会自动取消

乐观锁使用演示

乐观锁(Optimistic Lock), 顾名思义，就是很乐观，每次去拿数据的时候都认为别人不会修改，所以不会上锁，期间该数据可以随便被其他人读取，但是在更新的时候会判断一下在此期间别人有没有去更新这个数据，可以使用版本号等机制。
        版本号机制是乐观锁最常用的方式，就是在表中增加一个版本号的字段，更新前先查一遍获取版本号，再作为更新语句的where条件进行更新，如果数据在获取版本号之后，在更新之前已经改变了，那就会更新失败，因为最后更新了0条数据，java后台拿到更新数如果为0，则说明更新失败，出现了并发问题，然后做具体的处理。

1.添加测试数据语句

开启监控，开启事务，执行语句

2.另起一个redis对数据进行修改

3.返回第一个数据库提交事务

这里我们可以看到执行事务失败。a变成了666

三、乐观锁秒杀抢票练习

/*基于reids实现一个简单的多线程抢票操作
* 重点延时乐观锁的应用*/
public class SecondsKillDemo02 {
    //定义抢票逻辑
    public static void KillTicket() {
        //1.连接
        Jedis jedis = JedisDataSource.getConnection();
        //2.监控reids中指定的key
        String a = jedis.get("a");
        if (a == null || Integer.valueOf(a) == 0)
            throw new RuntimeException("没票了");
        jedis.watch("a", "b");
        //3.开启事务执行业务
        Transaction multi = jedis.multi();
        try {
            multi.decr("a");
            multi.incrBy("b", 100);
            //4.提交事务
             multi.discard();
            System.out.println("ok");
        } catch (Exception e) {
            multi.exec();
        } finally {
            //5.取消监控
            jedis.unwatch();
            //6.释放
            jedis.close();
        }
    }

    public static void main(String[] args) {
        //1.定义初始数据
        Jedis jedis = JedisDataSource.getConnection();
        jedis.set("a", "1");
        jedis.set("b", "0");
        //2.创建多个线程，在线程中执行抢票
        Thread t1 = new Thread(new Runnable() {
            @Override
            public void run() {
                KillTicket();
            }
        });
        Thread t2 = new Thread(new Runnable() {
            @Override
            public void run() {
                KillTicket();
            }
        });
        t1.start();
        t2.start();

    }
}

到此这篇关于Redis事务处理的文章就介绍到这了,更多相关Redis事务处理内容请搜索我们以前的文章或继续浏览下面的相关文章希望大家以后多多支持我们！

赞 (0)

相关推荐

  • Redis 基础教程之事务的使用方法

    Redis 基础教程之事务的使用方法 Redis 事务可以一次执行多个命令, 并且带有以下两个重要的保证: 事务是一个单独的隔离操作:事务中的所有命令都会序列化.按顺序地执行.事务在执行的过程中,不会被其他客户端发送来的命令请求所打断. 事务是一个原子操作:事务中的命令要么全部被执行,要么全部都不执行. 一个事务从开始到执行会经历以下三个阶段: 开始事务. 命令入队. 执行事务. 实例 以下是一个事务的例子, 它先以 MULTI 开始一个事务, 然后将多个命令入队到事务中, 最后由 EXEC 命

  • Redis 事务与过期时间详细介绍

    Redis 事务与过期时间详细介绍 一.Redis事务: Redis中支持事务,事务即为当我们需要执行几条命令时,要么这几条命令都不执行,要么都执行: 1.开始事务写入: multi 2.然后写入命令,注意写完事务要执行的每条命令之后回车即可,命令会自动入队: lpush art:1 hello lpush art:1 nihao 3.执行事务: exec Redis则会保证事务中的所有命令要么都执行,要么都不执行. 二.Redis过期时间: 实际开发中经常会遇到一些有时效性的数据,比如缓存,过

  • Redis 事务知识点相关总结

    Redis中的事务介绍     MySQL中的事务大家都不陌生,Redis中的事务和MySQL中的事务不同,今天看下Redis事务中的一些知识点吧. 01 事务简介 Redis中的事务使用multi.exec来标记,其中multi代表事务开始,exec代表事务结束,multi和exec之间的命令是原子顺序执行的.下面是一个例子: 127.0.0.1:7397> multi OK 127.0.0.1:7397> set key_hello hello QUEUED 127.0.0.1:7397&

  • redis中的事务操作案例分析

    redis中的事务操作案例分析

    本文实例讲述了redis中的事务操作.分享给大家供大家参考,具体如下: redis与mysql的事务 Redis支持简单的事务 简单使用 讲张三的100圆钱转账给lisi: set zhangsan 800 set lisi 100 multi decrby zhangsan 100 incrby lisi 100 exec 失败的两种情况 在mutil后面的语句中, 语句出错可能有2种情况,还是以转账的情况来分析: (1)语法就有问题 127.0.0.1:6379> multi OK 127.

  • Redis事务涉及的watch、multi等命令详解

    Redis Watch 命令 作用: 用于监视一个(或多个) key ,如果在事务执行之前这个(或这些) key 被其他命令所改动,那么事务将被打断. 用法: redis 127.0.0.1:6379> WATCH key1 key2 OK Redis Unwatch 命令 作用: 用于取消 WATCH 命令对所有 key 的监视. 用法: redis 127.0.0.1:6379> UNWATCH OK Redis Multi 命令 作用: 用于标记一个事务块的开始.事务块内的多条命令会按照

  • redis事务常用操作详解

    事务 MULTI . EXEC . DISCARD 和 WATCH 是 Redis 事务相关的命令.事务可以一次执行多个命令, 并且带有以下两个重要的保证: 事务是一个单独的隔离操作:事务中的所有命令都会序列化.按顺序地执行.事务在执行的过程中,不会被其他客户端发送来的命令请求所打断. 事务是一个原子操作:事务中的命令要么全部被执行,要么全部都不执行. EXEC 命令负责触发并执行事务中的所有命令: 如果客户端在使用 MULTI 开启了一个事务之后,却因为断线而没有成功执行 EXEC ,那么事务

  • Redis事务为什么不支持回滚

    Redis事务为什么不支持回滚

    目录 前言 Redis 有事务吗 Redis 事务实现原理 Redis 事务 ACID 特性 A - 原子性 C - 一致性 I - 隔离性 D - 持久性 watch 命令 watch 命令的作用 watch 原理分析 总结 前言 事务是关系型数据库的特征之一,那么作为 Nosql 的代表 Redis 中有事务吗?如果有,那么 Redis 当中的事务又是否具备关系型数据库的 ACID 四大特性呢? Redis 有事务吗 这个答案可能会令很多人感到意外,Redis 当中是存在"事务"的

  • Redis事务处理的使用操作方法

    Redis事务处理的使用操作方法

    一.简介 Redis采用了乐观锁方式进行事务控制,它使用watch命令监视给定的key,当exec(提交事务)的时候,如果监视的key从调用watch后发生过变化,则整个事务会失败.也可以调用watch多次监视多个key.注意watch的key是对整个连接有效的,如果连接断开,监视和事务都会被自动清除.当然exec,discard,unwatch命令都会清除连接中的所有监视. Redis保证一个事务中的所有命令要么都执行,要么都不执行(原子性).如果在发送EXEC命令前客户端断线了,则Redis

  • redis批量操作pipeline管道操作方法

    redis批量操作pipeline管道操作方法

    目录 redis | pipeline(管道) 背景 什么是流水线(pipeline) 适用场景 benchmark压测pipeline 代码测试-python: StrictRedis 代码测试-java:Jedis使用pipeline pipeline注意事项 参考资料 redis | pipeline(管道) 背景 Redis是一种基于客户端-服务端模型以及请求/响应的TCP服务.这意味着通常情况下一个请求会遵循以下步骤: 客户端向服务端发送一个查询请求,并监听 Socket 返回,通常是

  • 超强、超详细Redis数据库入门教程

    超强、超详细Redis数据库入门教程

    [本教程目录] 1.redis是什么 2.redis的作者何许人也 3.谁在使用redis 4.学会安装redis 5.学会启动redis 6.使用redis客户端 7.redis数据结构 – 简介 8.redis数据结构 – strings 9.redis数据结构 – lists 10.redis数据结构 – 集合 11.redis数据结构 – 有序集合 12.redis数据结构 – 哈希 13.聊聊redis持久化 – 两种方式 14.聊聊redis持久化 – RDB 15.聊聊redis持

  • Java操作Redis详细介绍

    1. 简介 Redis 是一个开源(BSD许可)的,内存中的key-value存储系统,它可以用作数据库.缓存和消息中间件. 2. 对key的操作 首先要建立连接Jedis jedis = new Jedis("127.0.0.1", 6379),然后就可以对string,set,zset,hash进行操作了. //对key的测试 public void keyTest() { System.out.println(jedis.flushDB()); //清空数据 System.out

  • Redis中的String类型及使用Redis解决订单秒杀超卖问题

    本系列将和大家分享Redis分布式缓存,本章主要简单介绍下Redis中的String类型,以及如何使用Redis解决订单秒杀超卖问题. Redis中5种数据结构之String类型:key-value的缓存,支持过期,value不超过512M. Redis是单线程的,比如SetAll & AppendToValue & GetValues & GetAndSetValue & IncrementValue & IncrementValueBy等等,这些看上去像是组合命

  • python笔记:mysql、redis操作方法

    模块安装: 数据操作用到的模块pymysql,需要通过pip install pymysql进行安装. redis操作用的模块是redis,需要通过pip install redis进行安装. 检验是否安装成功:进入到Python命令行模式,输入import pymysql. import redis ,无报错代表成功: mysql操作方法如下: 查询数据:fetchone.fetchmany(n).fetchall() import pymysql #建立mysql连接,ip.端口.用户名.密

  • spring boot+redis 监听过期Key的操作方法

    前言: 在订单业务中,有时候需要对订单设置有效期,有效期到了后如果还未支付,就需要修改订单状态.对于这种业务的实现,有多种不同的办法,比如: 1.使用querytz,每次生成一个订单,就创建一个定时任务,到期后执行业务代码: 2.rabbitMq中的延迟队列: 3.对Redis的Key进行监控: 1.引入依赖 <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring

  • Redis 缓存实现存储和读取历史搜索关键字的操作方法

    Redis 缓存实现存储和读取历史搜索关键字的操作方法

    一.本案例涉及知识 Layui Redis Vue.js jQuery Ajax 二.效果图 三.功能实现 (一)使用 Layui 的样式构建页面 <!DOCTYPE html> <html> <head> <meta charset="utf-8"> <title>Redis应用 - 搜索历史</title> <!-- 引入 Layui CSS --> <link rel="style

  • 使用Grafana监控Redis的操作方法

    使用Grafana监控Redis的操作方法

    目录 Grafana简介 Prometheus简介 安装 使用 监控系统信息 监控SpringBoot应用 总结 参考资料 项目源码地址 当面对一个复杂的系统时,我们往往需要监控工具来帮助我们解决一些性能问题.比如之前我们使用SpringBoot Admin来监控应用,从而获取到SpringBoot Actuator暴露的指标信息.今天给大家介绍一个功能强大的监控工具Grafana,只要需要用到监控的地方,用它做可视化就对了! Grafana简介 Grafana是一款开源的数据可视化和分析工具,

  • SpringBoot整合Redis实现序列化存储Java对象的操作方法

    目录 一.背景 1.思考 2.方案 二.源码分析 三.注入RedisTemplate 1.引入依赖 2.Redis 连接信息 3.Redis 核心配置类 4.Redis工具类 四.测试 1.创建 Java 实体类 UserInfo 2.测试用例 3.测试结果 之前介绍过 https://www.jb51.net/article/223539.htm 我们可以看出,在 SpringBoot 对 Redis 做了一系列的自动装配,使用还是非常方便的 一.背景 1.思考 通过我们前面的学习,我们已经可

随机推荐