国内阿里网站建设,前端页面设计,长沙免费建站模板,商标设计与制作CAP 是一个基于 .NET Standard 的 C# 库#xff0c;它是一种处理分布式事务的解决方案#xff0c;同样具有 EventBus 的功能#xff0c;它具有轻量级、易使用、高性能等特点。https://github.com/dotnetcore/CAP在我们构建 SOA 或者 微服务系统的过程中#xff0c;我们通常… CAP 是一个基于 .NET Standard 的 C# 库它是一种处理分布式事务的解决方案同样具有 EventBus 的功能它具有轻量级、易使用、高性能等特点。https://github.com/dotnetcore/CAP在我们构建 SOA 或者 微服务系统的过程中我们通常需要使用事件来对各个服务进行集成在这过程中简单的使用消息队列并不能保证数据的最终一致性 CAP 采用的是和当前数据库集成的本地消息表的方案来解决在分布式系统互相调用的各个环节可能出现的异常它能够保证任何情况下事件消息都是不会丢失的。你同样可以把 CAP 当做 EventBus 来使用CAP提供了一种更加简单的方式来实现事件消息的发布和订阅在订阅以及发布的过程中你不需要继承或实现任何接口。这是CAP集在ASP.NET Core 微服务架构中的一个示意图架构预览CAP 实现了 eShop 电子书 中描述的发件箱模式Getting StartedNuGet你可以运行以下下命令在你的项目中安装 CAP。PM Install-Package DotNetCore.CAP
CAP 支持 Kafka、RabbitMQ、AzureServiceBus 等消息队列你可以按需选择下面的包进行安装PM Install-Package DotNetCore.CAP.Kafka
PM Install-Package DotNetCore.CAP.RabbitMQ
PM Install-Package DotNetCore.CAP.AzureServiceBus
CAP 提供了 Sql Server, MySql, PostgreSQLMongoDB 的扩展作为数据库存储// 按需选择安装你正在使用的数据库
PM Install-Package DotNetCore.CAP.SqlServer
PM Install-Package DotNetCore.CAP.MySql
PM Install-Package DotNetCore.CAP.PostgreSql
PM Install-Package DotNetCore.CAP.MongoDB
Configuration首先配置CAP到 Startup.cs 文件中如下public void ConfigureServices(IServiceCollection services)
{......services.AddDbContextAppDbContext();services.AddCap(x {//如果你使用的 EF 进行数据操作你需要添加如下配置x.UseEntityFrameworkAppDbContext(); //可选项你不需要再次配置 x.UseSqlServer 了//如果你使用的ADO.NET根据数据库选择进行配置x.UseSqlServer(数据库连接字符串);x.UseMySql(数据库连接字符串);x.UsePostgreSql(数据库连接字符串);//如果你使用的 MongoDB你可以添加如下配置x.UseMongoDB(ConnectionStrings); //注意仅支持MongoDB 4.0集群//CAP支持 RabbitMQ、Kafka、AzureServiceBus 等作为MQ根据使用选择配置x.UseRabbitMQ(ConnectionStrings);x.UseKafka(ConnectionStrings);x.UseAzureServiceBus(ConnectionStrings);});
}
发布在 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);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 中则你订阅的类需要继承 ICapSubscribenamespace xxx.Service
{public interface ISubscriberService{void CheckReceivedMessage(DateTime datetime);}public class SubscriberService: ISubscriberService, ICapSubscribe{[CapSubscribe(xxx.services.show.time)]public void CheckReceivedMessage(DateTime datetime){}}
}
然后在 Startup.cs 中的 ConfigureServices() 中注入你的 ISubscriberService 类public void ConfigureServices(IServiceCollection services)
{//注意: 注入的服务需要在 services.AddCap() 之前services.AddTransientISubscriberService,SubscriberService();services.AddCap(x{});
}订阅者组订阅者组的概念类似于 Kafka 中的消费者组它和消息队列中的广播模式相同用来处理不同微服务实例之间同时消费相同的消息。当CAP启动的时候她将创建一个默认的消费者组如果多个相同消费者组的消费者消费同一个Topic消息的时候只会有一个消费者被执行。相反如果消费者都位于不同的消费者组则所有的消费者都会被执行。相同的实例中你可以通过下面的方式来指定他们位于不同的消费者组。[CapSubscribe(xxx.services.show.time, Group group1 )]
public void ShowTime1(DateTime datetime)
{
}[CapSubscribe(xxx.services.show.time, Group group2)]
public void ShowTime2(DateTime datetime)
{
}
ShowTime1 和 ShowTime2 处于不同的组他们将会被同时调用。PS你可以通过下面的方式来指定默认的消费者组名称services.AddCap(x
{x.DefaultGroup default-group-name;
});
DashboardCAP 2.1 以上版本中提供了仪表盘Dashboard功能你可以很方便的查看发出和接收到的消息。除此之外你还可以在仪表盘中实时查看发送或者接收到的消息。使用一下命令安装 DashboardPM Install-Package DotNetCore.CAP.Dashboard
在分布式环境中仪表盘内置集成了 Consul 作为节点的注册发现同时实现了网关代理功能你同样可以方便的查看本节点或者其他节点的数据它就像你访问本地资源一样。services.AddCap(x
{//...// 注册 Dashboardx.UseDashboard();// 注册节点到 Consulx.UseDiscovery(d {d.DiscoveryServerHostName localhost;d.DiscoveryServerPort 8500;d.CurrentNodeHostName localhost;d.CurrentNodePort 5800;d.NodeId 1;d.NodeName CAP No.1 Node;});
});仪表盘默认的访问地址是http://localhost:xxx/cap你可以在d.MatchPath配置项中修改cap路径后缀为其他的名字。
