以一个故事的角度展开RocketMQ

1什么是消息队列来，讲个故事：一位进京赶考的人儿，在一个渡口准备上船，父母送他到渡口，看着他上船，走远，直到消失在视野，但是没有得到孩儿安全到达的消息他们是不会走的，等了好久好久，船夫回来了，告诉他们他们的孩子安全到达了，他们满意的走了。某一天，来了100位进京赶考的人儿，都急着上船，乱做一团，结果船翻了，更乱了。但是，有一位高人，给码头建了一座房子，雇了一帮工作人员。房子还有好几层多少人都能装下

【RocketMQ源码学习错误已解决】之broker启动一直报错。错误code-3。

【RocketMQ源码学习】之broker启动一直报错。报错一直提示退出code为-3解决办法

【RocketMQ源码学习】RocketMQ源码学习之环境搭建

本文介绍rocket源码学习之环境搭建

【RocketMQ】发送事务消息

在淘宝购物车下单时，涉及到购物车系统和交易系统，这两个系统之间的数据最终一致性可以通过分布式事务消息的异步处理实现。在这种场景下，交易系统是最为核心的系统，需要最大限度地保证下单成功。而购物车系统只需要订阅交易订单消息，做相应的业务处理，即可保证最终的数据一致性。

【已解决】在使用RocketMQ消费消息的时候，提示不支持SQL92的错误：CODE: 1 DESC: The broker does not support consumer to filter message by SQL92

【已解决】在使用RocketMQ消费消息的时候，提示不支持SQL92的错误 CODE: 1 DESC: The broker does not support consumer to filter message by SQL92

【已解决】RocketMQ在发送消息的时候，提示：MQClientException: No route info of this topic

RocketMQ在发送消息的时候，提示：MQClientException: No route info of this topic xxx

rocketmq 连接异常 senddefaultimpl call timeout

rocketmq 连接异常 senddefaultimpl call timeout

消息队列（四）如何处理消息丢失的问题？

一、为什么消息会丢失？跟消息重复问题类似，消息丢失也可能出现在生产者、MQ、消费者三者中。这三者导致消息丢失的原因是什么呢？生产者：生产者推送消息到MQ中，由于网络抖动等原因消息没有推送到MQ中，或者消息推送到MQ中了但是MQ内部出错了，导致消息丢失。MQ：MQ接收到消息后先把消息暂存在OSCache中，消费者还没消费的时候MQ自己挂了，导致消息丢失。消费者：消费者消费到了这条消息，但是还没来得及

消息队列（三）如何保证消息不被重复消费？

一、为什么会出现重复消费的问题？RabbitMQ、RocketMQ、Kafka都有可能出现重复消费的问题，导致重复消费的原因可能出现在生产者，也可能出现在MQ或消费者。这里说的重复消费问题是指同一个数据被执行了两次，不单单指MQ中一条消息被消费了两次，也可能是MQ中存在两条一模一样的消费。生产者：生产者可能会重复推送一条数据到MQ中，为什么会出现这种情况呢？也许是一个Controller接口被重复

消息队列（二）如何保证消息队列的高可用？

一、什么是高可用性？对于高可用性，维基百科上是这么描述的：高可用性（英语：highavailability，缩写为HA），IT术语，指系统无中断地执行其功能的能力，代表系统的可用性程度。也就是说，我们不可能做到100%的可用性，所以用可用性度来表示高可用性，通常我们会用多少个9来表示高可用的目标，比如99.99%表示系统的年停机时间为8.76个小时，也就是99.99%的时间都是可用的。要做到高可用