RocketMQ
共 16 篇已发布文章
知道了rocketmq-spring-boot-starter版本号，怎么知道依赖的rocket版本号？
<dependency> <groupId>org.apache.rocketmq</groupId> <artifactId>rocketmq-spring-boot-starter</artifactI
怎么修改RocketMQ中broker使用内存大小
问题：那broker现在是-Xms8g-Xmx8g我想该成4g怎么修改？然后怎么重启？修改RocketMQBroker的内存大小当前broker进程的JVM配置是：sh复制代码-Xms8g -Xmx8g如果你想修改为：sh复制代码-Xms4g -Xmx4g可以按照以下步骤操作。1.找到Broker的JAVA选项Broker的JVM参数通常是在runbroker.sh里设置的。(
怎么修改RocketMQ中nameServer使用内存大小
问题：我的rocketMQ位置：/tol/rocketmq/bin我现在想要修改nameserver的内存大小。catmqnamesrv 内容如下：catmqnamesrvif[-z"$ROCKETMQ_HOME"];then ##resolvelinks-$0maybealinktomaven'shome PRG="$0&quo
以一个故事的角度展开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 连接异常 senddefaultimpl call timeout
rocketmq 连接异常 senddefaultimpl call timeout
【已解决】RocketMQ在发送消息的时候，提示：MQClientException: No route info of this topic
RocketMQ在发送消息的时候，提示：MQClientException: No route info of this topic xxx
消息队列（四）如何处理消息丢失的问题？
一、为什么消息会丢失？跟消息重复问题类似，消息丢失也可能出现在生产者、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%的时间都是可用的。要做到高可用
消息队列（一）为什么要使用消息队列？
不知大家是否有遇到过这样的问题？我们要调其他系统推送数据，对方接口改了参数要围着对方转，配合调试和测试；调第三方接口经常调不通；每次大促系统都处于崩溃的边缘，如 618、双十一、秒杀活动等。这时候使用 MQ 就可以轻松解决这些问题。
消息队列（五）如何保证消息的顺序性？
一、为什么出现顺序错乱？在生产中经常会有一些类似报表系统这样的系统，需要做MySQL的binlog同步。比如订单系统要同步订单表的数据到大数据部门的MySQL库中用于报表统计分析，通常的做法是基于Canal这样的中间件去监听订单数据库的binlog，然后把这些binlog发送到MQ中，再由消费者从MQ中获取binlog落地到大数据部门的MySQL中。在这个过程中，可能会有对某个订单的增删改操作，比
RocketMQ——角色与术语详解
RocketMQ中有很多概念，其中包括一些术语和角色。 理清楚基本的概念能有效的帮助理解RocketMQ的原理以及排查问题。