网络延迟传输中,会造成金出MQ重试中,在重试过程中,可能会造成重复消费
如果消息做数据库的插入操作,给整个消息做一个唯一的主键,那么就算出现重复的情况,就会导致主键冲突,避免数据库出现脏读数据
如果上面两种情况还不行,准备第一个第三个来做消费记录,以redis为例,给消息分配一个全局id,主要消费过改消息 ,将<id,message>以k-Y的形式写入redis.那消费者开始消费前,先去redis中查询有没有消费记录即可
网络延迟传输中,会造成金出MQ重试中,在重试过程中,可能会造成重复消费
如果消息做数据库的插入操作,给整个消息做一个唯一的主键,那么就算出现重复的情况,就会导致主键冲突,避免数据库出现脏读数据
如果上面两种情况还不行,准备第一个第三个来做消费记录,以redis为例,给消息分配一个全局id,主要消费过改消息 ,将<id,message>以k-Y的形式写入redis.那消费者开始消费前,先去redis中查询有没有消费记录即可
One comment
老哥 你这网站维护费用高吗