目录 六、消息的重复消费问题 1.什么幂等性 1）在请求方式中的幂等性的体现 2）在消息队列中的幂等性体现 2.业务代码中实现幂等性 1）生产者端修改配置文件 ...

分布式消息系统作为实现分布式系统可扩展、可伸缩性的关键组件，需要具有高吞吐量、高可用等特点。而谈到消息系统的设计，就回避不了两个问题： 消息的顺序问题 消息的重复问题 RocketMQ作为阿里开源的一款高性能、高吞吐量的消息中间件，它是 ...

为什么要使用MQ？ 1.解耦，系统A在代码中直接调用系统B和系统C的代码，如果将来D系统接入，系统A还需要修改代码，过于麻烦！ 2.异步，将消息写入消息队列，非必要的业务逻辑以异步的方式运行，加快响应速度 3.削峰，并发量大的时候，所有的请求直接怼到数据库，造成数据库连接异常 使用了消息 ...

如果要你实现一个支付宝向余额宝转账的功能，比如：账户a从支付宝转出5000余额宝转入5000，该怎么做呢？ 可能有些人会说，这还不简单，直接上图 支付宝先给账户a减50 ...

https://www.jianshu.com/p/8a5630e2c317 https://www.jianshu.com/p/4491cba335d1 ...

1.幂等性 幂等（idempotent、idempotence）是一个数学与计算机学概念，常见于抽象代数中。 在编程中一个幂等操作的特点是其任意多次执行所产生的影响均与一次执行的影响相同。幂等函数，或幂等方法，是指可以使用相同参数重复执行，并能获得相同结果的函数。这些函数不会影响系统状态 ...

重复消费的问题的一个可能的问题：消费者消费消息时产生了异常，并没有返回CONSUME_SUCCESS标志。 重复消费的消息和第一次消费的消息不同，多了一些重复消费的信息：reconsumeTimes=1，2，…10REAL_TOPIC也会是：%RETRY%XXXXX这就是因为消息处理异常导致 ...

也没看到能解决重复消费的问题的文章，于是在flink官网中搜索此类场景的处理方式，发现官网也没有实现f ...