IT数码 购物 网址 头条 软件 日历 阅读 图书馆
TxT小说阅读器
↓语音阅读,小说下载,古典文学↓
图片批量下载器
↓批量下载图片,美女图库↓
图片自动播放器
↓图片自动播放器↓
一键清除垃圾
↓轻轻一点,清除系统垃圾↓
开发: C++知识库 Java知识库 JavaScript Python PHP知识库 人工智能 区块链 大数据 移动开发 嵌入式 开发工具 数据结构与算法 开发测试 游戏开发 网络协议 系统运维
教程: HTML教程 CSS教程 JavaScript教程 Go语言教程 JQuery教程 VUE教程 VUE3教程 Bootstrap教程 SQL数据库教程 C语言教程 C++教程 Java教程 Python教程 Python3教程 C#教程
数码: 电脑 笔记本 显卡 显示器 固态硬盘 硬盘 耳机 手机 iphone vivo oppo 小米 华为 单反 装机 图拉丁
 
   -> 大数据 -> Redis事务 -> 正文阅读

[大数据]Redis事务

作者:color:#a2e043;

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

?

? ? ? ? Redis事务的主要作用就是串联多个命令防止别的命令插队。

?Multi ,Exec,? discard

? ? ? ? 从输入Multi命令开始,输入的命令都会依次进入命令队列中,但不会执行,直到输入Exec后,Redis会将之前的命令队列中的命令依次执行。

组队过程中可以通过discard来放组队

案例

?

?

事务的错误处理

(1)组队中某个命令出现了错误,执行时整个所有队列都会被取消

?案例:

(2)如果执行阶段某个命令报出了错误,则只有报错的命令不会被执行,而其他的命令都会执行,不会回滚

?案例:

为什么要做成事务

场景:很多人有人的账务,同时去参加双十一抢购

事务冲突的问题

一个请求想给金额减8000

一个请求想给金额减5000

一个请求想给金额减1000

解决方法 加锁

悲观锁

? ? ? ? 顾名思义,就是很悲观,每次去拿数据的时候都认为别人会修改,所以每次在拿数据的时候都会上锁,这样别人想拿这个数据就会被block直到它拿到锁。传统的关系型数据库里边就用到了很多这种锁机制,比如行锁,表锁等,读锁,写锁等,都是在操作之前先上锁。

乐观锁(抢票)

? ? ? ??顾名思义,就是很乐观,每次去拿数据的时候都会认为别人不会修改,所以不会上锁,但是在更新的时候会判断一下在此期间别人有没有去更新这个数据,可以使用版本号。乐观锁设用于多读的应用类型,这样可以提高吞吐量,Redis就是利用这种check-and-set机制实现事务的。

WATCH key [key...]? ? ? ( 乐观锁)

在执行multi之前,先执行watch key1 [key2],可以监视一个(或多个)key,如果在事务执行之前(或这些)key被其他命令所改动,那么事务将被打断

创建两个客户端,两个客户端中都使用watch balance 进行监视 ,并使用multi开启事务,第一个客户端使用incrby balance 10 对balance进行加10操作。进入等待队列。第二个客户端 incrby balance 20 加20操作,进行等待队列,先对第一个客户端exec执行,结果为110。再对第二个客户端exec ,操作失败nil

?

?unwatch 取消watch命令对所有key的监视

Redis事务三特性

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

没有隔离级别的概念:队列中的命令没有提交之前都不会实际被执行,因为事务提交前任何指令都不会被实际执行

不保证原子性:事务中如果有一条命令执行失败,其后的命令仍然会被执行,没有回滚。

安装工具ab模拟高并发测试

centos7 :yum install httpd-tools

ab -n 1000 -c 100 -p? ~/profile -T application/x-www-form-uelencoded http://127.0.0.0:8080/Seckill/doseckill

~/profile:表示当前目录下的profile文件,里面内容是请求参数

已经秒杀完了,但是还是会描述成功。出现超卖现象。主要导致的原因是Redis并不能一次处理大量的数据,会出现连接超时的情况,最终导致超卖。

解决方案 连接池

Jedis连接池工具类

package com.example.redis_springboot.utils;/**
 * @Author: ZCL
 * @DATE: 2022/10/27 20:35
 */

import org.springframework.boot.autoconfigure.data.redis.RedisProperties;
import redis.clients.jedis.JedisPool;
import redis.clients.jedis.JedisPoolConfig;

/**
 * @program: redis_springboot
 * @author: ZCL
 * @create: 2022-10-27 20:35
 */
public class JedisPoolUtil {
    private static volatile JedisPool jedisPool =null;

    private JedisPoolUtil(){
    }

    public static JedisPool getJedisPoolInstance(){
        if (null == jedisPool){
            synchronized (JedisPoolUtil.class){
                if (null == jedisPool){
                    JedisPoolConfig poolConfig = new JedisPoolConfig();
                    poolConfig.setMaxTotal(200);
                    poolConfig.setMaxIdle(32);
                    poolConfig.setMaxWaitMillis(100*1000);
                    poolConfig.setBlockWhenExhausted(true);

                    jedisPool = new JedisPool(poolConfig,"192.168.238.80",6379,60000);
                }
            }
        }
        return jedisPool;
    }

    public static void release(JedisPool jedisPool, RedisProperties.Jedis jedis){
        if (null == jedis){
            jedisPool.getResource();
        }
    }
}

库存遗留,没有秒杀完

乐观锁造成库存遗留问题? ?,只能使用悲观锁,但是默认使用乐观锁,所有必须通过Lua脚本语言来采用悲观锁

解决方法LUA脚本语言

Lua是一个小巧的脚本语言,,Lua脚本可以很容易的被C++/C代码调用,也可以反过来调用C/C++的函数,Lua并没有提供强大的库,一个完整的Lua解析器不过200k,所以Lua不适合作为开发独立应用的语言,而是作为嵌入式脚本语言。

Lua在Redis中存在的优势,

将复杂的或者多步的Redis操作,写为一个脚本,一次提交给reids执行,减少反复连接redis的次数。提高性能。

Lua脚本是雷士redis事务,有一点的原子性,不会被其他命令插队,可以完成一些redis事务性的操作。

但是注意redis的Lua脚本功能,只有在Redis2.6以上的版本才可以使用。

利用lua脚本淘汰用户,解决超卖问题

local userid = KEYS[1];
local userid = KEYS[2];
local qtkey = "sk:"..prodid..":qt";
local userKey = "sk:"..prodid..":usr";
local userExists = redis.call("sismember",userKey,userid);
if tonumber(userExists) == 1 then
    return 2;
end
local num = redis.call("get",qtkey);
if tonumber(num)<=0 then
    returnn 0;
else
    redis.call("decr",qtkey);
    redis.call("sadd",userKey,userid);
end
retuen 1;

  大数据 最新文章
实现Kafka至少消费一次
亚马逊云科技:还在苦于ETL?Zero ETL的时代
初探MapReduce
【SpringBoot框架篇】32.基于注解+redis实现
Elasticsearch:如何减少 Elasticsearch 集
Go redis操作
Redis面试题
专题五 Redis高并发场景
基于GBase8s和Calcite的多数据源查询
Redis——底层数据结构原理
上一篇文章      下一篇文章      查看所有文章
加:2022-10-31 12:04:09  更:2022-10-31 12:07:56 
 
开发: C++知识库 Java知识库 JavaScript Python PHP知识库 人工智能 区块链 大数据 移动开发 嵌入式 开发工具 数据结构与算法 开发测试 游戏开发 网络协议 系统运维
教程: HTML教程 CSS教程 JavaScript教程 Go语言教程 JQuery教程 VUE教程 VUE3教程 Bootstrap教程 SQL数据库教程 C语言教程 C++教程 Java教程 Python教程 Python3教程 C#教程
数码: 电脑 笔记本 显卡 显示器 固态硬盘 硬盘 耳机 手机 iphone vivo oppo 小米 华为 单反 装机 图拉丁

360图书馆 购物 三丰科技 阅读网 日历 万年历 2024年11日历 -2024/11/26 10:26:54-

图片自动播放器
↓图片自动播放器↓
TxT小说阅读器
↓语音阅读,小说下载,古典文学↓
一键清除垃圾
↓轻轻一点,清除系统垃圾↓
图片批量下载器
↓批量下载图片,美女图库↓
  网站联系: qq:121756557 email:121756557@qq.com  IT数码