RabbitMQ、RocketMQ、Kafka等任何队列列不不保证消息不不重复，如果业务需要消息不不重复消 费，则需要消费端处理理业务消息要保持幂等性

标签：bit   redis   rabbitmq   record   过期   create   业务   flag   not   

方式?：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;

RabbitMQ、RocketMQ、Kafka等任何队列列不不保证消息不不重复，如果业务需要消息不不重复消 费，则需要消费端处理理业务消息要保持幂等性

标签：bit   redis   rabbitmq   record   过期   create   业务   flag   not   

原文地址：https://www.cnblogs.com/yuebuxichen/p/14168744.html