zoukankan      html  css  js  c++  java
  • RabbitMQ、RocketMQ、Kafka等任何队列不保证消息不重复,如果业务需要消息不重复消 费,则需要消费端处理理业务消息要保持幂等性

    方式⼀:Redis的setNX() , 做消息id去重 java版本⽬目前不不⽀支持设置过期时间
    //Redis中操作,判断是否已经操作过 TODO
    boolean flag = jedis.setNX(key);
    if(flag){
    //消费
    }else{
    //忽略略,重复消费
    }
    方式⼆:redis的 Incr 原⼦子操作:key⾃自增,⼤大于0 返回值⼤大于0则说明消费过,(key可以
    是消息的md5取值, 或者如果消息id设计合理理直接⽤用id做key)
    int num = jedis.incr(key);
    if(num == 1){
    //消费
    }else{
    //忽略略,重复消费
    }
    方式三:数据库去重表
    设计⼀一个去重表,某个字段使⽤用Message的key做唯⼀一索引,因为存在唯⼀一索引,
    所以重复消费会失败
    CREATE TABLE message_record ( id int(11) unsigned NOT NULL
    AUTO_INCREMENT, key varchar(128) DEFAULT NULL, create_time datetime
    DEFAULT NULL, PRIMARY KEY ( id ), UNIQUE KEY key ( key ) )
    ENGINE=InnoDB DEFAULT CHARSET=utf8mb4;

  • 相关阅读:
    点分治 / 点分树题目集
    HNOI2019 游记
    WC2019 题目集
    SA / SAM 题目集
    Min_25 筛小结
    NOIP2018 差点退役记
    Atcoder 乱做
    DP及其优化
    计数与概率期望小结
    分库分表之后全局id咋生成?
  • 原文地址:https://www.cnblogs.com/yuebuxichen/p/14168744.html
Copyright © 2011-2022 走看看