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

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


1 )概述

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

2 )场景

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

最大努力通知方案

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

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/pingmian/25040.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

获取东方财富网股票的实时数据股票的数据,并保存到Excel文件中

可以运行python文件获取东方财富网:【序号,代码,名称,最新价,涨跌幅,涨跌额,成交量,成交额,振幅,最高,最低,今开,昨收,量比,换手率,市盈率-动态,市净率,总市值,流通市值,涨速,5分钟涨跌,60日涨跌幅,年初至今涨跌幅,】数据,保存到Excel文件中。 import pandas as pd import re…

公司面试题总结(二)

7. 说说 JavaScript 中的数据类型?存储上的差别? • 基本类型: o Number o String o Boolean o Undefined o null o symbol • 引用类型 o Object o Array o Function • 声明变量时不同的内存地址分配: o 简单类型的…

嵌入式Linux系统编程 — 3.3 chown、fchown 和 lchown 函数更改文件属主

目录 1 文件属主 1.1 文件属主概念 1.2 如何查看文件属主 1.3 有效用户 ID 和有效组 ID 2 chown 函数 2.1 chown命令 2.2 chown函数 2.3 getuid 和 getgid函数 3 fchown函数 3.1 fchown函数简介 3.2 示例代码 4 lchown函数 1 文件属主 1.1 文件属主概念 Linux…

tkinter颜色选择器

tkinter颜色选择器 颜色选择器效果代码 颜色选择器 Tkinter 提供了一个简单易用的颜色选择器模块 colorchooser,通过调用 colorchooser.askcolor() 方法,我们可以轻松实现颜色选择功能。 效果 代码 import tkinter as tk from tkinter import colorch…

angularJS资料

return home 目录结构 文章目录 [toc]angular4工作angular2下arcgis开发angular2相关资料BootstrapJavaScriptJavaScript视频教程 TypeScriptHTML CSS菜鸟教程 http://www.runoob.com/手册网 http://www.shouce.ren/w3school http://www.w3school.com.cn/ angular4 angular-CLI…

CSS函数: translate、translate3d的使用

translate()和translate3d()函数可以实现元素在指定轴的平移的功能。函数使用在CSS转换属性transform的属性值。实现转换的函数类型有: translate():2D平面实现X轴、Y轴的平移translate3d():3D空间实现位置的平移translateX():实…

LLVM Cpu0 新后端4

想好好熟悉一下llvm开发一个新后端都要干什么,于是参考了老师的系列文章: LLVM 后端实践笔记 代码在这里(还没来得及准备,先用网盘暂存一下): 链接: https://pan.baidu.com/s/1V_tZkt9uvxo5bnUufhMQ_Q?…

向量数据库是什么?

向量数据库是什么? 随着人工智能和机器学习技术的迅猛发展,向量数据库作为一种新型数据库引起了广泛关注。向量数据库专门用于存储和查询高维向量数据,是在大规模数据检索和相似性搜索领域的重要工具。 向量数据库的定义 向量数据库是一种…

#09 Stable Diffusion动画制作入门

文章目录 前言1. 理解Stable Diffusion2. 动画制作的基本概念3. 准备阶段3.1 设计文本提示3.2 选择参数 4. 制作过程4.1 生成图像序列4.2 合成动画 5. 后期处理5.1 调色和特效5.2 输出格式 6. 最佳实践结论 前言 随着AI技术的飞速发展,Stable Diffusion作为一种先进…

定时清理Linux服务器缓存shell脚本

服务器内存占用过高,如何定时清理一下服务器内存呢?写一个清理缓存脚本,加入到定时任务中。 一、编写脚本 clear_cache.sh 脚本,放到home目录下。 #!/bin/bash# 清除页面缓存、目录项和 inode 缓存 sudo sync echo 3 | sudo tee /proc/sys/vm/drop_caches# 记录执行时间到日…

为下一波创新做准备:人工智能和元宇宙

人工智能和元宇宙的发展带来了独特的可能性和挑战。随着这些技术的发展,我们进入了一个沉浸式虚拟体验和智能系统的时代,我们正站在一个历史性的时刻。为迎接下一波创新,采取必要的措施是很重要的。 我们正在见证两项变革性技术的激动人心的发…

qt中网络编程关于QNetworkReply导致崩溃

现场项目上线之后,使用中总是闪退,release版本exe不好查找问题,困扰了我好几天,最后发现导致问题的可能点是:由于请求的网址都是一样的,只是请求数据不一样,所以只使用了一个reply,即…

数据赋能(113)——体系:监控数据采集——实施过程、应用特点

实施过程 监控数据采集的实施过程通常包括以下步骤: 明确监控目标:需要明确监控数据的采集目标,包括需要监控哪些数据、监控的目的以及预期的监控效果。确定监控数据源:确定监控数据来源,这包括各种数据库、网络设备…

WebSocket前端分页:技术深度、实践困境与未来展望

WebSocket前端分页:技术深度、实践困境与未来展望 在前端开发的广阔领域中,WebSocket前端分页技术以其独特的优势逐渐崭露头角。它不仅为开发者带来了全新的交互体验,也为用户带来了更加流畅和高效的信息获取方式。然而,这一技术…

以sqlilabs靶场为例,讲解SQL注入攻击原理【54-65关】

【Less-54】 与前面的题目不同是,这里只能提交10次,一旦提交超过十次,数据会重新刷新,所有的步骤需要重来一次。 解题步骤: 根据测试,使用的是单引号闭合。 # 判断字段的数量 ?id1 order by 3 -- aaa# …

WPF视频学习-基础知识篇

1.简介WPF: C# 一套关于windows界面应用开发框架 2.WPF和winform的差别 ,(WPF比较新) 创建新项目使用模板: WPF使用.xaml后缀,双击可查看操作界面和设置代码,其文件展开之后中有MainWindow.xaml.cs为程序交互逻辑。…

云上小知识:企业选择云服务的小Tips

企业在选择云服务模式时,应综合考虑以下几个关键因素: 1. 业务需求与场景 企业需要根据自身的业务特点和需求来选择合适的云服务模式。例如,如果企业的用户分布广泛,需要跨地域提供服务,那么公有云可能是更好的选择。…

【Python】数据处理:文本文件操作

在Python中,处理文本文件是非常常见的任务。可以使用内置的open函数来打开、读取和写入文本文件。 打开文件 使用open函数打开文件。该函数有两个主要参数: open(file, moder, buffering-1, encodingNone, errorsNone, newlineNone, closefdTrue, ope…

Windows 批处理(bat) 中文件操作使用教程

文章目录 dir:列出当前目录下的文件和子目录cd:改变当前目录md 或 mkdir:创建新目录rd 或 rmdir:删除目录del:删除一个或多个文件copy:复制文件到另一个位置xcopy:用于复制目录及其内容到另一个…

#08 文本到图像转换:Stable Diffusion的创意应用

文章目录 前言1. 文本提示的艺术1.1 创意描述1.2 故事叙述 2. 图像生成的技巧2.1 参数调整2.2 风格迁移 3. 创意应用实例3.1 艺术创作3.2 商业设计3.3 社交媒体内容 4. 实践指南4.1 实验与迭代4.2 学习与借鉴4.3 版权与伦理 结论 前言 Stable Diffusion作为一种先进的AI图像生…