logo
publist
写文章

简介

该用户还未填写简介

擅长的技术栈

可提供的服务

暂无可提供的服务

高可用 RocketMQ 消费端设计(防数据丢失 + 批量处理 + 无数据库锁)

DLQ%+消费组名,例如;触发条件:消息重试次数达到(20 次)后自动进入死信队列;特性:死信队列的消息不会被自动消费,需人工介入。核心逻辑:通过注解式消费端实现批量消费,利用实现原子化新增 / 更新,避免数据库锁竞争;高可用:集群消费 + 线程池隔离 + 指数退避重试,保证消费端不宕机、不堆积;零数据丢失:消费签收机制 + 事务 + 失败日志 + 死信队列,覆盖全链路数据兜底;幂等性:Redis

#rocketmq#数据库
到底了