---

---

項目地址

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

• 代碼倉庫地址：

• 所用到的框架和插件：

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. 實現消費者接口