NETCORE - CAP的使用

CAP 同时支持使用 RabbitMQ，Kafka，Azure Service Bus 等进行底层之间的消息发送。

CAP 目前支持使用 Sql Server，MySql，PostgreSql，MongoDB 数据库的项目。

 

安装部署RabbbitMQ：https://www.cnblogs.com/1285026182YUAN/p/12896851.html 

 

 

 文中以 CAP + MySql + RabbitMQ +EF 为例：

 

由于样例项目为 netcore 2.2 框架。

安装DotNetCore.CAP nuGet包，此处安装 2.6.0版本。

 

 

安装EF nuGet包。

 

 

  

配置 appsettings.json 数据 。

{
  "Logging": {
    "LogLevel": {
      "Default": "Warning"
    }
  },
  "ConnectionStrings": {
    "Mysql_Conn": "Server=localhost;port=3306;Database=db1;UserId=root;Password=123456",
  },
  "RabbitMQ": {
    "HostName": "192.168.122.199",
    "UserName": "admin",
    "Password": "123456",
    "VirtualHost": "vhost_lihy",
    "Port": 5672,
    "ExchangeName": "cap.text.lihy.exchange"

  }, 
  "AllowedHosts": "*"
}

View Code