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

Go微服务: 分布式之通过本地消息实现最终一致性和最大努力通知方案

news 文章来源：https://blog.csdn.net/Tyro_java/article/details/139538856 2024/11/18 15:41:58

通过本地消息实现最终一致性


1 ）概述

  • 我们的业务场景是可以允许我们一段时间有不一致的消息的状态的，并没有说必须特别高的这个消息的一致性
  • 比如说在TCC这个架构中，如果采用了消息的最终一致性，整体架构设计要轻松好多
  • 即便我们库存服务挂了，或者我们积分服务挂了也没有关系，只要我们有中间的这个消息，那就是没有问题的
  • 因为你在消息消费中，如果你你没有消费成功，那么消息就会一直存在在这个消息队列里

2 ）场景

  • 看看这个我们的这个具体的案例的场景是什么样的？还是以这个订单服务和库存服务，还有积分服务为例
  • 比如说，现在要下个订单，直接就在订单服务里，把它搞定了，我们就正常下订单
  • 建立我们的订单表和我们的订单产品表，然后，这时候发送一条消息到这个消息队列里
  • 那么我们说这个如果我们发送失败了，我们本地这个订单服务也能感知到，它就进行回滚就可以了
  • 但是我们说突然的这个停电，这个我们就没办法感知到了
  • 另一种情况，说你发送这个成功了，比如说我们建这个订单单服务，然后订单生成了订单产品表，也生成了, 消息发送也成功了
  • 但是消息队列给我回消息的时候，由于网络的拥塞或者是抖动，这都很正常
  • 然后，我们这个订单服务，肯定是要有超时机制的，它就超时了，订单就要回滚
  • 但是这个这个消息队列是消息，可是真的到消息队列里存在了
  • 那我下游的就库存，还有积分服务就拿着这个消息去做自己的业务了，该扣减库存就扣减库存，该增加积分就增加积分
  • 但是，这个时候订单已经回滚了，那老板或者业务就会问了，这订单都没有了，你这个库存的积分增加是个什么意思
  • 那我们要怎么解决这个问题呢？
  • 那我们就是在我们这个订单服务增加订单的时候，我们不先去给他发这个消息
  • 我们是先在本地表里头建立一个消息发送这个各种情况的一张表
  • 比如说, 我这个订单服务，我建立了一条消息，但是这个消息没有返回来
  • 有没有返回来也没有关系，这个表里已经记录了，说可以定一种状态，说就是未发送成功
  • 我们这里这个本地消息表，就以发送成功的这个状态为准
  • 只要是你能记录到这个表里的，没有发送成功的，我们就把它这个状态记录上
  • 我们下次启动的时候，在这个订单服务里增加一个循环的这种定时任务
  • 我们一般是做成异步的，因为你要是同步的话，相当于本地的这个数据库也是也有造成一定的压力的
  • 我们就扫描这个之前没有发送成功的这个消息，那就是说直到我们这个定时任务，一直发送这个消息队列发送成功为止
  • 所以他一定是能达到最终一致性的，我们这个里面就有一个问题，说你没发送成功，我记录一条可以没问题
  • 那我下次一发送这个消息队列就成功了, 我回写消息本地这个表就记录了这条消息成功
  • 如果，遇到我们的这个库存服务了，或者积分服务挂了都没有问题
  • 因为你不消费消息队列里的这个消息，你就不会确认，你不会确认的这个消息就永远在消息队列里，这个就没有问题
  • 但是还有一种情况，比如我这个消息，可能发很多次都有问题，可能是消息队列问题或者网络等问题
  • 这样，重复发送就带来一个风险，比如下游如果重复消费怎么办？这个就是我们下游服务要解决的问题
  • 本地消息的最终一致性，比TCC要简单很多，但是在某些高并发的场景，它也是有自己的问题的
  • 如果一切正常，就发送，让消息队列让消费者去消费就可以了
  • 如果有问题，就建立一张本地的这个消息发送表，记录各种情况，它最后能保证我们消息的最终一致性，但是要解决重复消费消息的这种情况

最大努力通知方案

  • 我们想投递一个消息的时候，一定要想方设法投递给对方，就是最大努力通知方案
  • 在生活中，你买了这个货物，商家是一定要给你发货的，但是你今天不在家，明天也不在家
  • 这个快递小哥是不是一直给你投递，直到你在家为止，收到快递或指定存放地点或触发退回机制
  • 在计算机当中，就是说这个消息一定要投递给你
  • 在商场购物的支付系统中，无论是，银联或微信，支付宝选一个
  • 小明在点击付款之后，他就会跳转到这个相应的这个第三方支付的页面
  • 支付成功之后，支付系统就要发送一个通知给我们的商户，比如小A
  • 对于这个小商户来说，它的网络是否稳定？对于支付机构来说是不确定的
  • 目前支付系统已经入账，但是小A仍未收到通知，支付系统就会一直通知你
  • 直到你告诉我，你确认了这个消息收到了，但是频繁调用对支付系统是一种无用的负担
  • 如果商户一直掉线，无疑会造成巨大的资源浪费，支付系统的策略可能是
  • 第一次是1s间隔，第二次是五s间隔, 第三次是15s间隔, …
  • 随着时间的拉长，通知的频率越来越低，这样缓解了支付系统的压力
  • 商家是有多个的，如果一直这么调用也不是办法，我们可以设置一个上限比如，调50次
  • 那么50次之后，还不通，那我就不调了，那商家的钱就放在了这个支付系统里
  • 如果商家的系统修复了，但是支付系统已通知到了上限，即超额了50次，这种场景下
  • 支付系统提供一个接口，让商家自己来查询，这就是最大努力通知方案
  • 它应用在，需要反复和对方确认的系统上

相关文章：

Go微服务: 分布式之通过本地消息实现最终一致性和最大努力通知方案

通过本地消息实现最终一致性 1 ）概述 我们的业务场景是可以允许我们一段时间有不一致的消息的状态的，并没有说必须特别高的这个消息的一致性比如说在TCC这个架构中，如果采用了消息的最终一致性，整体架构设计要轻松好多即便我们库…...

编程日记 2024/6/9 4:53:15

BC C language

题目汇总 No.1 打印有规律的字符(牛牛的字符菱形) 代码展示 #include<stdio.h> int main() {char ch0;scanf("%c",&ch);for(int i0;i<5;i){for(int j0;j<5;j){if((i0||i4)&&j2)printf("%c", ch);else if ((i 1||i3) &&…...

编程日记 2024/6/9 4:52:14

算法训练营第四十九天 | LeetCode 139单词拆分

LeetCode 139 单词拆分 基本还是完全背包的思路&#xff0c;不过用了三重循环&#xff0c;第三重循环是用于判断当前字符串尾部指定长度字符是否和列表中某一字符串相同&#xff0c;是的话可以将当前dp[j]或上当前下标减去该单词长度后的下标值。 代码如下&#xff1a; clas…...

编程日记 2024/6/9 4:51:13

阿里云一键登录号码认证服务

阿里云文档&#xff1a;号码认证SDK_号码认证服务(PNVS)-阿里云帮助中心 对于后端大概流程 前端App会传一个token过来 后端通过下面方法解析 如果解析可以获得号码,说明号码认证成功,如果无法正确解析则认证失败 /*** actoken来换取电话号码* param token app端用户授权actok…...

编程日记 2024/6/9 4:50:11

【UML用户指南】-05-对基本结构建模-类

目录 1、名称&#xff08;name&#xff09; 2、属性 &#xff08;attribute&#xff09; 3、操作&#xff08;operation&#xff09; 4、对属性和操作的组织 4.1、衍型 4.2、职责 &#xff08;responsibility&#xff09; 4.3、其他特征 4.4、对简单类型建模 5、结构良…...

编程日记 2024/6/9 4:48:10

【C++ 初阶】引用 () 实际的一些用法、常引用问题 详解！

文章目录 1. 常引用的背景2. 字符 a 与 整形 97 是相同的&#xff0c;但是具体是怎么比较的呢 &#xff1f; 1. 常引用的背景 注意&#xff1a; &#x1f427;① 权限可以平移、可以缩小&#xff0c;但是权限 不可以放大。 &#x1f427; 类型转换中间会产生临时变量 2. 字…...

编程日记 2024/6/9 4:45:06

adb dump当前可见的窗口

1、窗口信息 adb shell dumpsys window windows > w.txt2、dump当前可见的窗口activity windows系统 adb shell dumpsys activity | findStr mFocusmac系统 adb shell dumpsys activity | grep mFocus3、dump当前处于栈顶的activity windows系统 adb shell dumpsys activi…...

编程日记 2024/6/9 4:44:04

Java Web学习笔记27——对话框、表单组件

常见组件对话框&#xff1a; Dialog对话框&#xff1a;在保留当前页面状态下&#xff0c;告知用户并承载相关操作。 dialogTableVisible: false 默认是不可见的。 在按钮属性中设置为true的意思&#xff0c;点击按钮的时候&#xff0c;才会true&#xff0c;对话框才会显示。 …...

编程日记 2024/6/9 4:42:03

使用vue3+ts封装一个Slider滑块组件

创建一个名为 Slider.vue 的文件 <template><div class"slider-container"><inputtype"range":value"value"input"handleInput"change"handleChange"/><div class"slider-value">{{ val…...

编程日记 2024/6/9 4:40:00

关于科技的总结与思考

文章目录 互联网时代有趣的数字数据驱动大数据的两个特性数据保护互联网免费模式的再探讨平台互联网的意义人工智能伦理的思考语言理性人梅特卡夫定律冲浪的神奇之处AR的恐怖之处叙词表、受控词表和大众分类法六度/十九度的解读知识图谱是真正的仿生智能幂次法则和优先连接现代…...

编程日记 2024/6/9 4:38:59

2024年几款优秀的SQL IDE优缺点分析

SQL 工具在数据库管理、查询优化和数据分析中扮演着重要角色。 以下是常见的 SQL 工具及其优缺点。 1. SQLynx 优点&#xff1a; 智能代码补全和建议&#xff1a;采用AI技术提供高级代码补全、智能建议和自动错误检测&#xff0c;大幅提高编写和调试SQL查询的效率。跨平台和…...

编程日记 2024/6/9 4:36:58

vue前端实现页面禁止缩放 前端适配问题处理 前端项目多端适配解决方案

在前端项目中，如果一个系统页面可以缩放可能会导致多种异常情况，这些异常情况涉及到页面布局、元素尺寸、事件触发、响应式设计和用户体验等方面。 1.布局错乱：页面元素在缩放后可能会出现错位、重叠或部分隐藏的情况，导致页面布局混乱，影响用户对页面内容的理解和操作。这…...

编程日记 2024/6/9 4:35:57

反射型xss靶场练习

反射型xss危害小&#xff0c;这里使用的xss靶场是常用的xss靶场&#xff1a;xss-labs。 当我们完成弹窗后就通过该关卡&#xff0c;说该关卡存在xss的一个漏洞并且可以解析js代码。 第一关&#xff1a; 这里没有过滤我们输入的代码&#xff1a;直接将js代码放在js代码中&a…...

编程日记 2024/6/9 4:33:55

vue3 【实战】封装 “心跳“ 组件

需求描述 在控制台每秒打印一个“hello” 代码实现 <script setup> import { onMounted, onBeforeUnmount, ref } from "vue";const timer ref(0);onMounted(() > {function fn() {console.log("hello");timer.value setTimeout(fn, 1000);}tim…...

编程日记 2024/6/9 4:31:53

k8s网络问题以及容器跨宿主机通信原理

【0】资源配置文件 [rootmcwk8s03 mcwtest]# ls mcwdeploy.yaml [rootmcwk8s03 mcwtest]# cat mcwdeploy.yaml apiVersion: apps/v1 kind: Deployment metadata:labels:app: mcwpythonname: mcwtest-deploy spec:replicas: 1selector:matchLabels:app: mcwpythontemplate:met…...

编程日记 2024/6/9 4:30:52

BM25算法以及变种算法简介

深入理解TF-IDF、BM25算法与BM25变种&#xff1a;揭秘信息检索的核心原理与应用 原文链接&#xff1a; https://xie.infoq.cn/article/8b7232877d0d4327a6943e8ac BM25算法以及变种算法简介 Okapi BM25&#xff0c;一般简称 BM25 算法&#xff0c;在 20 世纪 70 年代到 80 年代…...

编程日记 2024/6/9 4:29:51

D455相机RGB与深度图像对齐，缓解相机无效区域的问题

前言 上一次我们介绍了深度相机D455的使用&#xff1a;intel深度相机D455的使用-CSDN博客&#xff0c;我们也看到了相机检测到的无效区域。 在使用Intel深度相机D455时&#xff0c;我们经常会遇到深度图中的无效区域。这些无效区域可能由于黑色物体、光滑表面、透明物体以及视…...

编程日记 2024/6/9 4:27:49

2024 cicsn ezbuf

文章目录 参考protobuf逆向学习复原结构思路exp 参考 https://www.y4ng.cn/posts/pwn/protobuf/#ciscn-2024-ezbuf protobuf 当时压根不知道用了protobuf这个玩意&#xff0c;提取工具也没提取出来&#xff0c;还是做题做太少了&#xff0c;很多关键性的结构都没看出来是pro…...

编程日记 2024/6/9 4:26:48

地面站Mission planner

官方教程; Mission Planner地面站介绍 | Autopilot (gitbook.io) Mission Planner 功能/屏幕 — Mission Planner 文档 (ardupilot.org) 安卓或者windows软件下载地址&#xff1a; 地面站连接及使用 plane (cuav.net) 在完全装机后再进行各干器件的校准&#xff0c;没有组…...

编程日记 2024/6/9 4:24:46

常见的api: BigInteger

一.获取一个大的随机整数 1.代码: BigInteger bd1 new BigInteger(4, new Random());System.out.println(bd1); 2.打印的结果:2 3.注释获取的是0-16之间的随机整数 二.获取一个指定的大的数 1.代码&#xff1a; BigInteger bd2 new BigInteger("100");System.o…...

编程日记 2024/6/9 4:22:44

Overall timing accuracy 和Edge placement accuracy 理解

在电子设计自动化(EDA)、集成电路(IC)制造和高速数字电路设计领域，"Overall Timing Accuracy" 和 "Edge Placement Accuracy" 是两个关键的性能指标，它们对于确保电路的功能正确性和性能至关重要。 当涉及到“Overall timing accuracy”（总体时序精度）…...

编程日记 2024/6/9 4:21:44

2024 vite 静态 scp2 自动化部署

1、导入库 npm install scp2 // 自动化部署 npm install chalk // 控制台输出的语句 npm install ora2、核心代码 创建文件夹放在主目录下的 deploy/index.js 复制粘贴以下代码&#xff1a; import client from scp2; import chalk from chalk; import ora from ora;const s…...

编程日记 2024/6/9 4:19:41

【数据结构】AVLTree实现详解

目录 一.什么是AVLTree 二.AVLTree的实现 1.树结点的定义 2.类的定义 3.插入结点 ①按二叉搜索树规则插入结点 ②更新平衡因子 更新平衡因子情况分析 ③判断是否要旋转 左单旋 右单旋 左右单旋 右左双旋 4.删除、查找和修改函数 查找结点 三.测试 1.判断是否是搜索树 …...

编程日记 2024/6/9 4:18:40

深度学习——TensorBoard的使用

官方文档torch.utils.tensorboard — PyTorch 2.3 documentation TensorBoard简介 TensorBoard是一个可视化工具&#xff0c;它可以用来展示网络图、张量的指标变化、张量的分布情况等。特别是在训练网络的时候&#xff0c;我们可以设置不同的参数&#xff08;比如&#xff1…...

编程日记 2024/6/9 4:17:38

【设计模式】观察者模式（行为型）⭐⭐⭐

文章目录 1.概念1.1 什么是观察者模式1.2 优点与缺点 2.实现方式3. Java 哪些地方用到了观察者模式4. Spring 哪些地方用到了观察者模式 1.概念 1.1 什么是观察者模式 观察者模式&#xff08;Observer Pattern&#xff09;是一种行为型设计模式&#xff0c;它允许对象在状态改…...

编程日记 2024/6/9 4:14:36

轻松搞定阿里云域名DNS解析

本文将会讲解如何设置阿里云域名DNS解析。在进行解析设置之前&#xff0c;你需要提前准备好需要设置的云服务器IP地址、域名以及CNAME记录。 如果你还没有云服务器和域名&#xff0c;可以参考下面的方法注册一个。 申请域名&#xff1a;《Namesilo域名注册》注册云服务器&…...

编程日记 2024/6/9 4:11:33

GAT1399协议分析（10）--单图像删除

一、官方接口 由于批量删除的接口&#xff0c;图像只能单独删除。 二、wireshark实例 这个接口比较简单&#xff0c;调用request delete即可 文本化&#xff1a; DELETE /VIID/Images/34078100001190001002012024060513561300065 HTTP/1.1 Host: 10.0.201.56:31400 User-Age…...

编程日记 2024/6/9 4:09:31

Hudi CLI 安装配置总结

前言 上篇文章 总结了Spark SQL Rollback, Hudi CLI 也能实现 Rollback，本文总结下 Hudi CLI 安装配置以及遇到的问题。 官方文档 https://hudi.apache.org/cn/docs/cli/ 版本 Hudi 0.13.0（发现有bug）、（然后升级）0.14.1Spark 3.2.3打包 mvn clean package -DskipTes…...

编程日记 2024/6/9 4:08:30

实验八、地址解析协议《计算机网络》

水逆退散&#xff0c;学业进步&#xff0c;祝我们都好&#xff0c;不止在夏天。 目录 一、实验目的 二、实验内容 &#xff08;1&#xff09;预备知识 &#xff08;2&#xff09;实验步骤 三、实验小结 一、实验目的 完成本练习之后&#xff0c;您应该能够确定给定 IP 地…...

编程日记 2024/6/9 4:07:29

Linux系统管理磁盘管理003

操作系统&#xff1a; CentOS Stream9 测试过程&#xff1a; 模拟磁盘被沾满&#xff0c; 创建文件 测试脚本 for i in seq 10do# echo $idd if/dev/zero of./$i-$RANDOM.txt bs1M count1024 Done[rootlocalhost ~]# vim 2.txt [rootlocalhost ~]# sh 2.txt 记录了10240 的…...

编程日记 2024/6/9 4:06:28

文档里网站超链接怎么做/软文推广广告

jdk1.5并发包中ReentrantLock的创建可以指定构造函数的boolean类型来得到公平锁或非公平锁&#xff0c;关于两者区别&#xff0c;java并发编程实践里面有解释 公平锁&#xff1a; Threads acquire a fair lock in the order in which they requested it非公平锁&#xff1a;a…...

编程日记 2024/11/18 9:50:02

启东 网站开发/互联网舆情

<?xml version"1.0" encoding"utf-8"?> 功能模块 LinearMath功能模块 LinearMath Table of Contents btScalar 宏定义类型函数btMinMax 文件btAlignedAllocator 宏定义函数类特殊说明btAlignedObjectArray 宏定义btAlignedObjectArray 类btList bt…...

编程日记 2024/11/18 9:43:57

那个网站专门做二手衣服的/怎样做一个产品营销方案

python作用域总结将Python与C的作用域规则对比理解试一下模块内变量作用域模块间作用域&#xff08;import&#xff09;总结将Python与C的作用域规则对比理解试一下 下面将Python与C的作用域规则对比理解试一下&#xff1a; 我个人认为python与C在作用域上的最大区别就是块作用…...

编程日记 2024/11/18 4:29:41

陕西省政府网站建设要求/seo网络推广知识

更多编程教程请到&#xff1a;菜鸟教程 https://www.piaodoo.com/ 友情链接&#xff1a; 高州阳光论坛https://www.hnthzk.com/人人影视http://www.sfkyty.com/一、python 开发工具的选择 python开发工具有很多&#xff0c;这里推荐使用 pycharm&#xff1b;因为jetbrains公…...

编程日记 2024/11/18 4:09:23

景区旅游门户网站建设方案/谷歌推广代理公司

一、spring security介绍 Spring Security是一个功能强大且可高度自定义的身份验证和访问控制框架。它是保护基于Spring的应用程序的事实上的标准。 Spring Security是一个专注于为Java应用程序提供身份验证和授权的框架。与所有Spring项目一样&#xff0c;Spring Security的…...

编程日记 2024/11/17 21:49:07

静态网页模板下载后怎么修改/seo赚钱方式

1、websocket概念 WebSocket是一种在客户端和服务器之间建立双向通信的协议&#xff0c;它可以实现实时的数据传输&#xff0c;避免了HTTP协议中频繁的请求和响应&#xff0c;从而提高了Web应用程序的性能和用户体验。 WebSocket最早是在2008年由Hixie提出的&#xff0c;后来…...

编程日记 2024/11/17 20:59:25