Java学习者

作者：微信小助手

<section data-tool="mdnice编辑器" data-website="https://www.mdnice.com" style="line-height: 1.6;word-break: break-word;text-align: left;font-family: Optima-Regular, Optima, PingFangSC-light, PingFangTC-light, "PingFang SC", Cambria, Cochin, Georgia, Times, "Times New Roman", serif;font-size: 15px;color: rgb(53, 53, 53);word-spacing: 0.8px;letter-spacing: 0.8px;border-radius: 16px;" data-mpa-powered-by="yiban.io"> <h2 data-tool="mdnice编辑器" style="font-weight: bold;color: black;font-size: 22px;margin-top: 20px;margin-right: 10px;">一、前言</h2> 上一篇我们讲解了客户端首次获取注册表时，需要从注册中心全量拉取注册表到本地存着。那后续如果有客户端注册、下线的话，注册表肯定就发生变化了，这个时候客户端就得更新本地注册表了，怎么更新呢？下面我会带着大家一起来看下客户端第二次（这里代表全量获取后的下一次）获取注册表的方式。 题外话：之前写过一篇 Redis 主从同步的架构原理，里面也涉及到首次同步和第二次同步，其实原理也类似，但是 Redis 的主从同步原理要复杂些。强烈推荐配合着看一波： <a href="http://mp.weixin.qq.com/s?__biz=MzAwMjI0ODk0NA==&mid=2451958462&idx=1&sn=5380b7967443f88ef180ccd9db11fcc2&chksm=8d1c1321ba6b9a374ceeb993775d57800c4f98c3b5d4a85c3d3bc5eab649a2b0ca96c3db6c12&scene=21#wechat_redirect" style="color: rgb(248, 57, 41);border-bottom: 1px solid rgb(248, 57, 41);" data-linktype="2">镜 | 5 个维度深度剖析「主从架构」原理</a> <h2 data-tool="mdnice编辑器" style="font-weight: bold;color: black;font-size: 22px;margin-top: 20px;margin-right: 10px;">二、增量获取引发的问题</h2> 上面我们说到，当第一次获取全量信息后，本地就有注册信息了。那如果 Server 的注册表有更新，比如有服务注册、下线，Client 必须要重新获取一次注册表信息才行。 <blockquote data-tool="mdnice编辑器" style="border-top: none;border-right: none;border-bottom: none;font-size: 0.9em;overflow: auto;color: rgb(106, 115, 125);padding: 10px 10px 10px 20px;margin-bottom: 20px;margin-top: 20px;border-left-color: rgb(255, 177, 27);background: rgb(255, 245, 227);"> 那是否可以重新全量拉取一次呢？ </blockquote> 可以是可以，但是，如果注册表信息很大呢？比如有几百个微服务都注册上去了，那一次拉取是非常耗时的，而且占用网络带宽，性能较差，这种方案是不靠谱的。 所以我们就需要用增量拉取注册信息表的方式，也就是说只拉取变化的数据，这样数据量就比较小了。如下图所示： <figure data-tool="mdnice编辑器" style="margin-top: 10px;margin-bottom: 10px;display: flex;flex-direction: column;justify-content: center;align-items: center;border-radius: 16px;overflow: hidden;"> <img data-fileid="304477068" data-ratio="0.5828220858895705" src="/upload/75dc5501d362d7cc44522b3a7446cb6b.png" data-type="png" data-w="815" style="border-radius: 6px;display: block;margin: 20px auto;max-width: 95%;object-fit: contain;"> <figcaption style="margin-top: 5px;text-align: center;color: rgb(136, 136, 136);font-size: 12px;"> 增量获取注册表 </figcaption> </figure> 从源码里面我们可以看到，Eureka Client 通过调用 getAndUpdateDelta 方法获取增量的变化的注册表数据，Eureka Server 将变化的数据返回给 Client。 这里就有几个问题： <blockquote data-tool="mdnice编辑器" style="border-top: none;border-right: none;border-bottom: none;font-size: 0.9em;overflow: auto;color: rgb(106, 115, 125);padding: 10px 10px 10px 20px;margin-bottom: 20px;margin-top: 20px;border-left-color: rgb(255, 177, 27);background: rgb(255, 245, 227);"> （1）Client 隔多久进行一次增量获取？ （2）Server 将变化的数据存放在哪里？ （3）Client 如何将变化的数据合并到本地注册表里面？ </blockquote> 下面分别针对上面的几个问题进行解答。 <h2 data-tool="mdnice编辑器" style="font-weight: bold;color: black;font-size: 22px;margin-top: 20px;margin-right: 10px;">三、间隔多久同步一次？</h2> <h3 data-tool="mdnice编辑器" style="margin-top: 30px;margin-bottom: 15px;font-weight: bold;color: black;font-size: 20px;">3.1 默认间隔时间</h3> 默认每隔 30 s 执行一次同步，如下图所示： <figure data-tool="mdnice编辑器" style="margin-top: 10px;margin-bottom: 10px;display: flex;flex-direction: column;justify-content: center;align-items: center;border-radius: 16px;overflow: hidden;"> <img data-fileid="304477067" data-ratio="0.4857142857142857" src="/upload/8b17cb33f93060a7f1f11297e225390.png" data-type="png" data-w="490" style="border-radius: 6px;display: block;margin: 20px auto;max-width: 95%;object-fit: contain;"> <figcaption style="margin-top: 5px;text-align: center;color: rgb(136, 136, 136);font-size: 12px;"> 默认 30s 同步一次 </figcaption> </figure> 这个 30 s 就是由变量 client.refresh.interval 定义的。 Eureka 每 30 s 会调用一个后台线程去拉取增量注册表，这个后台线程的名字叫做：cacheRefresh。如下所示： <figure data-tool="mdnice编辑器" style="margin-top: 10px;margin-bottom: 10px;display: flex;flex-direction: column;justify-content: center;align-items: center;border-radius: 16px;overflow: hidden;"> <img data-fileid="304477070" data-ratio="0.5266457680250783" src="/upload/69d3572d578fd3ad65bcb3a05c39fb1f.png" data-type="png" data-w="638" style="border-radius: 6px;display: block;margin: 20px auto;max-width: 95%;object-fit: contain;"> <figcaption style="margin-top: 5px;text-align: center;color: rgb(136, 136, 136);font-size: 12px;"> 间隔时间的源码 </figcaption> </figure> <h3 data-tool="mdnice编辑器" style="margin-top: 30px;margin-bottom: 15px;font-weight: bold;color: black;font-size: 20px;">3.2 Client 发送拉取注册表的请求</h3> 就是调用 getDelta 方法，发送 HTTP请求调用 jersey 的 restful 接口，然后 Server 端的 Jersey 框架就会去处理这个请求了。发送请求的方法 getDelta 如下所示： <pre data-tool="mdnice编辑器" style="margin-top: 10px;margin-bottom: 10px;border-radius: 5px;box-shadow: rgba(0, 0, 0, 0.55) 0px 2px 10px;"><span style="display: block;background: url("https://mmbiz.qpic.cn/mmbiz_svg/ibKHP1TZZeXJcMdxaKL5xIqr9DpnY6trz4s5R2CQqYUEEQBU7DCabVJWONJGSp9WD9g5zwcBRXE2wnia0n7WHibCIfhEUW7zw5d/640?wx_fmt=svg") 10px 10px / 40px no-repeat rgb(250, 250, 250);height: 30px;width: 100%;margin-bottom: -7px;border-radius: 5px;"><code style="overflow-x: auto;padding: 16px;color: #383a42;display: -webkit-box;font-family: Operator Mono, Consolas, Monaco, Menlo, monospace;font-size: 12px;-webkit-overflow-scrolling: touch;padding-top: 15px;background: #fafafa;border-radius: 5px;">eurekaTransport.queryClient.getDelta(remoteRegionsRef.get()); restful 接口的地址就长这样： http://localhost:8080/v2/apps/delta </code></pre> 那么 Server 端如何过滤出增量的注册表信息呢？我们可以找到这个方法：getContainerDifferential。如下图所示： <figure data-tool="mdnice编辑器" style="margin-top: 10px;margin-bottom: 10px;display: flex;flex-direction: column;justify-content: center;align-items: center;border-radius: 16px;overflow: hidden;"> <img data-fileid="304477066" data-ratio="0.178335535006605" src="/upload/bbfe7509ac003c5b81ea965f8644d334.png" data-type="png" data-w="757" style="border-radius: 6px;display: block;margin: 20px auto;max-width: 95%;object-fit: contain;"> </figure> 这个方法主要干的活就是去获取最近改变的数据。接下来我们看下最近改变的数据存放在哪。 <h2 data-tool="mdnice编辑器" style="font-weight: bold;color: black;font-size: 22px;margin-top: 20px;margin-right: 10px;">四、变化的数据存放在哪？</h2> <h3 data-tool="mdnice编辑器" style="margin-top: 30px;margin-bottom: 15px;font-weight: bold;color: black;font-size: 20px;">4.1 数据结构</h3> 其实就是放在这个队列里面：recentlyChangedQueue。 它的数据结构是一个并发安全的链表队列 ConcurrentLinkedQueue。 链表里面存放的元素就是最近变化的注册信息 RecentlyChangedItem。 <pre data-tool="mdnice编辑器" style="margin-top: 10px;margin-bottom: 10px;border-radius: 5px;box-shadow: rgba(0, 0, 0, 0.55) 0px 2px 10px;"><span style="display: block;background: url("https://mmbiz.qpic.cn/mmbiz_svg/ibKHP1TZZeXJcMdxaKL5xIqr9DpnY6trz4s5R2CQqYUEEQBU7DCabVJWONJGSp9WD9g5zwcBRXE2wnia0n7WHibCIfhEUW7zw5d/640?wx_fmt=svg") 10px 10px / 40px no-repeat rgb(250, 250, 250);height: 30px;width: 100%;margin-bottom: -7px;border-radius: 5px;"><code style="overflow-x: auto;padding: 16px;color: #383a42;display: -webkit-box;font-family: Operator Mono, Consolas, Monaco, Menlo, monospace;font-size: 12px;-webkit-overflow-scrolling: touch;padding-top: 15px;background: #fafafa;border-radius: 5px;">ConcurrentLinkedQueue<RecentlyChangedItem> </code></pre> 当有客户端注册的时候，这个链表里面的尾部就会追加一个对象。 关于 ConcurrentLinkedQueue，还记得我之前写过的 18 种队列吗？不记得话看下这篇： <a href="https://mp.weixin.qq.com/s?__biz=MzAwMjI0ODk0NA==&mid=2451945316&idx=1&sn=2394559adb6b0aec9a70feaccc18b6a4&scene=21#wechat_redirect" style="color: rgb(248, 57, 41);border-bottom: 1px solid rgb(248, 57, 41);" data-linktype="2">45张图庖丁解牛18种Queue，你知道几种？</a> ConcurrentLinkedQueue 是由链表结构组成的线程安全的先进先出无界队列。如下图所示： <figure data-tool="mdnice编辑器" style="margin-top: 10px;margin-bottom: 10px;display: flex;flex-direction: column;justify-content: center;align-items: center;border-radius: 16px;overflow: hidden;"> <img data-fileid="304477074" data-ratio="0.29554655870445345" src="/upload/ceaaf5790b1ebe199e03956d80a5ca38.png" data-type="png" data-w="1235" style="border-radius: 6px;display: block;margin: 20px auto;max-width: 95%;object-fit: contain;"> <figcaption style="margin-top: 5px;text-align: center;color: rgb(136, 136, 136);font-size: 12px;"> ConcurrentLinkedQueue原理 </figcaption> </figure> <h3 data-tool="mdnice编辑器" style="margin-top: 30px;margin-bottom: 15px;font-weight: bold;color: black;font-size: 20px;">4.2 内部构造</h3> 我觉得这个队列的构造还是非常值得我们学习的，我们来看下这个队列的构造，如下图所示： <figure data-tool="mdnice编辑器" style="margin-top: 10px;margin-bottom: 10px;display: flex;flex-direction: column;justify-content: center;align-items: center;border-radius: 16px;overflow: hidden;"> <img data-fileid="304477075" data-ratio="0.838475499092559" src="/upload/87381415d33d4db6f9b4958eadae832d.png" data-type="png" data-w="551" style="border-radius: 6px;display: block;margin: 20px auto;max-width: 95%;object-fit: contain;"> <figcaption style="margin-top: 5px;text-align: center;color: rgb(136, 136, 136);font-size: 12px;"> 增量数据内部构造 </figcaption> </figure> <ul data-tool="mdnice编辑器" style="margin-top: 8px;margin-bottom: 8px;padding-left: 25px;color: rgb(248, 57, 41);font-size: 16px;" class="list-paddingleft-2"> <li> <section style="margin-top: 5px;margin-bottom: 5px;line-height: 26px;color: rgb(53, 53, 53);"> 这个队列里面存放的对象是最近改变的对象 <code style="font-size: 14px;padding: 2px 4px;border-radius: 4px;margin-right: 2px;margin-left: 2px;background-color: rgba(27, 31, 35, 0.05);font-family: "Operator Mono", Consolas, Monaco, Menlo, monospace;word-break: break-all;color: rgb(255, 93, 108);">RecentlyChangedItem</code>。 </section></li> <li> <section style="margin-top: 5px;margin-bottom: 5px;line-height: 26px;color: rgb(53, 53, 53);"> RecentlyChangedItem 存有三个元素：实例信息、操作类型和最后更新时间。 </section></li> <li> <section style="margin-top: 5px;margin-bottom: 5px;line-height: 26px;color: rgb(53, 53, 53);"> 实例信息：使用 Lease <instanceinfo> 保存一个客户端的注册表信息，这个在第四篇讲解注册表结构已经介绍过。 </instanceinfo> </section></li> <li> <section style="margin-top: 5px;margin-bottom: 5px;line-height: 26px;color: rgb(53, 53, 53);"> 操作类型：当有客户端发起注册、更新注册表、下线时，会设置 actionType，对应三种枚举值：新增、更新、删除。 </section></li> <li> <section style="margin-top: 5px;margin-bottom: 5px;line-height: 26px;color: rgb(53, 53, 53);"> 最后更新时间：客户端注册信息发生改变时，需要同时更新最后更新时间。 </section></li> </ul> <h3 data-tool="mdnice编辑器" style="margin-top: 30px;margin-bottom: 15px;font-weight: bold;color: black;font-size: 20px;">4.3 最近的数据</h3> 既然上面说到是最近改变的数据才会放进去，那这个最近是多近呢？1 分钟？2分钟？ 通过源码我们找到了这个默认配置，<code style="font-size: 14px;padding: 2px 4px;border-radius: 4px;margin-right: 2px;margin-left: 2px;background-color: rgba(27, 31, 35, 0.05);font-family: "Operator Mono", Consolas, Monaco, Menlo, monospace;word-break: break-all;color: rgb(255, 93, 108);">三分钟</code>刷新一次，也就是 180s 刷新一次。 <figure data-tool="mdnice编辑器" style="margin-top: 10px;margin-bottom: 10px;display: flex;flex-direction: column;justify-content: center;align-items: center;border-radius: 16px;overflow: hidden;"> <img data-fileid="304477071" data-ratio="0.17205882352941176" src="/upload/77ef0f4dd11850f9a57888e2aa6d2514.png" data-type="png" data-w="680" style="border-radius: 6px;display: block;margin: 20px auto;max-width: 95%;object-fit: contain;"> </figure> 那刷新了什么？刷新其实是会遍历这个队列：recentlyChangedQueue。 将队列里面的所有元素都遍历一遍，比对每个对象的最后更新时间是否超过了三分钟，如果超过了，就移除这个元素。如下图所示： <figure data-tool="mdnice编辑器" style="margin-top: 10px;margin-bottom: 10px;display: flex;flex-direction: column;justify-content: center;align-items: center;border-radius: 16px;overflow: hidden;"> <img data-fileid="304477072" data-ratio="0.43112701252236135" src="/upload/fe2872e99363efb76414a5b09b6586ab.png" data-type="png" data-w="559" style="border-radius: 6px;display: block;margin: 20px auto;max-width: 95%;object-fit: contain;"> <figcaption style="margin-top: 5px;text-align: center;color: rgb(136, 136, 136);font-size: 12px;"> 比较最后更新时间 </figcaption> </figure> 当元素的最后更新时间超过 3 分钟未更新，则移除该元素。如下图所示： <figure data-tool="mdnice编辑器" style="margin-top: 10px;margin-bottom: 10px;display: flex;flex-direction: column;justify-content: center;align-items: center;border-radius: 16px;overflow: hidden;"> <img data-fileid="304477073" data-ratio="0.9373297002724795" src="/upload/5f035bfb775a1cbd98ddd3ef60be2d3a.png" data-type="png" data-w="367" style="border-radius: 6px;display: block;margin: 20px auto;max-width: 95%;object-fit: contain;"> <figcaption style="margin-top: 5px;text-align: center;color: rgb(136, 136, 136);font-size: 12px;"> 移除元素 </figcaption> </figure> <h3 data-tool="mdnice编辑器" style="margin-top: 30px;margin-bottom: 15px;font-weight: bold;color: black;font-size: 20px;">4.4 检查间隔</h3> Server 端会将最近 3 分钟有更新的注册信息放入到队列中，超过 3 分钟未更新的数据将会被移除。那么多久会检查一次呢？ 通过源码我们找到，每隔 30s 就会调用一次检查任务。如下图所示： <figure data-tool="mdnice编辑器" style="margin-top: 10px;margin-bottom: 10px;display: flex;flex-direction: column;justify-content: center;align-items: center;border-radius: 16px;overflow: hidden;"> <img data-fileid="304477078" data-ratio="0.2163265306122449" src="/upload/54322c5c1fc239daedbaef8ab861edc4.png" data-type="png" data-w="735" style="border-radius: 6px;display: block;margin: 20px auto;max-width: 95%;object-fit: contain;"> <figcaption style="margin-top: 5px;text-align: center;color: rgb(136, 136, 136);font-size: 12px;"> 检查间隔 </figcaption> </figure> <h3 data-tool="mdnice编辑器" style="margin-top: 30px;margin-bottom: 15px;font-weight: bold;color: black;font-size: 20px;">4.5 小结</h3> <ul data-tool="mdnice编辑器" style="margin-top: 8px;margin-bottom: 8px;padding-left: 25px;color: rgb(248, 57, 41);font-size: 16px;" class="list-paddingleft-2"> <li> <section style="margin-top: 5px;margin-bottom: 5px;line-height: 26px;color: rgb(53, 53, 53);"> Client 每隔 30 秒调用一次增量获取注册表的接口。 </section></li> <li> <section style="margin-top: 5px;margin-bottom: 5px;line-height: 26px;color: rgb(53, 53, 53);"> Server 每隔 30 秒调用检查一次队列。 </section></li> <li> <section style="margin-top: 5px;margin-bottom: 5px;line-height: 26px;color: rgb(53, 53, 53);"> 如果队列中有元素在 3 分钟以内都没有更新过，则从队列中移除该元素。 </section></li> </ul> <h2 data-tool="mdnice编辑器" style="font-weight: bold;color: black;font-size: 22px;margin-top: 20px;margin-right: 10px;">五、客户端注册表合并</h2> 这里有个问题：客户端首次拿到的全量注册表，存放本地了。第二次拿到的是增量的注册表，怎么将两次的数据合并在一起呢？如下图所示： <figure data-tool="mdnice编辑器" style="margin-top: 10px;margin-bottom: 10px;display: flex;flex-direction: column;justify-content: center;align-items: center;border-radius: 16px;overflow: hidden;"> <img data-fileid="304477079" data-ratio="0.5129958960328317" src="/upload/f8fad9c48033959f62cc7698a061912.png" data-type="png" data-w="731" style="border-radius: 6px;display: block;margin: 20px auto;max-width: 95%;object-fit: contain;"> <figcaption style="margin-top: 5px;text-align: center;color: rgb(136, 136, 136);font-size: 12px;"> 注册表合并 </figcaption> </figure> 下面我们来看看下客户端注册表合并的原理。 当客户端调用获取增量注册表的请求后，注册表会返回增量信息，然后客户端就会调用本地合并的方法：updateDelta。 合并注册表的原理图如下所示： <figure data-tool="mdnice编辑器" style="margin-top: 10px;margin-bottom: 10px;display: flex;flex-direction: column;justify-content: center;align-items: center;border-radius: 16px;overflow: hidden;"> <img data-fileid="304477080" data-ratio="0.9929328621908127" src="/upload/49b794a2ea6ada55a91744c6bcafb073.png" data-type="png" data-w="849" style="border-radius: 6px;display: block;margin: 20px auto;max-width: 95%;object-fit: contain;"> <figcaption style="margin-top: 5px;text-align: center;color: rgb(136, 136, 136);font-size: 12px;"> 合并注册表的原理 </figcaption> </figure> <ul data-tool="mdnice编辑器" style="margin-top: 8px;margin-bottom: 8px;padding-left: 25px;color: rgb(248, 57, 41);font-size: 16px;" class="list-paddingleft-2"> <li> <section style="margin-top: 5px;margin-bottom: 5px;line-height: 26px;color: rgb(53, 53, 53);"> 首先就会遍历增量注册表，检查其中的每一项，不论 actionType 是新增、删除还是更新，如果本地本来就有，则执行后续的类型判断逻辑。 </section></li> <li> <section style="margin-top: 5px;margin-bottom: 5px;line-height: 26px;color: rgb(53, 53, 53);"> 如果实例信息的名字在本地不存在则会先往本地注册表新增一个注册信息。然后本地肯定存在注册信息了，执行后续的判断逻辑。 </section></li> <li> <section style="margin-top: 5px;margin-bottom: 5px;line-height: 26px;color: rgb(53, 53, 53);"> 当类型字段 actionType 等于新增或更新时，先删除后增加。 </section></li> <li> <section style="margin-top: 5px;margin-bottom: 5px;line-height: 26px;color: rgb(53, 53, 53);"> 当类型字段 actionType 等于删除时，直接进行删除。 </section></li> </ul> 经过这一些列的逻辑之后，增量注册表和本地注册表就合并好了。 <h2 data-tool="mdnice编辑器" style="font-weight: bold;color: black;font-size: 22px;margin-top: 20px;margin-right: 10px;">六、比对注册表</h2> 经过重重判断 + 合并操作，客户端终于完成了本地注册表的刷新，理论上来说，这个时候客户端的注册表应该和注册中心的注册表一致了。 但是如何确定是一致的呢？这里我们来考虑几种方案： <ul data-tool="mdnice编辑器" style="margin-top: 8px;margin-bottom: 8px;padding-left: 25px;color: rgb(248, 57, 41);font-size: 16px;" class="list-paddingleft-2"> <li> <section style="margin-top: 5px;margin-bottom: 5px;line-height: 26px;color: rgb(53, 53, 53);"> 再全量拉取一次注册表，和本地注册表进行比对。但是既然又要做一次全量拉取，那之前的增量拉取就没有必要了。 </section></li> <li> <section style="margin-top: 5px;margin-bottom: 5px;line-height: 26px;color: rgb(53, 53, 53);"> 拉取增量注册表，Server 返回全量注册表的实例 id，客户端比对每个实例 id 是否存在，以及检查本地是否有多余的，如果能匹配上，则认为是一致的。但是这里也有一个问题，对于新增和更新的注册实例，得把更新的实例信息的字段一一比对才能确定是否一致，这就太麻烦了。 另外还有一个致命的问题：如果客户端因为网络故障下线了，上一次最近 3 分钟的增量数据没有拉取到，那么相当于丢失了一次增量数据，这个时候，就不是完整的注册表信息了。 </section></li> </ul> <blockquote data-tool="mdnice编辑器" style="border-top: none;border-right: none;border-bottom: none;font-size: 0.9em;overflow: auto;color: rgb(106, 115, 125);padding: 10px 10px 10px 20px;margin-bottom: 20px;margin-top: 20px;border-left-color: rgb(255, 177, 27);background: rgb(255, 245, 227);"> 有没有既方便又准确的比对方式呢？ </blockquote> 有的，那就是<code style="font-size: 14px;padding: 2px 4px;border-radius: 4px;margin-right: 2px;margin-left: 2px;background-color: rgba(27, 31, 35, 0.05);font-family: "Operator Mono", Consolas, Monaco, Menlo, monospace;word-break: break-all;color: rgb(255, 93, 108);">哈希比对</code>。哈希比对的意思就是将两个对象经过哈希算法计算出两个 hash 值，如果两个 hash 值相等，则认为这两个对象相等。这种方式在代码中也非常常见，比如类的 hashcode() 方法。 从源码中，我们看到 Eureka Server 返回注册表时，会返回一个 hash 值，是将全量注册表 hash 之后的值。调用的是这个方法：getReconcileHashCode()。 如下图所示，获取增量注册表的接口，会返回增量注册表和 hashcode。 <figure data-tool="mdnice编辑器" style="margin-top: 10px;margin-bottom: 10px;display: flex;flex-direction: column;justify-content: center;align-items: center;border-radius: 16px;overflow: hidden;"> <img data-fileid="304477077" data-ratio="0.5919117647058824" src="/upload/1e0a32bf29941359262d8bb220e167e6.png" data-type="png" data-w="816" style="border-radius: 6px;display: block;margin: 20px auto;max-width: 95%;object-fit: contain;"> </figure> 然后本地注册表合并后，再计算出一个 hashcode，和 Server 返回的 hashcode 进行比对，如果一致，说明本地注册表和 Server 端一致。如果不一致，则会进行一次全量拉取。 上面说的原理我们画一张原理图看下就清楚了： <figure data-tool="mdnice编辑器" style="margin-top: 10px;margin-bottom: 10px;display: flex;flex-direction: column;justify-content: center;align-items: center;border-radius: 16px;overflow: hidden;"> <img data-fileid="304477076" data-ratio="0.862144420131291" src="/upload/e7cbe44944d8d03456faa85ef26a6f53.png" data-type="png" data-w="457" style="border-radius: 6px;display: block;margin: 20px auto;max-width: 95%;object-fit: contain;"> </figure> <h2 data-tool="mdnice编辑器" style="font-weight: bold;color: black;font-size: 22px;margin-top: 20px;margin-right: 10px;">七、总结</h2> 本篇文章可以用一张图来做总结，直接上图： <figure data-tool="mdnice编辑器" style="margin-top: 10px;margin-bottom: 10px;display: flex;flex-direction: column;justify-content: center;align-items: center;border-radius: 16px;overflow: hidden;"> <img data-fileid="304477083" data-ratio="0.7178014766201805" src="/upload/54085d9b4ec5957c85dbceea00ac012f.png" data-type="png" data-w="1219" style="border-radius: 6px;display: block;margin: 20px auto;max-width: 95%;object-fit: contain;"> <figcaption style="margin-top: 5px;text-align: center;color: rgb(136, 136, 136);font-size: 12px;"> 客户端注册表同步原理 </figcaption> </figure> <ul data-tool="mdnice编辑器" style="margin-top: 8px;margin-bottom: 8px;padding-left: 25px;color: rgb(248, 57, 41);font-size: 16px;" class="list-paddingleft-2"> <li> <section style="margin-top: 5px;margin-bottom: 5px;line-height: 26px;color: rgb(53, 53, 53);"> 客户端每隔 30s 获取一次增量数据，注册中心返回最近 3 分钟变化的注册信息，包含了新注册的、更新的和下线的服务实例。然后将增量注册表 + 全量注册表的 hash 值返回。 </section></li> <li> <section style="margin-top: 5px;margin-bottom: 5px;line-height: 26px;color: rgb(53, 53, 53);"> 客户端将本地注册表 + 增量注册表进行合并。合并完成后，计算一个 hash 值，和 Server 返回的 hash 值进行比对，如果相等，则说明客户端的注册表和注册中心的注册表一致，同步完成。如果不一致，则还需要全量拉取一次。 </section></li> </ul> <blockquote data-tool="mdnice编辑器" style="border-top: none;border-right: none;border-bottom: none;font-size: 0.9em;overflow: auto;color: rgb(106, 115, 125);padding: 10px 10px 10px 20px;margin-bottom: 20px;margin-top: 20px;border-left-color: rgb(255, 177, 27);background: rgb(255, 245, 227);"></blockquote> </section> <figure data-tool="mdnice编辑器" style="margin-top: 10px;margin-bottom: 10px;white-space: normal;color: rgb(0, 0, 0);font-family: Optima-Regular, Optima, PingFangSC-light, PingFangTC-light, "PingFang SC", Cambria, Cochin, Georgia, Times, "Times New Roman", serif;font-size: 16px;text-align: left;"></figure>

mysql/mongo/nginx手册整理(2021版)

作者：微信小助手

<section data-mpa-powered-by="yiban.io"> <section style="font-size: 16px;color: rgb(62, 62, 62);line-height: 1.6;letter-spacing: 0px;font-family: "Helvetica Neue", Helvetica, "Hiragino Sans GB", "Microsoft YaHei", Arial, sans-serif;"> limits.conf{ <pre style="font-size: inherit;color: inherit;line-height: inherit;"><code style="margin-right: 2px;margin-left: 2px;line-height: 18px;font-size: 14px;letter-spacing: 0px;font-family: Consolas, Inconsolata, Courier, monospace;border-radius: 0px;color: rgb(169, 183, 198);background: rgb(40, 43, 46);padding: 0.5em;overflow-wrap: normal !important;word-break: normal !important;overflow: auto !important;display: -webkit-box !important;">    ulimit -SHn 65535  # 临时设置文件描述符大小 进程最大打开文件柄数 还有socket最大连接数, 等同配置 nofile     ulimit -SHu 65535  # 临时设置用户最大进程数     ulimit -a          # 查看     /etc/security/limits.conf     # 文件描述符大小  open files     # lsof |wc -l   查看当前文件句柄数使用数量     * soft nofile 16384         # 设置太大，进程使用过多会把机器拖死     * hard nofile 32768     # 用户最大进程数  max user processes     # echo $((`ps uxm |wc -l`-`ps ux |wc -l`))  查看当前用户占用的进程数 [包括线程]     user soft nproc 16384     user hard nproc 32768     # 如果/etc/security/limits.d/有配置文件，将会覆盖/etc/security/limits.conf里的配置     # 即/etc/security/limits.d/的配置文件里就不要有同样的参量设置     /etc/security/limits.d/90-nproc.conf    # centos6.3的默认这个文件会覆盖 limits.conf     user soft nproc 16384     user hard nproc 32768     sysctl -p    # 修改配置文件后让系统生效 } 随机分配端口范围{     # 本机连其它端口用的     echo "10000 65535" > /proc/sys/net/ipv4/ip_local_port_range } 百万长链接设置{     # 内存消耗需要较大     vim /root/.bash_profile     # 添加如下2行,退出bash重新登陆     # 一个进程不能使用超过NR_OPEN文件描述符     echo 20000500 > /proc/sys/fs/nr_open     # 当前用户最大文件数     ulimit -n 10000000 } core崩溃文件查看{     gdb  core.13844     bt   # 查看函数调用信息(堆栈) } libc.so故障修复{     # 由于升级glibc导致libc.so不稳定,突然报错,幸好还有未退出的终端     grep: error while loading shared libraries: /lib64/libc.so.6: ELF file OS ABI invalid     # 看看当前系统有多少版本 libc.so     ls /lib64/libc-[tab]     # 更改环境变量指向其他 libc.so 文件测试     export LD_PRELOAD=/lib64/libc-2.7.so    # 如果不改变LD_PRELOAD变量,ln不能用,需要使用 /sbin/sln 命令做链接     # 当前如果好使了，在执行下面强制替换软链接。如不好使，测试其他版本的libc.so文件     ln -f -s /lib64/libc-2.7.so /lib64/libc.so.6 } 无法分配内存 {     fork: Cannot allocate memory     # 报错不一定是内存不够用，进程数或者线程数满了也会报这个错误， 可以适当增加 kernel.pid_max 的值，     cat /proc/sys/kernel/pid_max  # 默认3.2w } sudo{     echo myPassword | sudo -S ls /tmp  # 直接输入sudo的密码非交互,从标准输入读取密码而不是终端设备     visudo                             # sudo命令权限添加  /etc/sudoers     用户  别名(可用all)=NOPASSWD:命令1,命令2     user  ALL=NOPASSWD:/bin/su         # 免root密码切换root身份     wangming linuxfan=NOPASSWD:/sbin/apache start,/sbin/apache restart     UserName ALL=(ALL) ALL     UserName ALL=(ALL) NOPASSWD: ALL     peterli        ALL=(ALL)       NOPASSWD:/sbin/service     Defaults requiretty                # sudo不允许后台运行,注释此行既允许     Defaults !visiblepw                # sudo不允许远程,去掉!既允许 } grub开机启动项添加{     vim /etc/grub.conf     title ms-dos     rootnoverify (hd0,0)     chainloader +1 } stty{     #stty时一个用来改变并打印终端行设置的常用命令     stty iuclc          # 在命令行下禁止输出大写     stty -iuclc         # 恢复输出大写     stty olcuc          # 在命令行下禁止输出小写     stty -olcuc         # 恢复输出小写     stty size           # 打印出终端的行数和列数     stty eof "string"   # 改变系统默认ctrl+D来表示文件的结束     stty -echo          # 禁止回显     stty echo           # 打开回显     stty -echo;read;stty echo;read  # 测试禁止回显     stty igncr          # 忽略回车符     stty -igncr         # 恢复回车符     stty erase '#'      # 将#设置为退格字符     stty erase '^?'     # 恢复退格字符     定时输入{         timeout_read(){             timeout=$1             old_stty_settings=`stty -g`　　# save current settings             stty -icanon min 0 time 100　　# set 10seconds,not 100seconds             eval read varname　　          # =read $varname             stty "$old_stty_settings"　　  # recover settings         }         read -t 10 varname    # 更简单的方法就是利用read命令的-t选项     }     检测用户按键{         #!/bin/bash         old_tty_settings=$(stty -g)   # 保存老的设置(为什么?).         stty -icanon         Keypress=$(head -c1)          # 或者使用$(dd bs=1 count=1 2> /dev/null)         echo "Key pressed was \""$Keypress"\"."         stty "$old_tty_settings"      # 恢复老的设置.         exit 0     } } iptables{     内建三个表：nat mangle 和 filter     filter预设规则表，有INPUT、FORWARD 和 OUTPUT 三个规则链     vi /etc/sysconfig/iptables    # 配置文件     INPUT    # 进入     FORWARD  # 转发     OUTPUT   # 出去     ACCEPT   # 将封包放行     REJECT   # 拦阻该封包     DROP     # 丢弃封包不予处理     -A       # 在所选择的链(INPUT等)末添加一条或更多规则     -D       # 删除一条     -E       # 修改     -p       # tcp、udp、icmp    0相当于所有all    !取反     -P       # 设置缺省策略(与所有链都不匹配强制使用此策略)     -s       # IP/掩码    (IP/24)    主机名、网络名和清楚的IP地址 !取反     -j       # 目标跳转，立即决定包的命运的专用内建目标     -i       # 进入的（网络）接口 [名称] eth0     -o       # 输出接口[名称]     -m       # 模块     --sport  # 源端口     --dport  # 目标端口     iptables -F                        # 将防火墙中的规则条目清除掉  # 注意: iptables -P INPUT ACCEPT     iptables-restore < 规则文件        # 导入防火墙规则     /etc/init.d/iptables save          # 保存防火墙设置     /etc/init.d/iptables restart       # 重启防火墙服务     iptables -L -n                     # 查看规则     iptables -t nat -nL                # 查看转发     iptables实例{         iptables -L INPUT                   # 列出某规则链中的所有规则         iptables -X allowed                 # 删除某个规则链 ,不加规则链，清除所有非内建的         iptables -Z INPUT                   # 将封包计数器归零         iptables -N allowed                 # 定义新的规则链         iptables -P INPUT DROP              # 定义过滤政策         iptables -A INPUT -s 192.168.1.1    # 比对封包的来源IP   # ! 192.168.0.0/24  ! 反向对比         iptables -A INPUT -d 192.168.1.1    # 比对封包的目的地IP         iptables -A INPUT -i eth0           # 比对封包是从哪片网卡进入         iptables -A FORWARD -o eth0         # 比对封包要从哪片网卡送出 eth+表示所有的网卡         iptables -A INPUT -p tcp            # -p ! tcp 排除tcp以外的udp、icmp。-p all所有类型         iptables -D INPUT 8                 # 从某个规则链中删除一条规则         iptables -D INPUT --dport 80 -j DROP         # 从某个规则链中删除一条规则         iptables -R INPUT 8 -s 192.168.0.1 -j DROP   # 取代现行规则         iptables -I INPUT 8 --dport 80 -j ACCEPT     # 插入一条规则         iptables -A INPUT -i eth0 -j DROP            # 其它情况不允许         iptables -A INPUT -p tcp -s IP -j DROP       # 禁止指定IP访问         iptables -A INPUT -p tcp -s IP --dport port -j DROP               # 禁止指定IP访问端口         iptables -A INPUT -s IP -p tcp --dport port -j ACCEPT             # 允许在IP访问指定端口         iptables -A INPUT -p tcp --dport 22 -j DROP                       # 禁止使用某端口         iptables -A INPUT -i eth0 -p icmp -m icmp --icmp-type 8 -j DROP   # 禁止icmp端口         iptables -A INPUT -i eth0 -p icmp -j DROP                         # 禁止icmp端口         iptables -t filter -A INPUT -i eth0 -p tcp --syn -j DROP                  # 阻止所有没有经过你系统授权的TCP连接         iptables -A INPUT -f -m limit --limit 100/s --limit-burst 100 -j ACCEPT   # IP包流量限制         iptables -A INPUT -i eth0 -s 192.168.62.1/32 -p icmp -m icmp --icmp-type 8 -j ACCEPT  # 除192.168.62.1外，禁止其它人ping我的主机         iptables -A INPUT -p tcp -m tcp --dport 80 -m state --state NEW -m recent --update --seconds 5 --hitcount 20 --rttl --name WEB --rsource -j DROP  # 可防御cc攻击(未测试)     }     iptables配置实例文件{         # Generated by iptables-save v1.2.11 on Fri Feb  9 12:10:37 2007         *filter         :INPUT ACCEPT [637:58967]         :FORWARD DROP [0:0]         :OUTPUT ACCEPT [5091:1301533]         # 允许的IP或IP段访问 建议多个         -A INPUT -s 127.0.0.1 -p tcp -j ACCEPT         -A INPUT -s 192.168.0.0/255.255.0.0 -p tcp -j ACCEPT         # 开放对外开放端口         -A INPUT -p tcp --dport 80 -j ACCEPT         # 指定某端口针对IP开放         -A INPUT -s 192.168.10.37 -p tcp --dport 22 -j ACCEPT         # 拒绝所有协议(INPUT允许)         -A INPUT -p tcp -m tcp --tcp-flags FIN,SYN,RST,PSH,URG RST -j DROP         # 允许已建立的或相关连的通行         -A INPUT -m state --state ESTABLISHED,RELATED -j ACCEPT         # 拒绝ping         -A INPUT -p tcp -m tcp -j REJECT --reject-with icmp-port-unreachable         COMMIT         # Completed on Fri Feb  9 12:10:37 2007     }     iptables配置实例{         # 允许某段IP访问任何端口         iptables -A INPUT -s 192.168.0.3/24 -p tcp -j ACCEPT         # 设定预设规则 (拒绝所有的数据包，再允许需要的,如只做WEB服务器.还是推荐三个链都是DROP)         iptables -P INPUT DROP         iptables -P FORWARD DROP         iptables -P OUTPUT ACCEPT         # 注意: 直接设置这三条会掉线         # 开启22端口         iptables -A INPUT -p tcp --dport 22 -j ACCEPT         # 如果OUTPUT 设置成DROP的，要写上下面一条         iptables -A OUTPUT -p tcp --sport 22 -j ACCEPT         # 注:不写导致无法SSH.其他的端口一样,OUTPUT设置成DROP的话,也要添加一条链         # 如果开启了web服务器,OUTPUT设置�

Spring中明明插入了数据，为什么事件监听器EventListener却读不到？

作者：微信小助手

<section data-width="100%" data-opacity="1" data-rotate="0" data-mpa-powered-by="yiban.io"> <section> <section> <section> <section data-width="100%" data-opacity="1" data-rotate="0"> <section> <section> <section data-width="100%" data-opacity="1" data-rotate="0"> <section> <section> <section> <section class="mp_profile_iframe_wrp"> <mpprofile class="js_uneditable custom_select_card mp_profile_iframe" data-pluginname="mpprofile" data-id="MzAwMTk4NjM1MA==" data-headimg="http://mmbiz.qpic.cn/mmbiz_png/PxMzT0Oibf4gcBzLSUNh2cgXUsuLIsvQYJE1lzZd74qpC3iciaM6gcYIfOVV0KjDDkeN4CTLTn4ETPtaHOAuTWSWA/0?wx_fmt=png" data-nickname="JAVA日知录" data-alias="javadaily" data-signature="写代码的架构师，做架构的程序员！实战、源码、数据库、架构...只要你来，你想了解的这里都有！" data-from="0"></mpprofile> </section> </section> </section> </section> </section> </section> </section> </section> <span style="color: rgb(136, 136, 136);font-family: -apple-system-font, BlinkMacSystemFont, "Helvetica Neue", "PingFang SC", "Hiragino Sans GB", "Microsoft YaHei UI", "Microsoft YaHei", Arial, sans-serif;font-size: 12px;letter-spacing: 0.544px;text-align: right;text-indent: 34px;background-color: rgb(255, 255, 255);">来源：https://blog.csdn.net/qq_41378597 <section data-tool="mdnice编辑器" data-website="https://www.mdnice.com" style="line-height: 1.6;word-break: break-word;text-align: left;font-family: Optima-Regular, Optima, PingFangSC-light, PingFangTC-light, "PingFang SC", Cambria, Cochin, Georgia, Times, "Times New Roman", serif;padding: 5px;font-size: 16px;color: rgb(53, 53, 53);word-spacing: 0.8px;letter-spacing: 0.8px;border-radius: 16px;"> <h2 data-tool="mdnice编辑器" style="font-weight: bold;color: black;font-size: 22px;margin-top: 20px;margin-right: 10px;">一、问题描述</h2> 平时我们在完成某些数据的入库后，发布了一个事件，此时使用的是 <code style="font-size: 14px;padding: 2px 4px;border-radius: 4px;margin-right: 2px;margin-left: 2px;background-color: rgba(27, 31, 35, 0.05);font-family: "Operator Mono", Consolas, Monaco, Menlo, monospace;word-break: break-all;color: rgb(255, 93, 108);">@EventListener</code>，然后在这个事件中，又去对刚才入库的数据进行查询，从而完成后续的操作。例如（数据入库=>对入库数据进行查询审核），这时候会发现，查询不到刚才入库的数据，这是因为事务还没提交完成，在同一个事务当中，查询不到才存入的数据，那么就引出了下面的解决方式。 为了解决上述问题，Spring为我们提供了两种方式： <ol data-tool="mdnice编辑器" style="margin-top: 8px;margin-bottom: 8px;padding-left: 25px;color: rgb(248, 57, 41);" class="list-paddingleft-2"> <li> <section style="margin-top: 5px;margin-bottom: 5px;line-height: 26px;color: rgb(53, 53, 53);"> <code style="font-size: 14px;padding: 2px 4px;border-radius: 4px;margin-right: 2px;margin-left: 2px;background-color: rgba(27, 31, 35, 0.05);font-family: "Operator Mono", Consolas, Monaco, Menlo, monospace;word-break: break-all;color: rgb(255, 93, 108);">@TransactionalEventListener</code>注解。 </section></li> <li> <section style="margin-top: 5px;margin-bottom: 5px;line-height: 26px;color: rgb(53, 53, 53);"> 事务同步管理器 <code style="font-size: 14px;padding: 2px 4px;border-radius: 4px;margin-right: 2px;margin-left: 2px;background-color: rgba(27, 31, 35, 0.05);font-family: "Operator Mono", Consolas, Monaco, Menlo, monospace;word-break: break-all;color: rgb(255, 93, 108);">TransactionSynchronizationManager</code>。 </section></li> </ol> 以便我们可以在事务提交后再触发某一事件来进行其他操作。 <h2 data-tool="mdnice编辑器" style="font-weight: bold;color: black;font-size: 22px;margin-top: 20px;margin-right: 10px;">二、使用场景</h2> 在项目当中，我们有时候需要在执行数据库操作之后，发送消息或事件来异步调用其他组件执行相应的操作，例如： <ol data-tool="mdnice编辑器" style="margin-top: 8px;margin-bottom: 8px;padding-left: 25px;color: rgb(248, 57, 41);" class="list-paddingleft-2"> <li> <section style="margin-top: 5px;margin-bottom: 5px;line-height: 26px;color: rgb(53, 53, 53);"> 数据完成导入之后，发布审核事件，对入库的数据进行审核。 </section></li> <li> <section style="margin-top: 5px;margin-bottom: 5px;line-height: 26px;color: rgb(53, 53, 53);"> 用户在完成注册后发送激活码。 </section></li> <li> <section style="margin-top: 5px;margin-bottom: 5px;line-height: 26px;color: rgb(53, 53, 53);"> 配置修改后，发送更新配置的事件。 </section></li> </ol> <h2 data-tool="mdnice编辑器" style="font-weight: bold;color: black;font-size: 22px;margin-top: 20px;margin-right: 10px;">三、@TransactionalEventListener详解</h2> 我们可以从命名上直接看出，它就是个 <code style="font-size: 14px;padding: 2px 4px;border-radius: 4px;margin-right: 2px;margin-left: 2px;background-color: rgba(27, 31, 35, 0.05);font-family: "Operator Mono", Consolas, Monaco, Menlo, monospace;word-break: break-all;color: rgb(255, 93, 108);">EventListener</code>，在Spring4.2+，有一种叫做 <code style="font-size: 14px;padding: 2px 4px;border-radius: 4px;margin-right: 2px;margin-left: 2px;background-color: rgba(27, 31, 35, 0.05);font-family: "Operator Mono", Consolas, Monaco, Menlo, monospace;word-break: break-all;color: rgb(255, 93, 108);">@TransactionEventListener</code>的方式，能够实现在控制事务的同时，完成对对事件的处理。 我们知道，Spring的事件监听机制（发布订阅模型）实际上并不是异步的（默认情况下），而是同步的来将代码进行解耦。而 <code style="font-size: 14px;padding: 2px 4px;border-radius: 4px;margin-right: 2px;margin-left: 2px;background-color: rgba(27, 31, 35, 0.05);font-family: "Operator Mono", Consolas, Monaco, Menlo, monospace;word-break: break-all;color: rgb(255, 93, 108);">@TransactionEventListener</code>仍是通过这种方式，但是加入了回调的方式来解决，这样就能够在事务进行Commited，Rollback…等时候才去进行Event的处理，来达到事务同步的目的。 <pre data-tool="mdnice编辑器" style="margin-top: 10px;margin-bottom: 10px;"><code style="overflow-x: auto;padding: 16px;color: #383a42;background: #fafafa;display: -webkit-box;font-family: Operator Mono, Consolas, Monaco, Menlo, monospace;border-radius: 0px;font-size: 12px;-webkit-overflow-scrolling: touch;">// @since 4.2 注解的方式提供的相对较晚，其实API的方式在第一个版本就已经提供了。 // 值得注意的是，在这个注解上面有一个注解：`@EventListener`，所以表明其实这个注解也是个事件监听器。  @Target({ElementType.METHOD, ElementType.ANNOTATION_TYPE}) @Retention(RetentionPolicy.RUNTIME) @Documented @EventListener //有类似于注解继承的效果 public @interface TransactionalEventListener {     // 这个注解取值有：BEFORE_COMMIT、AFTER_COMMIT、AFTER_ROLLBACK、AFTER_COMPLETION     // 各个值都代表什么意思表达什么功能，非常清晰，下面解释了对应的枚举类~     // 需要注意的是：AFTER_COMMIT + AFTER_COMPLETION是可以同时生效的     // AFTER_ROLLBACK + AFTER_COMPLETION是可以同时生效的     TransactionPhase phase() default TransactionPhase.AFTER_COMMIT;          // 表明若没有事务的时候，对应的event是否需要执行，默认值为false表示，没事务就不执行了。     boolean fallbackExecution() default false;     // 这里巧妙的用到了@AliasFor的能力，放到了@EventListener身上     // 注意：一般建议都需要指定此值，否则默认可以处理所有类型的事件，范围太广了。     @AliasFor(annotation = EventListener.class, attribute = "classes")     Class<?>[] value() default {};     @AliasFor(annotation = EventListener.class, attribute = "classes")     Class<?>[] classes() default {};     String condition() default ""; } </code></pre> <pre data-tool="mdnice编辑器" style="margin-top: 10px;margin-bottom: 10px;"><code style="overflow-x: auto;padding: 16px;color: #383a42;background: #fafafa;display: -webkit-box;font-family: Operator Mono, Consolas, Monaco, Menlo, monospace;border-radius: 0px;font-size: 12px;-webkit-overflow-scrolling: touch;">public enum TransactionPhase {    // 指定目标方法在事务commit之前执行    BEFORE_COMMIT,    // 指定目标方法在事务commit之后执行    AFTER_COMMIT,    // 指定目标方法在事务rollback之后执行    AFTER_ROLLBACK,    // 指定目标方法在事务完成时执行，这里的完成是指无论事务是成功提交还是事务回滚了    AFTER_COMPLETION } </code></pre> <h2 data-tool="mdnice编辑器" style="font-weight: bold;color: black;font-size: 22px;margin-top: 20px;margin-right: 10px;">四、代码示例</h2> 这里主要是为了讲解如何使用 <code style="font-size: 14px;padding: 2px 4px;border-radius: 4px;margin-right: 2px;margin-left: 2px;background-color: rgba(27, 31, 35, 0.05);font-family: "Operator Mono", Consolas, Monaco, Menlo, monospace;word-break: break-all;color: rgb(255, 93, 108);">@TransactionalEventListener</code>，所以就不列出所有代码了。 <pre data-tool="mdnice编辑器" style="margin-top: 10px;margin-bottom: 10px;"><code style="overflow-x: auto;padding: 16px;color: #383a42;background: #fafafa;display: -webkit-box;font-family: Operator Mono, Consolas, Monaco, Menlo, monospace;border-radius: 0px;font-size: 12px;-webkit-overflow-scrolling: touch;">@Data public class User {  private long id;  private String name;  private Integer age; } </code></pre> 业务实现： <pre data-tool="mdnice编辑器" style="margin-top: 10px;margin-bottom: 10px;"><code style="overflow-x: auto;padding: 16px;color: #383a42;background: #fafafa;display: -webkit-box;font-family: Operator Mono, Consolas, Monaco, Menlo, monospace;border-radius: 0px;font-size: 12px;-webkit-overflow-scrolling: touch;">@Service @Slf4j public class UserServiceImpl extends implements UserService {     @Autowired     UserMapper userMapper;          @Autowired     ApplicationEventPublisher eventPublisher;        public void userRegister(User user){         userMapper.insertUser(user);         eventPublisher.publishEvent(new UserRegisterEvent(new Date()));     } } </code></pre> 自定义事件： <pre data-tool="mdnice编辑器" style="margin-top: 10px;margin-bottom: 10px;"><code style="overflow-x: auto;padding: 16px;color: #383a42;background: #fafafa;display: -webkit-box;font-family: Operator Mono, Consolas, Monaco, Menlo, monospace;border-radius: 0px;font-size: 12px;-webkit-overflow-scrolling: touch;">@Getter @Setter public class UserRegisterEvent extends ApplicationEvent {     private Date registerDate;          public UserRegisterEvent(Date registerDate) {         super(registerDate);         this.registerDate = registerDate;     } } </code></pre> 事件监听器： <pre data-tool="mdnice编辑器" style="margin-top: 10px;margin-bottom: 10px;"><code style="overflow-x: auto;padding: 16px;color: #383a42;background: #fafafa;display: -webkit-box;font-family: Operator Mono, Consolas, Monaco, Menlo, monospace;border-radius: 0px;font-size: 12px;-webkit-overflow-scrolling: touch;">@Slf4j @Component public class UserListener {     @Autowired     UserService userService;          @Async     @TransactionalEventListener(phase = TransactionPhase.AFTER_COMMIT, classes = UserRegisterEvent.class)     public void onUserRegisterEvent(UserRegisterEvent event) {         userService.sendActivationCode(event.getRegisterDate());     } } </code></pre> <h2 data-tool="mdnice编辑器" style="font-weight: bold;color: black;font-size: 22px;margin-top: 20px;margin-right: 10px;">五、实现原理</h2> 关于事务的实现原理，这里其实是比较简单的,Spring对事务监控的处理逻辑在 <code style="font-size: 14px;padding: 2px 4px;border-radius: 4px;margin-right: 2px;margin-left: 2px;background-color: rgba(27, 31, 35, 0.05);font-family: "Operator Mono", Consolas, Monaco, Menlo, monospace;word-break: break-all;color: rgb(255, 93, 108);">TransactionSynchronization</code>中，如下是该接口的声明： <pre data-tool="mdnice编辑器" style="margin-top: 10px;margin-bottom: 10px;"><code style="overflow-x: auto;padding: 16px;color: #383a42;background: #fafafa;display: -webkit-box;font-family: Operator Mono, Consolas, Monaco, Menlo, monospace;border-radius: 0px;font-size: 12px;-webkit-overflow-scrolling: touch;">public interface TransactionSynchronization extends Flushable {     // 在当前事务挂起时执行     default void suspend() {     }     // 在当前事务重新加载时执行     default void resume() {     }     // 在当前数据刷新到数据库时执行     default void flush() {     }     // 在当前事务commit之前执行     default void beforeCommit(boolean readOnly) {     }     // 在当前事务completion之前执行     default void beforeCompletion() {     }     // 在当前事务commit之后实质性     default void afterCommit() {     }     // 在当前事务completion之后执行     default void afterCompletion(int status) {     } } </code></pre> 很明显，这里的 <code style="font-size: 14px;padding: 2px 4px;border-radius: 4px;margin-right: 2px;margin-left: 2px;background-color: rgba(27, 31, 35, 0.05);font-family: "Operator Mono", Consolas, Monaco, Menlo, monospace;word-break: break-all;color: rgb(255, 93, 108);">TransactionSynchronization</code>接口只是抽象了一些行为，用于事务事件发生时触发，这些行为在Spring事务中提供了内在支持，即在相应的事务事件时，其会获取当前所有注册的 <code style="font-size: 14px;padding: 2px 4px;border-radius: 4px;margin-right: 2px;margin-left: 2px;background-color: rgba(27, 31, 35, 0.05);font-family: "Operator Mono", Consolas, Monaco, Menlo, monospace;word-break: break-all;color: rgb(255, 93, 108);">TransactionSynchronization</code>对象，然后调用其相应的方法。那么这里 <code style="font-size: 14px;padding: 2px 4px;border-radius: 4px;margin-right: 2px;margin-left: 2px;background-color: rgba(27, 31, 35, 0.05);font-family: "Operator Mono", Consolas, Monaco, Menlo, monospace;word-break: break-all;color: rgb(255, 93, 108);">TransactionSynchronization</code>对象的注册点对于我们了解事务事件触发有至关重要的作用了。这里我们首先回到事务标签的解析处，在前面讲解事务标签解析时，我们讲到Spring会注册一个 <code style="font-size: 14px;padding: 2px 4px;border-radius: 4px;margin-right: 2px;margin-left: 2px;background-color: rgba(27, 31, 35, 0.05);font-family: "Operator Mono", Consolas, Monaco, Menlo, monospace;word-break: break-all;color: rgb(255, 93, 108);">TransactionalEventListenerFactory</code>类型的bean到Spring容器中，这里关于标签的解析读者可以阅读本人前面的文章Spring事务用法示例与实现原理。这里注册的 <code style="font-size: 14px;padding: 2px 4px;border-radius: 4px;margin-right: 2px;margin-left: 2px;background-color: rgba(27, 31, 35, 0.05);font-family: "Operator Mono", Consolas, Monaco, Menlo, monospace;word-break: break-all;color: rgb(255, 93, 108);">TransactionalEventListenerFactory</code>实现了 <code style="font-size: 14px;padding: 2px 4px;border-radius: 4px;margin-right: 2px;margin-left: 2px;background-color: rgba(27, 31, 35, 0.05);font-family: "Operator Mono", Consolas, Monaco, Menlo, monospace;word-break: break-all;color: rgb(255, 93, 108);">EventListenerFactory</code>接口，这个接口的主要作用是先判断目标方法是否是某个监听器的类型，然后为目标方法生成一个监听器，其会在某个bean初始化之后由Spring调用其方法用于生成监听器。如下是该类的实现： <pre data-tool="mdnice编辑器" style="margin-top: 10px;margin-bottom: 10px;"><code style="overflow-x: auto;padding: 16px;color: #383a42;background: #fafafa;display: -webkit-box;font-family: Operator Mono, Consolas, Monaco, Menlo, monospace;border-radius: 0px;font-size: 12px;-webkit-overflow-scrolling: touch;">public class TransactionalEventListenerFactory implements EventListenerFactory, Ordered {     // 指定当前监听器的顺序     private int order = 50;     public void setOrder(int order) {         this.order = order;     }     @Override     public int getOrder() {         return this.order;     }     // 指定目标方法是否是所支持的监听器的类型，这里的判断逻辑就是如果目标方法上包含有     // TransactionalEventListener注解，则说明其是一个事务事件监听器     @Override     public boolean supportsMethod(Method method) {         return (AnnotationUtils.findAnnotation(method, TransactionalEventListener.class) != null);     }     // 为目标方法生成一个事务事件监听器，这里ApplicationListenerMethodTransactionalAdapter实现了     // ApplicationEvent接口     @Override     public ApplicationListener<?> createApplicationListener(String beanName, Class<?> type, Method method) {         return new ApplicationListenerMethodTransactionalAdapter(beanName, type, method);     } } </code></pre> 这里关于事务事件监听的逻辑其实已经比较清楚了。<code style="font-size: 14px;padding: 2px 4px;border-radius: 4px;margin-right: 2px;margin-left: 2px;background-color: rgba(27, 31, 35, 0.05);font-family: "Operator Mono", Consolas, Monaco, Menlo, monospace;word-break: break-all;color: rgb(255, 93, 108);">ApplicationListenerMethodTransactionalAdapter</code>本质上是实现了 <code style="font-size: 14px;padding: 2px 4px;border-radius: 4px;margin-right: 2px;margin-left: 2px;background-color: rgba(27, 31, 35, 0.05);font-family: "Operator Mono", Consolas, Monaco, Menlo, monospace;word-break: break-all;color: rgb(255, 93, 108);">ApplicationListener</code>接口的，也就是说，其是Spring的一个事件监听器，这也就是为什么进行事务处理时需要使用 <code style="font-size: 14px;padding: 2px 4px;border-radius: 4px;margin-right: 2px;margin-left: 2px;background-color: rgba(27, 31, 35, 0.05);font-family: "Operator Mono", Consolas, Monaco, Menlo, monospace;word-break: break-all;color: rgb(255, 93, 108);">ApplicationEventPublisher.publish()</code>方法发布一下当前事务的事件。 <code style="font-size: 14px;padding: 2px 4px;border-radius: 4px;margin-right: 2px;margin-left: 2px;background-color: rgba(27, 31, 35, 0.05);font-family: "Operator Mono", Consolas, Monaco, Menlo, monospace;word-break: break-all;color: rgb(255, 93, 108);">ApplicationListenerMethodTransactionalAdapter</code>在监听到发布的事件之后会生成一个 <code style="font-size: 14px;padding: 2px 4px;border-radius: 4px;margin-right: 2px;margin-left: 2px;background-color: rgba(27, 31, 35, 0.05);font-family: "Operator Mono", Consolas, Monaco, Menlo, monospace;word-break: break-all;color: rgb(255, 93, 108);">TransactionSynchronization</code>对象，并且将该对象注册到当前事务逻辑中，如下是监听事务事件的处理逻辑： <pre data-tool="mdnice编辑器" style="margin-top: 10px;margin-bottom: 10px;"><code style="overflow-x: auto;padding: 16px;color: #383a42;background: #fafafa;display: -webkit-box;font-family: Operator Mono, Consolas, Monaco, Menlo, monospace;border-radius: 0px;font-size: 12px;-webkit-overflow-scrolling: touch;">@Override public void onApplicationEvent(ApplicationEvent event) {     // 如果当前TransactionManager已经配置开启事务事件监听，     // 此时才会注册TransactionSynchronization对象     if (TransactionSynchronizationManager.isSynchronizationActive()) {         // 通过当前事务事件发布的参数，创建一个TransactionSynchronization对象         TransactionSynchronization transactionSynchronization =              createTransactionSynchronization(event);         // 注册TransactionSynchronization对象到TransactionManager中         TransactionSynchronizationManager             .registerSynchronization(transactionSynchronization);     } else if (this.annotation.fallbackExecution()) {         // 如果当前TransactionManager没有开启事务事件处理，但是当前事务监听方法中配置了         // fallbackExecution属性为true，说明其需要对当前事务事件进行监听，无论其是否有事务         if (this.annotation.phase() == TransactionPhase.AFTER_ROLLBACK              && logger.isWarnEnabled()) {             logger.warn("Processing "                          + event + " as a fallback execution on AFTER_ROLLBACK phase");         }         processEvent(event);     } else {         // 走到这里说明当前是不需要事务事件处理的，因而直接略过         if (logger.isDebugEnabled()) {             logger.debug("No transaction is active - skipping " + event);         }     } } </code></pre> 这里需要说明的是，上述annotation属性就是在事务监听方法上解析的 <code style="font-size: 14px;padding: 2px 4px;border-radius: 4px;margin-right: 2px;margin-left: 2px;background-color: rgba(27, 31, 35, 0.05);font-family: "Operator Mono", Consolas, Monaco, Menlo, monospace;word-break: break-all;color: rgb(255, 93, 108);">TransactionalEventListener</code>注解中配置的属性。可以看到，对于事务事件的处理，这里创建了一个 <code style="font-size: 14px;padding: 2px 4px;border-radius: 4px;margin-right: 2px;margin-left: 2px;background-color: rgba(27, 31, 35, 0.05);font-family: "Operator Mono", Consolas, Monaco, Menlo, monospace;word-break: break-all;color: rgb(255, 93, 108);">TransactionSynchronization</code>对象，其实主要的处理逻辑就是在返回的这个对象中，而 <code style="font-size: 14px;padding: 2px 4px;border-radius: 4px;margin-right: 2px;margin-left: 2px;background-color: rgba(27, 31, 35, 0.05);font-family: "Operator Mono", Consolas, Monaco, Menlo, monospace;word-break: break-all;color: rgb(255, 93, 108);">createTransactionSynchronization()</code>方法内部只是创建了一个 <code style="font-size: 14px;padding: 2px 4px;border-radius: 4px;margin-right: 2px;margin-left: 2px;background-color: rgba(27, 31, 35, 0.05);font-family: "Operator Mono", Consolas, Monaco, Menlo, monospace;word-break: break-all;color: rgb(255, 93, 108);">TransactionSynchronizationEventAdapter</code>对象就返回了。这里我们直接看该对象的源码： <pre data-tool="mdnice编辑器" style="margin-top: 10px;margin-bottom: 10px;"><code style="overflow-x: auto;padding: 16px;color: #383a42;background: #fafafa;display: -webkit-box;font-family: Operator Mono, Consolas, Monaco, Menlo, monospace;border-radius: 0px;font-size: 12px;-webkit-overflow-scrolling: touch;">private static class TransactionSynchronizationEventAdapter      extends TransactionSynchronizationAdapter {     private final ApplicationListenerMethodAdapter listener;     private final ApplicationEvent event;     private final TransactionPhase phase; public TransactionSynchronizationEventAdapter(ApplicationListenerMethodAdapter      listener, ApplicationEvent event, TransactionPhase phase) {     this.listener = listener;     this.event = event;     this.phase = phase; }     @Override     public int getOrder() {         return this.listener.getOrder();     }     // 在目标方法配置的phase属性为BEFORE_COMMIT时，处理before commit事件     public void beforeCommit(boolean readOnly) {         if (this.phase == TransactionPhase.BEFORE_COMMIT) {             processEvent();         }     }     // 这里对于after completion事件的处理，虽然分为了三个if分支，但是实际上都是执行的processEvent()     // 方法，因为after completion事件是事务事件中一定会执行的，因而这里对于commit，     // rollback和completion事件都在当前方法中处理也是没问题的     public void afterCompletion(int status) {         if (this.phase == TransactionPhase.AFTER_COMMIT && status == STATUS_COMMITTED) {             processEvent();         } else if (this.phase == TransactionPhase.AFTER_ROLLBACK                     && status == STATUS_ROLLED_BACK) {             processEvent();         } else if (this.phase == TransactionPhase.AFTER_COMPLETION) {             processEvent();         }     }     // 执行事务事件     protected void processEvent() {         this.listener.processEvent(this.event);     } } </code></pre> 可以看到，对于事务事件的处理，最终都是委托给了 <code style="font-size: 14px;padding: 2px 4px;border-radius: 4px;margin-right: 2px;margin-left: 2px;background-color: rgba(27, 31, 35, 0.05);font-family: "Operator Mono", Consolas, Monaco, Menlo, monospace;word-break: break-all;color: rgb(255, 93, 108);">ApplicationListenerMethodAdapter.processEvent()</code>方法进行的。如下是该方法的源码： <pre data-tool="mdnice编辑器" style="margin-top: 10px;margin-bottom: 10px;"><code style="overflow-x: auto;padding: 16px;color: #383a42;background: #fafafa;display: -webkit-box;font-family: Operator Mono, Consolas, Monaco, Menlo, monospace;border-radius: 0px;font-size: 12px;-webkit-overflow-scrolling: touch;">public void processEvent(ApplicationEvent event) {     // 处理事务事件的相关参数，这里主要是判断TransactionalEventListener注解中是否配置了value     // 或classes属性，如果配置了，则将方法参数转换为该指定类型传给监听的方法；如果没有配置，则判断     // 目标方法是ApplicationEvent类型还是PayloadApplicationEvent类型，是则转换为该类型传入     Object[] args = resolveArguments(event);     // 这里主要是获取TransactionalEventListener注解中的condition属性，然后通过     // Spring expression language将其与目标类和方法进行匹配     if (shouldHandle(event, args)) {         // 通过处理得到的参数借助于反射调用事务监听方法         Object result = doInvoke(args);         if (result != null) {             // 对方法的返回值进行处理             handleResult(result);         } else {             logger.trace("No result object given - no result to handle");         }     }      }      // 处理事务监听方法的参数     protected Object[] resolveArguments(ApplicationEvent event) {     // 获取发布事务事件时传入的参数类型     ResolvableType declaredEventType = getResolvableType(event);     if (declaredEventType == null) {         return null;     }     // 如果事务监听方法的参数个数为0，则直接返回     if (this.method.getParameterCount() == 0) {         return new Object[0];     }     // 如果事务监听方法的参数不为ApplicationEvent或PayloadApplicationEvent，则直接将发布事务     // 事件时传入的参数当做事务监听方法的参数传入。从这里可以看出，如果事务监听方法的参数不是     // ApplicationEvent或PayloadApplicationEvent类型，那么其参数必须只能有一个，并且这个     // 参数必须与发布事务事件时传入的参数一致     Class<?> eventClass = declaredEventType.getRawClass();     if ((eventClass == null || !ApplicationEvent.class.isAssignableFrom(eventClass)) &&         event instanceof PayloadApplicationEvent) {         return new Object[] {((PayloadApplicationEvent) event).getPayload()};     } else {         // 如果参数类型为ApplicationEvent或PayloadApplicationEvent，则直接将其传入事务事件方法         return new Object[] {event};     }      }      // 判断事务事件方法方法是否需要进行事务事件处理     private boolean shouldHandle(ApplicationEvent event, @Nullable Object[] args) {     if (args == null) {         return false;     }     String condition = getCondition();     if (StringUtils.hasText(condition)) {         Assert.notNull(this.evaluator, "EventExpressionEvaluator must no be null");         EvaluationContext evaluationContext = this.evaluator.createEvaluationContext(             event, this.targetClass, this.method, args, this.applicationContext);         return this.evaluator.condition(condition, this.methodKey, evaluationContext);     }     return true;      }      // 对事务事件方法的返回值进行处理，这里的处理方式主要是将其作为一个事件继续发布出去，这样就可以在     // 一个统一的位置对事务事件的返回值进行处理     protected void handleResult(Object result) {     // 如果返回值是数组类型，则对数组元素一个一个进行发布     if (result.getClass().isArray()) {         Object[] events = ObjectUtils.toObjectArray(result);         for (Object event : events) {             publishEvent(event);         }     } else if (result instanceof Collection<?>) {         // 如果返回值是集合类型，则对集合进行遍历，并且发布集合中的每个元素         Collection<?> events = (Collection<?>) result;         for (Object event : events) {             publishEvent(event);         }     } else {         // 如果返回值是一个对象，则直接将其进行发布         publishEvent(result);     } } </code></pre> <h2 data-tool="mdnice编辑器" style="font-weight: bold;color: black;font-size: 22px;margin-top: 20px;margin-right: 10px;">六、小结</h2> 对于事务事件的处理，总结而言，就是为每个事务事件监听方法创建了一个 <code style="font-size: 14px;padding: 2px 4px;border-radius: 4px;margin-right: 2px;margin-left: 2px;background-color: rgba(27, 31, 35, 0.05);font-family: "Operator Mono", Consolas, Monaco, Menlo, monospace;word-break: break-all;color: rgb(255, 93, 108);">TransactionSynchronizationEventAdapter</code>对象，通过该对象在发布事务事件的时候，会在当前线程中注册该对象，这样就可以保证每个线程每个监听器中只会对应一个 <code style="font-size: 14px;padding: 2px 4px;border-radius: 4px;margin-right: 2px;margin-left: 2px;background-color: rgba(27, 31, 35, 0.05);font-family: "Operator Mono", Consolas, Monaco, Menlo, monospace;word-break: break-all;color: rgb(255, 93, 108);">TransactionSynchronizationEventAdapter</code>对象。在Spring进行事务事件的时候会调用该对象对应的监听方法，从而达到对事务事件进行监听的目的。 </section> </section> </section> </section>

Spring Cloud Gateway 整合阿里 Sentinel网关限流实战！

作者：微信小助手

<section style="font-size: 16px;" data-mpa-powered-by="yiban.io"> <section data-tool="mdnice编辑器" data-website="https://www.mdnice.com" style="line-height: 1.6;word-break: break-word;text-align: left;font-family: Optima-Regular, Optima, PingFangSC-light, PingFangTC-light, "PingFang SC", Cambria, Cochin, Georgia, Times, "Times New Roman", serif;padding: 5px;font-size: 16px;color: rgb(53, 53, 53);word-spacing: 0.8px;letter-spacing: 0.8px;border-radius: 16px;"> <section data-tool="mdnice编辑器" data-website="https://www.mdnice.com" style="line-height: 1.6;word-break: break-word;text-align: left;font-family: Optima-Regular, Optima, PingFangSC-light, PingFangTC-light, "PingFang SC", Cambria, Cochin, Georgia, Times, "Times New Roman", serif;padding: 5px;font-size: 16px;color: rgb(53, 53, 53);word-spacing: 0.8px;letter-spacing: 0.8px;border-radius: 16px;"> 文章目录如下： <figure data-tool="mdnice编辑器" style="margin-top: 10px;margin-bottom: 10px;display: flex;flex-direction: column;justify-content: center;align-items: center;border-radius: 16px;overflow: hidden;padding: 0px 0.5em;"> <img class="rich_pages wxw-img" data-fileid="100016833" data-ratio="0.21674140508221226" src="/upload/8790972537ebb048b1921239a5d10703.png" data-type="png" data-w="1338" style="border-radius: 9px;display: block;margin: 20px auto;max-width: 95%;object-fit: contain;box-shadow: rgb(210, 210, 210) 0em 0em 0.5em 0px;font-size: 17px;"> </figure> <h2 data-tool="mdnice编辑器" style="font-weight: bold;color: black;font-size: 22px;margin-top: 20px;margin-right: 10px;">网关如何限流？</h2> Spring Cloud Gateway本身自带的限流实现，过滤器是<code style="font-size: 14px;padding: 2px 4px;border-radius: 4px;margin-right: 2px;margin-left: 2px;background-color: rgba(27, 31, 35, 0.05);font-family: "Operator Mono", Consolas, Monaco, Menlo, monospace;word-break: break-all;color: rgb(255, 93, 108);">RequestRateLimiterGatewayFilterFactory</code>，不过这种上不了台面的就不再介绍了，有兴趣的可以实现下。 今天的重点是集成阿里的Sentinel实现网关限流，sentinel有不懂的可以看陈某的文章：<a href="https://mp.weixin.qq.com/s?__biz=MzU3MDAzNDg1MA==&mid=2247498039&idx=1&sn=3a3caee655ff015b46249bd51aa4dc79&scene=21#wechat_redirect" style="color: rgb(248, 57, 41);border-bottom: 1px solid rgb(248, 57, 41);" data-linktype="2">阿里限流神器Sentinel夺命连环 17 问？</a> 从1.6.0版本开始，Sentinel提供了SpringCloud Gateway的适配模块，可以提供两种资源维度的限流： <ul data-tool="mdnice编辑器" style="margin-top: 8px;margin-bottom: 8px;padding-left: 25px;color: rgb(248, 57, 41);" class="list-paddingleft-2"> <li> <section style="margin-top: 5px;margin-bottom: 5px;line-height: 26px;color: rgb(53, 53, 53);"> route维度：即在配置文件中配置的路由条目，资源名为对应的 <code style="font-size: 14px;padding: 2px 4px;border-radius: 4px;margin-right: 2px;margin-left: 2px;background-color: rgba(27, 31, 35, 0.05);font-family: "Operator Mono", Consolas, Monaco, Menlo, monospace;word-break: break-all;color: rgb(255, 93, 108);">routeId</code>，这种属于粗粒度的限流，一般是对某个微服务进行限流。 </section></li> <li> <section style="margin-top: 5px;margin-bottom: 5px;line-height: 26px;color: rgb(53, 53, 53);"> 自定义API维度：用户可以利用Sentinel提供的API来自定义一些API分组，这种属于细粒度的限流，针对某一类的uri进行匹配限流，可以跨多个微服务。 </section></li> </ul> <blockquote data-tool="mdnice编辑器" style="border-width: initial;border-style: none;border-color: initial;font-size: 0.9em;overflow: auto;margin-bottom: 20px;margin-top: 20px;padding-top: 15px;padding-right: 10px;padding-bottom: 15px;line-height: 1.75;border-radius: 13px;color: rgb(53, 53, 53);background: rgb(245, 245, 245);"> “ sentinel官方文档：https://github.com/alibaba/Sentinel/wiki/%E7%BD%91%E5%85%B3%E9%99%90%E6%B5%81 ” </blockquote> Spring Cloud Gateway集成Sentinel实现很简单，这就是阿里的魅力，提供简单、易操作的工具，让程序员专注于业务。 <h3 data-tool="mdnice编辑器" style="margin-top: 30px;margin-bottom: 15px;font-weight: bold;color: black;font-size: 20px;">新建项目</h3> 新建一个<code style="font-size: 14px;padding: 2px 4px;border-radius: 4px;margin-right: 2px;margin-left: 2px;background-color: rgba(27, 31, 35, 0.05);font-family: "Operator Mono", Consolas, Monaco, Menlo, monospace;word-break: break-all;color: rgb(255, 93, 108);">gateway-sentinel9026</code>模块，添加如下依赖： <pre data-tool="mdnice编辑器" style="margin-top: 10px;margin-bottom: 10px;border-radius: 5px;box-shadow: rgba(0, 0, 0, 0.55) 0px 2px 10px;"><span style="display: block;background: url("https://mmbiz.qpic.cn/mmbiz_svg/A7sq8BD8oewJibQ3rHv2SQ8IrX6oXXiciaPmTIMiceSuiam7YoSysiccdJTCbfZDRyQCvbnAUPXSbdRxIAZMPO5wTlonFpFWHWJN6E/640?wx_fmt=svg") 10px 10px / 40px no-repeat rgb(250, 250, 250);height: 30px;width: 100%;margin-bottom: -7px;border-radius: 5px;"><code style="overflow-x: auto;padding: 16px;color: #383a42;display: -webkit-box;font-family: Operator Mono, Consolas, Monaco, Menlo, monospace;font-size: 12px;-webkit-overflow-scrolling: touch;padding-top: 15px;background: #fafafa;border-radius: 5px;">     <dependency>       <groupId>com.alibaba.cloud</groupId>       <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>     </dependency>          <dependency>       <groupId>org.springframework.cloud</groupId>       <artifactId>spring-cloud-starter-gateway</artifactId>     </dependency>          <dependency>       <groupId>com.alibaba.cloud</groupId>       <artifactId>spring-cloud-alibaba-sentinel-gateway</artifactId>     </dependency>          <dependency>       <groupId>com.alibaba.cloud</groupId>       <artifactId>spring-cloud-starter-alibaba-sentinel</artifactId>     </dependency> </code></pre> <blockquote data-tool="mdnice编辑器" style="border-width: initial;border-style: none;border-color: initial;font-size: 0.9em;overflow: auto;margin-bottom: 20px;margin-top: 20px;padding-top: 15px;padding-right: 10px;padding-bottom: 15px;line-height: 1.75;border-radius: 13px;color: rgb(53, 53, 53);background: rgb(245, 245, 245);"> “ 注意：这依然是一个网关服务，不要添加WEB的依赖 ” </blockquote> <h3 data-tool="mdnice编辑器" style="margin-top: 30px;margin-bottom: 15px;font-weight: bold;color: black;font-size: 20px;">配置文件</h3> 配置文件中主要指定以下三种配置： <ul data-tool="mdnice编辑器" style="margin-top: 8px;margin-bottom: 8px;padding-left: 25px;color: rgb(248, 57, 41);" class="list-paddingleft-2"> <li> <section style="margin-top: 5px;margin-bottom: 5px;line-height: 26px;color: rgb(53, 53, 53);"> nacos的地址 </section></li> <li> <section style="margin-top: 5px;margin-bottom: 5px;line-height: 26px;color: rgb(53, 53, 53);"> sentinel控制台的地址 </section></li> <li> <section style="margin-top: 5px;margin-bottom: 5px;line-height: 26px;color: rgb(53, 53, 53);"> 网关路由的配置 </section></li> </ul> 配置如下： <pre data-tool="mdnice编辑器" style="margin-top: 10px;margin-bottom: 10px;border-radius: 5px;box-shadow: rgba(0, 0, 0, 0.55) 0px 2px 10px;"><span style="display: block;background: url("https://mmbiz.qpic.cn/mmbiz_svg/A7sq8BD8oewJibQ3rHv2SQ8IrX6oXXiciaPmTIMiceSuiam7YoSysiccdJTCbfZDRyQCvbnAUPXSbdRxIAZMPO5wTlonFpFWHWJN6E/640?wx_fmt=svg") 10px 10px / 40px no-repeat rgb(250, 250, 250);height: 30px;width: 100%;margin-bottom: -7px;border-radius: 5px;"><code style="overflow-x: auto;padding: 16px;color: #383a42;display: -webkit-box;font-family: Operator Mono, Consolas, Monaco, Menlo, monospace;font-size: 12px;-webkit-overflow-scrolling: touch;padding-top: 15px;background: #fafafa;border-radius: 5px;">spring:   cloud:     ## 整合sentinel，配置sentinel控制台的地址     sentinel:       transport:         ## 指定控制台的地址，默认端口8080         dashboard: localhost:8080     nacos:       ## 注册中心配置       discovery:         # nacos的服务地址，nacos-server中IP地址:端口号         server-addr: 127.0.0.1:8848     gateway:       ## 路由       routes:         ## id只要唯一即可，名称任意         - id: gateway-provider           uri: lb://gateway-provider           ## 配置断言           predicates:             ## Path Route Predicate Factory断言，满足/gateway/provider/**这个请求路径的都会被路由到http://localhost:9024这个uri中             - Path=/gateway/provider/** </code></pre> 上述配置中设置了一个路由<code style="font-size: 14px;padding: 2px 4px;border-radius: 4px;margin-right: 2px;margin-left: 2px;background-color: rgba(27, 31, 35, 0.05);font-family: "Operator Mono", Consolas, Monaco, Menlo, monospace;word-break: break-all;color: rgb(255, 93, 108);">gateway-provider</code>，只要请求路径满足<code style="font-size: 14px;padding: 2px 4px;border-radius: 4px;margin-right: 2px;margin-left: 2px;background-color: rgba(27, 31, 35, 0.05);font-family: "Operator Mono", Consolas, Monaco, Menlo, monospace;word-break: break-all;color: rgb(255, 93, 108);">/gateway/provider/**</code>都会被路由到<code style="font-size: 14px;padding: 2px 4px;border-radius: 4px;margin-right: 2px;margin-left: 2px;background-color: rgba(27, 31, 35, 0.05);font-family: "Operator Mono", Consolas, Monaco, Menlo, monospace;word-break: break-all;color: rgb(255, 93, 108);">gateway-provider</code>这个服务中。 <h3 data-tool="mdnice编辑器" style="margin-top: 30px;margin-bottom: 15px;font-weight: bold;color: black;font-size: 20px;">限流配置</h3> 经过上述两个步骤其实已经整合好了Sentinel，此时访问一下接口：http://localhost:9026/gateway/provider/port 然后在sentinel控制台可以看到已经被监控了，监控的路由是<code style="font-size: 14px;padding: 2px 4px;border-radius: 4px;margin-right: 2px;margin-left: 2px;background-color: rgba(27, 31, 35, 0.05);font-family: "Operator Mono", Consolas, Monaco, Menlo, monospace;word-break: break-all;color: rgb(255, 93, 108);">gateway-provider</code>，如下图： <figure data-tool="mdnice编辑器" style="margin-top: 10px;margin-bottom: 10px;display: flex;flex-direction: column;justify-content: center;align-items: center;border-radius: 16px;overflow: hidden;padding: 0px 0.5em;"> <img class="rich_pages wxw-img" data-fileid="100016834" data-ratio="0.33877766069546894" src="/upload/4b96255c379b7f2b236f31bbb2ca0fd9.png" data-type="png" data-w="1898" style="border-radius: 9px;display: block;margin: 20px auto;max-width: 95%;object-fit: contain;box-shadow: rgb(210, 210, 210) 0em 0em 0.5em 0px;font-size: 17px;"> </figure> 此时我们可以为其新增一个route维度的限流，如下图： <figure data-tool="mdnice编辑器" style="margin-top: 10px;margin-bottom: 10px;display: flex;flex-direction: column;justify-content: center;align-items: center;border-radius: 16px;overflow: hidden;padding: 0px 0.5em;"> <img class="rich_pages wxw-img" data-fileid="100016835" data-ratio="0.70261066969353" src="/upload/9e221768d24a8f5811d3248467b2fb8d.png" data-type="png" data-w="881" style="border-radius: 9px;display: block;margin: 20px auto;max-width: 95%;object-fit: contain;box-shadow: rgb(210, 210, 210) 0em 0em 0.5em 0px;font-size: 17px;"> </figure> 上图中对<code style="font-size: 14px;padding: 2px 4px;border-radius: 4px;margin-right: 2px;margin-left: 2px;background-color: rgba(27, 31, 35, 0.05);font-family: "Operator Mono", Consolas, Monaco, Menlo, monospace;word-break: break-all;color: rgb(255, 93, 108);">gateway-provider</code>这个路由做出了限流，QPS阈值为1。 此时快速访问：http://localhost:9026/gateway/provider/port，看到已经被限流了，如下图： <figure data-tool="mdnice编辑器" style="margin-top: 10px;margin-bottom: 10px;display: flex;flex-direction: column;justify-content: center;align-items: center;border-radius: 16px;overflow: hidden;padding: 0px 0.5em;"> <img class="rich_pages wxw-img" data-fileid="100016836" data-ratio="0.4675419401896426" src="/upload/9b11ccf146c547f6a5e9899807f05626.png" data-type="png" data-w="1371" style="border-radius: 9px;display: block;margin: 20px auto;max-width: 95%;object-fit: contain;box-shadow: rgb(210, 210, 210) 0em 0em 0.5em 0px;font-size: 17px;"> </figure> 以上route维度的限流已经配置成功，小伙伴可以自己照着上述步骤尝试一下。 API分组限流也很简单，首先需要定义一个分组，API管理-> 新增API分组，如下图： <figure data-tool="mdnice编辑器" style="margin-top: 10px;margin-bottom: 10px;display: flex;flex-direction: column;justify-content: center;align-items: center;border-radius: 16px;overflow: hidden;padding: 0px 0.5em;"> <img class="rich_pages wxw-img" data-fileid="100016837" data-ratio="0.33125" src="/upload/67aeb63c65709b51e8d67acb04a777ac.png" data-type="png" data-w="1920" style="border-radius: 9px;display: block;margin: 20px auto;max-width: 95%;object-fit: contain;box-shadow: rgb(210, 210, 210) 0em 0em 0.5em 0px;font-size: 17px;"> </figure> 匹配模式选择了精确匹配（还有前缀匹配，正则匹配），因此只有这个uri：<code style="font-size: 14px;padding: 2px 4px;border-radius: 4px;margin-right: 2px;margin-left: 2px;background-color: rgba(27, 31, 35, 0.05);font-family: "Operator Mono", Consolas, Monaco, Menlo, monospace;word-break: break-all;color: rgb(255, 93, 108);">http://xxxx/gateway/provider/port</code>会被限流。 第二步需要对这个分组添加流控规则，流控规则->新增网关流控，如下图： <figure data-tool="mdnice编辑器" style="margin-top: 10px;margin-bottom: 10px;display: flex;flex-direction: column;justify-content: center;align-items: center;border-radius: 16px;overflow: hidden;padding: 0px 0.5em;"> <img class="rich_pages wxw-img" data-fileid="100016841" data-ratio="0.4164484023048717" src="/upload/5cce17df4d6d895def63cb9d0e428c73.png" data-type="png" data-w="1909" style="border-radius: 9px;display: block;margin: 20px auto;max-width: 95%;object-fit: contain;box-shadow: rgb(210, 210, 210) 0em 0em 0.5em 0px;font-size: 17px;"> </figure> API名称那里选择对应的分组即可，新增之后，限流规则就生效了。 陈某不再测试了，小伙伴自己动手测试一下吧............... <blockquote data-tool="mdnice编辑器" style="border-width: initial;border-style: none;border-color: initial;font-size: 0.9em;overflow: auto;margin-bottom: 20px;margin-top: 20px;padding-top: 15px;padding-right: 10px;padding-bottom: 15px;line-height: 1.75;border-radius: 13px;color: rgb(53, 53, 53);background: rgb(245, 245, 245);"> “ 陈某这里只是简单的配置一下，至于限流规则持久化一些内容请看陈某的Sentinel文章，这里就不再过多的介绍了。 ” </blockquote> <h2 data-tool="mdnice编辑器" style="font-weight: bold;color: black;font-size: 22px;margin-top: 20px;margin-right: 10px;">如何自定义限流异常信息？</h2> 从上面的演示中可以看到默认的异常返回信息是："Block........."，这种肯定是客户端不能接受的，因此需要定制自己的异常返回信息。 下面介绍两种不同的方式定制异常返回信息，开发中自己选择其中一种。 <h3 data-tool="mdnice编辑器" style="margin-top: 30px;margin-bottom: 15px;font-weight: bold;color: black;font-size: 20px;">直接配置文件中定制</h3> 开发者可以直接在配置文件中直接修改返回信息，配置如下： <pre data-tool="mdnice编辑器" style="margin-top: 10px;margin-bottom: 10px;border-radius: 5px;box-shadow: rgba(0, 0, 0, 0.55) 0px 2px 10px;"><span style="display: block;background: url("https://mmbiz.qpic.cn/mmbiz_svg/A7sq8BD8oewJibQ3rHv2SQ8IrX6oXXiciaPmTIMiceSuiam7YoSysiccdJTCbfZDRyQCvbnAUPXSbdRxIAZMPO5wTlonFpFWHWJN6E/640?wx_fmt=svg") 10px 10px / 40px no-repeat rgb(250, 250, 250);height: 30px;width: 100%;margin-bottom: -7px;border-radius: 5px;"><code style="overflow-x: auto;padding: 16px;color: #383a42;display: -webkit-box;font-family: Operator Mono, Consolas, Monaco, Menlo, monospace;font-size: 12px;-webkit-overflow-scrolling: touch;padding-top: 15px;background: #fafafa;border-radius: 5px;">spring:   cloud:     ## 整合sentinel，配置sentinel控制台的地址     sentinel:       #配置限流之后，响应内容       scg:         fallback:           ## 两种模式，一种是response返回文字提示信息，           ## 一种是redirect，重定向跳转，需要同时配置redirect(跳转的uri)           mode: response           ## 响应的状态           response-status: 200           ## 响应体           response-body: '{"code": 200,"message": "请求失败，稍后重试！"}' </code></pre> 上述配置中<code style="font-size: 14px;padding: 2px 4px;border-radius: 4px;margin-right: 2px;margin-left: 2px;background-color: rgba(27, 31, 35, 0.05);font-family: "Operator Mono", Consolas, Monaco, Menlo, monospace;word-break: break-all;color: rgb(255, 93, 108);">mode</code>配置的是<code style="font-size: 14px;padding: 2px 4px;border-radius: 4px;margin-right: 2px;margin-left: 2px;background-color: rgba(27, 31, 35, 0.05);font-family: "Operator Mono", Consolas, Monaco, Menlo, monospace;word-break: break-all;color: rgb(255, 93, 108);">response</code>，一旦被限流了，将会返回<code style="font-size: 14px;padding: 2px 4px;border-radius: 4px;margin-right: 2px;margin-left: 2px;background-color: rgba(27, 31, 35, 0.05);font-family: "Operator Mono", Consolas, Monaco, Menlo, monospace;word-break: break-all;color: rgb(255, 93, 108);">JSON</code>串。 <pre data-tool="mdnice编辑器" style="margin-top: 10px;margin-bottom: 10px;border-radius: 5px;box-shadow: rgba(0, 0, 0, 0.55) 0px 2px 10px;"><span style="display: block;background: url("https://mmbiz.qpic.cn/mmbiz_svg/A7sq8BD8oewJibQ3rHv2SQ8IrX6oXXiciaPmTIMiceSuiam7YoSysiccdJTCbfZDRyQCvbnAUPXSbdRxIAZMPO5wTlonFpFWHWJN6E/640?wx_fmt=svg") 10px 10px / 40px no-repeat rgb(250, 250, 250);height: 30px;width: 100%;margin-bottom: -7px;border-radius: 5px;"><code style="overflow-x: auto;padding: 16px;color: #383a42;display: -webkit-box;font-family: Operator Mono, Consolas, Monaco, Menlo, monospace;font-size: 12px;-webkit-overflow-scrolling: touch;padding-top: 15px;background: #fafafa;border-radius: 5px;">{     "code": 200,     "message": "请求失败，稍后重试！" } </code></pre> 重定向的配置如下： <pre data-tool="mdnice编辑器" style="margin-top: 10px;margin-bottom: 10px;border-radius: 5px;box-shadow: rgba(0, 0, 0, 0.55) 0px 2px 10px;"><span style="display: block;background: url("https://mmbiz.qpic.cn/mmbiz_svg/A7sq8BD8oewJibQ3rHv2SQ8IrX6oXXiciaPmTIMiceSuiam7YoSysiccdJTCbfZDRyQCvbnAUPXSbdRxIAZMPO5wTlonFpFWHWJN6E/640?wx_fmt=svg") 10px 10px / 40px no-repeat rgb(250, 250, 250);height: 30px;width: 100%;margin-bottom: -7px;border-radius: 5px;"><code style="overflow-x: auto;padding: 16px;color: #383a42;display: -webkit-box;font-family: Operator Mono, Consolas, Monaco, Menlo, monospace;font-size: 12px;-webkit-overflow-scrolling: touch;padding-top: 15px;background: #fafafa;border-radius: 5px;">spring:   cloud:     ## 整合sentinel，配置sentinel控制台的地址     sentinel:       #配置限流之后，响应内容       scg:         fallback:           ## 两种模式，一种是response返回文字提示信息，一种是redirect，重定向跳转，需要同时配置redirect(跳转的uri)           mode: redirect           ## 跳转的URL           redirect: http://www.baidu.com </code></pre> 一旦被限流，将会直接跳转到：http://www.baidu.com <h3 data-tool="mdnice编辑器" style="margin-top: 30px;margin-bottom: 15px;font-weight: bold;color: black;font-size: 20px;">编码定制</h3> 这种就不太灵活了，通过硬编码的方式，完整代码如下： <pre data-tool="mdnice编辑器" style="margin-top: 10px;margin-bottom: 10px;border-radius: 5px;box-shadow: rgba(0, 0, 0, 0.55) 0px 2px 10px;"><span style="display: block;background: url("https://mmbiz.qpic.cn/mmbiz_svg/A7sq8BD8oewJibQ3rHv2SQ8IrX6oXXiciaPmTIMiceSuiam7YoSysiccdJTCbfZDRyQCvbnAUPXSbdRxIAZMPO5wTlonFpFWHWJN6E/640?wx_fmt=svg") 10px 10px / 40px no-repeat rgb(250, 250, 250);height: 30px;width: 100%;margin-bottom: -7px;border-radius: 5px;"><code style="overflow-x: auto;padding: 16px;color: #383a42;display: -webkit-box;font-family: Operator Mono, Consolas, Monaco, Menlo, monospace;font-size: 12px;-webkit-overflow-scrolling: touch;padding-top: 15px;background: #fafafa;border-radius: 5px;">@Configuration public class GatewayConfig {     /**      * 自定义限流处理器      */     @PostConstruct     public void initBlockHandlers() {         BlockRequestHandler blockHandler = (serverWebExchange, throwable) -> {             Map map = new HashMap();             map.put("code",200);             map.put("message","请求失败，稍后重试！");             return ServerResponse.status(HttpStatus.OK)                     .contentType(MediaType.APPLICATION_JSON_UTF8)                     .body(BodyInserters.fromObject(map));         };         GatewayCallbackManager.setBlockHandler(blockHandler);     } } </code></pre> 两种方式介绍完了，根据业务需求自己选择适合的方式，当然陈某更喜欢第一种，理由：约定>配置>编码。 <h2 data-tool="mdnice编辑器" style="font-weight: bold;color: black;font-size: 22px;margin-top: 20px;margin-right: 10px;">网关限流了，服务就安全了吗？</h2> 很多人认为只要网关层面做了限流，躲在身后的服务就可以高枕无忧了，你是不是也有这种想法？ 很显然这种想法是错误的，复杂的微服务架构一个独立服务不仅仅被一方调用，往往是多方调用，如下图： <figure data-tool="mdnice编辑器" style="margin-top: 10px;margin-bottom: 10px;display: flex;flex-direction: column;justify-content: center;align-items: center;border-radius: 16px;overflow: hidden;padding: 0px 0.5em;"> <img data-fileid="100016839" data-ratio="0.5913838120104439" src="/upload/c32619339f86f42cdb366946869024dc.png" data-type="png" data-w="766" style="border-radius: 9px;display: block;margin: 20px auto;max-width: 95%;object-fit: contain;box-shadow: rgb(210, 210, 210) 0em 0em 0.5em 0px;font-size: 17px;"> </figure> 商品服务不仅仅被网关层调用，还被内部订单服务调用，这时候仅仅在网关层限流，那么商品服务还安全吗？ 一旦大量的请求订单服务，比如大促秒杀，商品服务不做限流会被瞬间击垮。 因此需要根据公司业务场景对自己负责的服务也要进行限流兜底，最常见的方案：网关层集群限流+内部服务的单机限流兜底，这样才能保证不被流量冲垮。 <h2 data-tool="mdnice编辑器" style="font-weight: bold;color: black;font-size: 22px;margin-top: 20px;margin-right: 10px;">总结</h2> 文章介绍了Spring Cloud Gateway整合Sentinel对网关层进行限流，以及关于限流的一些思考。如有错误之处，欢迎留言指正。 </section> </section> </section>

Postman 最被低估的功能

作者：微信小助手

<section data-tool="mdnice编辑器" data-website="https://www.mdnice.com" data-mpa-powered-by="yiban.io" style="outline: 0px;max-width: 100%;font-family: -apple-system, BlinkMacSystemFont, "Helvetica Neue", "PingFang SC", "Hiragino Sans GB", "Microsoft YaHei UI", "Microsoft YaHei", Arial, sans-serif;letter-spacing: 0.544px;white-space: normal;background-color: rgb(255, 255, 255);box-sizing: border-box !important;overflow-wrap: break-word !important;"> <h3 data-tool="mdnice编辑器" style="margin: 5px 16px 10px;outline: 0px;max-width: 100%;text-align: left;line-height: 2em;box-sizing: border-box !important;overflow-wrap: break-word !important;">Postman 最被低估的功能，自动化接口测试效率简直无敌！</h3> </section> <section style="margin: 10px 16px;padding-top: 8px;padding-bottom: 8px;outline: 0px;max-width: 100%;font-family: -apple-system, BlinkMacSystemFont, "Helvetica Neue", "PingFang SC", "Hiragino Sans GB", "Microsoft YaHei UI", "Microsoft YaHei", Arial, sans-serif;letter-spacing: 0.544px;white-space: normal;background-color: rgb(255, 255, 255);color: rgb(63, 63, 63);line-height: 2em;box-sizing: border-box !important;overflow-wrap: break-word !important;"> 该篇文章针对已经掌握 Postman 基本用法的读者，即对接口相关概念有一定了解、已经会使用 Postman 进行模拟请求的操作。 </section> <section style="margin: 10px 16px;padding-top: 8px;padding-bottom: 8px;outline: 0px;max-width: 100%;font-family: -apple-system, BlinkMacSystemFont, "Helvetica Neue", "PingFang SC", "Hiragino Sans GB", "Microsoft YaHei UI", "Microsoft YaHei", Arial, sans-serif;letter-spacing: 0.544px;white-space: normal;background-color: rgb(255, 255, 255);color: rgb(63, 63, 63);line-height: 2em;box-sizing: border-box !important;overflow-wrap: break-word !important;"> 当前环境： </section> <ul data-tool="mdnice编辑器" class="list-paddingleft-2" style="margin: 8px 16px;padding-left: 25px;outline: 0px;max-width: 100%;font-family: -apple-system, BlinkMacSystemFont, "Helvetica Neue", "PingFang SC", "Hiragino Sans GB", "Microsoft YaHei UI", "Microsoft YaHei", Arial, sans-serif;letter-spacing: 0.544px;white-space: normal;background-color: rgb(255, 255, 255);overflow-wrap: break-word !important;"> <li style="outline: 0px;max-width: 100%;font-size: 15px;font-family: Optima-Regular, PingFangTC-light;letter-spacing: 1px;box-sizing: border-box !important;overflow-wrap: break-word !important;">Window 7 - 64</li> <li style="outline: 0px;max-width: 100%;font-size: 15px;font-family: Optima-Regular, PingFangTC-light;letter-spacing: 1px;box-sizing: border-box !important;overflow-wrap: break-word !important;">Postman 版本（免费版）：Chrome App v5.5.3</li> </ul> <section style="margin: 10px 16px;padding-top: 8px;padding-bottom: 8px;outline: 0px;max-width: 100%;font-family: -apple-system, BlinkMacSystemFont, "Helvetica Neue", "PingFang SC", "Hiragino Sans GB", "Microsoft YaHei UI", "Microsoft YaHei", Arial, sans-serif;letter-spacing: 0.544px;white-space: normal;background-color: rgb(255, 255, 255);color: rgb(63, 63, 63);line-height: 2em;box-sizing: border-box !important;overflow-wrap: break-word !important;"> 不同版本页面 UI 和部分功能位置会有点不同，不过影响不大。 </section> <section style="margin: 10px 16px;padding-top: 8px;padding-bottom: 8px;outline: 0px;max-width: 100%;font-family: -apple-system, BlinkMacSystemFont, "Helvetica Neue", "PingFang SC", "Hiragino Sans GB", "Microsoft YaHei UI", "Microsoft YaHei", Arial, sans-serif;letter-spacing: 0.544px;white-space: normal;background-color: rgb(255, 255, 255);color: rgb(63, 63, 63);line-height: 2em;box-sizing: border-box !important;overflow-wrap: break-word !important;"> 我们先思考一下，如果需要达到自动化接口测试的效果，那么我们在基本的模拟请求上还需要做哪些呢？ </section> <section style="margin: 10px 16px;padding-top: 8px;padding-bottom: 8px;outline: 0px;max-width: 100%;font-family: -apple-system, BlinkMacSystemFont, "Helvetica Neue", "PingFang SC", "Hiragino Sans GB", "Microsoft YaHei UI", "Microsoft YaHei", Arial, sans-serif;letter-spacing: 0.544px;white-space: normal;background-color: rgb(255, 255, 255);color: rgb(63, 63, 63);line-height: 2em;box-sizing: border-box !important;overflow-wrap: break-word !important;"> 以下我粗略概括为 3 个问题（欢迎更多补充与建议）： </section> <ul data-tool="mdnice编辑器" class="list-paddingleft-2" style="margin: 8px 16px;padding-left: 25px;outline: 0px;max-width: 100%;font-family: -apple-system, BlinkMacSystemFont, "Helvetica Neue", "PingFang SC", "Hiragino Sans GB", "Microsoft YaHei UI", "Microsoft YaHei", Arial, sans-serif;letter-spacing: 0.544px;white-space: normal;background-color: rgb(255, 255, 255);overflow-wrap: break-word !important;"> <li style="outline: 0px;max-width: 100%;font-size: 15px;font-family: Optima-Regular, PingFangTC-light;letter-spacing: 1px;box-sizing: border-box !important;overflow-wrap: break-word !important;">如何判断接口是否请求成功</li> <li style="outline: 0px;max-width: 100%;font-size: 15px;font-family: Optima-Regular, PingFangTC-light;letter-spacing: 1px;box-sizing: border-box !important;overflow-wrap: break-word !important;">如何进行接口批量、定期测试</li> <li style="outline: 0px;max-width: 100%;font-size: 15px;font-family: Optima-Regular, PingFangTC-light;letter-spacing: 1px;box-sizing: border-box !important;overflow-wrap: break-word !important;">如何处理依赖接口问题（比如商品下单的接口必须要求先登录）</li> </ul> <section style="margin: 10px 16px;padding-top: 8px;padding-bottom: 8px;outline: 0px;max-width: 100%;font-family: -apple-system, BlinkMacSystemFont, "Helvetica Neue", "PingFang SC", "Hiragino Sans GB", "Microsoft YaHei UI", "Microsoft YaHei", Arial, sans-serif;letter-spacing: 0.544px;white-space: normal;background-color: rgb(255, 255, 255);color: rgb(63, 63, 63);line-height: 2em;box-sizing: border-box !important;overflow-wrap: break-word !important;"> 所以，接下来就主要分为 3 个部分进行介绍，以分别解决这 3 个问题。 </section> <h3 data-tool="mdnice编辑器" style="margin: 10px 16px;outline: 0px;font-weight: bold;font-size: 20.4px;max-width: 100%;font-family: -apple-system, BlinkMacSystemFont, "Helvetica Neue", "PingFang SC", "Hiragino Sans GB", "Microsoft YaHei UI", "Microsoft YaHei", Arial, sans-serif;letter-spacing: 0.544px;white-space: normal;background-color: rgb(255, 255, 255);color: rgb(63, 63, 63);line-height: 2em;text-align: left;box-sizing: border-box !important;overflow-wrap: break-word !important;"><span style="color: rgb(123, 12, 0);outline: 0px;max-width: 100%;font-family: Optima-Regular, PingFangTC-light;letter-spacing: 1px;font-size: 17px;box-sizing: border-box !important;overflow-wrap: break-word !important;">接口结果判断</h3> <section style="margin: 10px 16px;padding-top: 8px;padding-bottom: 8px;outline: 0px;max-width: 100%;font-family: -apple-system, BlinkMacSystemFont, "Helvetica Neue", "PingFang SC", "Hiragino Sans GB", "Microsoft YaHei UI", "Microsoft YaHei", Arial, sans-serif;letter-spacing: 0.544px;white-space: normal;background-color: rgb(255, 255, 255);color: rgb(63, 63, 63);line-height: 2em;box-sizing: border-box !important;overflow-wrap: break-word !important;"> 首先，既然是自动化测试，那么我们肯定需要工具 (Postman) 或者代码能帮我们直接判断结果是否符合预期。那么在接口测试上，大体就两个思路： </section> <ul data-tool="mdnice编辑器" class="list-paddingleft-2" style="margin: 8px 16px;padding-left: 25px;outline: 0px;max-width: 100%;font-family: -apple-system, BlinkMacSystemFont, "Helvetica Neue", "PingFang SC", "Hiragino Sans GB", "Microsoft YaHei UI", "Microsoft YaHei", Arial, sans-serif;letter-spacing: 0.544px;white-space: normal;background-color: rgb(255, 255, 255);overflow-wrap: break-word !important;"> <li style="outline: 0px;max-width: 100%;font-size: 15px;font-family: Optima-Regular, PingFangTC-light;letter-spacing: 1px;box-sizing: border-box !important;overflow-wrap: break-word !important;">判断请求返回的 code 是否符合预期</li> <li style="outline: 0px;max-width: 100%;font-size: 15px;font-family: Optima-Regular, PingFangTC-light;letter-spacing: 1px;box-sizing: border-box !important;overflow-wrap: break-word !important;">判断请求返回的内容中是否包含预期的内容（关键字）</li> </ul> <section style="margin: 10px 16px;padding-top: 8px;padding-bottom: 8px;outline: 0px;max-width: 100%;font-family: -apple-system, BlinkMacSystemFont, "Helvetica Neue", "PingFang SC", "Hiragino Sans GB", "Microsoft YaHei UI", "Microsoft YaHei", Arial, sans-serif;letter-spacing: 0.544px;white-space: normal;background-color: rgb(255, 255, 255);color: rgb(63, 63, 63);line-height: 2em;box-sizing: border-box !important;overflow-wrap: break-word !important;"> 接下来我们看看如何利用 Postman 来解决上述的问题： </section> <h3 data-tool="mdnice编辑器" style="margin: 10px 16px;outline: 0px;font-weight: bold;font-size: 20.4px;max-width: 100%;font-family: -apple-system, BlinkMacSystemFont, "Helvetica Neue", "PingFang SC", "Hiragino Sans GB", "Microsoft YaHei UI", "Microsoft YaHei", Arial, sans-serif;letter-spacing: 0.544px;white-space: normal;background-color: rgb(255, 255, 255);color: rgb(63, 63, 63);line-height: 2em;box-sizing: border-box !important;overflow-wrap: break-word !important;">功能区</h3> <section style="margin-right: 16px;margin-left: 16px;outline: 0px;max-width: 100%;font-family: -apple-system, BlinkMacSystemFont, "Helvetica Neue", "PingFang SC", "Hiragino Sans GB", "Microsoft YaHei UI", "Microsoft YaHei", Arial, sans-serif;letter-spacing: 0.544px;white-space: normal;background-color: rgb(255, 255, 255);box-sizing: border-box !important;overflow-wrap: break-word !important;"> <figure data-tool="mdnice编辑器" style="margin-top: 10px;margin-bottom: 10px;outline: 0px;max-width: 100%;display: flex;flex-direction: column;justify-content: center;align-items: center;box-sizing: border-box !important;overflow-wrap: break-word !important;"> <img data-fileid="504020082" data-ratio="0.39644444444444443" src="/upload/322e4a736bd2d5c24e7e0573c039845b.png" data-type="png" data-w="2250" style="margin-right: auto;margin-left: auto;outline: 0px;display: block;box-sizing: border-box !important;overflow-wrap: break-word !important;width: 556px !important;visibility: visible !important;"> </figure> </section> <section style="margin: 10px 16px;padding-top: 8px;padding-bottom: 8px;outline: 0px;max-width: 100%;font-family: -apple-system, BlinkMacSystemFont, "Helvetica Neue", "PingFang SC", "Hiragino Sans GB", "Microsoft YaHei UI", "Microsoft YaHei", Arial, sans-serif;letter-spacing: 0.544px;white-space: normal;background-color: rgb(255, 255, 255);color: rgb(63, 63, 63);line-height: 2em;box-sizing: border-box !important;overflow-wrap: break-word !important;"> 在 Postman 中相关的功能在非常显眼的地方，Tests 功能的使用需要我们有一定的编程语言基础，目前支持的脚本语言即为 JavaScript 。但比较好的一点是，我们不需要再去考虑上下文问题以及运行环境的问题，也就是说我们只需要在这边完成结果逻辑判断的代码块即可。 </section> <section style="margin: 10px 16px;padding-top: 8px;padding-bottom: 8px;outline: 0px;max-width: 100%;font-family: -apple-system, BlinkMacSystemFont, "Helvetica Neue", "PingFang SC", "Hiragino Sans GB", "Microsoft YaHei UI", "Microsoft YaHei", Arial, sans-serif;letter-spacing: 0.544px;white-space: normal;background-color: rgb(255, 255, 255);color: rgb(63, 63, 63);line-height: 2em;box-sizing: border-box !important;overflow-wrap: break-word !important;"> 而 Postman 还为我们提供了一些常用的代码模板，在 Tests 面板右边的 SNIPPETS 功能区中，所以对 JavaScript 不大了解问题也不大。代码编写相关将在下文进行具体介绍。 </section> <h3 data-tool="mdnice编辑器" style="margin: 10px 16px;outline: 0px;font-weight: bold;font-size: 20.4px;max-width: 100%;font-family: -apple-system, BlinkMacSystemFont, "Helvetica Neue", "PingFang SC", "Hiragino Sans GB", "Microsoft YaHei UI", "Microsoft YaHei", Arial, sans-serif;letter-spacing: 0.544px;white-space: normal;background-color: rgb(255, 255, 255);color: rgb(63, 63, 63);line-height: 2em;text-align: left;box-sizing: border-box !important;overflow-wrap: break-word !important;"><span style="color: rgb(123, 12, 0);outline: 0px;max-width: 100%;font-family: Optima-Regular, PingFangTC-light;letter-spacing: 1px;font-size: 17px;box-sizing: border-box !important;overflow-wrap: break-word !important;">脚本相关</h3> <section style="margin: 10px 16px;padding-top: 8px;padding-bottom: 8px;outline: 0px;max-width: 100%;font-family: -apple-system, BlinkMacSystemFont, "Helvetica Neue", "PingFang SC", "Hiragino Sans GB", "Microsoft YaHei UI", "Microsoft YaHei", Arial, sans-serif;letter-spacing: 0.544px;white-space: normal;background-color: rgb(255, 255, 255);color: rgb(63, 63, 63);line-height: 2em;box-sizing: border-box !important;overflow-wrap: break-word !important;"> 先看上图的代码部分，我们可以发现 responseCode 、 responseBody 和 tests 三个变量（可直接使用）： </section> <ul data-tool="mdnice编辑器" class="list-paddingleft-2" style="margin: 8px 16px;padding-left: 25px;outline: 0px;max-width: 100%;font-family: -apple-system, BlinkMacSystemFont, "Helvetica Neue", "PingFang SC", "Hiragino Sans GB", "Microsoft YaHei UI", "Microsoft YaHei", Arial, sans-serif;letter-spacing: 0.544px;white-space: normal;background-color: rgb(255, 255, 255);overflow-wrap: break-word !important;"> <li style="outline: 0px;max-width: 100%;box-sizing: border-box !important;overflow-wrap: break-word !important;"><code style="outline: 0px;max-width: 100%;box-sizing: border-box !important;overflow-wrap: break-word !important;">responseCode</code> ：包含请求的返回的状态信息(如：code)</li> <li style="outline: 0px;max-width: 100%;box-sizing: border-box !important;overflow-wrap: break-word !important;"><code style="outline: 0px;max-width: 100%;box-sizing: border-box !important;overflow-wrap: break-word !important;">responseBody</code>：为接口请求放回的数据内容（类型为字符串）</li> <li style="outline: 0px;max-width: 100%;box-sizing: border-box !important;overflow-wrap: break-word !important;"><code style="outline: 0px;max-width: 100%;box-sizing: border-box !important;overflow-wrap: break-word !important;">tests</code> ：为键值对形式，用于表示我们的测试结果是成功与否，最终展示在 Test Results 中。</li> <li style="outline: 0px;max-width: 100%;box-sizing: border-box !important;overflow-wrap: break-word !important;"><code style="outline: 0px;max-width: 100%;box-sizing: border-box !important;overflow-wrap: break-word !important;">key</code> ：（如：code 200）我们可以用来当做结果的一个描述</li> <li style="outline: 0px;max-width: 100%;box-sizing: border-box !important;overflow-wrap: break-word !important;"><code style="outline: 0px;max-width: 100%;box-sizing: border-box !important;overflow-wrap: break-word !important;">value</code>：其值为布尔型，ture 表示测试通过， false 表示测试失败。</li> </ul> <section style="margin: 10px 16px;padding-top: 8px;padding-bottom: 8px;outline: 0px;max-width: 100%;font-family: -apple-system, BlinkMacSystemFont, "Helvetica Neue", "PingFang SC", "Hiragino Sans GB", "Microsoft YaHei UI", "Microsoft YaHei", Arial, sans-serif;letter-spacing: 0.544px;white-space: normal;background-color: rgb(255, 255, 255);color: rgb(63, 63, 63);line-height: 2em;box-sizing: border-box !important;overflow-wrap: break-word !important;"> 所以上述代码应该不难理解了，而有了返回结果的数据以及表示结果成功与否的方式，那么我们“接口结果判断”的问题也就基本解决了。 </section> <section style="margin: 10px 16px;padding-top: 8px;padding-bottom: 8px;outline: 0px;max-width: 100%;font-family: -apple-system, BlinkMacSystemFont, "Helvetica Neue", "PingFang SC", "Hiragino Sans GB", "Microsoft YaHei UI", "Microsoft YaHei", Arial, sans-serif;letter-spacing: 0.544px;white-space: normal;background-color: rgb(255, 255, 255);color: rgb(63, 63, 63);line-height: 2em;box-sizing: border-box !important;overflow-wrap: break-word !important;"> 另外还有几个比较常用的： </section> <ul data-tool="mdnice编辑器" class="list-paddingleft-2" style="margin: 8px 16px;padding-left: 25px;outline: 0px;max-width: 100%;font-family: -apple-system, BlinkMacSystemFont, "Helvetica Neue", "PingFang SC", "Hiragino Sans GB", "Microsoft YaHei UI", "Microsoft YaHei", Arial, sans-serif;letter-spacing: 0.544px;white-space: normal;background-color: rgb(255, 255, 255);overflow-wrap: break-word !important;"> <li style="outline: 0px;max-width: 100%;font-size: 15px;font-family: Optima-Regular, PingFangTC-light;letter-spacing: 1px;box-sizing: border-box !important;overflow-wrap: break-word !important;">responseTime ：请求所耗时长</li> <li style="outline: 0px;max-width: 100%;font-size: 15px;font-family: Optima-Regular, PingFangTC-light;letter-spacing: 1px;box-sizing: border-box !important;overflow-wrap: break-word !important;">postman ：可以做的比较多，比如</li> <ul class="list-paddingleft-2" style="margin-top: 8px;margin-bottom: 8px;padding-left: 25px;outline: 0px;max-width: 100%;color: black;list-style-type: square;overflow-wrap: break-word !important;"> <li style="outline: 0px;max-width: 100%;box-sizing: border-box !important;overflow-wrap: break-word !important;">获取返回数据的头部信息：<code style="outline: 0px;max-width: 100%;box-sizing: border-box !important;overflow-wrap: break-word !important;">postman.getResponseHeader("")</code></li> <li style="outline: 0px;max-width: 100%;box-sizing: border-box !important;overflow-wrap: break-word !important;">设置全局变量：<code style="outline: 0px;max-width: 100%;box-sizing: border-box !important;overflow-wrap: break-word !important;">postman.setGlobalVariable("variable_key", "variable_value");</code></li> </ul> </ul> <h3 data-tool="mdnice编辑器" style="margin: 10px 16px;outline: 0px;font-weight: bold;font-size: 20.4px;max-width: 100%;font-family: -apple-system, BlinkMacSystemFont, "Helvetica Neue", "PingFang SC", "Hiragino Sans GB", "Microsoft YaHei UI", "Microsoft YaHei", Arial, sans-serif;letter-spacing: 0.544px;white-space: normal;background-color: rgb(255, 255, 255);color: rgb(63, 63, 63);line-height: 2em;text-align: left;box-sizing: border-box !important;overflow-wrap: break-word !important;"><span style="color: rgb(123, 12, 0);outline: 0px;max-width: 100%;font-family: Optima-Regular, PingFangTC-light;letter-spacing: 1px;font-size: 17px;box-sizing: border-box !important;overflow-wrap: break-word !important;">代码模板</h3> <section style="margin: 10px 16px;padding-top: 8px;padding-bottom: 8px;outline: 0px;max-width: 100%;font-family: -apple-system, BlinkMacSystemFont, "Helvetica Neue", "PingFang SC", "Hiragino Sans GB", "Microsoft YaHei UI", "Microsoft YaHei", Arial, sans-serif;letter-spacing: 0.544px;white-space: normal;background-color: rgb(255, 255, 255);color: rgb(63, 63, 63);line-height: 2em;box-sizing: border-box !important;overflow-wrap: break-word !important;"> Postman 在 SNIPPETS 功能区中为我们提供的代码模板已经能解决大部分情况了，以下先挑几个跟结果判断相关的进行讲解： </section> <section style="margin: 10px 16px;padding-top: 8px;padding-bottom: 8px;outline: 0px;max-width: 100%;font-family: -apple-system, BlinkMacSystemFont, "Helvetica Neue", "PingFang SC", "Hiragino Sans GB", "Microsoft YaHei UI", "Microsoft YaHei", Arial, sans-serif;letter-spacing: 0.544px;white-space: normal;background-color: rgb(255, 255, 255);color: rgb(63, 63, 63);line-height: 2em;box-sizing: border-box !important;overflow-wrap: break-word !important;"> Status code : Code is 200 </section> <section data-mpa-preserve-tpl-color="t" data-mpa-template="t" mpa-preserve="t" mpa-from-tpl="t" style="outline: 0px;max-width: 100%;font-family: -apple-system, BlinkMacSystemFont, "Helvetica Neue", "PingFang SC", "Hiragino Sans GB", "Microsoft YaHei UI", "Microsoft YaHei", Arial, sans-serif;letter-spacing: 0.544px;white-space: normal;background-color: rgb(255, 255, 255);box-sizing: border-box !important;overflow-wrap: break-word !important;"> <pre style="outline: 0px;max-width: 100%;background: none;box-sizing: border-box !important;overflow-wrap: break-word !important;"> <section style="margin-right: 16px;margin-left: 16px;padding: 5.20625px;outline: 0px;max-width: 100%;border-radius: 4px;font-size: 0.85em;background: rgb(248, 248, 248);overflow-x: auto;white-space: nowrap;line-height: 2em;box-sizing: border-box !important;overflow-wrap: break-word !important;"> <span style="outline: 0px;max-width: 100%;color: rgb(153, 153, 136);background: rgba(0, 0, 0, 0);width: 197px;text-decoration-style: solid;text-decoration-color: rgb(153, 153, 136);font-style: italic;box-sizing: border-box !important;overflow-wrap: break-word !important;">//根据返回的 Code 判断请求情况 tests[<span style="outline: 0px;max-width: 100%;color: rgb(221, 17, 68);background: rgba(0, 0, 0, 0);width: 145px;text-decoration-style: solid;text-decoration-color: rgb(221, 17, 68);box-sizing: border-box !important;overflow-wrap: break-word !important;">"Status code is 200"] = responseCode.code === <span style="outline: 0px;max-width: 100%;color: rgb(0, 128, 128);background: rgba(0, 0, 0, 0);width: 22px;text-decoration-style: solid;text-decoration-color: rgb(0, 128, 128);box-sizing: border-box !important;overflow-wrap: break-word !important;">200; </section></pre> </section> <section style="margin: 10px 16px;padding-top: 8px;padding-bottom: 8px;outline: 0px;max-width: 100%;font-family: -apple-system, BlinkMacSystemFont, "Helvetica Neue", "PingFang SC", "Hiragino Sans GB", "Microsoft YaHei UI", "Microsoft YaHei", Arial, sans-serif;letter-spacing: 0.544px;white-space: normal;background-color: rgb(255, 255, 255);color: rgb(63, 63, 63);line-height: 2em;box-sizing: border-box !important;overflow-wrap: break-word !important;"> Response body: Contains string </section> <section data-mpa-preserve-tpl-color="t" data-mpa-template="t" mpa-preserve="t" mpa-from-tpl="t" style="outline: 0px;max-width: 100%;font-family: -apple-system, BlinkMacSystemFont, "Helvetica Neue", "PingFang SC", "Hiragino Sans GB", "Microsoft YaHei UI", "Microsoft YaHei", Arial, sans-serif;letter-spacing: 0.544px;white-space: normal;background-color: rgb(255, 255, 255);box-sizing: border-box !important;overflow-wrap: break-word !important;"> <pre style="outline: 0px;max-width: 100%;background: none;box-sizing: border-box !important;overflow-wrap: break-word !important;"> <section style="margin-right: 16px;margin-left: 16px;padding: 5.20625px;outline: 0px;max-width: 100%;border-radius: 4px;font-size: 0.85em;background: rgb(248, 248, 248);overflow-x: auto;white-space: nowrap;box-sizing: border-box !important;overflow-wrap: break-word !important;"> <span style="outline: 0px;max-width: 100%;color: rgb(153, 153, 136);background: rgba(0, 0, 0, 0);width: 459px;text-decoration-style: solid;text-decoration-color: rgb(153, 153, 136);font-style: italic;box-sizing: border-box !important;overflow-wrap: break-word !important;">//判断返回的内容中是否存在“关键字”。（tests 的 key 可修改，将不再强调） tests[<span style="outline: 0px;max-width: 100%;color: rgb(221, 17, 68);background: rgba(0, 0, 0, 0);width: 152px;text-decoration-style: solid;text-decoration-color: rgb(221, 17, 68);box-sizing: border-box !important;overflow-wrap: break-word !important;">"Body matches string"] = responseBody.has(<span style="outline: 0px;max-width: 100%;color: rgb(221, 17, 68);background: rgba(0, 0, 0, 0);width: 206px;text-decoration-style: solid;text-decoration-color: rgb(221, 17, 68);box-sizing: border-box !important;overflow-wrap: break-word !important;">"这里可以改为你要判断的关键字内容"); <span style="outline: 0px;max-width: 100%;color: rgb(153, 153, 136);background: rgba(0, 0, 0, 0);width: 98px;text-decoration-style: solid;text-decoration-color: rgb(153, 153, 136);font-style: italic;box-sizing: border-box !important;overflow-wrap: break-word !important;">//如上文提到的： <span style="outline: 0px;max-width: 100%;color: rgb(153, 153, 136);background: rgba(0, 0, 0, 0);width: 267px;text-decoration-style: solid;text-decoration-color: rgb(153, 153, 136);font-style: italic;box-sizing: border-box !important;overflow-wrap: break-word !important;">// 判断结果中是否存在 access_token 关键字 tests[<span style="outline: 0px;max-width: 100%;color: rgb(221, 17, 68);background: rgba(0, 0, 0, 0);width: 130px;text-decoration-style: solid;text-decoration-color: rgb(221, 17, 68);box-sizing: border-box !important;overflow-wrap: break-word !important;">"has access_token"] = responseBody.has(<span style="outline: 0px;max-width: 100%;color: rgb(221, 17, 68);background: rgba(0, 0, 0, 0);width: 101px;text-decoration-style: solid;text-decoration-color: rgb(221, 17, 68);box-sizing: border-box !important;overflow-wrap: break-word !important;">"access_token"); </section></pre> </section> <section style="margin: 10px 16px;padding-top: 8px;padding-bottom: 8px;outline: 0px;max-width: 100%;font-family: -apple-system, BlinkMacSystemFont, "Helvetica Neue", "PingFang SC", "Hiragino Sans GB", "Microsoft YaHei UI", "Microsoft YaHei", Arial, sans-serif;letter-spacing: 0.544px;white-space: normal;background-color: rgb(255, 255, 255);color: rgb(63, 63, 63);line-height: 2em;box-sizing: border-box !important;overflow-wrap: break-word !important;"> Response body: is equal to string </section> <section data-mpa-preserve-tpl-color="t" data-mpa-template="t" mpa-preserve="t" mpa-from-tpl="t" style="outline: 0px;max-width: 100%;font-family: -apple-system, BlinkMacSystemFont, "Helvetica Neue", "PingFang SC", "Hiragino Sans GB", "Microsoft YaHei UI", "Microsoft YaHei", Arial, sans-serif;letter-spacing: 0.544px;white-space: normal;background-color: rgb(255, 255, 255);box-sizing: border-box !important;overflow-wrap: break-word !important;"> <pre style="outline: 0px;max-width: 100%;background: none;box-sizing: border-box !important;overflow-wrap: break-word !important;"> <section style="margin-right: 16px;margin-left: 16px;padding: 5.20625px;outline: 0px;max-width: 100%;border-radius: 4px;font-size: 0.85em;background: rgb(248, 248, 248);overflow-x: auto;white-space: nowrap;box-sizing: border-box !important;overflow-wrap: break-word !important;"> <span style="outline: 0px;max-width: 100%;color: rgb(153, 153, 136);background: rgba(0, 0, 0, 0);width: 206px;text-decoration-style: solid;text-decoration-color: rgb(153, 153, 136);font-style: italic;box-sizing: border-box !important;overflow-wrap: break-word !important;">//判断返回内容是否跟预期完全相等。 tests[<span style="outline: 0px;max-width: 100%;color: rgb(221, 17, 68);background: rgba(0, 0, 0, 0);width: 123px;text-decoration-style: solid;text-decoration-color: rgb(221, 17, 68);box-sizing: border-box !important;overflow-wrap: break-word !important;">"Body is correct"] = responseBody === <span style="outline: 0px;max-width: 100%;color: rgb(221, 17, 68);background: rgba(0, 0, 0, 0);width: 158px;text-decoration-style: solid;text-decoration-color: rgb(221, 17, 68);box-sizing: border-box !important;overflow-wrap: break-word !important;">"这里可以改为你的预期内容"; </section></pre> </section> <section style="margin: 10px 16px;padding-top: 8px;padding-bottom: 8px;outline: 0px;max-width: 100%;font-family: -apple-system, BlinkMacSystemFont, "Helvetica Neue", "PingFang SC", "Hiragino Sans GB", "Microsoft YaHei UI", "Microsoft YaHei", Arial, sans-serif;letter-spacing: 0.544px;white-space: normal;background-color: rgb(255, 255, 255);color: rgb(63, 63, 63);line-height: 2em;box-sizing: border-box !important;overflow-wrap: break-word !important;"> Response body: JSON value check </section> <section data-mpa-preserve-tpl-color="t" data-mpa-template="t" mpa-preserve="t" mpa-from-tpl="t" style="outline: 0px;max-width: 100%;font-family: -apple-system, BlinkMacSystemFont, "Helvetica Neue", "PingFang SC", "Hiragino Sans GB", "Microsoft YaHei UI", "Microsoft YaHei", Arial, sans-serif;letter-spacing: 0.544px;white-space: normal;background-color: rgb(255, 255, 255);box-sizing: border-box !important;overflow-wrap: break-word !important;"> <pre style="outline: 0px;max-width: 100%;background: none;box-sizing: border-box !important;overflow-wrap: break-word !important;"> <section style="margin-right: 16px;margin-left: 16px;padding: 5.20625px;outline: 0px;max-width: 100%;border-radius: 4px;font-size: 0.85em;background: rgb(248, 248, 248);overflow-x: auto;white-space: nowrap;box-sizing: border-box !important;overflow-wrap: break-word !important;"> <span style="outline: 0px;max-width: 100%;color: rgb(153, 153, 136);background: rgba(0, 0, 0, 0);width: 367px;text-decoration-style: solid;text-decoration-color: rgb(153, 153, 136);font-style: italic;box-sizing: border-box !important;overflow-wrap: break-word !important;">//上文提到，responseBody 为字符串类型，支持转为 Json 格式 <span style="outline: 0px;max-width: 100%;background: rgba(0, 0, 0, 0);width: 21px;text-decoration-style: solid;text-decoration-color: rgb(51, 51, 51);font-weight: 700;box-sizing: border-box !important;overflow-wrap: break-word !important;">var jsonData = JSON.parse(re

shell脚本编写手册(2021重编)

作者：微信小助手

<section data-mpa-powered-by="yiban.io"> <section style="font-size: 16px;color: rgb(62, 62, 62);line-height: 1.6;letter-spacing: 0px;font-family: "Helvetica Neue", Helvetica, "Hiragino Sans GB", "Microsoft YaHei", Arial, sans-serif;"> <pre style="font-size: inherit;color: inherit;line-height: inherit;"><code style="margin-right: 2px;margin-left: 2px;line-height: 18px;font-size: 14px;letter-spacing: 0px;font-family: Consolas, Inconsolata, Courier, monospace;border-radius: 0px;color: rgb(169, 183, 198);background: rgb(40, 43, 46);padding: 0.5em;overflow-wrap: normal !important;word-break: normal !important;overflow: auto !important;display: -webkit-box !important;">{     #!/bin/sh                             # 在脚本第一行脚本头 # sh为当前系统默认shell,可指定为bash等shell     shopt                                 # 显示和设置shell中的行为选项     sh -x                                 # 执行过程     sh -n                                 # 检查语法     set -e                                # 若指令传回值不等于0，则立即退出shell     (a=bbk)                               # 括号创建子shell运行     basename /a/b/c                       # 从全路径中保留最后一层文件名或目录     dirname                               # 取路径     $RANDOM                               # 随机数     $$                                    # 进程号     source FileName                       # 在当前bash环境下读取并执行FileName中的命令  # 等同 . FileName     sleep 5                               # 间隔睡眠5秒     trap                                  # 在接收到信号后将要采取的行动     trap "" 2 3                           # 禁止ctrl+c     $PWD                                  # 当前目录     $HOME                                 # 家目录     $OLDPWD                               # 之前一个目录的路径     cd -                                  # 返回上一个目录路径     local ret                             # 局部变量     yes                                   # 重复打印     yes |rm -i *                          # 自动回答y或者其他     ls -p /home                           # 区分目录和文件夹     ls -d /home/                          # 查看匹配完整路径     time a.sh                             # 测试程序执行时间     echo -n aa;echo bb                    # 不换行执行下一句话 将字符串原样输出     echo -e "s\tss\n\n\n"                 # 使转义生效     echo $a | cut -c2-6                   # 取字符串中字元     echo {a,b,c}{a,b,c}{a,b,c}            # 排列组合(括号内一个元素分别和其他括号内元素组合)     echo $((2#11010))                     # 二进制转10进制     echo aaa | tee file                   # 打印同时写入文件 默认覆盖 -a追加     echo {1..10}                          # 打印10个字符     printf '%10s\n'|tr " " a              # 打印10个字符     pwd | awk -F/ '{ print $2 }'          # 返回目录名     tac file |sed 1,3d|tac                # 倒置读取文件  # 删除最后3行     tail -3 file                          # 取最后3行     outtmp=/tmp/$$`date +%s%N`.outtmp     # 临时文件定义     :(){ :|:& };:                         # fork炸弹,系统执行海量的进程,直到系统僵死     echo -e "\e[32mcolour\e[0m"           # 打印颜色     echo -e "\033[32mcolour\033[m"        # 打印颜色     echo -e "\033[0;31mL\033[0;32mO\033[0;33mV\033[0;34mE\t\033[0;35mY\033[0;36mO\033[0;32mU\e[m"    # 打印颜色     正则表达式{         ^                       # 行首定位         $                       # 行尾定位         .                       # 匹配除换行符以外的任意字符         *                       # 匹配0或多个重复字符         +                       # 重复一次或更多次         ?                       # 重复零次或一次         ?                       # 结束贪婪因子 .*? 表示最小匹配         []                      # 匹配一组中任意一个字符         [^]                     # 匹配不在指定组内的字符         \                       # 用来转义元字符         <                       # 词首定位符(支持vi和grep)  <love         >                       # 词尾定位符(支持vi和grep)  love>         x\{m\}                  # 重复出现m次         x\{m,\}                 # 重复出现至少m次         x\{m,n\}                # 重复出现至少m次不超过n次         X?                      # 匹配出现零次或一次的大写字母 X         X+                      # 匹配一个或多个字母 X         ()                      # 括号内的字符为一组         (ab|de)+                # 匹配一连串的（最少一个） abc 或 def；abc 和 def 将匹配         [[:alpha:]]             # 代表所有字母不论大小写         [[:lower:]]             # 表示小写字母         [[:upper:]]             # 表示大写字母         [[:digit:]]             # 表示数字字符         [[:digit:][:lower:]]    # 表示数字字符加小写字母         元字符{             \d       # 匹配任意一位数字             \D       # 匹配任意单个非数字字符             \w       # 匹配任意单个字母数字下划线字符，同义词是 [:alnum:]             \W       # 匹配非数字型的字符         }         字符类:空白字符{             \s       # 匹配任意的空白符             \S       # 匹配非空白字符             \b       # 匹配单词的开始或结束             \n       # 匹配换行符             \r       # 匹配回车符             \t       # 匹配制表符             \b       # 匹配退格符             \0       # 匹配空值字符         }         字符类:锚定字符{             \b       # 匹配字边界(不在[]中时)             \B       # 匹配非字边界             \A       <span style="font-size: inherit;line-h

Wireshark的抓包和分析，看这篇就够了！

作者：微信小助手

<section data-mpa-powered-by="yiban.io"> <span style="background-color: rgb(255, 255, 255);font-family: 微软雅黑, "Microsoft YaHei", "WenQuanYi Micro Hei", PingFangSC;font-size: 15px;letter-spacing: 0.544px;text-align: start;caret-color: rgb(51, 51, 51);">WireShark是一个网络封包分析软件。<span style="background-color: rgb(255, 255, 255);font-family: 微软雅黑, "Microsoft YaHei", "WenQuanYi Micro Hei", PingFangSC;font-size: 15px;letter-spacing: 0.544px;text-align: start;caret-color: rgb(51, 51, 51);">网络封包分析软件的功能是撷取网络封包，并尽可能显示出最为详细的网络封包资料。<span style="background-color: rgb(255, 255, 255);font-family: 微软雅黑, "Microsoft YaHei", "WenQuanYi Micro Hei", PingFangSC;font-size: 15px;letter-spacing: 0.544px;text-align: start;caret-color: rgb(51, 51, 51);">Wireshark使用WinPCAP作为接口，直接与网卡进行数据报文交换。<span style="background-color: rgb(255, 255, 255);font-family: 微软雅黑, "Microsoft YaHei", "WenQuanYi Micro Hei", PingFangSC;font-size: 15px;letter-spacing: 0.544px;text-align: start;caret-color: rgb(51, 51, 51);">在网络封包和流量分析领域有着十分强大功能的工具，深受各类<strong style="font-family: 微软雅黑, "Microsoft YaHei", "WenQuanYi Micro Hei", PingFangSC;font-size: 15px;letter-spacing: 0.544px;text-align: start;caret-color: rgb(51, 51, 51);outline: 0px;max-width: 100%;box-sizing: border-box !important;overflow-wrap: break-word !important;">网络工程师<span style="background-color: rgb(255, 255, 255);font-family: 微软雅黑, "Microsoft YaHei", "WenQuanYi Micro Hei", PingFangSC;font-size: 15px;letter-spacing: 0.544px;text-align: start;caret-color: rgb(51, 51, 51);">和网络分析师的喜爱。 <section> <p style="margin-bottom: 10px;outline: none;max-width: 100%;caret-color: rgb(51, 51, 51);letter-spacing: 0.544px;white-space: normal;text-size-adjust: auto;border-width: 0px;border-style: initial;border-color: initial;font-variant-numeric: inherit;font-variant-east-asian: inherit;font-stretch: inherit;font-size: 15px;line-height: 26px;vertical-align: baseline;font-family: 微软雅黑, "Microsoft YaHei", "WenQuanYi Micro Hei", PingFangSC;overflow: auto;word-break: break-word;text-align: start;background-color: rgb(255, 255, 255);box-sizing: border-box !important;overflow-wrap: break-word !important;">本文主要内容包括： <section data-tool="mdnice编辑器" data-website="https://www.mdnice.com" style="padding-right: 10px;padding-left: 10px;outline: 0px;max-width: 100%;caret-color: rgb(51, 51, 51);white-space: normal;text-size-adjust: auto;font-size: 16px;line-height: 1.6;letter-spacing: 0px;word-break: break-word;text-align: left;font-family: -apple-system, system-ui, BlinkMacSystemFont, "Helvetica Neue", "PingFang SC", "Hiragino Sans GB", "Microsoft YaHei", Arial, sans-serif;box-sizing: border-box !important;overflow-wrap: break-word !important;"> <blockquote data-tool="mdnice编辑器" style="margin-top: 20px;margin-bottom: 20px;padding: 10px 10px 10px 20px;outline: 0px;border-top-style: none;border-right-style: none;border-bottom-style: none;border-left-color: rgb(178, 174, 197);color: rgb(106, 115, 125);font-size: 0.9em;max-width: 100%;overflow: auto;background-color: rgb(255, 249, 249);box-sizing: border-box !important;overflow-wrap: break-word !important;"> <ul class="list-paddingleft-2" style="margin-top: 8px;margin-bottom: 8px;padding-left: 25px;outline: 0px;max-width: 100%;color: black;overflow-wrap: break-word !important;"> <li style="outline: 0px;max-width: 100%;box-sizing: border-box !important;overflow-wrap: break-word !important;"> <section style="margin-top: 5px;margin-bottom: 5px;outline: 0px;max-width: 100%;color: rgb(1, 1, 1);line-height: 2;box-sizing: border-box !important;overflow-wrap: break-word !important;"> 1、Wireshark主界面介绍。 </section></li> <li style="outline: 0px;max-width: 100%;box-sizing: border-box !important;overflow-wrap: break-word !important;"> <section style="margin-top: 5px;margin-bottom: 5px;outline: 0px;max-width: 100%;color: rgb(1, 1, 1);line-height: 2;box-sizing: border-box !important;overflow-wrap: break-word !important;"> 2、WireShark简单抓包示例。通过该例子学会怎么抓包以及如何简单查看分析数据包内容。 </section></li> <li style="outline: 0px;max-width: 100%;box-sizing: border-box !important;overflow-wrap: break-word !important;"> <section style="margin-top: 5px;margin-bottom: 5px;outline: 0px;max-width: 100%;color: rgb(1, 1, 1);line-height: 2;box-sizing: border-box !important;overflow-wrap: break-word !important;"> 3、Wireshark过滤器使用。通过过滤器可以筛选出想要分析的内容。包括按照协议过滤、端口和主机名过滤、数据包内容过滤。 </section></li> </ul> </blockquote> </section> <p style="margin-bottom: 10px;outline: none;max-width: 100%;caret-color: rgb(51, 51, 51);letter-spacing: 0.544px;white-space: normal;text-size-adjust: auto;border-width: 0px;border-style: initial;border-color: initial;font-variant-numeric: inherit;font-variant-east-asian: inherit;font-stretch: inherit;font-size: 15px;line-height: 26px;vertical-align: baseline;font-family: 微软雅黑, "Microsoft YaHei", "WenQuanYi Micro Hei", PingFangSC;overflow: auto;word-break: break-word;text-align: start;background-color: rgb(255, 255, 255);box-sizing: border-box !important;overflow-wrap: break-word !important;">我们首先来介绍一下Wireshark这款软件。<img class="rich_pages wxw-img" data-fileid="100007154" data-ratio="1.0526315789473684" src="/upload/f56e0592a0517f5b2c9567ef4ee0a974.jpg" data-type="jpeg" data-w="76" style="margin: 15px auto 10px;outline: none;max-width: 635px;box-sizing: border-box;vertical-align: top;border-width: 0px;border-style: initial;border-color: initial;font-style: inherit;font-variant: inherit;font-weight: inherit;font-stretch: inherit;font-size: inherit;line-height: inherit;display: block;overflow-wrap: break-word !important;width: 76px !important;visibility: visible !important;"> <p style="margin-bottom: 10px;outline: none;max-width: 100%;caret-color: rgb(51, 51, 51);letter-spacing: 0.544px;white-space: normal;text-size-adjust: auto;border-width: 0px;border-style: initial;border-color: initial;font-variant-numeric: inherit;font-variant-east-asian: inherit;font-stretch: inherit;font-size: 15px;line-height: 26px;vertical-align: baseline;font-family: 微软雅黑, "Microsoft YaHei", "WenQuanYi Micro Hei", PingFangSC;overflow: auto;word-break: break-word;text-align: start;background-color: rgb(255, 255, 255);box-sizing: border-box !important;overflow-wrap: break-word !important;">首先我们先认识一下这个软件的主界面是长这样的 <p style="margin-bottom: 10px;padding-right: 0.5em;padding-left: 0.5em;outline: none;max-width: 100%;caret-color: rgb(51, 51, 51);letter-spacing: 0.544px;white-space: normal;text-size-adjust: auto;border-width: 0px;border-style: initial;border-color: initial;font-variant-numeric: inherit;font-variant-east-asian: inherit;font-stretch: inherit;font-size: 15px;line-height: 26px;vertical-align: baseline;font-family: 微软雅黑, "Microsoft YaHei", "WenQuanYi Micro Hei", PingFangSC;overflow: auto;word-break: break-word;text-align: start;background-color: rgb(255, 255, 255);box-sizing: border-box !important;overflow-wrap: break-word !important;"><img class="rich_pages wxw-img" data-fileid="100007155" data-ratio="0.5379061371841155" src="/upload/efc5b2d9e61d3cd483b1d38c95685841.jpg" data-type="jpeg" data-w="554" style="margin: 15px auto 10px;outline: none;max-width: 635px;box-sizing: border-box;vertical-align: top;border-width: 0px;border-style: initial;border-color: initial;font-style: inherit;font-variant: inherit;font-weight: inherit;font-stretch: inherit;font-size: 17px;line-height: inherit;display: block;box-shadow: rgb(0, 0, 0) 0em 0em 0.5em 0px;overflow-wrap: break-word !important;width: 554px !important;visibility: visible !important;"> <p style="margin-bottom: 10px;outline: none;max-width: 100%;caret-color: rgb(51, 51, 51);letter-spacing: 0.544px;white-space: normal;text-size-adjust: auto;border-width: 0px;border-style: initial;border-color: initial;font-variant-numeric: inherit;font-variant-east-asian: inherit;font-stretch: inherit;font-size: 15px;line-height: 26px;vertical-align: baseline;font-family: 微软雅黑, "Microsoft YaHei", "WenQuanYi Micro Hei", PingFangSC;overflow: auto;word-break: break-word;text-align: start;background-color: rgb(255, 255, 255);box-sizing: border-box !important;overflow-wrap: break-word !important;">在这个界面中为Wireshark的主界面 <p style="margin-bottom: 10px;outline: none;max-width: 100%;caret-color: rgb(51, 51, 51);letter-spacing: 0.544px;white-space: normal;text-size-adjust: auto;border-width: 0px;border-style: initial;border-color: initial;font-variant-numeric: inherit;font-variant-east-asian: inherit;font-stretch: inherit;font-size: 15px;line-height: 26px;vertical-align: baseline;font-family: 微软雅黑, "Microsoft YaHei", "WenQuanYi Micro Hei", PingFangSC;overflow: auto;word-break: break-word;text-align: start;background-color: rgb(255, 255, 255);box-sizing: border-box !important;overflow-wrap: break-word !important;">选择菜单栏上Capture -> Option，勾选WLAN网卡（这里需要根据各自电脑网卡使用情况选择，简单的办法可以看使用的IP对应的网卡）。点击Start。启动抓包。 <p style="margin-bottom: 10px;padding-right: 0.5em;padding-left: 0.5em;outline: none;max-width: 100%;caret-color: rgb(51, 51, 51);letter-spacing: 0.544px;white-space: normal;text-size-adjust: auto;border-width: 0px;border-style: initial;border-color: initial;font-variant-numeric: inherit;font-variant-east-asian: inherit;font-stretch: inherit;font-size: 15px;line-height: 26px;vertical-align: baseline;font-family: 微软雅黑, "Microsoft YaHei", "WenQuanYi Micro Hei", PingFangSC;overflow: auto;word-break: break-word;text-align: start;background-color: rgb(255, 255, 255);box-sizing: border-box !important;overflow-wrap: break-word !important;"><img class="rich_pages wxw-img" data-fileid="100007156" data-ratio="0.4927797833935018" src="/upload/64ef7b5d25a761e3a7a243a4b59defcc.jpg" data-type="jpeg" data-w="554" style="margin: 15px auto 10px;outline: none;max-width: 635px;box-sizing: border-box;vertical-align: top;border-width: 0px;border-style: initial;border-color: initial;font-style: inherit;font-variant: inherit;font-weight: inherit;font-stretch: inherit;font-size: 17px;line-height: inherit;display: block;box-shadow: rgb(0, 0, 0) 0em 0em 0.5em 0px;overflow-wrap: break-word !important;width: 554px !important;visibility: visible !important;"> <p style="margin-bottom: 10px;outline: none;max-width: 100%;caret-color: rgb(51, 51, 51);letter-spacing: 0.544px;white-space: normal;text-size-adjust: auto;border-width: 0px;border-style: initial;border-color: initial;font-variant-numeric: inherit;font-variant-east-asian: inherit;font-stretch: inherit;font-size: 15px;line-height: 26px;vertical-align: baseline;font-family: 微软雅黑, "Microsoft YaHei", "WenQuanYi Micro Hei", PingFangSC;overflow: auto;word-break: break-word;text-align: start;background-color: rgb(255, 255, 255);box-sizing: border-box !important;overflow-wrap: break-word !important;">wireshark启动后，wireshark处于抓包状态中。 <p style="margin-bottom: 10px;padding-right: 0.5em;padding-left: 0.5em;outline: none;max-width: 100%;caret-color: rgb(51, 51, 51);letter-spacing: 0.544px;white-space: normal;text-size-adjust: auto;border-width: 0px;border-style: initial;border-color: initial;font-variant-numeric: inherit;font-variant-east-asian: inherit;font-stretch: inherit;font-size: 15px;line-height: 26px;vertical-align: baseline;font-family: 微软雅黑, "Microsoft YaHei", "WenQuanYi Micro Hei", PingFangSC;overflow: auto;word-break: break-word;text-align: start;background-color: rgb(255, 255, 255);box-sizing: border-box !important;overflow-wrap: break-word !important;"><img class="rich_pages wxw-img" data-fileid="100007157" data-ratio="0.17443868739205526" data-type="jpeg" data-w="579" src="/upload/cc1ffa31ac54597a8196a7ca9cbc3fc7.jpg" style="margin: 15px auto 10px;outline: none;max-width: 635px;box-sizing: border-box;vertical-align: top;border-width: 0px;border-style: initial;border-color: initial;font-style: inherit;font-variant: inherit;font-weight: inherit;font-stretch: inherit;font-size: 17px;line-height: inherit;display: block;box-shadow: rgb(0, 0, 0) 0em 0em 0.5em 0px;overflow-wrap: break-word !important;width: 579px !important;visibility: visible !important;"> <p style="margin-bottom: 10px;outline: none;max-width: 100%;caret-color: rgb(51, 51, 51);letter-spacing: 0.544px;white-space: normal;text-size-adjust: auto;border-width: 0px;border-style: initial;border-color: initial;font-variant-numeric: inherit;font-variant-east-asian: inherit;font-stretch: inherit;font-size: 15px;line-height: 26px;vertical-align: baseline;font-family: 微软雅黑, "Microsoft YaHei", "WenQuanYi Micro Hei", PingFangSC;overflow: auto;word-break: break-word;text-align: start;background-color: rgb(255, 255, 255);box-sizing: border-box !important;overflow-wrap: break-word !important;">1、执行需要抓包的操作，如ping www.baidu.com。 <p style="margin-bottom: 10px;outline: none;max-width: 100%;caret-color: rgb(51, 51, 51);letter-spacing: 0.544px;white-space: normal;text-size-adjust: auto;border-width: 0px;border-style: initial;border-color: initial;font-variant-numeric: inherit;font-variant-east-asian: inherit;font-stretch: inherit;font-size: 15px;line-height: 26px;vertical-align: baseline;font-family: 微软雅黑, "Microsoft YaHei", "WenQuanYi Micro Hei", PingFangSC;overflow: auto;word-break: break-word;text-align: start;background-color: rgb(255, 255, 255);box-sizing: border-box !important;overflow-wrap: break-word !important;">2、操作完成后相关数据包就抓取到了。为避免其他无用的数据包影响分析，可以通过在过滤栏设置过滤条件进行数据包列表过滤，获取结果如下。说明：ip.addr == 119.75.217.26 and icmp 表示只显示ICPM协议且源主机IP或者目的主机IP为119.75.217.26的数据包。 <p style="margin-bottom: 10px;padding-right: 0.5em;padding-left: 0.5em;outline: none;max-width: 100%;caret-color: rgb(51, 51, 51);letter-spacing: 0.544px;white-space: normal;text-size-adjust: auto;border-width: 0px;border-style: initial;border-color: initial;font-variant-numeric: inherit;font-variant-east-asian: inherit;font-stretch: inherit;font-size: 15px;line-height: 26px;vertical-align: baseline;font-family: 微软雅黑, "Microsoft YaHei", "WenQuanYi Micro Hei", PingFangSC;overflow: auto;word-break: break-word;text-align: start;background-color: rgb(255, 255, 255);box-sizing: border-box !important;overflow-wrap: break-word !important;"><img class="rich_pages wxw-img" data-fileid="100007158" data-ratio="0.33934426229508197" src="/upload/476f699afd1f9ab86a6301ede1cbb9c4.jpg" data-type="jpeg" data-w="610" style="margin: 15px auto 10px;outline: none;max-width: 635px;box-sizing: border-box;border-width: 0px;border-style: initial;border-color: initial;vertical-align: top;font-style: inherit;font-variant: inherit;font-weight: inherit;font-stretch: inherit;font-size: 17px;line-height: inherit;display: block;box-shadow: rgb(0, 0, 0) 0em 0em 0.5em 0px;overflow-wrap: break-word !important;background-color: rgb(238, 237, 235) !important;background-size: 22px !important;height: 207px !important;width: 610px !important;background-position: center center !important;background-repeat: no-repeat !important;"> <p style="margin-bottom: 10px;outline: none;max-width: 100%;caret-color: rgb(51, 51, 51);letter-spacing: 0.544px;white-space: normal;text-size-adjust: auto;border-width: 0px;border-style: initial;border-color: initial;font-variant-numeric: inherit;font-variant-east-asian: inherit;font-stretch: inherit;font-size: 15px;line-height: 26px;vertical-align: baseline;font-family: 微软雅黑, "Microsoft YaHei", "WenQuanYi Micro Hei", PingFangSC;overflow: auto;word-break: break-word;text-align: start;background-color: rgb(255, 255, 255);box-sizing: border-box !important;overflow-wrap: break-word !important;">3、wireshark抓包完成，就这么简单。关于wireshark过滤条件和如何查看数据包中的详细内容在后面介绍。 <h3 style="margin-top: 20px;margin-bottom: 20px;outline: none;font-weight: 600;max-width: 100%;letter-spacing: 0.544px;white-space: normal;text-size-adjust: auto;border-width: 0px;border-style: initial;border-color: initial;font-variant-numeric: inherit;font-variant-east-asian: inherit;font-stretch: inherit;line-height: 26px;vertical-align: baseline;font-family: PingFangSC-Medium, "PingFang SC";word-break: break-word;color: rgba(0, 0, 0, 0.85);text-align: start;background-color: rgb(255, 255, 255);box-sizing: border-box !important;overflow-wrap: break-word !important;"></h3> <h3 style="margin-top: 20px;margin-bottom: 20px;outline: none;font-weight: 600;max-width: 100%;letter-spacing: 0.544px;white-space: normal;text-size-adjust: auto;border-width: 0px;border-style: initial;border-color: initial;font-variant-numeric: inherit;font-variant-east-asian: inherit;font-stretch: inherit;line-height: 26px;vertical-align: baseline;font-family: PingFangSC-Medium, "PingFang SC";word-break: break-word;color: rgba(0, 0, 0, 0.85);text-align: start;background-color: rgb(255, 255, 255);box-sizing: border-box !important;overflow-wrap: break-word !important;"><span style="outline: none;max-width: 100%;border-width: 0px;border-style: initial;border-color: initial;font-variant: inherit;font-stretch: inherit;font-size: inherit;line-height: inherit;vertical-align: baseline;font-family: 微软雅黑, "Microsoft YaHei", "WenQuanYi Micro Hei", PingFangSC;box-sizing: border-box !important;overflow-wrap: break-word !important;">Wireshakr抓包界面</h3> <p style="margin-bottom: 10px;padding-right: 0.5em;padding-left: 0.5em;outline: none;max-width: 100%;caret-color: rgb(51, 51, 51);letter-spacing: 0.544px;white-space: normal;text-size-adjust: auto;border-width: 0px;border-style: initial;border-color: initial;font-variant-numeric: inherit;font-variant-east-asian: inherit;font-stretch: inherit;font-size: 15px;line-height: 26px;vertical-align: baseline;font-family: 微软雅黑, "Microsoft YaHei", "WenQuanYi Micro Hei", PingFangSC;overflow: auto;word-break: break-word;text-align: start;background-color: rgb(255, 255, 255);box-sizing: border-box !important;overflow-wrap: break-word !important;"><img class="rich_pages wxw-img" data-fileid="100007159" data-ratio="0.5351170568561873" src="/upload/11cf0cbf04959435574081ea2a60507d.jpg" data-type="jpeg" data-w="598" style="margin: 15px auto 10px;outline: none;max-width: 635px;box-sizing: border-box;border-width: 0px;border-style: initial;border-color: initial;vertical-align: top;font-style: inherit;font-variant: inherit;font-weight: inherit;font-stretch: inherit;font-size: 17px;line-height: inherit;display: block;box-shadow: rgb(0, 0, 0) 0em 0em 0.5em 0px;overflow-wrap: break-word !important;background-color: rgb(238, 237, 235) !important;background-size: 22px !important;height: 320px !important;width: 598px !important;background-position: center center !important;background-repeat: no-repeat !important;"> <p style="margin-bottom: 10px;outline: none;max-width: 100%;caret-color: rgb(51, 51, 51);letter-spacing: 0.544px;white-space: normal;text-size-adjust: auto;border-width: 0px;border-style: initial;border-color: initial;font-variant-numeric: inherit;font-variant-east-asian: inherit;font-stretch: inherit;font-size: 15px;line-height: 26px;vertical-align: baseline;font-family: 微软雅黑, "Microsoft YaHei", "WenQuanYi Micro Hei", PingFangSC;overflow: auto;word-break: break-word;text-align: start;background-color: rgb(255, 255, 255);box-sizing: border-box !important;overflow-wrap: break-word !important;">说明：数据包列表区中不同的协议使用了不同的颜色区分。协议颜色标识定位在菜单栏View --> Coloring Rules。如下所示 <p style="margin-bottom: 10px;padding-right: 0.5em;padding-left: 0.5em;outline: none;max-width: 100%;caret-color: rgb(51, 51, 51);letter-spacing: 0.544px;white-space: normal;text-size-adjust: auto;border-width: 0px;border-style: initial;border-color: initial;font-variant-numeric: inherit;font-variant-east-asian: inherit;font-stretch: inherit;font-size: 15px;line-height: 26px;vertical-align: baseline;font-family: 微软雅黑, "Microsoft YaHei", "WenQuanYi Micro Hei", PingFangSC;overflow: auto;word-break: break-word;text-align: start;background-color: rgb(255, 255, 255);box-sizing: border-box !important;overflow-wrap: break-word !important;"><img class="rich_pages wxw-img" data-fileid="100007163" data-ratio="0.4278523489932886" src="/upload/1b4d6819

为什么不建议你用分布式事务？

作者：微信小助手

<section class="mp_profile_iframe_wrp"> <mpprofile class="js_uneditable custom_select_card mp_profile_iframe" data-pluginname="mpprofile" data-id="MjM5ODI5Njc2MA==" data-headimg="http://mmbiz.qpic.cn/mmbiz_png/MOwlO0INfQpzXtDQlnqOx4arg3nssiap6PXl3MYlficbxT9ML65AQrcp3HESLmibjjxOHoFKNKQBt3vHNmNXAsqnA/0?wx_fmt=png" data-nickname="51CTO技术栈" data-alias="blog51cto" data-signature="51CTO技术栈专注于IT技术领域，汇聚技术大咖为您分享开发架构、系统运维、大数据、人工智能等一线技术解析和实践案例等深度干货文章，愿我们一起悦享技术，成就CTO梦想！" data-from="0"></mpprofile> </section> <section style="box-sizing: border-box;font-size: 16px;"> <section style="margin-top: 10px;margin-bottom: 10px;box-sizing: border-box;" powered-by="xiumi.us"> <section style="padding-top: 10px;padding-right: 10px;padding-left: 10px;background-color: rgb(239, 239, 239);box-sizing: border-box;"> <section style="box-sizing: border-box;"> “ </section> <section style="display: inline-block;vertical-align: top;float: right;width: 90%;line-height: 1.5;font-size: 15px;color: rgb(89, 89, 89);box-sizing: border-box;"> 伴随着业务的快速的发展、越来越高的业务复杂度，几乎每个公司的系统都会从单体走向分布式，特别是转向微服务架构。 </section> <section style="clear: both;box-sizing: border-box;"> <section> <svg viewbox="0 0 1 1" style="float:left;line-height:0;width:0;vertical-align:top;"></svg> </section> </section> </section> </section> </section> <section style="line-height: normal;"> </section> <section style="text-align: center;margin-left: 8px;margin-right: 8px;"> <img class="rich_pages wxw-img custom_select_img" data-fileid="508370886" data-galleryid="" data-ratio="0.661432777232581" data-s="300,640" src="/upload/4bbc5f893e460ea5f6b83e5b77c7725b.png" data-type="png" data-w="1019" style=""> </section> 图片来自 Pexels <section style="line-height: normal;"> </section> 随之而来就必然遇到分布式事务这个难题。而我的这篇文章总结了分布式事务的解决方案，希望给大家带来帮助。 <section style="box-sizing: border-box;font-size: 16px;"> <section style="border-bottom: 1px solid black;margin-top: 0.5em;margin-bottom: 0.5em;line-height: 1.2;box-sizing: border-box;" powered-by="xiumi.us"> <section style="display: inline-block;border-bottom: 6px solid rgb(89, 89, 89);margin-bottom: -1px;border-top-color: rgb(89, 89, 89);border-right-color: rgb(89, 89, 89);border-left-color: rgb(89, 89, 89);font-size: 20px;color: rgb(89, 89, 89);box-sizing: border-box;"> 分布式事务基础 </section> </section> </section> ①到底什么是事务呢？ <section style="line-height: normal;"> </section> 什么是事务？举个生活中的例子：你去小卖铺买东西，“一手交钱，一手交货”就是一个事务的例子，交钱和交货必须全部成功，事务才算成功，任一个活动失败，事务将撤销所有已成功的活动。 <section style="line-height: normal;"> </section> 明白上述例子，再来看事务的定义：事务可以看做是一次大的活动，它由不同的小活动组成，这些活动要么全部成功，要么全部失败。 <section style="line-height: normal;"> </section> ②先来回顾本地事务 <section style="line-height: normal;"> </section> 在计算机系统中，更多的是通过关系型数据库来控制事务，这是利用数据库本身的事务特性来实现的，因此叫数据库事务。 <section style="line-height: normal;"> </section> 由于应用主要靠关系数据库来控制事务，而数据库通常和应用在同一个服务器，所以基于关系型数据库的事务又被称为本地事务。 <section style="line-height: normal;"> </section> 回顾一下数据库事务的四大特性 ACID： <ul class="list-paddingleft-2" style="list-style-type: disc;"> <li>A（Atomic）：原子性，构成事务的所有操作，要么都执行完成，要么全部不执行，不可能出现部分成功部分失败的情况。</li> <li>C（Consistency）：一致性，在事务执行前后，数据库的一致性约束没有被破坏。比如：张三向李四转 100 元，转账前和转账后的数据是正确状态这叫一致性，如果出现张三转出 100 元，李四账户没有增加 100 元这就出现了数据错误，就没有达到一致性。</li> <li>I（Isolation）：隔离性，数据库中的事务一般都是并发的，隔离性是指并发的两个事务的执行互不干扰，一个事务不能看到其他事务运行过程的中间状态。通过配置事务隔离级别可以避脏读、重复读等问题。</li> <li>D（Durability）：持久性，事务完成之后，该事务对数据的更改会被持久化到数据库，且不会被回滚。</li> </ul> <section style="line-height: normal;"> </section> 数据库事务在实现时会将一次事务涉及的所有操作全部纳入到一个不可分割的执行单元，该执行单元中的所有操作要么都成功，要么都失败，只要其中任一操作执行失败，都将导致整个事务的回滚。 <section style="line-height: normal;"> </section> ③分布式事务 <section style="line-height: normal;"> </section> 银行跨行转账业务是一个典型分布式事务场景，假设 A 需要跨行转账给 B，那么就涉及两个银行的数据，无法通过一个数据库的本地事务保证转账的 ACID，只能够通过分布式事务来解决。 <section style="line-height: normal;"> </section> 分布式事务就是指事务的发起者、资源及资源管理器和事务协调者分别位于分布式系统的不同节点之上。 <section style="line-height: normal;"> </section> 在上述转账的业务中，用户 A-100 操作和用户 B+100 操作不是位于同一个节点上。 <section style="line-height: normal;"> </section> 本质上来说，分布式事务就是为了保证在分布式场景下，数据操作的正确执行。 <section style="line-height: normal;"> </section> 分布式事务在分布式环境下，为了满足可用性、性能与降级服务的需要，降低一致性与隔离性的要求，一方面遵循 BASE 理论（BASE 相关理论，涉及内容非常多，感兴趣的程序员们，可以参考 BASE 理论）。 <section style="line-height: normal;"> </section> BASE 理论： <ul class="list-paddingleft-2" style="list-style-type: disc;"> <li>基本业务可用性（Basic Availability）</li> <li>柔性状态（Soft state）</li> <li>最终一致性（Eventual consistency）</li> </ul> 同样的，分布式事务也部分遵循 ACID 规范： <ul class="list-paddingleft-2" style="list-style-type: disc;"> <li>原子性：严格遵循</li> <li>一致性：事务完成后的一致性严格遵循；事务中的一致性可适当放宽</li> <li>隔离性：并行事务间不可影响；事务中间结果可见性允许安全放宽</li> <li>持久性：严格遵循</li> </ul> <section style="line-height: normal;"> </section> ④分布式事务场景 <section style="line-height: normal;"> </section> 典型的场景就是微服务架构：微服务之间通过远程调用完成事务操作。 <section style="line-height: normal;"> </section> 比如：订单微服务和库存微服务，下单的同时订单微服务请求库存微服务减库存。简言之：跨 JVM 进程产生分布式事务。 <section style="text-align: center;margin-left: 8px;margin-right: 8px;line-height: 1.75em;margin-bottom: 5px;"> <img class="rich_pages wxw-img" data-fileid="508370863" data-galleryid="" data-ratio="0.9218009478672986" data-s="300,640" src="/upload/c31a6d0a1279b75942604330fd24974f.png" data-type="png" data-w="422" style=""> </section> 单体系统访问多个数据库实例：当单体系统需要访问多个数据库（实例）时就会产生分布式事务。 <section style="line-height: normal;"> </section> 比如：用户信息和订单信息分别在两个 MySQL 实例存储，用户管理系统删除用户信息，需要分别删除用户信息及用户的订单信息，由于数据分布在不同的数据实例，需要通过不同的数据库链接去操作数据，此时产生分布式事务。 <section style="line-height: normal;"> </section> <section style="text-align: justify;margin-left: 8px;margin-right: 8px;line-height: 1.75em;margin-bottom: 5px;"> 简言之：跨数据库实例产生分布式事务。 </section> <section style="text-align: center;margin-left: 8px;margin-right: 8px;line-height: 1.75em;margin-bottom: 5px;"> <img class="rich_pages wxw-img" data-fileid="508370864" data-galleryid="" data-ratio="0.8452380952380952" data-s="300,640" src="/upload/aa6083b30eb0795610cfbbc5d4efa454.png" data-type="png" data-w="504" style=""> </section> <section style="text-align: justify;margin-left: 8px;margin-right: 8px;line-height: 1.75em;margin-bottom: 5px;"> 多服务访问同一个数据库实例： 比如：订单微服务和库存微服务即使访问同一个数据库也会产生分布式事务，原因就是跨 JVM 进程，两个微服务持有了不同的数据库链接进行数据库操作，此时产生分布式事务。 </section> <section style="text-align: center;line-height: 1.75em;margin-left: 8px;margin-right: 8px;margin-bottom: 5px;"> <img class="rich_pages wxw-img" data-fileid="508370865" data-galleryid="" data-ratio="0.8034782608695652" data-s="300,640" src="/upload/c7fb7c3f5f30de5b8d1e2d356d156300.png" data-type="png" data-w="575" style=""> </section> <section style="box-sizing: border-box;font-size: 16px;"> <section style="border-bottom: 1px solid black;margin-top: 0.5em;margin-bottom: 0.5em;line-height: 1.2;box-sizing: border-box;" powered-by="xiumi.us"> <section style="display: inline-block;border-bottom: 6px solid rgb(89, 89, 89);margin-bottom: -1px;border-top-color: rgb(89, 89, 89);border-right-color: rgb(89, 89, 89);border-left-color: rgb(89, 89, 89);font-size: 20px;color: rgb(89, 89, 89);box-sizing: border-box;"> 分布式事务的解决方案 </section> </section> </section> <h2 style="text-align: justify;margin-left: 8px;margin-right: 8px;line-height: 1.75em;">①2PC（两阶段提交）/XA</h2> <section style="line-height: normal;"> </section> 2PC（Two-phase commit protocol），中文叫二阶段提交。  <section style="line-height: normal;"> </section> 二阶段提交是一种强一致性设计，2PC 引入一个事务协调者的角色来协调管理各参与者（也可称之为各本地资源）的提交和回滚，二阶段分别指的是准备（投票）和提交两个阶段。 <section style="line-height: normal;"> </section> XA 是由 X/Open 组织提出的分布式事务的规范，XA 规范主要定义了（全局）事务管理器（TM）和（局部）资源管理器（RM）之间的接口。本地的数据库如 MySQL 在 XA 中扮演的是 RM 角色。 <section style="line-height: normal;"> </section> XA 一共分为两阶段： <ul class="list-paddingleft-2" style="list-style-type: disc;"> <li>第一阶段（prepare）：即所有的参与者 RM 准备执行事务并锁住需要的资源。参与者 ready 时，向 TM 报告已准备就绪。</li> <li>第二阶段 (commit/rollback)：当事务管理者（TM）确认所有参与者（RM）都 ready 后，向所有参与者发送 commit 命令。</li> </ul> <section style="line-height: normal;"> </section> 目前主流的数据库基本都支持 XA 事务，包括 MySQL、Oracle、SQL Server、Postgre。 <section style="line-height: normal;"> </section> XA 事务由一个或多个资源管理器（RM）、一个事务管理器（TM）和一个应用程序（ApplicationProgram）组成。 <section style="text-align: justify;margin-left: 8px;margin-right: 8px;line-height: 1.75em;margin-bottom: 5px;"> <img class="rich_pages wxw-img" data-fileid="508370866" data-galleryid="" data-ratio="0.8602409638554217" data-s="300,640" src="/upload/5f063e06d51b922f1cca33dbbb3b35ae.png" data-type="png" data-w="830" style=""> </section> 如果有任何一个参与者 prepare 失败，那么 TM 会通知所有完成 prepare 的参与者进行回滚。 <section style="line-height: normal;"> </section> XA 事务的特点是： <ul class="list-paddingleft-2" style="list-style-type: disc;"> <li>简单易理解，开发较容易</li> <li>对资源进行了长时间的锁定，并发度低</li> </ul> ②三阶段提交（3PC） <section style="line-height: normal;"> </section> 三阶段提交又称 3PC，相对于 2PC 来说增加了 CanCommit 阶段和超时机制。 <section style="line-height: normal;"> </section> 如果段时间内没有收到协调者的 commit 请求，那么就会自动进行 commit，解决了 2PC 单点故障的问题。但是性能问题和不一致问题仍然没有根本解决。 <section style="line-height: normal;"> </section> 下面我们还是一起看下三阶段流程的是什么样的？ <section style="line-height: normal;"> </section> 第一阶段：CanCommit 阶段。这个阶段所做的事很简单，就是协调者询问事务参与者，你是否有能力完成此次事务。 <section style="line-height: normal;"> </section> 如果都返回 yes，则进入第二阶段。有一个返回 no 或等待响应超时，则中断事务，并向所有参与者发送 abort 请求。 <section style="line-height: normal;"> </section> 第二阶段：PreCommit 阶段。此时协调者会向所有的参与者发送 PreCommit 请求，参与者收到后开始执行事务操作，并将 Undo 和 Redo 信息记录到事务日志中。 <section style="line-height: normal;"> </section> 参与者执行完事务操作后（此时属于未提交事务的状态），就会向协调者反馈“Ack”表示我已经准备好提交了，并等待协调者的下一步指令。 <section style="line-height: normal;"> </section> 第三阶段：DoCommit 阶段。在阶段二中如果所有的参与者节点都可以进行 PreCommit 提交，那么协调者就会从“预提交状态”转变为“提交状态”。 <section style="line-height: normal;"> </section> 然后向所有的参与者节点发送"doCommit"请求，参与者节点在收到提交请求后就会各自执行事务提交操作，并向协调者节点反馈“Ack”消息，协调者收到所有参与者的 Ack 消息后完成事务。 <section style="line-height: normal;"> </section> 相反，如果有一个参与者节点未完成 PreCommit 的反馈或者反馈超时，那么协调者都会向所有的参与者节点发送 abort 请求，从而中断事务。 <section style="line-height: normal;"> </section> ③SAGA <section style="line-height: normal;"> </section> Saga 是这一篇数据库论文 saga 提到的一个方案。其核心思想是将长事务拆分为多个本地短事务，由 Saga 事务协调器协调，如果正常结束那就正常完成，如果某个步骤失败，则根据相反顺序一次调用补偿操作。 <section style="line-height: normal;"> </section> <section style="text-align: justify;margin-left: 8px;margin-right: 8px;line-height: 1.75em;margin-bottom: 5px;"> 把上面的转账作为例子，一个成功完成的 SAGA 事务时序图如下： </section> <img class="rich_pages wxw-img" data-fileid="508370867" data-galleryid="" data-ratio="0.6077015643802648" data-s="300,640" src="/upload/4fbf34bfc1175d5012d5a82828f858a6.png" data-type="png" data-w="831" style=""> SAGA 事务的特点： <ul class="list-paddingleft-2" style="list-style-type: disc;"> <li>并发度高，不用像 XA 事务那样长期锁定资源</li> <li>需要定义正常操作以及补偿操作，开发量比 XA 大</li> <li>一致性较弱，对于转账，可能发生 A 用户已扣款，最后转账又失败的情况</li> </ul> ④TCC <section style="line-height: normal;"> </section> 2PC 是数据库层面的，而 TCC 是业务层面的分布式事务，就像我前面说的分布式事务不仅仅包括数据库的操作，还包括发送短信等，这时候 TCC 就派上用场了！ <section style="line-height: normal;"> </section> TCC 的 3 个阶段： <ul class="list-paddingleft-2" style="list-style-type: disc;"> <li>Try 阶段：尝试执行，完成所有业务检查（一致性）, 预留必须业务资源（准隔离性）</li> <li>Confirm 阶段：确认执行真正执行业务，不作任何业务检查，只使用 Try 阶段预留的业务资源，Confirm 操作要求具备幂等设计，Confirm 失败后需要进行重试。</li> <li>Cancel 阶段：取消执行，释放 Try 阶段预留的业务资源，也可以理解为可以理解为把预留阶段的动作撤销了。Cancel 阶段的异常和 Confirm 阶段异常处理方案基本上一致，要求满足幂等设计。</li> </ul> 把上面的转账作为例子，通常会在 Try 里面冻结金额，但不扣款，Confirm 里面扣款，Cancel 里面解冻金额。 <section style="line-height: normal;"> </section> <section style="text-align: justify;margin-left: 8px;margin-right: 8px;line-height: 1.75em;margin-bottom: 5px;"> 一个成功完成的 TCC 事务时序图如下： </section> <img class="rich_pages wxw-img" data-fileid="508370868" data-galleryid="" data-ratio="0.9048192771084337" data-s="300,640" src="/upload/392246c60bbee19539a2ec3c389386.png" data-type="png" data-w="830" style=""> TCC 特点如下： <ul class="list-paddingleft-2" style="list-style-type: disc;"> <li>并发度较高，无长期资源锁定</li> <li>开发量较大，需要提供 Try/Confirm/Cancel 接口</li> <li>一致性较好，不会发生 SAGA 已扣款最后又转账失败的情况</li> <li>TCC 适用于订单类业务，对中间状态有约束的业务</li> </ul> <section style="line-height: normal;"> </section> ⑤本地消息表 <section style="line-height: normal;"> </section> <section style="text-align: justify;margin-left: 8px;margin-right: 8px;line-height: 1.75em;margin-bottom: 5px;"> 本地消息表其实就是利用了 各系统本地的事务来实现分布式事务。 </section> <img class="rich_pages wxw-img" data-fileid="508370869" data-galleryid="" data-ratio="0.5282791817087846" data-s="300,640" src="/upload/b741ef02254d2483110cbaad652b2ed4.png" data-type="png" data-w="831" style=""> 本地消息表顾名思义就是会有一张存放本地消息的表，一般都是放在数据库中，然后在执行业务的时候将业务的执行和将消息放入消息表中的操作放在同一个事务中，这样就能保证消息放入本地表中业务肯定是执行成功的。 <section style="line-height: normal;"> </section> 然后再去调用下一个操作，如果下一个操作调用成功了好说，消息表的消息状态可以直接改成已成功。 <section style="line-height: normal;"> </section> 如果调用失败也没事，会有后台任务定时去读取本地消息表，筛选出还未成功的消息再调用对应的服务，服务更新成功了再变更消息的状态。 <section style="line-height: normal;"> </section> 这时候有可能消息对应的操作不成功，因此也需要重试，重试就得保证对应服务的方法是幂等的，而且一般重试会有最大次数，超过最大次数可以记录下报警让人工处理。 <section style="line-height: normal;"> </section> 可以看到本地消息表其实实现的是最终一致性，容忍了数据暂时不一致的情况。 <section style="line-height: normal;"> </section> ⑤消息事务 <section style="line-height: normal;"> </section> RocketMQ 就很好的支持了消息事务，让我们来看一下如何通过消息实现事务。 <section style="line-height: normal;"> </section> 第一步先给 Broker 发送事务消息即半消息，半消息不是说一半消息，而是这个消息对消费者来说不可见，然后发送成功后发送方再执行本地事务。再根据本地事务的结果向 Broker 发送 Commit 或者 RollBack 命令。 <section style="line-height: normal;"> </section> 并且 RocketMQ 的发送方会提供一个反查事务状态接口，如果一段时间内半消息没有收到任何操作请求，那么 Broker 会通过反查接口得知发送方事务是否执行成功，然后执行 Commit 或者 RollBack 命令。 <section style="line-height: normal;"> </section> 如果是 Commit 那么订阅方就能收到这条消息，然后再做对应的操作，做完了之后再消费这条消息即可。 <section style="line-height: normal;"> </section> <section style="text-align: justify;margin-left: 8px;margin-right: 8px;line-height: 1.75em;margin-bottom: 5px;"> 如果是 RollBack 那么订阅方收不到这条消息，等于事务就没执行过。可以看到通过 RocketMQ 还是比较容易实现的，RocketMQ 提供了事务消息的功能，我们只需要定义好事务反查接口即可。 </section> <section style="text-align: center;margin-left: 8px;margin-right: 8px;line-height: 1.75em;margin-bottom: 5px;"> <img class="rich_pages wxw-img" data-fileid="508370870" data-galleryid="" data-ratio="0.53309265944645" data-s="300,640" src="/upload/93dcad6d9d27eaafe99af61a49f6a6d8.png" data-type="png" data-w="831" style=""> </section> 同时也可以看到消息事务实现的也是最终一致性。 ⑥最大努力通知 <section style="line-height: normal;"> </section> 发起通知方通过一定的机制最大努力将业务处理结果通知到接收方。 <section style="line-height: normal;"> </section> 具体包括： <ul class="list-paddingleft-2" style="list-style-type: disc;"> <li>有一定的消息重复通知机制。因为接收通知方可能没有接收到通知，此时要有一定的机制对消息重复通知。</li> <li>消息校对机制。如果尽最大努力也没有通知到接收方，或者接收方消费消息后要再次消费，此时可由接收方主动向通知方查询消息信息来满足需求。</li> </ul> <section style="line-height: normal;"> </section> 前面介绍的的本地消息表和消息事务都属于可靠消息，与这里介绍的最大努力通知有什么不同？ <section style="line-height: normal;"> </section> 可靠消息一致性，发起通知方需要保证将消息发出去，并且将消息发到接收通知方，消息的可靠性关键由发起通知方来保证。 <section style="line-height: normal;"> </section> 最大努力通知，发起通知方尽最大的努力将业务处理结果通知为接收通知方，但是可能消息接收不到，此时需要接收通知方主动调用发起通知方的接口查询业务处理结果，通知的可靠性关键在接收通知方。 <section style="line-height: normal;"> </section> 解决方案上，最大努力通知需要： <ul class="list-paddingleft-2" style="list-style-type: disc;"> <li>提供接口，让接受通知放能够通过接口查询业务处理结果</li> <li>消息队列 ACK 机制，消息队列按照间隔 1min、5min、10min、30min、1h、2h、5h、10h 的方式，逐步拉大通知间隔，直到达到通知要求的时间窗口上限。之后不再通知</li> </ul> <section style="line-height: normal;"> </section> <section style="text-align: justify;margin-left: 8px;margin-right: 8px;line-height: 1.75em;margin-bottom: 5px;"> 最大努力通知适用于业务通知类型，例如微信交易的结果，就是通过最大努力通知方式通知各个商户，既有回调通知，也有交易查询接口。 </section> <section style="text-align: center;margin-left: 8px;margin-right: 8px;line-height: 1.75em;margin-bottom: 5px;"> <img class="rich_pages wxw-img" data-fileid="508370871" data-galleryid="" data-ratio="0.6469879518072289" data-s="300,640" src="/upload/4d40adabe6e1973f058618e8af4b7897.png" data-type="png" data-w="830" style=""> </section> <h3 style="text-align: justify;margin-left: 8px;margin-right: 8px;line-height: 1.75em;">⑦AT 事务模式</h3> <section style="line-height: normal;"> </section> 这是阿里开源项目 seata 中的一种事务模式，在蚂蚁金服也被称为 FMT。优点是该事务模式使用方式，类似 XA 模式，业务无需编写各类补偿操作，回滚由框架自动完成，缺点也类似 AT，存在较长时间的锁，不满足高并发的场景。 <section style="line-height: normal;"> </section> 在 Seata 项目中，最早由阿里巴巴中间件开源出的 AT 模式（Automatic Transaction）是一套创新的、业务无侵入的分布式事务解决方案。 <section style="line-height: normal;"> </section> 截止 Seata 的 GA 版本发布，AT 模式已经在开源社区引起了广泛关注，很多家企业用户已经将 Seata 的 AT 模式应用于生产。 <section style="line-height: normal;"> </section> AT 模式一阶段：首先，在 Seata 的组件中，如果你想开启分布式事务，那么就应该在你的业务入口或者事务发起入口加上 @GlobalTransactional 注解。 <section style="line-height: normal;"> </section> 如果你是 AT 模式就要做好数据源代理（seata1.0 后全面支持自动代理），并被 sqlsessionfactroy 使用（或者直接 jdbc 操作使用被代理数据源）。 <section style="text-align: justify;margin-left: 8px;margin-right: 8px;line-height: 1.75em;margin-bottom: 5px;"> 可以发现比较关键的异步，与其他模式的区别便是代理数据源，而代理数据源又有什么奥秘呢？ </section> <img class="rich_pages wxw-img" data-fileid="508370872" data-galleryid="" data-ratio="0.5819277108433735" data-s="300,640" src="/upload/d07877fe119cdaa2a81bbd09fb050aee.png" data-type="png" data-w="830" style=""> <section style="text-align: justify;margin-left: 8px;margin-right: 8px;line-height: 1.75em;margin-bottom: 5px;"> AT 模式二阶段提交： 二阶段如果是提交的话，因为“业务 SQL”在一阶段已经提交至数据库，所以 Seata 框架只需将一阶段保存的快照数据和行锁删掉，完成数据清理即可。 </section> <img class="rich_pages wxw-img" data-fileid="508370873" data-galleryid="" data-ratio="0.5939759036144578" data-s="300,640" src="/upload/35ddcdb985fbfababae4d59c1ea7eb8.png" data-type="png" data-w="830" style=""> AT 模式二阶段回滚：二阶段如果是回滚的话，Seata 就需要回滚一阶段已经执行的“业务 SQL”，还原业务数据。 <section style="line-height: normal;"> </section> 回滚方式便是用“before image”还原业务数据；但在还原前要首先要校验脏写，对比“数据库当前业务数据”和 “after image”。 <section style="line-height: normal;"> </section> <section style="text-align: justify;margin-left: 8px;margin-right: 8px;line-height: 1.75em;margin-bottom: 5px;"> 如果两份数据完全一致就说明没有脏写，可以还原业务数据，如果不一致就说明有脏写，出现脏写就需要转人工处理。 </section> <section style="text-align: center;line-height: 1.75em;margin-left: 8px;margin-right: 8px;margin-bottom: 5px;"> <img class="rich_pages wxw-img" data-fileid="508370874" data-galleryid="" data-ratio="0.5679903730445247" data-s="300,640" src="/upload/6a3c9291b1548229b216c0de78f9a88e.png" data-type="png" data-w="831" style=""> </section> <section style="box-sizing: border-box;font-size: 16px;"> <section style="border-bottom: 1px solid black;margin-top: 0.5em;margin-bottom: 0.5em;line-height: 1.2;box-sizing: border-box;" powered-by="xiumi.us"> <section style="display: inline-block;border-bottom: 6px solid rgb(89, 89, 89);margin-bottom: -1px;border-top-color: rgb(89, 89, 89);border-right-color: rgb(89, 89, 89);border-left-color: rgb(89, 89, 89);font-size: 20px;color: rgb(89, 89, 89);box-sizing: border-box;"> 小结 </section> </section> </section> <section style="line-height: normal;"> </section> 本文介绍了分布式事务的一些基础理论，并对常用的分布式事务方案进行了讲解。 <section style="line-height: normal;"> </section> 分布式事务本身就是一个技术难题，业务中具体使用哪种方案还是需要不同的业务特点自行选择。 <section style="line-height: normal;"> </section> 但是我们也会发现，分布式事务会大大的提高流程的复杂度，会带来很多额外的开销工作，「代码量上去了，业务复杂了，性能下跌了」。 <section style="line-height: normal;"> </section> 所以，当我们真实开发的过程中，能不使用分布式事务就不使用。 </section>

原来 Lamda 表达式是这样写的

作者：微信小助手

<section data-tool="mdnice编辑器" data-website="https://www.mdnice.com" style="line-height: 1.5em;" data-mpa-powered-by="yiban.io"> <pre data-tool="mdnice编辑器" style="line-height: 1.5em;"><span style="font-family: mp-quote, -apple-system-font, BlinkMacSystemFont, "Helvetica Neue", "PingFang SC", "Hiragino Sans GB", "Microsoft YaHei UI", "Microsoft YaHei", Arial, sans-serif;font-size: 16px;letter-spacing: 0.5px;">Lamda 表达式非常方便，在项目中一般在 stream 编程中用的比较多。 </pre> </section> <section data-tool="mdnice编辑器" data-website="https://www.mdnice.com" style="color: black;line-height: 1.6;letter-spacing: 0px;word-break: break-word;text-align: left;font-family: PingFangSC-Light;font-size: 16px;padding: 10px;"> <pre data-tool="mdnice编辑器" style="margin-top: 10px;margin-bottom: 10px;"><code style="overflow-x: auto;padding: 16px;color: #333;background: #f8f8f8;display: -webkit-box;font-family: Operator Mono, Consolas, Monaco, Menlo, monospace;border-radius: 0px;font-size: 12px;-webkit-overflow-scrolling: touch;">List<Student> studentList = gen(); Map<String, Student> map = studentList .stream()         .collect(Collectors.toMap(Student::getId, a -> a, (a, b) -> a)); </code></pre> </section> <section style="line-height: 1.5em;"> 理解一个 Lamda 表达式就三步： </section> <section style="line-height: 1.5em;"> <span style="font-family: mp-quote, -apple-system-font, BlinkMacSystemFont, "Helvetica Neue", "PingFang SC", "Hiragino Sans GB", "Microsoft YaHei UI", "Microsoft YaHei", Arial, sans-serif;font-size: 16px;letter-spacing: 0.5px;"> </section> 1. 确认 Lamda 表达式的类型 2. 找到要实现的方法 3. 实现这个方法 <section style="line-height: 1.5em;">   </section> <section style="line-height: 1.5em;"> 就这三步，没其他的了。而每一步，都非常非常简单，以至于我分别展开讲一下，你就懂了。 </section> <section style="line-height: 1.5em;">   </section> <section style="line-height: 1.5em;"> </section> <h2 data-foldable-wrapper=""> <section style="line-height: 1.5em;"> 确认 Lamda 表达式的类型 </section></h2> <section style="line-height: 1.5em;">   </section> <section style="line-height: 1.5em;"> </section> <section style="line-height: 1.5em;"> 能用 Lamda 表达式来表示的类型，必须是一个函数式接口，而函数式接口，就是只有一个抽象方法的接口。 </section> <section style="line-height: 1.5em;">   </section> <section style="line-height: 1.5em;"> 我们看下非常熟悉的 Runnable 接口在 JDK 中的样子就明白了。 </section> <pre> <section data-tool="mdnice编辑器" data-website="https://www.mdnice.com" style="color: black;line-height: 1.6;letter-spacing: 0px;word-break: break-word;text-align: left;font-family: PingFangSC-Light;font-size: 16px;padding: 10px;"> <pre data-tool="mdnice编辑器" style="margin-top: 10px;margin-bottom: 10px;"><code style="overflow-x: auto;padding: 16px;color: #333;background: #f8f8f8;display: -webkit-box;font-family: Operator Mono, Consolas, Monaco, Menlo, monospace;border-radius: 0px;font-size: 12px;-webkit-overflow-scrolling: touch;">@FunctionalInterface public interface Runnable {     public abstract void run(); } </code></pre> </section> <section style="line-height: 1.5em;"> <span style="font-family: mp-quote, -apple-system-font, BlinkMacSystemFont, "Helvetica Neue", "PingFang SC", "Hiragino Sans GB", "Microsoft YaHei UI", "Microsoft YaHei", Arial, sans-serif;font-size: 16px;letter-spacing: 0.5px;">这就是一个标准的函数式接口。 </section> <section style="line-height: 1.5em;"> <span style="font-family: mp-quote, -apple-system-font, BlinkMacSystemFont, "Helvetica Neue", "PingFang SC", "Hiragino Sans GB", "Microsoft YaHei UI", "Microsoft YaHei", Arial, sans-serif;font-size: 16px;letter-spacing: 0.5px;"> </section> <section style="line-height: 1.5em;"> <span style="font-family: mp-quote, -apple-system-font, BlinkMacSystemFont, "Helvetica Neue", "PingFang SC", "Hiragino Sans GB", "Microsoft YaHei UI", "Microsoft YaHei", Arial, sans-serif;font-size: 16px;letter-spacing: 0.5px;">因为只有一个抽象方法。而且这个接口上有个注解 </section></pre> <section style="line-height: 1.5em;margin-bottom: 10px;margin-top: 10px;"> <span style="font-size: 16px;letter-spacing: 0.5px;font-family: mp-quote, -apple-system-font, BlinkMacSystemFont, "Helvetica Neue", "PingFang SC", "Hiragino Sans GB", "Microsoft YaHei UI", "Microsoft YaHei", Arial, sans-serif;color: rgb(0, 122, 170);">@FunctionalInterface </section> <section style="line-height: 1.5em;"> <span style="font-size: 16px;letter-spacing: 0.5px;font-family: mp-quote, -apple-system-font, BlinkMacSystemFont, "Helvetica Neue", "PingFang SC", "Hiragino Sans GB", "Microsoft YaHei UI", "Microsoft YaHei", Arial, sans-serif;">这个仅仅是在编译期帮你检查你这个接口是否符合函数式接口的条件，比如你没有任何抽象方法，或者有多个抽象方法，编译是无法通过的。 </section> <section data-tool="mdnice编辑器" data-website="https://www.mdnice.com" style="color: black;line-height: 1.6;letter-spacing: 0px;word-break: break-word;text-align: left;font-family: PingFangSC-Light;font-size: 16px;padding: 10px;"> <pre data-tool="mdnice编辑器" style="margin-top: 10px;margin-bottom: 10px;"><code style="overflow-x: auto;padding: 16px;color: #333;background: #f8f8f8;display: -webkit-box;font-family: Operator Mono, Consolas, Monaco, Menlo, monospace;border-radius: 0px;font-size: 12px;-webkit-overflow-scrolling: touch;">// 没有实现任何抽象方法的接口 @FunctionalInterface public interface MyRunnable {} // 编译后控制台显示如下信息 Error:(3, 1) java:    意外的 @FunctionalInterface 注释   MyRunnable 不是函数接口     在 接口 MyRunnable 中找不到抽象方法 </code></pre> </section> <section style="line-height: 1.5em;"> 再稍稍复杂一点，Java 8 之后接口中是允许使用 默认方法 和 静态方法 的，而这些都不算抽象方法，所以也可以加在函数式接口里。 </section> <section style="line-height: 1.5em;">   </section> <section style="line-height: 1.5em;"> 看看你可能不太熟悉又有点似曾相识的一个接口。 </section> <section data-tool="mdnice编辑器" data-website="https://www.mdnice.com" style="color: black;line-height: 1.6;letter-spacing: 0px;word-break: break-word;text-align: left;font-family: PingFangSC-Light;font-size: 16px;padding: 10px;"> <pre data-tool="mdnice编辑器" style="margin-top: 10px;margin-bottom: 10px;"><code style="overflow-x: auto;padding: 16px;color: #333;background: #f8f8f8;display: -webkit-box;font-family: Operator Mono, Consolas, Monaco, Menlo, monospace;border-radius: 0px;font-size: 12px;-webkit-overflow-scrolling: touch;">@FunctionalInterface public interface Consumer<T> {     void accept(T t);     default Consumer<T> andThen(Consumer<? super T> after) {...} } </code></pre> </section> <section style="line-height: 1.5em;"> 看，只有一个抽象方法，还有一个默认方法（方法体的代码省略了），这个也不影响它是个函数式接口。再看一个更复杂的，多了静态方法，这同样也是个函数式接口，因为它仍然只有一个抽象方法。自行体会吧。 </section> <section data-tool="mdnice编辑器" data-website="https://www.mdnice.com" style="color: black;line-height: 1.6;letter-spacing: 0px;word-break: break-word;text-align: left;font-family: PingFangSC-Light;font-size: 16px;padding: 10px;"> <pre data-tool="mdnice编辑器" style="margin-top: 10px;margin-bottom: 10px;"><code style="overflow-x: auto;padding: 16px;color: #333;background: #f8f8f8;display: -webkit-box;font-family: Operator Mono, Consolas, Monaco, Menlo, monospace;border-radius: 0px;font-size: 12px;-webkit-overflow-scrolling: touch;">@FunctionalInterface public interface Predicate<T> {     boolean test(T t);          default Predicate<T> and(Predicate<? super T> other) {...}     default Predicate<T> negate() {...}     default Predicate<T> or(Predicate<? super T> other) {...}          static <T> Predicate<T> isEqual(Object targetRef) {...}     static <T> Predicate<T> not(Predicate<? super T> target) {...} } </code></pre> </section> <section style="line-height: 1.5em;"> 先不用管这些方法都是干嘛的，这些类在 Stream 设计的方法中比比皆是，我们就先记住这么一句话， Lamda 表达式需要的类型为函数式接口，函数式接口里只有一个抽象方法 ，就够了，以上三个例子都属于函数式接口。 </section> <section style="line-height: 1.5em;">   </section> <section style="line-height: 1.5em;"> 恭喜你，已经学会了 Lamda 表达式最难的部分，就是认识函数式接口。 </section> <section style="line-height: 1.5em;">   </section> <section style="line-height: 1.5em;"> </section> <h2 data-foldable-wrapper=""> <section style="line-height: 1.5em;"> 找到要实现的方法 </section></h2> <section style="line-height: 1.5em;"> </section> <section style="line-height: 1.5em;">   </section> <section style="line-height: 1.5em;"> Lamda 表达式就是实现一个方法，什么方法呢？就是刚刚那些函数式接口中的抽象方法。 </section> <section style="line-height: 1.5em;">   </section> <section style="line-height: 1.5em

Redis如何高效实现点赞、取消点赞功能

作者：微信小助手

<p style="outline: 0px;font-family: -apple-system, BlinkMacSystemFont, "Helvetica Neue", "PingFang SC", "Hiragino Sans GB", "Microsoft YaHei UI", "Microsoft YaHei", Arial, sans-serif;letter-spacing: 0.544px;white-space: normal;background-color: rgb(255, 255, 255);" data-mpa-powered-by="yiban.io">点击关注公众号，实用技术文章及时了解<img data-fileid="100030893" data-ratio="1" data-type="png" data-w="64" src="/upload/29316807de8eec165a101cfe6173a39c.png" style="outline: 0px;letter-spacing: 0.544px;text-align: left;font-family: 微软雅黑;font-size: 16px;box-sizing: border-box !important;max-height: 20px !important;visibility: visible !important;width: 20px !important;"> <section class="mp_profile_iframe_wrp"> <mpprofile class="js_uneditable custom_select_card mp_profile_iframe" data-pluginname="mpprofile" data-id="MzI4Njc5NjM1NQ==" data-headimg="http://mmbiz.qpic.cn/mmbiz_png/eQPyBffYbueAgIuCqZdZnW3NW44AOD32W2BOe28vCWLC2XdcNqJufjmlCCI2YVbFh0fjL6qCxEoNjHN9jTBItQ/0?wx_fmt=png" data-nickname="Java知音" data-alias="Java_friends" data-signature="专注于java。分享java基础、原理性知识、JavaWeb实战、spring全家桶、设计模式及面试资料、开源项目，助力开发者成长！" data-from="0"></mpprofile> </section> <h3 data-tool="mdnice编辑器" style="outline: 0px;font-family: -apple-system, BlinkMacSystemFont, "Helvetica Neue", "PingFang SC", "Hiragino Sans GB", "Microsoft YaHei UI", "Microsoft YaHei", Arial, sans-serif;letter-spacing: 0.544px;white-space: normal;background-color: rgb(255, 255, 255);text-align: right;">来源：blog.csdn.net/lsy0903/article/details/103949459</h3> <section data-tool="mdnice编辑器" data-website="https://www.mdnice.com" style="font-size: 16px;color: black;padding-right: 10px;padding-left: 10px;line-height: 1.6;letter-spacing: 0px;word-break: break-word;text-align: left;font-family: Optima-Regular, Optima, PingFangSC-light, PingFangTC-light, "PingFang SC", Cambria, Cochin, Georgia, Times, "Times New Roman", serif;"> 基于 SpringCloud, 用户发起点赞、取消点赞后先存入 Redis 中，再每隔两小时从 Redis 读取点赞数据写入数据库中做持久化存储。 点赞功能在很多系统中都有，但别看功能小，想要做好需要考虑的东西还挺多的。 点赞、取消点赞是高频次的操作，若每次都读写数据库，大量的操作会影响数据库性能，所以需要做缓存。 至于多久从 Redis 取一次数据存到数据库中，根据项目的实际情况定吧，我是暂时设了两个小时。 项目需求需要查看都谁点赞了，所以要存储每个点赞的点赞人、被点赞人，不能简单的做计数。 文章分四部分介绍： <ul data-tool="mdnice编辑器" style="margin-top: 8px;margin-bottom: 8px;padding-left: 25px;" class="list-paddingleft-2"> <li> <section style="margin-top: 5px;margin-bottom: 5px;line-height: 26px;color: rgb(1, 1, 1);"> Redis 缓存设计及实现 </section></li> <li> <section style="margin-top: 5px;margin-bottom: 5px;line-height: 26px;color: rgb(1, 1, 1);"> 数据库设计 </section></li> <li> <section style="margin-top: 5px;margin-bottom: 5px;line-height: 26px;color: rgb(1, 1, 1);"> 数据库操作 </section></li> <li> <section style="margin-top: 5px;margin-bottom: 5px;line-height: 26px;color: rgb(1, 1, 1);"> 开启定时任务持久化存储到数据库 </section></li> </ul> <h2 data-tool="mdnice编辑器" style="margin: 80px 10px 40px;text-align: center;color: rgb(63, 63, 63);font-size: 140%;">一、Redis 缓存设计及实现</h2> <h3 data-tool="mdnice编辑器" style="margin-top: 40px;margin-bottom: 20px;font-weight: bold;line-height: 1.5;color: rgb(63, 63, 63);font-size: 120%;">1.1 Redis 安装及运行</h3> <blockquote data-tool="mdnice编辑器" style="border-top: none;border-right: none;border-bottom: none;font-size: 0.9em;overflow: auto;color: rgb(91, 91, 91);border-left-color: rgb(158, 158, 158);background: rgba(158, 158, 158, 0.1);padding-top: 1px;padding-bottom: 1px;margin-top: 20px;margin-bottom: 20px;"> Redis 安装请自行查阅相关教程。 </blockquote> 说下Docker 安装运行 Redis <pre data-tool="mdnice编辑器" style="margin-top: 10px;margin-bottom: 10px;"><code style="overflow-x: auto;padding: 16px;color: #333;background: #f8f8f8;display: -webkit-box;font-family: Operator Mono, Consolas, Monaco, Menlo, monospace;border-radius: 0px;font-size: 12px;-webkit-overflow-scrolling: touch;">docker run -d -p 6379:6379 redis:4.0.8   </code></pre> 如果已经安装了 Redis，打开命令行，输入启动 Redis 的命令 <pre data-tool="mdnice编辑器" style="margin-top: 10px;margin-bottom: 10px;"><code style="overflow-x: auto;padding: 16px;color: #333;background: #f8f8f8;display: -webkit-box;font-family: Operator Mono, Consolas, Monaco, Menlo, monospace;border-radius: 0px;font-size: 12px;-webkit-overflow-scrolling: touch;">redis-server   </code></pre> <h3 data-tool="mdnice编辑器" style="margin-top: 40px;margin-bottom: 20px;font-weight: bold;line-height: 1.5;color: rgb(63, 63, 63);font-size: 120%;">1.2 Redis 与 SpringBoot 项目的整合</h3> 1.在 pom.xml 中引入依赖 <pre data-tool="mdnice编辑器" style="margin-top: 10px;margin-bottom: 10px;"><code style="overflow-x: auto;padding: 16px;color: #333;background: #f8f8f8;display: -webkit-box;font-family: Operator Mono, Consolas, Monaco, Menlo, monospace;border-radius: 0px;font-size: 12px;-webkit-overflow-scrolling: touch;"><dependency>       <groupId>org.springframework.boot</groupId>       <artifactId>spring-boot-starter-data-redis</artifactId>   </dependency>   </code></pre> 2.在启动类上添加注释 @EnableCaching <pre data-tool="mdnice编辑器" style="margin-top: 10px;margin-bottom: 10px;"><code style="overflow-x: auto;padding: 16px;color: #333;background: #f8f8f8;display: -webkit-box;font-family: Operator Mono, Consolas, Monaco, Menlo, monospace;border-radius: 0px;font-size: 12px;-webkit-overflow-scrolling: touch;">@SpringBootApplication   @EnableDiscoveryClient   @EnableSwagger2   @EnableFeignClients(basePackages = "com.solo.coderiver.project.client")   @EnableCaching   public class UserApplication {          public static void main(String[] args) {           SpringApplication.run(UserApplication.class, args);       }   }   </code></pre> 3.编写 Redis 配置类 RedisConfig <pre data-tool="mdnice编辑器" style="margin-top: 10px;margin-bottom: 10px;"><code style="overflow-x: auto;padding: 16px;color: #333;background: #f8f8f8;display: -webkit-box;font-family: Operator Mono, Consolas, Monaco, Menlo, monospace;border-radius: 0px;font-size: 12px;-webkit-overflow-scrolling: touch;">import com.fasterxml.jackson.annotation.JsonAutoDetect;   import com.fasterxml.jackson.annotation.PropertyAccessor;   import com.fasterxml.jackson.databind.ObjectMapper;   import org.springframework.boot.autoconfigure.condition.ConditionalOnMissingBean;   import org.springframework.context.annotation.Bean;   import org.springframework.context.annotation.Configuration;   import org.springframework.data.redis.connection.RedisConnectionFactory;   import org.springframework.data.redis.core.RedisTemplate;   import org.springframework.data.redis.core.StringRedisTemplate;   import org.springframework.data.redis.serializer.Jackson2JsonRedisSerializer;      import java.net.UnknownHostException;         @Configuration   public class RedisConfig {          @Bean       @ConditionalOnMissingBean(name = "redisTemplate")       public RedisTemplate<String, Object> redisTemplate(               RedisConnectionFactory redisConnectionFactory)               throws UnknownHostException {              Jackson2JsonRedisSerializer<Object> jackson2JsonRedisSerializer = new Jackson2JsonRedisSerializer<Object>(Object.class);           ObjectMapper om = new ObjectMapper();           om.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);           om.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL);           jackson2JsonRedisSerializer.setObjectMapper(om);              RedisTemplate<String, Object> template = new RedisTemplate<String, Object>();           template.setConnectionFactory(redisConnectionFactory);           template.setKeySerializer(jackson2JsonRedisSerializer);           template.setValueSerializer(jackson2JsonRedisSerializer);           template.setHashKeySerializer(jackson2JsonRedisSerializer);           template.setHashValueSerializer(jackson2JsonRedisSerializer);           template.afterPropertiesSet();           return template;       }             @Bean       @ConditionalOnMissingBean(StringRedisTemplate.class)       public StringRedisTemplate stringRedisTemplate(               RedisConnectionFactory redisConnectionFactory)               throws UnknownHostException {           StringRedisTemplate template = new StringRedisTemplate();           template.setConnectionFactory(redisConnectionFactory);           return template;       }   }   </code></pre> 至此 Redis 在 SpringBoot 项目中的配置已经完成，可以愉快的使用了。 <h3 data-tool="mdnice编辑器" style="margin-top: 40px;margin-bottom: 20px;font-weight: bold;line-height: 1.5;color: rgb(63, 63, 63);font-size: 120%;">1.3 Redis 的数据结构类型</h3> Redis 可以存储键与5种不同数据结构类型之间的映射，这5种数据结构类型分别为String（字符串）、List（列表）、Set（集合）、Hash（散列）和 Zset（有序集合）。 下面来对这5种数据结构类型作简单的介绍： <figure data-tool="mdnice编辑器" style="margin-top: 10px;margin-bottom: 10px;display: flex;flex-direction: column;justify-content: center;align-items: center;"> <img src="/upload/525d7f3749f972f406c88eea960bb02e.png" style="display: block;margin-right: auto;margin-left: auto;" data-type="png" class="rich_pages wxw-img" data-ratio="0.75920245398773" data-w="652" data-fileid="100030892"> <figcaption style="margin-top: 5px;text-align: center;color: #888;font-size: 14px;"> 图片 </figcaption> </figure> <h3 data-tool="mdnice编辑器" style="margin-top: 40px;margin-bottom: 20px;font-weight: bold;line-height: 1.5;color: rgb(63, 63, 63);font-size: 120%;">1.4 点赞数据在 Redis 中的存储格式</h3> 用 Redis 存储两种数据，一种是记录点赞人、被点赞人、点赞状态的数据，另一种是每个用户被点赞了多少次，做个简单的计数。 由于需要记录点赞人和被点赞人，还有点赞状态（点赞、取消点赞），还要固定时间间隔取出 Redis 中所有点赞数据，分析了下 Redis 数据格式中 Hash 最合适。 因为 Hash 里的数据都是存在一个键里，可以通过这个键很方便的把所有的点赞数据都取出。这个键里面的数据还可以存成键值对的形式，方便存入点赞人、被点赞人和点赞状态。 设点赞人的 id 为 likedPostId，被点赞人的 id 为 likedUserId ，点赞时状态为 1，取消点赞状态为 0。将点赞人 id 和被点赞人 id 作为键，两个 id 中间用 :: 隔开，点赞状态作为值。 所以如果用户点赞，存储的键为：likedUserId::likedPostId，对应的值为 1 。取消点赞，存储的键为：likedUserId::likedPostId，对应的值为 0 。取数据时把键用 :: 切开就得到了两个id，也很方便。 在可视化工具 RDM 中看到的是这样子 <figure data-tool="mdnice编辑器" style="margin-top: 10px;margin-bottom: 10px;display: flex;flex-direction: column;justify-content: center;align-items: center;"> <img src="/upload/44949f005402d2a2324d8ef126a327c5.jpg" style="display: block;margin-right: auto;margin-left: auto;" data-type="jpeg" data-ratio="0.2574074074074074" data-w="1080" data-fileid="100030891"> <figcaption style="margin-top: 5px;text-align: center;color: #888;font-size: 14px;"> 图片 </figcaption> </figure> <figure data-tool="mdnice编辑器" style="margin-top: 10px;margin-bottom: 10px;display: flex;flex-direction: column;justify-content: center;align-items: center;"> <img src="/upload/64cd6e400019ac0a82185f9f5a338d02.jpg" style="display: block;margin-right: auto;margin-left: auto;" data-type="jpeg" class="rich_pages wxw-img" data-ratio="0.23425925925925925" data-w="1080" data-fileid="100030890"> <figcaption style="margin-top: 5px;text-align: center;color: #888;font-size: 14px;"> 图片 </figcaption> </figure> <h3 data-tool="mdnice编辑器" style="margin-top: 40px;margin-bottom: 20px;font-weight: bold;line-height: 1.5;color: rgb(63, 63, 63);font-size: 120%;">1.5 操作 Redis</h3> 将具体操作方法封装到了 RedisService 接口里 RedisService.java <pre data-tool="mdnice编辑器" style="margin-top: 10px;margin-bottom: 10px;"><code style="overflow-x: auto;padding: 16px;color: #333;background: #f8f8f8;display: -webkit-box;font-family: Operator Mono, Consolas, Monaco, Menlo, monospace;border-radius: 0px;font-size: 12px;-webkit-overflow-scrolling: touch;">import com.solo.coderiver.user.dataobject.UserLike;   import com.solo.coderiver.user.dto.LikedCountDTO;      import java.util.List;      public interface RedisService {          /**        * 点赞。状态为1        * @param likedUserId        * @param likedPostId        */       void saveLiked2Redis(String likedUserId, String likedPostId);          /**        * 取消点赞。将状态改变为0        * @param likedUserId        * @param likedPostId        */       void unlikeFromRedis(String likedUserId, String likedPostId);          /**        * 从Redis中删除一条点赞数据        * @param likedUserId        * @param likedPostId        */       void deleteLikedFromRedis(String likedUserId, String likedPostId);          /**        * 该用户的点赞数加1        * @param likedUserId        */       void incrementLikedCount(String likedUserId);          /**        * 该用户的点赞数减1        * @param likedUserId        */       void decrementLikedCount(String likedUserId);          /**        * 获取Redis中存储的所有点赞数据        * @return        */       List<UserLike> getLikedDataFromRedis();          /**        * 获取Redis中存储的所有点赞数量        * @return        */       List<LikedCountDTO> getLikedCountFromRedis();      }   </code></pre> 实现类 RedisServiceImpl.java <pre data-tool="mdnice编辑器" style="margin-top: 10px;margin-bottom: 10px;"><code style="overflow-x: auto;padding: 16px;color: #333;background: #f8f8f8;display: -webkit-box;font-family: Operator Mono, Consolas, Monaco, Menlo, monospace;border-radius: 0px;font-size: 12px;-webkit-overflow-scrolling: touch;">import com.solo.coderiver.user.dataobject.UserLike;   import com.solo.coderiver.user.dto.LikedCountDTO;   import com.solo.coderiver.user.enums.LikedStatusEnum;   import com.solo.coderiver.user.service.LikedService;   import com.solo.coderiver.user.service.RedisService;   import com.solo.coderiver.user.utils.RedisKeyUtils;   import lombok.extern.slf4j.Slf4j;   import org.springframework.beans.factory.annotation.Autowired;   import org.springframework.data.redis.core.Cursor;   import org.springframework.data.redis.core.RedisTemplate;   import org.springframework.data.redis.core.ScanOptions;   import org.springframework.stereotype.Service;      import java.util.ArrayList;   import java.util.List;   import java.util.Map;      @Service   @Slf4j   public <span style="font-

文章列表