---

---

项目地址

• 教程作者：
• 教程地址：

• 代码仓库地址：

• 所用到的框架和插件：

dbt 
airflow

一、Rabbit MQ

1.1 Pulibsher

• Products模块，发送ProductNameUpadateMessage
  

1. IRabbitMQPublisher接口

• 用于发布消息的接口

namespace eCommerce.ProductsService.BusinessLogicLayer.RabbitMQ;
public interface IRabbitMQPublisher
{void Publish<T>(string routingKey, T message);
}

2. RabbitMQPublisher接口实现

• 实现上面的发布接口
  

3. 使用

1.2 Consumer

1. 消费接口

2. 实现消费者接口