Skip to content

消息队列消费端

消息队列消费端,用于接收消息队列中的消息,并进行处理。

消息队列消费端支持多种消息队列,如RabbitMQ、Kafka、RocketMQ等。

针对高并发或者耗时场景,建议使用消息队列进行异步处理, 不会影响主流程的执行。

配置

  • Api项目需要开启RabbitMQ服务、EventBus事件总线,并配置好RabbitMQ连接信息,添加事件模型, 请参照: SysLogEventModel.cs 文件。

  • 修改appsetting.json文件,保持数据库链接与Api项目一致

  • MQConfig.cs 文件中添加事件订阅, e.g: eventBus.Subscribe<SysLogEventModel, SysLogEventHandler>();

  • 编写消费逻辑, 参考SysLogEventHandler.cs