当前位置: 首页 > wzjs >正文

丹徒网站建设机构邢台做移动网站报价

丹徒网站建设机构,邢台做移动网站报价,英文网站 模板,家里的电脑ip做网站在分布式系统中,RabbitMQ 自身不直接提供消息幂等性保障机制,但可通过业务逻辑设计和技术组合实现消息处理的幂等性。以下是 8 种核心实现方案及最佳实践: 一、消息唯一标识符 (Message Deduplication) 原理 每条消息携带全局唯一ID&#xff…

在分布式系统中,RabbitMQ 自身不直接提供消息幂等性保障机制,但可通过业务逻辑设计和技术组合实现消息处理的幂等性。以下是 8 种核心实现方案及最佳实践:


一、消息唯一标识符 (Message Deduplication)

  1. 原理

    • 每条消息携带全局唯一ID(如 UUID、Snowflake ID)
    • 消费者维护已处理消息ID的存储(Redis/DB)
  2. 实现步骤

    // 生产者端
    MessageProperties props = new MessageProperties();
    props.setMessageId(UUID.randomUUID().toString());
    Message message = new Message(body.getBytes(), props);// 消费者端
    @RabbitListener(queues = "order_queue")
    public void process(Message message) {String msgId = message.getMessageProperties().getMessageId();if (redis.setnx(msgId, "processed") == 1) {// 处理业务逻辑// 成功后设置过期时间防止存储膨胀redis.expire(msgId, 72 * 3600); } else {// 幂等拦截}
    }
    

二、版本号控制 (Optimistic Concurrency Control)

  1. 适用场景
    数据更新类操作(如账户余额修改)

  2. 实现方案

    -- 消息体包含数据版本号
    UPDATE account 
    SET balance = new_balance, version = version + 1 
    WHERE id = 123 AND version = current_version;
    

三、状态机驱动 (State Machine)

  1. 应用场景
    订单状态流转(创建→支付→发货)

  2. 实现示例

    public void handleOrderMessage(OrderMessage msg) {Order order = orderDao.get(msg.getOrderId());if (order.getStatus() != msg.getExpectedStatus()) {log.warn("状态不匹配,当前状态:{}", order.getStatus());return;}// 执行状态变更逻辑
    }
    

四、业务唯一键约束

  1. 实现方式
    CREATE TABLE payment_records (id BIGINT PRIMARY KEY,order_no VARCHAR(64) UNIQUE, -- 业务唯一键amount DECIMAL(10,2)
    );-- 插入时捕获唯一键冲突
    try {insertPaymentRecord();
    } catch (DuplicateKeyException e) {// 幂等处理
    }
    

五、消息确认策略优化

  1. 关键配置

    spring:rabbitmq:listener:simple:acknowledge-mode: manual  # 手动ACKretry:enabled: truemax-attempts: 3         # 最大重试次数
    
  2. 处理逻辑

    @RabbitListener(queues = "critical_queue")
    public void process(Message message, Channel channel) throws IOException {try {// 业务处理channel.basicAck(tag, false);} catch (Exception e) {channel.basicNack(tag, false, false); // 直接进入死信队列}
    }
    

六、分布式锁机制

  1. Redis 分布式锁示例
    public void processWithLock(Message msg) {String lockKey = "msg_lock:" + msg.getId();try {if (redisLock.tryLock(lockKey, 30)) {// 真正的业务处理}} finally {redisLock.unlock(lockKey);}
    }
    

七、时序控制 (Timestamp Validation)

  1. 实现逻辑
    if (message.getEventTime() < lastProcessedTime.get()) {log.info("丢弃过期消息,事件时间:{}", message.getEventTime());return;
    }
    

八、消息轨迹追踪表

  1. 设计表结构

    CREATE TABLE message_log (message_id VARCHAR(64) PRIMARY KEY,status ENUM('PROCESSING','SUCCESS','FAILED'),processed_time DATETIME,retry_count INT DEFAULT 0
    );
    
  2. 处理流程

    // 开启事务
    beginTransaction();
    try {// 1. 插入消息记录insertMessageLog(msgId, "PROCESSING");// 2. 执行业务操作processBusinessLogic();// 3. 更新状态updateMessageStatus(msgId, "SUCCESS");commit();
    } catch (Exception e) {rollback();
    }
    

最佳实践组合建议

  1. 金融交易场景
    唯一ID + 版本号控制 + 数据库唯一约束 + 分布式锁

  2. 电商订单场景
    状态机 + 业务唯一键 + 消息轨迹表

  3. 日志处理场景
    时序验证 + Redis去重 + 自动重试策略


注意事项

  1. 存储选择权衡

    • Redis: 高性能但存在数据丢失风险
    • 数据库: 可靠性高但性能较低
    • 建议:关键业务使用DB+缓存双写
  2. 清理策略

    • 设置合理的TTL(例如72小时)
    • 定时任务清理已处理记录
  3. 性能优化

    • 使用Bloom Filter减少内存消耗
    • 批量查询优化(如一次查询1000个ID是否存在)

通过以上方案组合,可在不同业务场景中实现可靠的幂等处理,建议根据实际业务压力和数据一致性要求选择合适的实现层级。

http://www.dtcms.com/wzjs/823077.html

相关文章:

  • 网站建设一条龙源码子商务网站建设的一般流程图
  • 企业官网属于什么网站西安网站建设兼职
  • 驻马店网站建设费用wordpress首页不显示工具栏
  • 一般网站模块图片素材网站建设
  • 网站的原理外贸企业网站系统
  • 长沙岳麓区网站建设做电影网站需要什么手续
  • 广州做网站建设的公司哪家好wordpress二级开发
  • 重庆双八自助建设网站网站建设服务好
  • 在哪个网站可以做试卷南宁seo网站建设费用
  • 国内设计网站公司网站汽车html静态网站
  • 百度收录好的网站公司网站建设推进表
  • 稻壳网站建设郴州网红
  • 学网站建设培训班桂林哪里做网站
  • xp花生壳做网站建e网室内设计图
  • 东莞网站建设制作软件网站开发 定制 合同范本
  • 太原网站推广wordpress更新是乱码
  • 秦皇岛建设厅网站衡阳县建设局网站
  • 庞各庄网站建设公司西安制作网站
  • 网站建设 域名 服务器旅游网网站建设目的
  • 电动工具咋在网上做网站wordpress企业类模板
  • 网站开发需要注册账户吗做网站的快捷方式代码
  • 梅州建站塔山双喜哪个网站名片做的号
  • 简单大气的企业网站做网站的会什么
  • 技术支持 东莞网站建设母婴护理一级a做爰片51网站
  • 做家教网站赚钱么做网站系统
  • 如何套模板做网站网站开发 英文文章
  • 做国学类网站合法吗wordpress论坛建设
  • 手机商城网站建设企业电子商务网站建设总结
  • 在线做效果图的网站有哪些和平天津网站建设
  • 有源码个人网站怎么建立新闻媒体发布平台