1. rocketmq源码安装参考官方文档：http://rocketmq.apache.org/docs/quick-start/安装好jdk和maven rocketmq安装包：https://pan.baidu.com/s/1I3CqWaxFnxtUX1kJpIJkcQ 密码: vu5m ...

发送丢失 　　我们发送消息时，broker写入到cache后就返回成功了，而producer只要获取到ACK就说明消息发送成功了，反之肯定会收到一个异常，比如网络错误、请求超时之内的。而当我们发送失败后一直重试发送，能保证消息一定到达MQ吗？比如这样： 　　 　　本地事务执行完之后、数据库 ...

前言 上篇文章，王子通过一个小案例和小伙伴们一起分析了一下消息是如何丢失的，但没有提出具体的解决方案。 我们已经知道发生消息丢失的原因大体上分为三个部分： 1.生产者发送消息到MQ这一过程导致消息丢失 2.MQ自己发生故障导致消息丢失 3.消费者拿到消息后，由于操作不当导致消息丢失 ...

作者：Jaskey Lam 来源：https://jaskey.github.io/blog/2020/06/08/rocketmq-message-dedup/ 消息中间件是分布式系统常用的组件，无论是异步化、解耦、削峰等都有广泛的应用价值。我们通常会认为，消息中间件是一个可靠的组件 ...

消息中间件是分布式系统常用的组件，无论是异步化、解耦、削峰等都有广泛的应用价值。我们通常会认为，消息中间件是一个可靠的组件——这里所谓的可靠是指，只要我把消息成功投递到了消息中间件，消息就不会丢失，即消息肯定会至少保证消息能被消费者成功消费一次，这是消息中间件最基本的特性之一，也就是我们常说 ...

一、为什么出现消息重复 从 Product 看 Rocketmq 提供三种发送消息模式 同步发送：Producer 向 broker 发送消息，阻塞当前线程等待 broker 响应 发送结果。DefaultMQProducerImpl 中如果没有设置 超时、发送失败，就会重发。 异步发送 ...

幂等性要求的场景： 1、表单提交，重复点击问题，产生两条相同数据。 2、接口超时重试，出现重复操作数据问题。 3、mq消费者读取消息，读取重复消息问题。 接口幂等性是指用户对于同一操作发起的一次请求或者多次请求的结果是一致。 如何解决请求重复，就需要接口的幂等 幂等解决方案： 1、insert ...

消费者接收重复消息幂等性解决方案： 1.利用数据库唯一性约束去实现幂等性创建消息去重表，把全局唯一ID作为主键，做唯一性约束，如果插入成功就表示没有消费过这条消息，可以进行消费了，插入失败表示消息已经被消费了。 2.利用Redis的原子性去实现幂等性我们都知道redis是单线程 ...