消息队列消费端
消息队列消费端,用于接收消息队列中的消息,并进行处理。
消息队列消费端支持多种消息队列,如RabbitMQ、Kafka、RocketMQ等。
针对高并发或者耗时场景,建议使用消息队列进行异步处理, 不会影响主流程的执行。
配置
Api项目需要开启RabbitMQ服务、EventBus事件总线,并配置好RabbitMQ连接信息,添加事件模型, 请参照:
SysLogEventModel.cs
文件。修改
appsetting.json
文件,保持数据库链接与Api项目一致MQConfig.cs
文件中添加事件订阅, e.g:eventBus.Subscribe<SysLogEventModel, SysLogEventHandler>();
编写消费逻辑, 参考
SysLogEventHandler.cs
类