我们知道mq发送消息消费失败后,默认会重试16次,那么因为这种重试机制导致消息很有可能被重复消费;
对于重复消费的情况,rocketMq是允许的,主要由业务放自己去避免,我们的业务系统需要自己做幂等性的操作
若消费过则不再重复消费;可采用的方式有很多,主要由业务系统自己去实现,主要方式可以做消息去重打标,和业务层面的幂等;
我们知道mq发送消息消费失败后,默认会重试16次,那么因为这种重试机制导致消息很有可能被重复消费;
对于重复消费的情况,rocketMq是允许的,主要由业务放自己去避免,我们的业务系统需要自己做幂等性的操作
若消费过则不再重复消费;可采用的方式有很多,主要由业务系统自己去实现,主要方式可以做消息去重打标,和业务层面的幂等;