SpringBoot整合RocketMQ的详细过程
目录 1. SpringBoot整合RocketMQ 2 使用RocketMQ会遇到的问题 2.1 WARN No appenders could be found for logger 2.2 不支持LocalDate 和 LocalDateTime 2.3 RockeMQ环境隔离 3. R »
SpringBoot整合RocketMQ，老鸟们都是这么玩的！
今天我们来讨论如何在项目开发中优雅地使用RocketMQ。本文分为三部分，第一部分实现SpringBoot与RocketMQ的整合，第二部分解决在使用RocketMQ过程中可能遇到的一些问题并解决他们，第三部分介绍如何封装RocketMQ以便更好地使用。 1. SpringBoot整合RocketM »
深入浅出RocketMQ的事务消息
目录 事务消息发送流程 发送事务消息源码分析 事务消息回查 事务消息发送流程 半消息实现了分布式环境下的数据一致性的处理，生产者发送事务消息的流程如上图所示，通过对源码的学习，我们可以弄清楚下面几点，也是半消息机制的核心： 1.为什么prepare消息不会被Consumer消费？ »
关于rocketmq中日志文件路径的配置指南
目录 服务端日志 客户端配置 logUseSlf4j 配置logRoot 总结 rocketmq 中的数据和日志文件默认都是存储在user.home路径下面的，往往我们都需要修改这些路径到指定文件夹以便管理。 服务端日志 网上搜索rocketmq日志存储路径的修改，一堆都是写着要把源 »
关于rocketmq中日志文件路径的配置指南
目录 服务端日志 客户端配置 logUseSlf4j 配置logRoot 总结 rocketmq 中的数据和日志文件默认都是存储在user.home路径下面的，往往我们都需要修改这些路径到指定文件夹以便管理。 服务端日志 网上搜索rocketmq日志存储路径的修改，一堆都是写着要把源 »
RocketMQ broker 消息投递流程处理PULL_MESSAGE请求解析
目录 RocketMq消息处理 1. 处理PULL_MESSAGE请求 2. 获取消息 3. 挂起请求：PullRequestHoldService#suspendPullRequest 3.1 处理挂起请求的线程：PullRequestHoldService 3.2 唤醒请求：PullMess »
RocketMQ broker 消息投递流程处理PULL_MESSAGE请求解析
目录 RocketMq消息处理 1. 处理PULL_MESSAGE请求 2. 获取消息 3. 挂起请求：PullRequestHoldService#suspendPullRequest 3.1 处理挂起请求的线程：PullRequestHoldService 3.2 唤醒请求：PullMess »
RocketMQ broker文件清理源码解析
目录 1. broker 清理文件介绍 1.1 哪些文件需要清理 1.2 RocketMQ文件清理的机制 2. 源码解析 2.1 清理commitlog 2.2 ConsumeQueue 清理 2.3 indexFile 清理 3. 总结 1. broker 清理文件介绍 本 »
RocketMQ broker文件清理源码解析
目录 1. broker 清理文件介绍 1.1 哪些文件需要清理 1.2 RocketMQ文件清理的机制 2. 源码解析 2.1 清理commitlog 2.2 ConsumeQueue 清理 2.3 indexFile 清理 3. 总结 1. broker 清理文件介绍 本 »
rocketmq-spring : 实战与源码解析一网打尽
RocketMQ 是大家耳熟能详的消息队列，开源项目 rocketmq-spring 可以帮助开发者在 Spring Boot 项目中快速整合 RocketMQ。 这篇文章会介绍 Spring Boot 项目使用 rocketmq-spring SDK 实现消息收发的操作流程，同时笔者会从开发者的角 »
RocketMQ源码解析broker 启动流程
目录 1. 启动入口 2. 创建BrokerController 2.1 controller实例化 2.2 初始化controller 2.2.1 注册处理器：BrokerController#registerProcessor 2.2.2 remotingServer注册处理器：Netty »
RocketMQ源码解析broker 启动流程
目录 1. 启动入口 2. 创建BrokerController 2.1 controller实例化 2.2 初始化controller 2.2.1 注册处理器：BrokerController#registerProcessor 2.2.2 remotingServer注册处理器：Netty »
一种异步延迟队列的实现方式
目前系统中有很多需要用到延时处理的功能：支付超时取消、排队超时、短信、微信等提醒延迟发送、token刷新、会员卡过期等等。通过延时处理，极大的节省系统的资源，不必轮询数据库处理任务。 目前大部分功能通过定时任务完成，定时任务还分使用quartz及xxljob两种类型轮询时间短，每秒执行一次，对数据 »
一种异步延迟队列的实现方式
目前系统中有很多需要用到延时处理的功能：支付超时取消、排队超时、短信、微信等提醒延迟发送、token刷新、会员卡过期等等。通过延时处理，极大的节省系统的资源，不必轮询数据库处理任务。 目前大部分功能通过定时任务完成，定时任务还分使用quartz及xxljob两种类型轮询时间短，每秒执行一次，对数据 »
太坑了，我竟然从RocketMQ源码中扒出了7种导致消息重复消费的原因
大家好，我是三友~~ 在众多关于MQ的面试八股文中有这么一道题，“如何保证MQ消息消费的幂等性”。 为什么需要保证幂等性呢？是因为消息会重复消费。 为什么消息会重复消费？ 明明已经消费了，为什么消息会被再次被消费呢？ 不同的MQ产生的原因可能不一样 本文就以RocketMQ为例，来扒一扒Rocket »
太坑了，我竟然从RocketMQ源码中扒出了7种导致消息重复消费的原因
大家好，我是三友~~ 在众多关于MQ的面试八股文中有这么一道题，“如何保证MQ消息消费的幂等性”。 为什么需要保证幂等性呢？是因为消息会重复消费。 为什么消息会重复消费？ 明明已经消费了，为什么消息会被再次被消费呢？ 不同的MQ产生的原因可能不一样 本文就以RocketMQ为例，来扒一扒Rocket »
RocketMQ producer同步发送单向发送源码解析
目录 RocketMQ生产者发送消息分为三种模式 1. 同步发送 1.1 DefaultMQProducerImpl#sendDefaultImpl 1.2 DefaultMQProducerImpl#sendKernelImpl 1.3 MQClientAPIImpl#sendMessage »
RocketMQ producer容错机制源码解析
目录 1. 前言 2. 失败重试 3. 延迟故障 3.1 最普通的选择策略 3.2 延迟故障的实现 1. 前言 本文主要是介绍一下RocketMQ消息生产者在发送消息的时候发送失败的问题处理？这里有两个点，一个是关于消息的处理，一个是关于broker的处理，比如说发送消息到brok »
RocketMQ producer容错机制源码解析
目录 1. 前言 2. 失败重试 3. 延迟故障 3.1 最普通的选择策略 3.2 延迟故障的实现 1. 前言 本文主要是介绍一下RocketMQ消息生产者在发送消息的时候发送失败的问题处理？这里有两个点，一个是关于消息的处理，一个是关于broker的处理，比如说发送消息到brok »
基于 RocketMQ Connect 构建数据流转处理平台
为什么在“双11”抢红包活动及大型数据系统中总是出现 RocketMQ 的身影？ RocketMQ Connect在RocketMQ 生态中扮演什么角色？本文为大家解答上述疑问。同时，介绍 OceanBase 与 RocketMQ 如何集成以及能帮助大家解决哪些问题。 本文作者：周波，阿 »