## 1、 何为幂等性

- 拿接口来说， 幂等性就是用户对于同一操作发起的一次请求或者多次请求的结果是一致的，不会因为多次点击而产生了副作用。举个最简单的例子，那就是支付，用户购买商品后支付，支付扣款成功，但是返回结果的时候网络异常，此时钱已经扣了，用户再次点击按钮，此时会进行第二次扣款，返回结果成功，用户查询余额返发现多扣钱了，流水记录也变成了两条,这就没有保证接口的幂等性 。换句话来说，要做到幂等性，必须做到无论用户在这个流程执行了多少次，处理结果都是一致的
- 从下单到支付再到付款为一整个流程，第一次成功扣款成功了，第二次点击支付时应该直接返回支付成功，而不是再执行扣款，流程如下。

![](https://kuangstudy.oss-cn-beijing.aliyuncs.com/bbs/2020/12/03/kuangstudy657bfe34-f214-4e60-bcb4-51660e1ab9c4.png)

- redis的set同样拥有幂等性

## 2、kafka是如何实现幂等性的（如何解决kafka消息重复问题）

为了实现生产者的幂等性，kafka引入了Producer ID (PID) 和 Sequence Number的概念

- PID: 每个Producer在初始化时，都会分配一个唯一的PID，这个PID对用户来说，是透明的

- Sequence Number: 针对每个生产者(对应的PID) 发送到指定主题分区的消息都对应一个从0开始递增的Sequence Number

- 生产者消息重复问题
    - kafka生产消息到partition，如果直接发送消息，kafka会将消息保存到分区中，但kafka会返回一个ACK给生产者，表示当前操作是否已经成功，如果ACK响应的过程失败了，此时生产者会重试，继续发送没有发送成功的消息，kafka又会去保存一条一模一样的消息
  - 如何解决消息重复问题
    - 可以在kafka中开启幂等性
    - 当kafka开启了幂等性后，生产者在生产消息时，会增加一个PID（生产者的唯一编号）和Sequence Number（针对消息的一个递增序列）
    - 发送消息，会连着pid和Sequence Number一块发送
    - kafka接收到消息，会将消息和PID、Sequence Number一并保存下来
    - 如果ACK响应失败，生产者重试，再次发送消息时，kafka会根据PID、Sequence Number判断是否需要再保存一条消息
    - 判断条件： 生产者发送过来的Sequence Number是否小于等于partition中消息对应的Sequence Number

![](https://kuangstudy.oss-cn-beijing.aliyuncs.com/bbs/2020/12/03/kuangstudy0263b4d6-1123-4688-b5d8-a096ef7fb7d9.png)

![](https://kuangstudy.oss-cn-beijing.aliyuncs.com/bbs/2020/12/03/kuangstudy323aace5-1f4a-4c17-8b65-84fc7690b3af.png)

###### kafka如何开启幂等性

props.put("enable.idempotence",true);

进阶之路-消息队列-kafka消息重复问题

总共已有 0 条评论