# 模块二基础巩固 RabbitMQ 业务场景详解 ## 2.6.5 RabbitMQ -- 业务场景详解 * 异步处理 * 应用解耦 * 流量削锋 * 日志处理 ### 异步处理 * 串行方式 * 并行方式 * 异步方式 #### 串行方式 ``` _userRepo.Add(user); _emailService.Send(user); _smsService.Send(user); ``` #### 并行方式 ``` _userRepo.Add(user); var emailTask = _emailService.Send(user); var smsTask = _smsService.Send(user); await Task.WhenAll(emailTask, smsTask) ``` #### 异步方式 ``` var user = await _userRepo.Add(user); _eventBus.publish(new UserRegisteredEvent(){ userId = user.Id }) return user; ``` ### 应用解耦订单系统调用库存系统改为订单系统写入消息队列库存系统订阅消息队列实现解耦 ### 流量削锋用户的请求，服务器接收后，首先写入消息队列。假如消息队列的长度超过最大数量，则直接抛弃用户请求或跳转到错误页面秒杀业务根据消息队列中的请求信息，再做后续处理 ### 日志处理 kafka：接收用户日志的消息队列 Logstash：日志解析，统一成 JSON 输出给 Elasticsearch Elasticsearch：实时日志分析服务的核心技术，一个 schemaless，实时的数据存储服务，通过 index 组织数据，兼具强大的搜索和统计功能 Kibana：基于 Elasticsearch 的数据可视化组件，超强的数据可视化能力是众多公司选择 ELK stack 的重要原因