背景

我们在生产系统中和其他系统进行交互时一般都会通过消息队列来解耦生产者和消费者，然后通过每个使用方消费消息队列的消息的方式来完成消息的消费，并且一般来说我们消费消息后极有可能会操作DB，不过这种方式如果处理不够仔细，很容易发生DB并发更新导致的数据覆盖

问题复现

解决方案：

1.对于DB的同一条记录的操作需要有先后顺序，这就要求对于同一个mid的消息消费要串行，而不能并行，所以这就要求生产者发送消息到消息队列时需要按照mid进行partition分区，这样同一个mid只会在一个分区中，而kafka的消息消费是分区有序的，这个问题就可以解决掉了

2.对于DB的并发更新使用加乐观锁（版本号）或者悲观锁的方式来达到串行更新DB记录的效果