茶叶网站源码php,wordpress上传图片不清楚,网站模板怎么做视频教程,wordpress美图前言
在分布式系统中#xff0c;由于各个系统服务之间的独立性和网络通信的不确定性#xff0c;要确保跨系统的事务操作的最终一致性是一项重大的挑战。今天给大家推荐一个.NET开源的处理分布式事务的解决方案基于 .NET Standard 的 C# 库#xff1a;CAP。 CAP项目介绍
CA…前言
在分布式系统中由于各个系统服务之间的独立性和网络通信的不确定性要确保跨系统的事务操作的最终一致性是一项重大的挑战。今天给大家推荐一个.NET开源的处理分布式事务的解决方案基于 .NET Standard 的 C# 库CAP。 CAP项目介绍
CAP 是一个基于 .NET Standard 的 C# 库它是一种处理分布式事务的解决方案同样具有 EventBus 的功能它具有轻量级、易使用、高性能等特点。CAP 是一个EventBus同时也是一个在微服务或者SOA系统中解决分布式事务问题的一个框架。它有助于创建可扩展可靠并且易于更改的微服务系统。 什么是 EventBus
事件总线是一种机制它允许不同的组件彼此通信而不彼此了解。组件可以将事件发送到Eventbus而无需知道是谁来接听或有多少其他人来接听。组件也可以侦听Eventbus上的事件而无需知道谁发送了事件。这样组件可以相互通信而无需相互依赖。同样很容易替换一个组件。只要新组件了解正在发送和接收的事件其他组件就永远不会知道。 CAP架构预览 CAP支持的存储
SQL Server、MySQL、PostgreSql、MongoDB、In-Memory Storage。 CAP 支持以下几种运输方式
RabbitMQ、Kafka、Azure Service Bus、Amazon SQS、NATS、In-Memory Queue、Redis Streams、Apache Pulsar。
怎么选择运输器 项目源码 快速开始
安装DotNetCore.CAP Nuget包 CAP 支持主流的消息队列作为传输器 我本地安装的是DotNetCore.CAP.RabbitMQ。 //你可以按需选择下面的包进行安装:
PM Install-Package DotNetCore.CAP.Kafka
PM Install-Package DotNetCore.CAP.RabbitMQ
PM Install-Package DotNetCore.CAP.AzureServiceBus
PM Install-Package DotNetCore.CAP.AmazonSQS
PM Install-Package DotNetCore.CAP.NATS
PM Install-Package DotNetCore.CAP.RedisStreams
PM Install-Package DotNetCore.CAP.Pulsar CAP 提供了主流数据库作为存储 我本地安装的是DotNetCore.CAP.MongoDB。 // 按需选择安装你正在使用的数据库:
PM Install-Package DotNetCore.CAP.SqlServer
PM Install-Package DotNetCore.CAP.MySql
PM Install-Package DotNetCore.CAP.PostgreSql
PM Install-Package DotNetCore.CAP.MongoDB 配置CAP到 Program.cs 文件中如下 builder.Services.AddCap(x {//如果你使用的 EF 进行数据操作你需要添加如下配置//配置数据库上下文x.UseEntityFrameworkAppDbContext();//如果你使用的 MongoDB你可以添加如下配置x.UseMongoDB(ConnectionStrings); //注意仅支持MongoDB 4.0集群//CAP RabbitMQ 配置x.UseRabbitMQ(rab {rab.HostName 192.0.1.1;rab.Password 123456;rab.Port 5672;rab.UserName 123456;});});发布
在 Controller 中注入 ICapPublisher 然后使用 ICapPublisher 进行消息发送。
public class PublishController : Controller
{private readonly ICapPublisher _capBus;public PublishController(ICapPublisher capPublisher){_capBus capPublisher;}//不使用事务[Route(~/without/transaction)]public IActionResult WithoutTransaction(){_capBus.Publish(xxx.services.show.time, DateTime.Now);// Publish delay message_capBus.PublishDelayAsync(TimeSpan.FromSeconds(delaySeconds), xxx.services.show.time, DateTime.Now);return Ok();}//Ado.Net 中使用事务自动提交[Route(~/adonet/transaction)]public IActionResult AdonetWithTransaction(){using (var connection new MySqlConnection(ConnectionString)){using (var transaction connection.BeginTransaction(_capBus, autoCommit: true)){//业务代码_capBus.Publish(xxx.services.show.time, DateTime.Now);}}return Ok();}//EntityFramework 中使用事务自动提交[Route(~/ef/transaction)]public IActionResult EntityFrameworkWithTransaction([FromServices]AppDbContext dbContext){using (var trans dbContext.Database.BeginTransaction(_capBus, autoCommit: true)){//业务代码_capBus.Publish(xxx.services.show.time, DateTime.Now);}return Ok();}
}订阅
Action Method
在 Action 上添加 CapSubscribeAttribute 来订阅相关消息。
public class PublishController : Controller
{[CapSubscribe(xxx.services.show.time)]public void CheckReceivedMessage(DateTime datetime){Console.WriteLine(datetime);}
}Service Method
如果你的订阅方法没有位于 Controller 中则你订阅的类需要继承 ICapSubscribe namespace xxx.Service
{public interface ISubscriberService{void CheckReceivedMessage(DateTime datetime);}public class SubscriberService: ISubscriberService, ICapSubscribe{[CapSubscribe(xxx.services.show.time)]public void CheckReceivedMessage(DateTime datetime){}}
} 项目源码地址
更多项目实用功能和特性欢迎前往项目开源地址查看别忘了给项目一个Star支持。 GitHub开源地址GitHub - dotnetcore/CAP: Distributed transaction solution in micro-service base on eventually consistency, also an eventbus with Outbox pattern 官方文档CAP 优秀项目和框架精选
该项目已收录到C#/.NET/.NET Core优秀项目和框架精选中关注优秀项目和框架精选能让你及时了解C#、.NET和.NET Core领域的最新动态和最佳实践提高开发工作效率和质量。坑已挖欢迎大家踊跃提交PR推荐或自荐让优秀的项目和框架不被埋没。 https://github.com/YSGStudyHards/DotNetGuide/blob/main/docs/DotNet/DotNetProjectPicks.md DotNetGuide技术社区交流群
DotNetGuide技术社区是一个面向.NET开发者的开源技术社区旨在为开发者们提供全面的C#/.NET/.NET Core相关学习资料、技术分享和咨询、项目推荐、招聘资讯和解决问题的平台。在这个社区中开发者们可以分享自己的技术文章、项目经验、遇到的疑难技术问题以及解决方案并且还有机会结识志同道合的开发者。我们致力于构建一个积极向上、和谐友善的.NET技术交流平台为广大.NET开发者带来更多的价值和成长机会。 欢迎加入DotNetGuide技术社区微信交流群
