首先，进入到RocketMQ安装目录，如：~/opt/rocketmq-all-5.2.0-bin-release。
在分布式系统中，消息队列（MQ）是实现服务解耦、异步消息处理、流量削峰等目的的关键组件。然而，消息传递过程中不可避免会遇到失败情况，如何处理MQ的重试失败和数据异常，是每个Java高级开发者必须面对的问题。本文将从设计和...
RocketMQ一个优点是有事务特性，可以保证事务的最终一致性。举一个简单的例子，以电商为例，创建订单ID9527被创建后要保存到数据库，通过该订单通过MQ投递给其他系统进行消费。如果要保证订单数据入库与消息投递状态要保证最...
在学习RocketMQ的时候，有几个疑问。 如果主题不存在，client把消息发给谁呢？ 当发送消息给不存在的主题时，主题是什么时候创建的呢？
通过前面学习，我们知道rocketmq消费消息的过程中，会有一个拉取的动作，而这个拉取的动作中又会涉及到对拉取消息的处理。而这里又分为好几种情况。...
prepare：将消息（消息上带有事务标识）投递到一个名为RMS_SYS_TRANS_HALF_TOPIC的topic中， 而不是投递到真正的topic中。
异步消息通常用在对响应时间敏感的业务场景，即发送端不能容忍长时间地等待Broker的响应。
这种方式风险较大，一旦Broker重启或者宕机时，会导致整个服务不可用。不建议线上环境使用,可以用于本地测试。
系统的耦合性越高，容错性就越低。以电商应用为例，用户创建订单后，如果耦合调用库存系统、物流系统、支付系统，任何一个子系统出了故障或者因为升级等原因暂时不可用，都会造成下单操作异常，影响用户使用体验。...
