分类：RocketMq

2021
09-14

基于rocketmq的有序消费模式和并发消费模式的区别说明

rocketmq消费者注册监听有两种模式有序消费MessageListenerOrderly和并发消费MessageListenerConcurrently，这两种模式返回值不同。MessageListenerOrderly正确消费返回ConsumeOrderlyStatus.SUCCESS稍后消费返回ConsumeOrderlyStatus.SUSPEND_CURRENT_QUEUE_A_MOMENTMessageListenerConcurrently正确消费返回ConsumeConcurrentlyStatus.CONSUME_SUCCESS稍后消费返回ConsumeConcurrentlyStatus.RECONSUME_LATER顾名思义，有序消费... 继续阅读 >

2020
10-09

RocketMQ获取指定消息的实现方法（源码）

概要消息查询是什么？消息查询就是根据用户提供的msgId从MQ中取出该消息RocketMQ如果有多个节点如何查询？问题：RocketMQ分布式结构中，数据分散在各个节点，即便是同一Topic的数据，也未必都在一个broker上。客户端怎么知道数据该去哪个节点上查？猜想1：逐个访问broker节点查询数据猜想2：有某种数据中心存在，该中心知道所有消息存储的位置，只要向该中心查询即可得到消息具体位置，进而取得消息内容实际：1.消息Id中含有消息所... 继续阅读 >

2020
10-08

RocketMq事务消息发送代码流程详解

一、RocketMq事务消息流程：1、首先会向broker发送一个预请求消息，消费者不可见2、回调执行本地事务（比如操作数据库）3、事务执行成功后，再次发送消息给broker，告诉broker事务执行成功这个消息要提交，让消费者可见。如果本地事务执行超时，会返回一个unknow，broker会发送一个消息回查，检查消息是否执行成功。二、RocketMq事务消息实例：1、引入rocketMq相关的依赖：<dependency><groupId>org.apache.rocketmq</groupId>... 继续阅读 >

2020
09-29

Springboot RocketMq实现过程详解

首先，在虚拟机上安装rocketmq和rocketMq可视化控制，安装不做描述。1、pom.xml文件添加依赖mq的版本与连接的rocketmq版本保持一致<dependency><groupId>org.apache.rocketmq</groupId><artifactId>rocketmq-remoting</artifactId><version>4.4.0</version></dependency>2、yml文件添加rocketmq配置apache:rocketmq:#消费者的配置consumer:pushConsumer:myConsumer#生产者的配置producer:... 继续阅读 >