BorgNet.CAP 1.0.0

使用 appsetting.json "CapOptions": { /// 是否开启，默认开启 "Enabled": false, "Mysql": { "TableNamePrefix": "cap_xxx_api", //表名前缀 "ConnectionString": "Server=127.0.0.1;port=3306;database=cap;user id=root;password=123456;minimumpoolsize=10;maximumpoolsize=50;AllowLoadLocalInfile=True;allowuservariables=True;" }, "RabbitMQ": { "HostName": "127.0.0.1", "Port": "5672", "UserName": "admin", "Password": "das@123!", "VirtualHost": "pro" }, "Dashboard": { "PathMatch": "/cap", //cap面板路由 "UseAuth": false //面板是否开启权限 }, "Options": { "FailedRetryCount": 3, //失败重试次数 "FailedRetryInterval": 120, //重试时间间隔120s "SucceedMessageExpiredAfter": 3600 //成功消息过期时间 3600s } } 启用服务 没有基于BorgNet.Core 的使用场景，必须手动进行初始化，如下： 如下：

IConfiguration Configuration;

public void ConfigureServices(IServiceCollection services) { services.AddCapOptions(configuration); } 基于BorgNet.Core的使用，只需要添加引用后配置以上appsetting.josn配置CapOptions节点即可 使用说明 entity 实体示例 public class Person { public int Id { get; set; }

    public string Name { get; set; }

    public override string ToString()
    {
        return $"Name:{Name}, Id:{Id}";
    }
}
 public class CapController : ControllerBase, ICapSubscribe, ITransientDependency
{
  
    private ICapPublisher _capPublisher;
    private IServiceProvider serviceProvider;
    public CapController( IServiceProvider serviceProvider)
    {
       
        this.serviceProvider = serviceProvider;
    }

    [NonAction]
    [CapSubscribe("person.added")]
    public async Task SubscribeAsync(Person input)
    {
        Console.WriteLine(input.ToString());

    }
    [HttpPost("Publish")]
    public async Task PublishAsync(Person input)
    {
        
          await serviceProvider.GetRequiredService<ICapPublisher>().PublishAsync("person.added", input);
    }
}

更新中...