¶">介绍¶

介绍¶

CAP 是一个EventBus，同时也是一个在微服务或者SOA系统中解决分布式事务问题的一个框架。它有助于创建可扩展，可靠并且易于更改的微服务系统。
在微软的 eShopOnContainer 微服务示例项目中，推荐使用 CAP 作为生产环境可用的 EventBus。
CAP 是一个基于 .NET Standard 的 C# 库，它是一种处理分布式事务的解决方案，同样具有 EventBus 功能，它具有轻量级、易使用、高性能等特点。

CAP docs看到更多详细资料。
CAP 视频教程，学习如何在项目中集成CAP。
GitHub源码：https://github.com/dotnetcore/cap
示例代码：https://github.com/dotnetcore/CAP/tree/master/samples
什么是 EventBus？
事件总线是一种机制，它允许不同的组件彼此通信而不彼此了解。组件可以将事件发送到Eventbus，而无需知道是谁来接听或有多少其他人来接听。组件也可以侦听Eventbus上的事件，而无需知道谁发送了事件。这样，组件可以相互通信而无需相互依赖。同样，很容易替换一个组件。只要新组件了解正在发送和接收的事件，其他组件就永远不会知道.
架构预览

CAP 实现了 eShop 电子书中描述的发件箱模式
CAP 的特色
相对于其他的 Service Bus 或者 Event Bus， CAP 拥有自己的特色，它不要求使用者发送消息或者处理消息的时候实现或者继承任何接口，拥有非常高的灵活性。我们一直坚信约定大于配置，所以CAP使用起来非常简单，对于新手非常友好，并且拥有轻量级。
CAP 采用模块化设计，具有高度的可扩展性。你有许多选项可以选择，包括消息队列，存储，序列化方式等，系统的许多元素内容可以替换为自定义实现。
快速入门示例
了解如何使用 CAP 构建微服务事件总线架构，它比直接集成消息队列提供了哪些优势，它提供了哪些开箱即用的功能。创建一个.net6 web api的CAP.InMemory.Demo。
NuGet
你可以运行以下下命令在你的项目中安装 CAP。
```
Install-Package DotNetCore.CAP
Install-Package DotNetCore.CAP.InMemoryStorage
Install-Package Savorboard.CAP.InMemoryMessageQueue
Install-Package DotNetCore.CAP.Dashboard
Install-Package DotNetCore.CAP.Pulsar
```
注入CAP
```csharp using Savorboard.CAP.InMemoryMessageQueue;

var builder = WebApplication.CreateBuilder(args);

builder.Services.AddCap(x => { x.UseInMemoryStorage(); x.UseInMemoryMessageQueue(); });

<a name="JCxZD"></a>
### 公共部分
```csharp
using Microsoft.AspNetCore.Mvc;
namespace CAP.InMemory.Demo2.Controllers;
/// <summary>
/// 基础控制器
/// </summary>
[Route("api/[area]/[controller]/[action]")]
[ApiController]
public abstract class BaseController : ControllerBase
{
}

using Microsoft.AspNetCore.Mvc;
namespace CAP.InMemory.Demo2.Controllers.CAP;
/// <summary>
/// 域控制器
/// </summary>
[Area("CAP")]
public abstract class AreaController : BaseController
{
}

发布消息

新建立一个PublishController

using DotNetCore.CAP;
using Microsoft.AspNetCore.Mvc;
namespace CAP.InMemory.Demo2.Controllers.CAP;
/// <summary>
/// 发送消息
/// </summary>
public class PublishController : AreaController
{
    ICapPublisher _capBus;
    public PublishController(ICapPublisher capBus)
    {
        _capBus = capBus;
    }
    [HttpGet]
    //[Route("/send")]
    public IActionResult SendMessage()
    {
        Console.WriteLine("SendMessage message time is:" + DateTime.Now);
        _capBus.Publish("test.show.time", DateTime.Now);
        return Ok();
    }
    [HttpGet]
    //[Route("/send.header")]
    public IActionResult SendMessageHeader()
    {
        var header = new Dictionary<string, string>()
        {
            ["my.header.first"] = "first",
            ["my.header.second"] = "second"
        };
        _capBus.Publish("test.show.time.header", DateTime.Now, header);
        return Ok();
    }
}

处理消息

新建立一个ConsumerController

using DotNetCore.CAP;
using Microsoft.AspNetCore.Mvc;
namespace CAP.InMemory.Demo2.Controllers.CAP;
/// <summary>
/// 处理消息
/// </summary>
[ApiController]
public class ConsumerController : ControllerBase
{
    /// <summary>
    /// 处理消息
    /// </summary>
    /// <param name="time"></param>
    [NonAction]
    [CapSubscribe("test.show.time")]
    public void ReceiveMessage(DateTime time)
    {
        Console.WriteLine("ReceiveMessage message time is:" + time);
    }
    /// <summary>
    /// 处理包含头信息的消息
    /// </summary>
    /// <param name="time"></param>
    [NonAction]
    [CapSubscribe("test.show.time.header")]
    public void ReceiveMessage(DateTime time, [FromCap] CapHeader header)
    {
        Console.WriteLine("ReceiveMessageHeader message time is:" + time);
        Console.WriteLine("message firset header :" + header["my.header.first"]);
        Console.WriteLine("message second header :" + header["my.header.second"]);
    }
}