当前位置: 首页 > news >正文

Redisson分布式锁实战

实战来源

此问题基于电商

这周遇见这么一个问题,简略的说一下

MQ发布了两个消息,一个是订单新增,一个是订单状态变更

由于直接付款之后,这两个消息的发布时间不分先后,可能会造成两种情况,1、订单状态变更在订单新增之前;2、订单新增在订单状态变更之前

逻辑二没有问题,有问题的是逻辑一,如果订单状态变更在订单新增之前,那么连新建订单都没有入库,怎么能改变订单的状态呢

为了完成这个逻辑就需要使用锁来让两个业务同步,必须让新建订单在订单状态变更之前,我这里使用的是基于Redisson的分布式Redis

前提,需要了解Redisson分布式锁、redis

redisson:Redis实现分布式锁原理和Redisson框架实现分布式锁,全网最详细讲解_

redis工具类:Redis工具类(redisTemplate)以及 redisTemplate 的用法

代码如下,从MQ取消息的的逻辑我就不写了

这里的代码还是有问题的,但在生产中95%可能遇不见,要么服务器炸了,要么redis挂了,要么其他人的接口被人发现漏洞随意调用,导致MQ传递参数有误,那么都是别人的问题,跟我们没关系

因为同一订单,订单新建和订单状态变更的订单号就是一样的,我用Redis做了以下三个K-V键值对

1、redis的key="前缀_STATUS_SYNCHRONIZATION_" + json.getString("订单号")

这个是,redis锁的key保证新建订单和订单状态变更的主要逻辑能同步valueredisson生成我们不用管,只用管超时时间就好了

2、redis的key="前缀_NEW_ORDER_" + json.getString("订单号")

这个是,判断是否新建订单在订单状态变更之前,有下述两种情况

  • 如果新建订单在订单状态变更之前,那么新建订单时会存入这个2中的redisK-V值,在订单状态变更的时候会用redis访问2中的key发现不为空(redis存在2中的K-V关系),就直接走入库操作
  • 如果订单状态变更在新建之前,访问redis2的这个key发现为空(redis不存在2中的K-V关系),就用下述3中的K-V把需要入库的订单状态变更的实体类存起来,由新建订单时候调用时。新建订单时发现下述3中的K-V存在就说明订单状态变更在新建订单之前,就需要把下述3中的V取出来做入库处理,否则就认为新建订单在订单状态变更之前,就不需要做处理

value无所谓是什么,不重要,我这里就写的value=等待付款 没什么特殊含义。设置了两个小时的超时时间,因为订单超过两个小时了就不让付款了

3、redis的key="前缀_STATUS_PUSH_" + json.getString("订单号")

这个是,如果订单状态变更在新建订单之前,那么我就存进去,由新建的时候判断是否存在这个值,如果存在就说明订单在状态变更之前,就取出这个key对应的value(因为我们存的就是订单状态变更时需要的数据)做入库处理,不存在说明新建订单在订单状态变更之前就不需要做处理

	/*** 我的redis工具类,在前提中有*/@Autowiredprivate RedisUtil redisUtil;/*** redisson,只需要配置一个配置类就可以使用了,可以看前提中redisson的文章*/@Resourceprivate Redisson redisson;/*** 订单状态变更* @param json* @return*/public boolean orderStatusChange(JSONObject json){try {// ...// 上面拼接需要入库的逻辑得到订单状态变更的实体类信息,不可能把源码展示出来,我仅放关键代码,order 就相当于从 MQ 获取的内容封装成了实体类 orderOrder order = new Order();// 主要看下面的代码// 只有付款的时候走此逻辑,因为可能出现,直接付款,状态推送和新建订单一起发过来且付款先执行的操作if (json.getString("code").equals("付款的code")){// 如果已付款是先执行就先缓存由新建调用RLock lock = redisson.getLock("前缀_STATUS_SYNCHRONIZATION_" + json.getString("订单号"));// 60秒自旋拿锁,拿到锁之后持有60秒 (如果后面的值 <0 的话会使用开门狗机制,一直持有锁,除非项目挂掉了)boolean success = lock.tryLock(60L, 60L, TimeUnit.SECONDS);try {// 判断新建订单执行了吗,因为我的逻辑是如果新建订单执行后会执行下述注解中的代码,存一个两小时的 redis 缓存,因为新建订单之后两个小时不付款就取消订单了// 这是新建订单后设置的值: redisUtil.set("前缀_NEW_ORDER_" + json.getString("订单号"),"已经新建订单",7200);if (redisUtil.get("前缀_NEW_ORDER_" + json.getString("订单号")) == null){// 如果为上诉为空,说明订单状态变更在订单新增之前,我们就缓存一下300秒,至于多少秒看着办吧,300就太多了,但不影响redisUtil.set("前缀_STATUS_PUSH_" + json.getString("订单号"),JSON.toJSONString(order),300);// 因为在之前就不需要执行之后的代码了,返回就行return true;}// 删除redis多余的keyredisUtil.delete("前缀_ORDER_" + json.getString("订单号"));} catch (Exception e) {logger.error("订单状态推送同步锁失效",e);}finally {// 判断当前线程是否持有锁if (success && lock.isHeldByCurrentThread()) {lock.unlock();}}}// 如果新增在订单状态变更之前就可以直接入库了,如果订单状态变更在新建之前的话,上面有return操作,就不会执行入库操作statusChangeReceiptOperation(order);return true;} catch (Exception e) {logger.error("订单状态变更 报错:",e);return false;}}/*** 订单状态变更入库操作* @param order*/private void statusChangeReceiptOperation(Order order){try {// 订单状态变更入库操作。。。} catch (Exception e) {logger.error("订单状态变更报错:",e);}}/*** 新建订单*/public boolean newOrder(JSONObject json){try {// 入库操作,因为订单新增肯定是最开始的,所以根据json的参数直接入库就行了,我就不写了// 。。。// 加和上述相同的锁,因为订单号是一样的RLock lock = redisson.getLock("前缀_STATUS_SYNCHRONIZATION_" + json.getString("订单号"));// 60秒自旋拿锁,拿到锁之后持有60秒 (如果后面的值 <0 的话会使用开门狗机制,一直持有锁,除非项目挂掉了)boolean success = lock.tryLock(60L, 60L, TimeUnit.SECONDS);try {// 设置两个小时缓存,超时就认为不付款了redisUtil.set("前缀_NEW_ORDER_" + json.getString("订单号"),"等待付款",7200);// 去拿订单状态变更设置的redis的k-v键值对Object o = redisUtil.get("前缀_STATUS_PUSH_" + json.getString("订单号"));// 判断这里为不为空,因为加了锁,为空说明新增在订单状态变更之前,不需要多余操作if (o != null){// 如果不为空,说明状况变更在新增之前,取值然后入库JSONObject out2 = JSON.parseObject(o.toString());// json转为实体类Order order = JSONObject.toJavaObject(out2,Order.class);// 入库statusChangeReceiptOperation(order);// 删除redis多余的keyredisUtil.delete("前缀_STATUS_PUSH_" + json.getString("订单号"));}} catch (Exception e) {logger.error("订单新建推送同步锁失效",e);}finally {// 判断当前线程是否持有锁if (success && lock.isHeldByCurrentThread()) {lock.unlock();}}return true;} catch (Exception e) {logger.error("新建导购商户订单:",e);return false;}}

我遇见的问题

Factory method 'redisson' threw exception; nested exception is java.lang.NoSuchMethodError: io.netty.util.NetUtil.isIpV4StackPreferred()Z

猜测原因:NetUtil没有redisson需要的isIpV4StackPreferred()方法

排查:发现两个相同的class文件,那么肯定是jar包冲突了

在这里插入图片描述

查看依赖:

在这里插入图片描述

发现是这个包有问题:

在这里插入图片描述

去pom文件中排除:

在这里插入图片描述

总结

这只是我的思路和解决方法,如果有大佬有更好的办法,希望可以劳烦跟我探讨一下,共同成长,万分感谢

相关文章:

Redisson分布式锁实战

实战来源 此问题基于电商 这周遇见这么一个问题&#xff0c;简略的说一下 由MQ发布了两个消息&#xff0c;一个是订单新增&#xff0c;一个是订单状态变更 由于直接付款之后&#xff0c;这两个消息的发布时间不分先后&#xff0c;可能会造成两种情况&#xff0c;1、订单状态变更…...

JavaScript中循环遍历数组、跳出循环和继续循环

循环遍历数组 上个文章我们简单的介绍for循环&#xff0c;接下来&#xff0c;我们使用for循环去读取数据的数据&#xff0c;之前我们写过这样的一个数组&#xff0c;如下&#xff1a; const ITshareArray ["张三","二愣子","2033-1997","…...

Java——》Synchronized和Lock区别

推荐链接&#xff1a; 总结——》【Java】 总结——》【Mysql】 总结——》【Redis】 总结——》【Kafka】 总结——》【Spring】 总结——》【SpringBoot】 总结——》【MyBatis、MyBatis-Plus】 总结——》【Linux】 总结——》【MongoD…...

JDK20 + SpringBoot 3.1.0 + JdbcTemplate 使用

JDK20 SpringBoot 3.1.0 JdbcTemplate 使用 一.测试数据库 Postgres二.SpringBoot项目1.Pom 依赖2.配置文件3.启动类4.数据源配置类5.实体对象类包装类6.测试用实体对象1.基类2.扩展类 7.测试类 通过 JdbcTemplate 直接执行 SQL 语句&#xff0c;结合源码动态编译即可方便实现…...

CTFhub_SSRF靶场教程

CTFhub SSRF 题目 1. Bypass 1.1 URL Bypass 请求的URL中必须包含http://notfound.ctfhub.com&#xff0c;来尝试利用URL的一些特殊地方绕过这个限制吧 1.利用?绕过限制urlhttps://www.baidu.com?www.xxxx.me 2.利用绕过限制urlhttps://www.baidu.comwww.xxxx.me 3.利用斜…...

【华为OD机试】单词接龙【2023 B卷|100分】

【华为OD机试】-真题 !!点这里!! 【华为OD机试】真题考点分类 !!点这里 !! 题目描述: 单词接龙的规则是:可用于接龙的单词首字母必须要前一个单词的尾字母相同; 当存在多个首字母相同的单词时,取长度最长的单词,如果长度也相等, 则取字典序最小的单词;已经参与接龙…...

如何优雅的实现无侵入性参数校验之spring-boot-starter-validation

在开发过程中&#xff0c;参数校验是一个非常重要的环节。但是&#xff0c;传统的参数校验方法往往需要在代码中手动添加大量的 if-else 语句&#xff0c;这不仅繁琐&#xff0c;而且容易出错。为了解决这个问题&#xff0c;我们可以使用无侵入性参数校验的方式来简化代码并提高…...

企业架构LNMP学习笔记27

Keepalived的配置补充&#xff1a; 脑裂&#xff08;裂脑&#xff09;&#xff1a;vip出现在了多台机器上。网络不通畅&#xff0c;禁用了数据包&#xff0c;主备服务器没法通讯&#xff0c;造成备服务器认为主服务器不可用&#xff0c;绑定VIP&#xff0c;主服务器VIP不会释放…...

品牌策划经理工作内容|工作职责|品牌策划经理做什么?

一位美国作家曾说过“品牌是一系列期望、记忆、故事和关系&#xff0c;他们共同构成了消费者最终原则一个产品或者服务的原因。” 所以&#xff0c;品牌经理这个岗位主要是创造感知价值主张&#xff0c;激发消费者购买这个品牌后带来的感知价值&#xff0c;这种回报的本质相对…...

【设计模式】三、概述分类+单例模式

文章目录 概述设计模式类型 单例模式饿汉式&#xff08;静态常量&#xff09;饿汉式&#xff08;静态代码块&#xff09;懒汉式(线程不安全)懒汉式(线程安全&#xff0c;同步方法)懒汉式(线程安全&#xff0c;同步代码块)双重检查静态内部类枚举单例模式在 JDK 应用的源码分析 …...

手把手教学 Springboot+ftp+下载图片

简单教学&#xff0c;复制即用的Ftp下载图片 引入配置包 <dependency><groupId>commons-fileupload</groupId><artifactId>commons-fileupload</artifactId><version>1.3.1</version></dependency><dependency><grou…...

LaaS LLM as a service

LaaS LLM as a service 核心构成GPT 产业链如何进行商业化LLM(Large Language Model) 发展和趋势LLM(Large Language Model) 对于行业公司的分层LLM(Large Language Model) 的机遇和挑战 LaaS LLM as a service 核心构成 计算&#xff1a;算力模型&#xff1a;算法输入&…...

数据结构与算法(一)数组的相关概念和底层java实现

一、前言 从今天开始&#xff0c;笔者也开始从0学习数据结构和算法&#xff0c;但是因为这次学习比较捉急&#xff0c;所以记录的内容并不会过于详细&#xff0c;会从基础和底层代码实现以及力扣相关题目去写相关的文章&#xff0c;对于详细的概念并不会过多讲解 二、数组基础…...

歌曲推荐《最佳损友》

最佳损友 陈奕迅演唱歌曲 《最佳损友》是陈奕迅演唱的一首粤语歌曲&#xff0c;由黄伟文作词&#xff0c;Eric Kwok&#xff08;郭伟亮&#xff09;作曲。收录于专辑《Life Continues》中&#xff0c;发行于2006年6月15日。 2006年12月26日&#xff0c;该曲获得2006香港新城…...

多元共进|科技促进艺术发展,助力文化传承

科技发展助力文化和艺术的传播 融合传统与创新&#xff0c;碰撞独特魅力 一起来了解 2023 Google 开发者大会上 谷歌如何依托科技创新 推动艺术与文化连接 传承和弘扬传统文化 自 2011 年成立以来&#xff0c;谷歌艺术与文化致力于提供体验艺术和文化的新方式&#xff0c;从生成…...

Java集合(Collection、Iterator、Map、Collections)概述——Java第十三讲

前言 本讲我们将继续来讲解Java的其他重要知识点——Java集合。Java集合框架是Java编程语言中一个重要的部分,它提供了一套预定义的类和接口,供程序员使用数据结构来存储和操作一组对象。Java集合框架主要包括两种类型:一种是集合(Collection),存储一个元素列表,…...

topscoding主题库模板题

目录 模板题 【模板题】分因数&#xff08;P1101&#xff09; 【模板题】区间素数 III&#xff08;P1113&#xff09; 进制转换 III (任意转任意) &#xff08;P2463&#xff09; AB Problem&#xff08;高精度加法&#xff09; A-B Problem&#xff08;高精度减法&…...

Linux--进程间通讯--FIFO(open打开)

1. 什么是FIFO FIFO命名管道&#xff0c;也叫有名管道&#xff0c;来区分管道pipe。管道pipe只能用于有血缘关系的进程间通信&#xff0c;但通过FIFO可以实现不相关的进程之间交换数据。FIFO是Linux基础文件类型中的一种&#xff0c;但是FIFO文件在磁盘上没有数据块&#xff0c…...

哪里可以了解轻量的工作流引擎?

如果想要实现高效率的办公&#xff0c;可以使用轻量的工作流引擎低代码技术平台。随着工作量日益繁重起来&#xff0c;传统的办公制作方式已经无法满足现实需要的&#xff0c;采用轻量级的表格制作工具&#xff0c;就能在无形中缓解办公压力&#xff0c;创造更高效、灵活、优质…...

lvs负载均衡、LVS集群部署

四&#xff1a;LVS集群部署 lvs给nginx做负载均衡项目 218lvs&#xff08;DR 负载均衡器&#xff09; yum -y install ipvsadm&#xff08;安装这个工具来管理lvs&#xff09; 设置VIP192.168.142.120 创建ipvsadm的文件用来存放lvs的规则 定义策略 ipvsadm -C //清空现有…...

如何应对核心员工提离职?

最近一年互联网行情不好&#xff0c;很多大厂都在裁员&#xff0c;但裁员并不是不要人做事了。原来你这个岗位10个人做&#xff0c;企业有钱赚养得起&#xff0c;现在企业不怎么赚钱了&#xff0c;只能养4个人了。那么会有六个被裁掉。这时候对企业价值最大的4个人会被留下。也…...

建站系列(八)--- 本地开发环境搭建(WNMP)

目录 相关系列文章前言一、准备工作二、Nginx安装三、MySQL安装四、PHP安装及Nginx配置五、总结 相关系列文章 建站系列&#xff08;一&#xff09;— 网站基本常识 建站系列&#xff08;二&#xff09;— 域名、IP地址、URL、端口详解 建站系列&#xff08;三&#xff09;— …...

21天学会C++:Day8----范围for与nullptr

目录 ​编辑 1. 范围for 2. nullptr 1. 范围for 我们在写C语言循环遍历代码的时候&#xff0c;无论是用 for循环&#xff0c;while循环都需要考虑循环的起始条件&#xff0c;循环变量的递增逻辑&#xff0c;循环的结束条件。麻烦不说还可能会出错。 int main() {int arr[]…...

Linux——环境变量

✅<1>主页&#xff1a;&#xff1a;我的代码爱吃辣 &#x1f4c3;<2>知识讲解&#xff1a;Linux——环境变量 ☂️<3>开发环境&#xff1a;Centos7 &#x1f4ac;<4>前言&#xff1a;环境变量(environment variables)一般是指在操作系统中用来指定操作…...

Screen的详细全面安装教程及Screen的用法

Screen可以大大提高终端使用效率&#xff0c;是Linux系统管理和运维的必备技能。当我们开启Screen后&#xff0c;只要Screen进程没有终止&#xff0c;其内部运行的会话都可以恢复。即使网络连接中断&#xff0c;用户也可以重新进入已开启的Screen中&#xff0c;对中断的会话进行…...

生成树、Prufer序列的计数问题:0912T1

看到生成树计数&#xff0c;很容易想到生成树计数 然后发现每个点有度数限制&#xff0c;我们可以先考虑枚举每个点的度数&#xff08;也可以是Prufer 序列中的出现次数&#xff09; 假设出现次数为 a a a&#xff0c;可以得出其生成树方案为 n ! ∏ ( a i − 1 ) ! \frac{…...

SQL_牛客网_SQL264_求每个登陆日期的次日留存率

牛客每个人最近的登录日期(五) 牛客每天有很多人登录&#xff0c;请你统计一下牛客每个日期新用户的次日留存率。 有一个登录(login)记录表&#xff0c;简况如下: id user_id client_id date 1 2 1 2020-10-12 2 3 2 2020-10-12 3 1 2 2020-10-…...

Hive 基础知识

目录 1.基础概念1.1 定义1.2 组件1.3 元数据1.4 内部表和外部表 2. Hive与关系型数据库的对比3. Hive 数据存储4. 参考文献 1.基础概念 1.1 定义 Hive是一个基于Hadoop的数据仓库基础设施工具&#xff0c;它可以将结构化的数据文件映射为一张数据库表&#xff0c;并提供类SQL查…...

【数据结构】树的基础知识及三种存储结构

&#x1f490; &#x1f338; &#x1f337; &#x1f340; &#x1f339; &#x1f33b; &#x1f33a; &#x1f341; &#x1f343; &#x1f342; &#x1f33f; &#x1f344;&#x1f35d; &#x1f35b; &#x1f364; &#x1f4c3;个人主页 &#xff1a;阿然成长日记 …...

ABB 3BHB003688R0101接口模块

通信接口&#xff1a;接口模块通常具有多种通信接口&#xff0c;如以太网、串行通信、Modbus、Profibus等&#xff0c;以便与其他设备和系统进行数据交换。 协议支持&#xff1a;它们支持各种通信协议&#xff0c;确保与不同制造商的设备和控制系统兼容。 数据转换和适配&…...

seo技术快速网站排名/最近的热点新闻

据前程无忧的网上调查显示&#xff0c;尽管“金三银四”和“金九银十”的说法仍然存在&#xff0c;但近年来跳槽一族对跳槽时机的掌握明显已经灵活多了&#xff1a;超过一半&#xff08;50.11%&#xff09;的求职者认为何时跳槽并不重要&#xff0c;机会成熟了随时都可以行动&a…...

汪清县 党风廉政建设网站/nba最新消息交易

高度之间的关系可以改写成一个递推式&#xff1a;Hi1 2Hi - Hi-1 2。Hn和Hi之间是正相关的。 思路见注释。&#xff08;一开始是那么想的&#xff0c;其实不用矩阵快速幂&#xff0c;二分H2也可以。 /********************************************************* * …...

做民宿最大的网站/seo优化教学视频

1. 最简单的方法是用base64: import base64 s1 base64.encodestring(hello world) s2 base64.decodestring(s1) print s1,s2 # aGVsbG8gd29ybGQ\n # hello world Note: 这是最简单的方法了&#xff0c;但是不够保险&#xff0c;因为如果别人拿到你的密文&#xff0c;也可以自…...

高端企业门户网站建设费用/搜索引擎网站

原文地址&#xff1a;Go面试看这里了~&#xff08;三&#xff09; 1、数组和切片的区别&#xff1f; 切片是指针类型&#xff0c;数组是值类型。 数组的长度是固定的&#xff0c;切片不是&#xff0c;切片是动态的。 切片比数组多一个容量【cap】属性。 切片的底层是数组。…...

网店网站技术方案/seo属于运营还是技术

本文实例讲述了PHP命名空间简单用法。分享给大家供大家参考&#xff0c;具体如下&#xff1a;有三个文件&#xff0c;分别是space1.php&#xff0c;space2.php&#xff0c;use.php吧&#xff0c;在同一目录里。space1.php&#xff1a;namespace MyNamespace\Factory;class Empl…...

有什么网站交互做的很好 知乎/福州百度推广电话

转载自https://mp.weixin.qq.com/s/MD2-xMWWXx7rpfWzd5XDxA 非常不错的总结 根据这几年的积累&#xff0c;整理了一份国内外学术界和工业界的牛人和大牛团队&#xff0c;供大家申请硕士、博士、博士后和找工作参考。 学校&#xff08;排名不分先后&#xff09;&#xff1a; 哈工…...