分布式锁定-再释放
最编程
2024-04-15 07:07:03
...
5、分布式锁-redission
5.1 分布式锁-redission功能介绍
基于setnx实现的分布式锁存在下面的问题：
重入问题：重入问题是指 获得锁的线程可以再次进入到相同的锁的代码块中，可重入锁的意义在于防止死锁，比如HashTable这样的代码中，他的方法都是使用synchronized修饰的，假如他在一个方法内，调用另一个方法，那么此时如果是不可重入的，不就死锁了吗？所以可重入锁他的主要意义是防止死锁，我们的synchronized和Lock锁都是可重入的。
不可重试：是指目前的分布式只能尝试一次，我们认为合理的情况是：当线程在获得锁失败后，他应该能再次尝试获得锁。
**超时释放：**我们在加锁时增加了过期时间，这样的我们可以防止死锁，但是如果卡顿的时间超长，虽然我们采用了lua表达式防止删锁的时候，误删别人的锁，但是毕竟没有锁住，有安全隐患
主从一致性： 如果Redis提供了主从集群，当我们向集群写数据时，主机需要异步的将数据同步给从机，而万一在同步过去之前，主机宕机了，就会出现死锁问题。
那么什么是Redission呢
Redisson是一个在Redis的基础上实现的Java驻内存数据网格（In-Memory Data Grid）。它不仅提供了一系列的分布式的Java常用对象，还提供了许多分布式服务，其中就包含了各种分布式锁的实现。
Redission提供了分布式锁的多种多样的功能
上一篇： 设计模式 (013) 行为观察者模式
下一篇： 设计模式系列：简单工厂模式
推荐阅读
-
分布式锁定-再释放
-
Redis 分布式锁定：微服务架构中确保并发控制和数据一致性的实用指南
-
趣谈留言队列，搞清楚留言队列到底是什么！-说到消息队列，洪觉大概能猜到人们听到消息队列的反应，大致可以分为以下几类人。 第一类人，懵懵懂懂，刚上大学接触编程，还没用过消息队列，甚至还以为消息队列就是代码里面要新建一个List之类的；第二类人，听过消息队列，了解消息队列，但具体是什么还不是太明白，只知道一说到消息队列，脑海里马上出现了三组词，削峰、异步、解耦；第三类人，用过消息队列，对它有一定了解，但不知道为什么要这样设计，消息队列有什么样的前世今生，是如何演化到现在的模式的？**第四类人，已经对消息队列有了足够的了解，可以阅读本帖作为复习和温习。**你属于哪一类？无论你对消息队列了解多少，读完这篇文章后，我相信你都会有所收获。 什么是消息队列？我们为什么要使用消息队列？真的只是因为它看起来很勉强、很常用吗？当然不是，一项技术的出现往往是为了解决某种痛点，我们就从这个痛点出发，看看消息队列到底是为了解决什么问题而诞生的。 相信大家在工作之前，或者工作中接触单片机的次数会多一点，不管什么业务都一股脑塞进一个系统里，这种情况下接触消息队列的场景会比较少。但随着业务的增长，量上去了，单机系统就很难维护了，也扛不住并发量的增长，就需要把原来的单体应用拆分成多个服务。例如，牛奇网采用分布式架构，将原来的单体系统拆分成用户服务、题库服务、求职服务、论坛服务等，每个分布式节点都有一个集群，保证高可用性。 那虽然在这样的微服务架构下，如果某个核心业务并发量过大，系统就扛不住了。比如淘宝、淘票票、拼多多、京东等电商场景中的支付场景，你在某宝下单并支付后，调用支付服务，完成支付后，还需要更新订单的状态，这个时候就需要调用订单服务，那我们平时也下单，除了简单完成这些操作外，还会给你相应的积分；商家也会收到订单消息，并给您发送旺旺消息，确认订单无误；同时，也会给您发送消息，确认订单无误。确认订单无误；同时您还可以查看您的物流状态；还有系统为了给您推荐更适合您的商品，会根据您的订单做类似的推荐等等，我说的这些都是当我们下单后，肉眼可以感知到系统所做的动作。 **一个支付动作如果还需要调用那么多服务，等他们响应成功，最后再告诉用户你支付成功了，用户在系统中的整个体验会非常糟糕。**设想一下，假设请求服务+处理请求+响应总共需要 50ms，我们上面列出的场景：支付服务、订单服务、积分服务、商家服务、物流服务、推荐服务，总共需要 300ms。
-
反传销网8月30日发布：视频区块链里的骗子，币里的韭菜，杜子建骂人了！金融大V周召说区块链！——“一小帮骗子玩一大帮小白，被割韭菜，小白还轮流被割，割的就是你！” 什么区块链，统统是骗子 作者：周召（知乎金融领域大Ｖ，毕业于上海财经大学，目前任职上海某股权投资基金合伙人） 有人问我，区块链现在这么火，到底是不是骗局？ 我的回答是： 是骗局。而且我并不是说数字货币是骗局，而是说所有搞区块链的都是骗局。 -01- 区块链是一种鸡肋技术 人类社会任何技术的发明应用，本质都是为了提高社会的生产效率。而所谓区块链技术本质不过是几种早已成熟的技术的大杂烩，冗余且十分低效，除了提高了洗钱和诈骗的效率以外，对人类社会的进步毫无贡献。 真正意义上的区块链得包含三个要素：分布式系统（包括记账和存储），无法篡改的数据结构，以及共识算法，三者互为基础和因果，就像三体世界一样。看上去挺让人不明觉厉的，而经过几年的瞎折腾，稍微懂点区块链的碰了几次壁后都已经渐渐明白区块链其实并没有什么卵用，区块链技术已经名存实亡，沦为了营销工具和传销组织的画皮。 因为符合上述定义的、以比特币为代表的原教旨区块链技术，是反效率的，从经济学角度来说，不但不是一种帕累托改进，甚至还可以说是一种帕累托倒退。 原教旨区块链技术的效率十分低下，因为要遍历所有节点，只能做非常轻量级的数据应用，一旦涉及到大量的数据传输与更新，区块链就瞎了。 一方面整条链交易速度会极慢，另一方面数据库容量极速膨胀，考虑到人手一份的存储机制，区块链其实是对存储资源和能源的一种极大的浪费。 这里还没有加上为了取得所谓的共识和挖矿消耗的巨大的能源，如果说区块链技术是屎，那么这波区块链投机浪潮可谓人类历史上最大规模的搅屎运动。 区块链也验证不了任何东西。 所谓的智能合约，即不智能，也非合约。我看有人还说，如果有了智能合约，就可以跟老板签一份放区块链上，如果明年销售业绩提升30%，就加薪10%，由于区块链不能篡改，不能抵赖，所以老板必须得执行，说得有板有眼，不懂行的愣一看，好像还真是那么回事。 但仔细一想，问题就来了。首先，在区块链上如何证明你真的达到了30%业绩提升？即便真的达到老板耍赖如何执行？ 也就是说，如果区块链真这么厉害，要法院和仲裁干什么。 人类社会真正的符合成本效益原则的是代理制度。之前有人说要用区块链改造注册会计师行业，我不知道他准备怎么设计，我猜想他思路大概是这样的，首先肯定搞去中心化，让所有会计师到链上来，然后一个新人要成为注册会计师就要所有会计师同意并记录在链上。 那我就请问了，我每天上班累死累活，为什么还要花时间去验证一个跟我无关的的人的专业能力？最优做法当然是组织一个委员会，让专门的人来负责，这不就是现在注册会师协会干的事儿吗？区块链的逻辑相当于什么事情都要拿出来公投，这个绝对是扯淡的。 当然这么说都有点抬举区块链了，区块链技术本身根本没有判断是非能力，如果这么高级的人工智能，靠一个无脑分布式记账就能实现的话，我们早就进入共产主义社会了。 虽然EOS等数字货币采用了超级节点，通过再中心化的方式提高效率，有点行业协会的意思，是对区块链原教旨主义的一种修正，但是依然无法突破区块链技术最本质的局限性。有人说，私有链和联盟链是区块链技术的未来，也是扯淡，因为区块链技术没有未来。如果有，说明他是包装成区块链的伪区块链技术。 区块链所涉及的所有底层技术，不管是分布式数据库技术，加密技术，还是点对点传输技术等，基本都是早已存在没什么秘密可言的技术。 比特币系统最重要的特性是封闭性和自洽性，他验证不了任何系统自身以外产生的信息的真实性。 所谓系统自身产生的信息，就是数据库数据的变动信息，有价值的基本上有且只有交易信息。所以说比特币最初不过是中本聪一种炫技的产物，来证明自己对几种技术的掌握，你看我多牛逼，设计出了一个像三体一样的系统。因此，数字货币很有可能是区块链从始至终唯一的杀手应用。 比特币和区块链概念从诞生到今天已经快10年了，很多人说区块链技术在爆发的前夜，但这个前夜好像是不是有点过长了啊朋友，跟三体里的长夜有一拼啊。都说区块链技术像是90年代初的互联网，可是90年代初的互联网在十年发展后，已经出现了一大批伟大的公司，阿里巴巴在99年都成立了，区块链怎么除了币还是币呢？ 正规的数字货币未来发展的形式无外乎几种，要么就是论坛币形式，或者类似股票的权益凭证等。问题是论坛币和股票之前，本来也都电子化了，区块链来了到底改变了什么呢？ 所有想把TOKEN和应用场景结合起来的人最后都很痛苦，最后他们会发现区块链技术就是脱裤子放屁，自己辛苦搞半天，干嘛不自己作为中心关心门来收钱？最后这些人都产生了价值的虚无感，最终精神崩溃，只能发币疯狂收割韭菜，一边嘴里还说着我是个好人之类的奇怪的话。 因此，之前币圈链圈还泾渭分明，互相瞧不起，但这两年链圈逐渐坐不住了，想着是不是趁着泡沫没彻底破灭之前赶快收割一波，不然可能什么都捞不着了。 前段时间和一个名校毕业的链圈朋友瞎聊天，他说他们“致力于用区块链技术解决数字版权保护问题”，我就问他一个问题，你们如何保证你链的版权所有权声明是真实的，万一盗版者抢先一步把数据放在链上怎么办。他说他们的解决方案是连入国家数字版权保护中心的数据库进行验证…… 所以说区块链技术就是个鸡肋，研究到最后都会落入效率与真实性的黑洞，很多人一头扎进链圈后才发现，真正意义上的区块链技术，其实什么都干不了。 -02- 不是蠢就是坏的区块链媒体 空气币和区块链的造富神话，让区块链自媒体也开始迎风乱扭。一群群根本不知道区块链为何物的妖魔鬼怪纷纷进驻区块链自媒体战场，开始大放厥词胡编乱造。 任何东西，但凡只要和区块，链，分，分布式，记账，加密，验证，可追溯等等这些个关键词沾到哪怕一点点，这些所谓的区块链媒体人就会像狗闻到了屎了一样疯狂地把区块链概念往上套。 这让我想起曾经一度也是热闹非凡的物联网，我曾经去看过江苏一家号称要改变世界的“物联网”企业，过去一看是生产路由器的，我黑人问号脸，对方解释说没有路由器万物怎么互联，我觉得他说得好有道理，竟无言以对。 好，下面让我们进入奇葩共赏析时间，来看看区城链媒体经常有哪些危言耸听的奇谈怪论 区块链（分布式记账）的典型应用是*？？ 正如前面所说，真正意义上的区块链分布式记账，不光包括“记”这个动作，还包括分布式存储和共识机制等。而*诞生远远早于区块链这个词的出现，勉强算是“分布式编辑”吧，就被很多区块链媒体拿来强行充当区块链技术应用的典范。 其实事实恰恰相反，*恰恰是去中心化失败的典范，现在如果没有精英和专业人士的编辑和维护，*早就没法看了。 区块链会促进社会分工？？ 罗振宇好像就说过类似的话，虽然罗振宇说过很多没有逻辑的话，但这句话绝对是最没逻辑思维的。很多区块链自媒体也常常用这句话来忽悠老百姓，说分工代表效率提高社会进步，而区块链“无疑”会促进分工，他们的理由仅仅是分工和分布式记账都共用一个“分”字，就强行把他们扯到一起。 实际情况恰恰相反，区块链是逆分工的，区块链精神是号召所有人积极地参与到他不擅长也不想掺合的事情里面去。 区块链不能像上帝一样许诺他的子民死后上天国，只能给他们许诺你们是六度人脉中的第一级，我可以赚后面五级人的钱，你处于金字塔的顶端。
-
Semaphore 锁定和释放过程
-
2.Zookeeper集成springboot操作节点、事件监听器，实现分布式锁定
-
[Redis | 第 6 部分] 基于 Setnx | Redisson 实现分布式锁（深入了解 Redisson 的锁定、重入锁和看门狗机制）
-
获取分布式锁定的令牌操作详解
-
【Netty】「萌新入门」（七）ByteBuf 的性能优化-堆内存的分配和释放都是由 Java 虚拟机自动管理的，这意味着它们可以快速地被分配和释放，但是也会产生一些开销。 直接内存需要手动分配和释放，因为它由操作系统管理，这使得分配和释放的速度更快，但是也需要更多的系统资源。 另外，直接内存可以映射到本地文件中，这对于需要频繁读写文件的应用程序非常有用。 此外，直接内存还可以避免在使用 NIO 进行网络传输时发生数据拷贝的情况。在使用传统的 I/O 时，数据必须先从文件或网络中读取到堆内存中，然后再从堆内存中复制到直接缓冲区中，最后再通过 SocketChannel 发送到网络中。而使用直接缓冲区时，数据可以直接从文件或网络中读取到直接缓冲区中，并且可以直接从直接缓冲区中发送到网络中，避免了不必要的数据拷贝和内存分配。 通过 ByteBufAllocator.DEFAULT.directBuffer 方法来创建基于直接内存的 ByteBuf： ByteBuf directBuf = ByteBufAllocator.DEFAULT.directBuffer(16); 通过 ByteBufAllocator.DEFAULT.heapBuffer 方法来创建基于堆内存的 ByteBuf： ByteBuf heapBuf = ByteBufAllocator.DEFAULT.heapBuffer(16); 注意： 直接内存是一种特殊的内存分配方式，可以通过在堆外申请内存来避免 JVM 堆内存的限制，从而提高读写性能和降低 GC 压力。但是，直接内存的创建和销毁代价昂贵，因此需要慎重使用。 此外，由于直接内存不受 JVM 垃圾回收的管理，我们需要主动释放这部分内存，否则会造成内存泄漏。通常情况下，可以使用 ByteBuffer.clear 方法来释放直接内存中的数据，或者使用 ByteBuffer.cleaner 方法来手动释放直接内存空间。 测试代码： public static void testCreateByteBuf { ByteBuf buf = ByteBufAllocator.DEFAULT.buffer(16); System.out.println(buf.getClass); ByteBuf heapBuf = ByteBufAllocator.DEFAULT.heapBuffer(16); System.out.println(heapBuf.getClass); ByteBuf directBuf = ByteBufAllocator.DEFAULT.directBuffer(16); System.out.println(directBuf.getClass); } 运行结果： class io.netty.buffer.PooledUnsafeDirectByteBuf class io.netty.buffer.PooledUnsafeHeapByteBuf class io.netty.buffer.PooledUnsafeDirectByteBuf 池化技术 在 Netty 中，池化技术指的是通过对象池来重用已经创建的对象，从而避免了频繁地创建和销毁对象，这种技术可以提高系统的性能和可伸缩性。 通过设置 VM options，来决定池化功能是否开启： -Dio.netty.allocator.type={unpooled|pooled} 在 Netty 4.1 版本以后，非 Android 平台默认启用池化实现，Android 平台启用非池化实现； 这里我们使用非池化功能进行测试，依旧使用的是上面的测试代码 testCreateByteBuf，运行结果如下所示： class io.netty.buffer.UnpooledByteBufAllocator$InstrumentedUnpooledUnsafeDirectByteBuf class io.netty.buffer.UnpooledByteBufAllocator$InstrumentedUnpooledUnsafeHeapByteBuf class io.netty.buffer.UnpooledByteBufAllocator$InstrumentedUnpooledUnsafeDirectByteBuf 可以看到，ByteBuf 类由 PooledUnsafeDirectByteBuf 变成了 UnpooledUnsafeDirectByteBuf； 在没有池化的情况下，每次使用都需要创建新的 ByteBuf 实例，这个操作会涉及到内存的分配和初始化，如果是直接内存则代价更为昂贵，而且频繁的内存分配也可能导致内存碎片问题，增加 GC 压力。 使用池化技术可以避免频繁内存分配带来的开销，并且重用池中的 ByteBuf 实例，减少了内存占用和内存碎片问题。另外，池化技术还可以采用类似 jemalloc 的内存分配算法，进一步提升分配效率。 在高并发环境下，池化技术的优点更加明显，因为内存的分配和释放都是比较耗时的操作，频繁的内存分配和释放会导致系统性能下降，甚至可能出现内存溢出的风险。使用池化技术可以将内存分配和释放的操作集中到预先分配的池中，从而有效地降低系统的内存开销和风险。 内存释放 当在 Netty 中使用 ByteBuf 来处理数据时，需要特别注意内存回收问题。 Netty 提供了不同类型的 ByteBuf 实现，包括堆内存（JVM 内存）实现 UnpooledHeapByteBuf 和堆外内存（直接内存）实现 UnpooledDirectByteBuf，以及池化技术实现的 PooledByteBuf 及其子类。 UnpooledHeapByteBuf：通过 Java 的垃圾回收机制来自动回收内存； UnpooledDirectByteBuf：由于 JVM 的垃圾回收机制无法管理这些内存，因此需要手动调用 release 方法来释放内存； PooledByteBuf：使用了池化机制，需要更复杂的规则来回收内存; 由于池化技术的特殊性质，释放 PooledByteBuf 对象所使用的内存并不是立即被回收的，而是被放入一个内存池中，待下次分配内存时再次使用。因此，释放 PooledByteBuf 对象的内存可能会延迟到后续的某个时间点。为了避免内存泄漏和占用过多内存，我们需要根据实际情况来设置池化技术的相关参数，以便及时回收内存； Netty 采用了引用计数法来控制 ByteBuf 对象的内存回收，在博文 「源码解析」ByteBuf 的引用计数机制 中将会通过解读源码的形式对 ByteBuf 的引用计数法进行深入理解； 每个 ByteBuf 对象被创建时，都会初始化为1，表示该对象的初始计数为1。 在使用 ByteBuf 对象过程中，如果当前 handler 已经使用完该对象，需要通过调用 release 方法将计数减1，当计数为0时，底层内存会被回收，该对象也就被销毁了。此时即使 ByteBuf 对象还在，其各个方法均无法正常使用。 但是，如果当前 handler 还需要继续使用该对象，可以通过调用 retain 方法将计数加1，这样即使其他 handler 已经调用了 release 方法，该对象的内存仍然不会被回收。这种机制可以有效地避免了内存泄漏和意外访问已经释放的内存的情况。 一般来说，应该尽可能地保证 retain 和 release 方法成对出现，以确保计数正确。