应用 Strangler 模式将遗留系统分解为微服务

许多来源在一般情况下提供了微服务的解释,但缺乏特定领域的示例。新来者或不确定从哪里开始的人可能会发现掌握如何将遗留系统过渡到微服务架构具有挑战性。本指南主要面向那些正在努力启动迁移工作的个人,它提供了特定于业务的示例来帮助理解该过程。

我想谈谈另一种模式 - Strangler模式 - 这是一种迁移模式,用于逐步从旧系统过渡到新系统,同时最大限度地降低风险。

让我们以传统杂货计费系统为例。现在是时候升级到微服务架构以利用其优势了。

Strangler 是一种逐步退役旧系统,同时逐步开发新系统的模式。这样,用户可以更快地开始使用新系统,而不是等待整个系统迁移完成。

在第一篇文章中,我将重点关注杂货店所需的微服务。例如,考虑这样一个场景:您当前有一个杂货店的遗留系统,并且您有兴趣将其升级到微服务架构并将其迁移到云。

杂货店遗留系统概述

首先,在线杂货店可能具有的模块是:

  1. 购物车服务

  2. 退款处理服务

  3. 库存管理服务:商品销售时减去商品数量,订单退款时加回商品数量。

根据 Strangler 模式,您应该能够用新的微服务替换一个模块,同时继续使用其他模块,直到更新的服务准备就绪。

在这里,您可以先用更新的服务替换购物车。由于购物车服务依赖于支付处理服务,因此您也需要开发该服务。

假设我们将逐步开发这些服务。出于演示目的,我将仅关注上述三个服务。但在现实场景中,您可能需要如下所示的其他服务来完成杂货店的整个电子商务网站:


public class Product
{public Guid Id { get; set; }public string Name { get; set; }public decimal Price { get; set; }public int StockQuantity { get; set; }public Category ProductCategory { get; set; }
}public class Category
{public Guid Id { get; set; }public string Name { get; set; }
}public class ShoppingCartItem
{public Product Product { get; set; }public int Quantity { get; set; }
}public class ShoppingCart
{public Guid Id { get; set; }public List<ShoppingCartItem> Items { get; set; }public Customer Customer { get; set; }public DateTime CreatedAt { get; set; }
}public class Order
{public Guid Id { get; set; }public List<ShoppingCartItem> Items { get; set; }public Customer Customer { get; set; }public decimal TotalAmount { get; set; }public DateTime CreatedAt { get; set; }
}

图片

现在让我们考虑每个服务所需的基本模型类和操作。

对于购物车服务,您需要以下模型类和操作:产品、产品类别、添加到购物车的商品、购物车和订单。它的结构如下:

购物车服务


public class Product
{public Guid Id { get; set; }public string Name { get; set; }public decimal Price { get; set; }public int StockQuantity { get; set; }public Category ProductCategory { get; set; }
}public class Category
{public Guid Id { get; set; }public string Name { get; set; }
}public class ShoppingCartItem
{public Product Product { get; set; }public int Quantity { get; set; }
}public class ShoppingCart
{public Guid Id { get; set; }public List<ShoppingCartItem> Items { get; set; }public Customer Customer { get; set; }public DateTime CreatedAt { get; set; }
}public class Order
{public Guid Id { get; set; }public List<ShoppingCartItem> Items { get; set; }public Customer Customer { get; set; }public decimal TotalAmount { get; set; }public DateTime CreatedAt { get; set; }
}

理想情况下,您应该创建一个共享项目来容纳所有模型和接口。首先必须确定必要的模型和操作。

在考虑客户可以在购物车中执行的操作时,通常只涉及一个主要操作,CreateOrder,即向购物车添加商品。然而,其他操作,例如支付处理、退款和库存调整,应作为单独的微服务来实现。这种模块化方法可以在管理业务流程的不同方面提供更大的灵活性和可扩展性。


public class BillingService : IBillingService
{public Order CreateOrder(Customer customer, List<ShoppingCartItem> items){return new Order{Id = Guid.NewGuid(), //Create a new order idItems = items,Customer = customer,TotalAmount = CalculateTotalAmount(items),CreatedAt = DateTime.Now};}private decimal CalculateTotalAmount(List<ShoppingCartItem> items){decimal totalAmount = 0;foreach (var item in items){totalAmount += item.Product.Price * item.Quantity;}return totalAmount;}
}

理想情况下,在共享项目中,您必须为 IBillingService 创建一个接口。它应该如下所示:

public interface IBillingService{   public Order CreateOrder(Customer customer, List<ShoppingCartItem> items);}

现在您可以对CreateOrder操作进行单元测试。

在现实世界中,通常的做法是创建IBillingRepository 将订单保存在数据库中。该存储库应包含在数据库中存储订单的方法,或者您可以选择使用下游服务来处理订单创建过程。

我不会解决用户身份验证、安全、托管、监控、代理以及本讨论中的其他相关主题,因为它们是不同的主题。我的主要关注点仍然是根据您的特定需求量身定制的微服务的设计方面。

创建购物车后,下一步涉及客户付款。让我们继续创建支付服务项目及其关联模型。

付款处理服务


public class Payment
{public Guid Id { get; set; }public decimal Amount { get; set; }public PaymentStatus Status { get; set; }public DateTime PaymentDate { get; set; }public PaymentMethod PaymentMethod { get; set; }
}public enum PaymentStatus
{Pending,Approved,Declined,
}
public enum PaymentMethod
{CreditCard,DebitCard,PayPal,
}public class Receipt
{public Guid Id { get; set; }public Order Order { get; set; }public decimal TotalAmount { get; set; }public DateTime IssuedDate { get; set; }
}public class PaymentService : IPaymentService
{private PaymentGateway paymentGateway;public PaymentService(){this.paymentGateway = new PaymentGateway();}public Payment MakePayment(decimal amount, PaymentMethod paymentMethod, string paymentDetails){// In a real system, you would handle the payment details and validation before calling the payment gateway.return paymentGateway.ProcessPayment(amount, paymentMethod, paymentDetails);}
}public class ReceiptService : IReceiptService
{public Receipt GenerateReceipt(Order order){var receipt = new Receipt{Id = Guid.NewGuid(),Order = order,TotalAmount = order.TotalAmount,IssuedDate = DateTime.Now};return receipt;}
}

在此服务项目中,您必须创建并实现以下接口:


public Interface IPaymentService
{public Payment MakePayment(decimal amount, PaymentMethod paymentMethod, string paymentDetails); 
}
public Interface IReceiptService
{public Receipt GenerateReceipt(Order order);
}public Interface IPaymentRepository
{public Payment ProcessPayment(decimal amount, PaymentMethod paymentMethod, string paymentDetails)
} public class PaymentGateway : IPaymentRepository
{public Payment ProcessPayment(decimal amount, PaymentMethod paymentMethod, string paymentDetails){// Simplified payment processing logic for demonstrationvar payment = new Payment{Id = Guid.NewGuid(),Amount = amount,Status = PaymentStatus.Pending,PaymentDate = DateTime.Now,PaymentMethod = paymentMethod};// In a real system, you would connect to a payment gateway and process the payment, updating the payment status accordingly.// For example, you might use an external payment processing library or API to handle the transaction.// Simulating a successful payment here for demonstration purposes.payment.Status = PaymentStatus.Approved;return payment;}
}

创建所有这些服务后,我们可以轻松地使用新系统停用购物车(假设您也有一个并行完成的新用户界面)。

接下来,我们必须解决下订单后的库存管理问题。库存管理服务负责在创建采购订单时补货。该服务项目的结构如下:

库存管理服务

public class Product
{public Guid Id { get; set; }public string Name { get; set; }public decimal Price { get; set; }public int QuantityInStock { get; set; }public Category ProductCategory { get; set; }
}
public class Category
{public Guid Id { get; set; }public string Name { get; set; }
}public class Supplier
{public Guid Id { get; set; }public string Name { get; set; }public string ContactEmail { get; set; }
}
public class PurchaseOrder
{public Guid Id { get; set; }public Supplier Supplier { get; set; }public List<PurchaseOrderItem> Items { get; set; }public DateTime OrderDate { get; set; }public bool IsReceived { get; set; }
}public class PurchaseOrderItem
{public Product Product { get; set; }public int QuantityOrdered { get; set; }public decimal UnitPrice { get; set; }
}public interface IInventoryManagementService
{void ReceivePurchaseOrder(PurchaseOrder purchaseOrder);void SellProduct(Product product, int quantitySold);
}public class InventoryManagementService : IInventoryManagementService
{public void ReceivePurchaseOrder(PurchaseOrder purchaseOrder){if (purchaseOrder.IsReceived){throw new InvalidOperationException("The order is already placed.");}foreach (var item in purchaseOrder.Items){item.Product.QuantityInStock += item.QuantityOrdered;}purchaseOrder.IsReceived = true;}public void SellProduct(Product product, int quantitySold){if (product.QuantityInStock < quantitySold){throw new InvalidOperationException("Item not in stock.");}product.QuantityInStock -= quantitySold;}
}

正如我所提到的,本指南主要面向那些正在努力启动迁移工作的个人,它提供了特定于业务的示例来帮助理解该过程。

我相信本文为如何在微服务架构中启动迁移项目提供了宝贵的见解。如果您正在开发杂货店或任何在线购物车系统,那么此信息对您来说应该特别有用。我希望你能从这里拿走它。在我的下一篇文章中,我将介绍另一个特定于领域的示例,因为您始终可以在其他地方探索有关微服务的更多一般信息。


作者:Somasundaram Kumarasamy

更多技术干货请关注公号【云原生数据库

squids.cn,云数据库RDS,迁移工具DBMotion,云备份DBTwin等数据库生态工具。

irds.cn,多数据库管理平台(私有云)。

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

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

相关文章

磁盘类型选择对阿里云RDS MySQL的性能影响

测试说明 这是一个云数据库性能测试系列&#xff0c;旨在通过简单标准的性能测试&#xff0c;帮助开发者、企业了解云数据库的性能&#xff0c;以选择适合的规格与类型。这个系列还包括&#xff1a; * 云数据库(RDS MySQL)性能深度测评与对比 * 阿里云RDS标准版(x86) vs 经济…

C++ 模拟实现string

目录 一.类的声明 二.确定成员变量 三.成员函数 1.带参的构造函数&#xff0c;析构函数&#xff0c;拷贝构造 2.size()与capacity() 3.运算符重载 重载数组下标访问[] 重载 重载比较运算符&#xff08;<&#xff0c; < &#xff0c; > &#xff0c; > …

改变传媒格局的新趋势

在如今信息高速发展的时代&#xff0c;人们早已进入了一个以手机为中心的智能化时代。随着科技的迅猛发展&#xff0c;手机无人直播成为了一种新兴的传媒形态&#xff0c;正逐渐改变着传媒格局。本文将从手机无人直播的定义、发展背景和影响等方面进行探讨。 首先&#xff0c;…

数字孪生开发技术分析

数字孪生的开发涉及多个技术领域&#xff0c;包括计算机科学、数据科学、人工智能和工程等。以下是数字孪生开发中常用的一些关键技术&#xff0c;希望对大家有所帮助。北京木奇移动技术有限公司&#xff0c;专业的软件外包开发公司&#xff0c;欢迎交流合作。 1.建模和仿真&am…

《论文阅读28》Unsupervised 3D Shape Completion through GAN Inversion

GAN&#xff0c;全称GenerativeAdversarialNetworks&#xff0c;中文叫生成式对抗网络。顾名思义GAN分为两个模块&#xff0c;生成网络以及判别网络&#xff0c;其中 生成网络负责根据随机向量产生图片、语音等内容&#xff0c;产生的内容是数据集中没有见过的&#xff0c;也可…

hive 用户自定义函数udf,udaf,udtf

udf&#xff1a;一对一的关系 udtf&#xff1a;一对多的关系 udaf&#xff1a;多对一的关系 使用Java实现步骤 自定义编写UDF函数注意&#xff1a; 1.需要继承org.apache.hadoop.hive.ql.exec.UDF 2.需要实现evaluete函数 编写UDTF函数注意&#xff1a; 1.需要继承org.apache…

Vue前端设计模式

文章目录 一、什么是设计模式&#xff1f;二、设计几个原则三、常见的设计模式及实际案例3.1、单例模式3.1.1、Element UI3.1.2、Vuex 3.2、工厂模式3.2.1、VNode3.2.2、vue-route 3.3、策略模式3.3.1、表格 formatter3.3.2、表单验证 3.4、代理模式3.4.1、拦截器3.4.2、前端框…

【分享】如何给Excel加密?码住这三种方法!

想要给Excel文件进行加密&#xff0c;方法有很多&#xff0c;今天分享三种Excel加密方法给大家。 打开密码 设置了打开密码的excel文件&#xff0c;打开文件就会提示输入密码才能打开excel文件&#xff0c;只有输入了正确的密码才能打开并且编辑文件&#xff0c;如果密码错误…

Elasticsearch常见面试题

文章目录 1.简单介绍下ES&#xff1f;2.简单介绍当前可以下载的ES稳定版本&#xff1f;3.安装ES前需要安装哪种软件&#xff1f;4.请介绍启动ES服务的步骤&#xff1f;5.ES中的倒排索引是什么&#xff1f;6. ES是如何实现master选举的&#xff1f;7. 如何解决ES集群的脑裂问题8…

高速视频采集卡设计方案:620-基于PCIe的高速视频采集卡

一、产品概述 基于PCIe的高速视频采集卡&#xff0c;通过PCIe3.0X8传输到存储计算服务器&#xff0c;实现信号的分析、存储。 北京太速科技 产品固化FPGA逻辑&#xff0c;适配视频连续采集&#xff0c;缓存容量2GB&#xff0c;开源的PCIe QT客户端软件&#xff0c…

(七)STM32 NVIC 中断、优先级管理及 AFIO 时钟的开启

目录 1. 中断相关知识简介 1.1 什么是中断 1.2 什么是内中断、外中断 1.3 什么是可屏蔽中断、不可屏蔽中断 2. CM3 内核中断介绍 2.1 F103系统异常清单 2.2 F103 外部中断清单 3. NVIC 简介 3.1 NVIC 寄存器简介 3.2 NVIC 相关寄存器的介绍 4. 中断优先级 4.1 优先…

2017年第六届数学建模国际赛小美赛B题电子邮件中的笔迹分析解题全过程文档及程序

2017年第六届数学建模国际赛小美赛 B题 电子邮件中的笔迹分析 原题再现&#xff1a; 笔迹分析是一种非常特殊的调查形式&#xff0c;用于将人们与书面证据联系起来。在法庭或刑事调查中&#xff0c;通常要求笔迹鉴定人确认笔迹样本是否来自特定的人。由于许多语言证据出现在电…

PyTorch深度学习实战(26)——卷积自编码器(Convolutional Autoencoder)

PyTorch深度学习实战&#xff08;26&#xff09;——卷积自编码器 0. 前言1. 卷积自编码器2. 使用 t-SNE 对相似图像进行分组小结系列链接 0. 前言 我们已经学习了自编码器 (AutoEncoder) 的原理&#xff0c;并使用 PyTorch 搭建了全连接自编码器&#xff0c;但我们使用的数据…

【PHP入门】2.2 流程控制

-流程控制- 流程控制&#xff1a;代码执行的方向 2.2.1控制分类 顺序结构&#xff1a;代码从上往下&#xff0c;顺序执行。&#xff08;代码执行的最基本结构&#xff09; 分支结构&#xff1a;给定一个条件&#xff0c;同时有多种可执行代码&#xff08;块&#xff09;&am…

阿里推荐 LongAdder ,不推荐 AtomicLong !

其他系列文章导航 Java基础合集数据结构与算法合集 设计模式合集 多线程合集 分布式合集 ES合集 文章目录 其他系列文章导航 文章目录 前言 一、CAS 1.1 CAS 全称 1.2 通俗理解CAS 1.3 CAS的问题 1.4 解决 ABA 问题 二、LongAdder 2.1 什么是 LongAdder 2.2 为什么推…

用JVS低代码实现业务流程的撤回和重新开始

在当今的数字化时代&#xff0c;业务流程的效率和准确性对于企业的运营至关重要。在实际业务场景中&#xff0c;我们可能需要处理一些复杂的流程&#xff0c;例如申请审批流程、合同签订流程等。这些流程在执行过程中可能会遇到各种情况&#xff0c;例如某个审批步骤需要重新审…

❀My虚拟机上的ftp服务器搭建(centos)❀

❀My虚拟机上的ftp服务器搭建(centos)❀ 在CentOS上搭建FTP服务器可以使用vsftpd软件&#xff0c;下面是详细的搭建教程&#xff1a; ①安装vsftpd软件 在终端中输入以下命令进行安装&#xff1a; sudo yum install vsftpd ②配置vsftpd 打开vsftpd的配置文件&#xff0c;…

【深度学习】序列生成模型(五):评价方法计算实例:计算BLEU-N得分【理论到程序】

文章目录 一、BLEU-N得分&#xff08;Bilingual Evaluation Understudy&#xff09;1. 定义2. 计算N1N2BLEU-N 得分 3. 程序 给定一个生成序列“The cat sat on the mat”和两个参考序列“The cat is on the mat”“The bird sat on the bush”分别计算BLEU-N和ROUGE-N得分(N1或…

WEB渗透—PHP反序列化(六)

Web渗透—PHP反序列化 课程学习分享&#xff08;课程非本人制作&#xff0c;仅提供学习分享&#xff09; 靶场下载地址&#xff1a;GitHub - mcc0624/php_ser_Class: php反序列化靶场课程&#xff0c;基于课程制作的靶场 课程地址&#xff1a;PHP反序列化漏洞学习_哔哩…

Ubuntu 22.04 禁用(彻底移除)Snap

什么是Snaps Snaps 是 Ubuntu 的母公司 Canonical 于 2016 年 4 月发布 Ubuntu 16.04 LTS&#xff08;Long Term Support&#xff0c;长期支持版&#xff09;时引入的一种容器化的软件包格式。自 Ubuntu 16.04 LTS 起&#xff0c;Ubuntu 操作系统可以同时支持 Snap 及 Debian …