一、安装：程序包管理器控制台
PM> Install-Package DotNetCore.CAP
我选择了RabbiitMQ
PM> Install-Package DotNetCore.CAP.Kafka
PM> Install-Package DotNetCore.CAP.RabbitMQ
PM> Install-Package DotNetCore.CAP.AzureServiceBus
数据库为SqlServer
PM> Install-Package DotNetCore.CAP.SqlServer
PM> Install-Package DotNetCore.CAP.MySql
PM> Install-Package DotNetCore.CAP.PostgreSql
PM> Install-Package DotNetCore.CAP.MongoDB //需要 MongoDB 4.0+ 集群
安装：Nuget包安装
image.png
项目是Net 2.1的装高版本的CAP 会提示不兼容
二、配置
在 Startup.cs 文件中ConfigureServices：
//CAP
services.AddCap(x=> {
//如果你使用的 EF 进行数据操作，你需要添加如下配置：
//x.UseEntityFramework<EFDbContext>(); //可选项，你不需要再次配置 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");
});
三、使用
1.发布事件/消息
只有业务代码和CAP的publish代码在同一个事务中，才能保证业务代码和消息代码同时成功或失败
public async Task<bool> Add()
{
using (var trans = _eFContext.Database.BeginTransaction())
{
User info = new User();
info.Id = Guid.NewGuid().ToString("N");
info.UserName = "xiaohua";
_eFContext.User.Add(info);
await _eFContext.SaveChangesAsync();
//发布事件/消息
await _capPublisher.PublishAsync("添加订单消息", info.Id);
trans.Commit();
// 只有业务代码和CAP的publish代码在同一个事务中，才能保证业务代码和消息代码同时成功或失败
}
return true;
}
2.订阅事件/消息
继承 ICapSubscribe 并在方法上添加 [CapSubscribe("")]
public class UserSubScribeService:ICapSubscribe
{
//订阅事件/消息
//发送右键给管理员，新增的用户需要审核
[CapSubscribe("添加新用户")]
public async Task SendEmail() {
//业务逻辑
}
}
启动项目时遇到问题：
image.png
An exception was thrown while activating λ:Microsoft.Extensions.Hosting.IHostedService[] -> DotNetCore.CAP.Internal.Bootstrapper.
以为是依赖注入的问题，原来是在ConfigureServices方法中services.AddCap少添加一行代码
x.UseEntityFramework<EFContext>();
需要引入包
1646019680(1).jpg
项目启动后，数据库中创建了本地消息表，这两个表的含义如下：
Cap.Published：这个表主要是用来存储 CAP 发送到MQ(Message Queue)的客户端消息，也就是说你使用 ICapPublisher 接口 Publish 的消息内容。
Cap.Received：这个表主要是用来存储 CAP 接收到 MQ(Message Queue) 的客户端订阅的消息，也就是使用 CapSubscribe[] 订阅的那些消息。
image.png
