中小学图书馆网站建设要制作网页

中小学图书馆网站建设,要制作网页,南昌做兼职的网站,手机网站设计占工程比重1. 消息队列的好处 异步处理#xff1a;解除流程阻塞#xff0c;提升系统响应速度系统解耦#xff1a;降低服务间直接依赖#xff0c;提高扩展性流量削峰#xff1a;缓冲瞬时高并发请求#xff0c;保护下游系统 2. 消息重复消费与幂等性保障 消费端无法直接处理重复消费…1. 消息队列的好处异步处理解除流程阻塞提升系统响应速度系统解耦降低服务间直接依赖提高扩展性流量削峰缓冲瞬时高并发请求保护下游系统2. 消息重复消费与幂等性保障消费端无法直接处理重复消费问题需业务端通过以下方式控制本地数据库表或Redis缓存业务标识每次处理前先校验标识确保幂等性参考实现幂等性处理方案2.1 注解式幂等实现实现原理拦截请求通过Spring AOP拦截带有Idempotent注解的方法生成幂等key根据配置的幂等类型和场景动态生成全局唯一key验证幂等性基于Token验证并删除token基于参数使用Redisson分布式锁基于SpEL检查分布式缓存中是否存在该key执行业务逻辑验证通过后执行原方法清理资源释放锁或更新缓存状态具体实现方式基于Token的幂等实现客户端调用/token接口获取token请求时在header或参数中携带token服务端验证token存在后删除确保同一token仅能使用一次基于方法参数的幂等实现计算请求路径、用户ID和方法参数的MD5值生成唯一key使用Redisson分布式锁同一key仅能被一个线程处理处理完成后释放锁确保同一请求仅处理一次基于SpEL表达式的幂等实现适用场景Canal订单数据变更MQ、支付结果回调MQ、订单创建业务实现方式使用SpEL表达式从请求中提取唯一标识将标识存储在分布式缓存并设置过期时间重复请求时检测到缓存中已存在该标识直接返回幂等错误3. 消息丢失问题与可靠性保障从生产、存储、消费三个阶段保障消息可靠性3.1 生产阶段Producer采用同步发送默认或重试机制失败时重试指定次数开启Broker确认ACKBroker收到消息并持久化后向Producer返回成功响应3.2 存储阶段消息持久化到磁盘CommitLog文件采用内存映射MMAP刷盘机制同步/异步主从同步Master将消息同步到Slave支持同步复制Master等待Slave确认后返回ACK或异步复制定期清理过期消息避免磁盘溢出3.3 消费阶段Consumer采用拉取式消费消费完成后向Broker发送确认ACKBroker才标记消息为已消费失败重试消费失败时可将消息重发回Broker重试队列默认重试16次超过次数进入死信队列DLQ3.4 原理解析持久化机制CommitLog是Broker存储消息的核心文件所有Topic的消息混合存储通过ConsumeQueue索引文件快速定位消息位置MMAP减少磁盘I/O开销同步刷盘保证消息不丢失适合金融场景异步刷盘提升性能适合非核心场景主从同步Master写入消息后通过异步线程将数据同步到Slave同步复制模式下Master需等待Slave写入成功后才返回ACK彻底避免单点故障导致的消息丢失4. 消息顺序性保障核心方案队列分区 串行消费4.1 分区顺序生产环境主流方案同一业务标识如订单ID的消息发送到同一个Message Queue消费时单线程处理该Queue保证局部顺序4.2 全局顺序特殊场景适用整个Topic仅配置1个Message Queue所有消息串行生产和消费特点性能极低仅适用于超低频场景如全局配置下发5. RocketMQ消息堆积问题排查与解决5.1 排查步骤查看Broker监控检查CommitLog磁盘使用率、消息堆积数量Queue中未消费Offset与最大Offset的差值检查Consumer状态是否有Consumer宕机、消费线程阻塞、消费逻辑耗时过长检查Producer发送速率是否突发大量消息导致生产速率远大于消费速率检查网络Broker与Consumer之间的网络是否延迟过高5.2 解决方法临时扩容增加Consumer节点集群消费模式Rebalance后分摊Queue消费压力优化消费逻辑减少消费耗时如异步处理、优化数据库操作增加消费线程数调整consumeThreadMax参数分流消息将热点Topic拆分为多个子Topic分散消费压力清理死信消息处理死信队列中无法消费的消息避免占用资源调整重试机制减少非核心业务的重试次数避免重试消息堆积5.3 原理解析消息堆积的本质是生产速率消费速率或消费中断。RocketMQ的监控指标如msgAccumulation可直接反映堆积情况通过扩容Consumer增加并行消费能力或优化消费逻辑提升单节点消费效率从根本上平衡生产与消费速率。