java-rocketmq

实现分布式事务的新标杆：RocketMQ的全面解析与应用指南

在分布式系统中，实现事务的一致性和可靠性是一项重要的挑战。本文将详细介绍如何利用 RocketMQ 的半消息机制来实现分布式事务，并提供具体的代码示例和最佳实践。 1. 引言在分布式系统中，事务处理是一项复杂而关键的任务。传统的 ACID 事务…

RocketMQ自定义日志输出

Log是监控系统状态，排查问题的重要手段，RocketMQ的默认Log存储位置是：${user.home}/Logs/rocketmqLogs，Log配置文件的设置可以通过JVM启动参数、环境变量、代码中的设置语句这三种方式来配置。RocketMQ日志相关的代码在org.apache…

30.RocketMQ之消费者拉取消息源码

highlight: arduino-light 消息拉取概述消息消费模式有两种模式：广播模式与集群模式。广播模式比较简单，每一个消费者需要拉取订阅主题下所有队列的消息。本文重点讲解集群模式。在集群模式下，同一个消费者组内有多个消息消费者&#xff0…

文章目录1、DefaultMQPushConsumer分发处理消息源码2、pullMessageServer3、pullMessageServer的pullMessage源码分析4、DefaultMQPushConsumerImpl的拉取消息5.1、pullKernelImpl拉取消息5.2 pullMessage发起拉取消息请求1、DefaultMQPushConsumer分发处理消息源码 /*** 分发…

RocketMQ 源码分析——Producer

文章目录消息发送代码实现消息发送者启动流程检查配置获得MQ客户端实例启动实例定时任务 Producer 消息发送流程选择队列默认选择队列策略故障延迟机制策略*两种策略的选择技术亮点:ThreadLocal 消息发送代码实现下面是一个生产者发送消息的demo（同步发送&#…

RocketMQ-01

1. MQ介绍 ##1.1 为什么要用MQ 消息队列是一种“先进先出”的数据结构其应用场景主要包含以下3个方面应用解耦系统的耦合性越高，容错性就越低。以电商应用为例，用户创建订单后，如果耦合调用库存系统、物流系统、支付系统，任…

RocketMQ源码阅读-Message拉取与消费-Consumer篇

RocketMQ源码阅读-Message拉取与消费-Consumer篇 1. Consumer2. PushConsumer3. PushConsumer 订阅3.1 subscribe订阅3.2 registerMessageListener注册监听器 4. PushConsumer 消息队列Rebalance4.1 Rebalance流程4.2 Rebalance策略AllocateMessageQueueAveragelyAllocateMessa…

系列四、RocketMQ各角色介绍

一、各角色 1.1、Producer 消息的发送者，举例：发信者； 1.2、Consumer 消息的接收者，举例：收信者； 1.3、Broker 暂存和传输消息，举例：邮局； 1.4、NameServer 管理Brok…

【RocketMQ】RocketMQ 5.0版本任意时刻延迟消息的实现原理浅析

文章目录意外发现设计方案时间轮定时消息存储具体实现流程图流程步骤意外发现无意间从官方的最新的客户端代码中看到下面的Example： 感兴趣的可以看看这个介绍：https://rocketmq.apache.org/docs/featureBehavior/02delaymessage 生产者：…

Springboot集成RocketMQ——简单使用

目录 1.MQ选型 2.RocketMQ基本架构 3.Springboot集成RocketMQ 4.顺序消息 5.延时消息 6.事务消息 1.MQ选型目前市面上的MQ选型：主要分为3个类型 Kafka：吞吐量大，且性能好，集群高可用；会丢失数据，功…

消息队列MQ 保证消息不丢失（消息可靠性）

文章目录概述RabbitMQ 怎么避免消息丢失（可靠传输）RocketMQ 怎么确保消息不丢失Kafka 怎么保证消息不丢失activeMQ 怎么避免消息丢失MQ 宕机了消息是否会丢失线上服务宕机时，如何保证数据100%不丢失吗？消息队列消息持久化概述 …

RocketMQ的Broker

1 Broker角色 Broker角色分为ASYNC_MASTER (异步主机)、SYNC_MASTER (同步主机)以及SLAVE (从机)。如果对消息的可靠性要求比较严格，可以采用SYNC_MASTER加SLAV E的部署方式。如果对消息可靠性要求不高，可以采用ASYNC_MASTER加ASL AVE的部署方式。如果只…

RocketMQ消息发送

消息发送示例代码： public static void main(String[] args) throws MQClientException, InterruptedException {DefaultMQProducer producer new DefaultMQProducer("please_rename_unique_group_name");producer.setNamesrvAddr("127.0.0.1:9876…

RocketMQ你不得不了解的 Rebalance机制源码分析

这里是weihubeats,觉得文章不错可以关注公众号小奏技术，文章首发。拒绝营销号，拒绝标题党 RocketMQ版本 version: 5.1.0 RocketMQ中consumer消费模型在了解RocketMQ的Rebalance机制之前，我们必须先简单了解下rocketmq的消费模型我们知道…

RocketMq面试题

RocketMq运行原理 RocketMq架构中有四大角色，分别是NameServer、Broker、Producer、Consumer NameServer：是一个注册中心，类似于ZooKeeper和SpringCloud中的Eureka，他能够管理Borker和路由信息；为了提高可用性&#x…

rocketmq源码-consumer启动

前言这篇笔记记录consumer启动的逻辑 consumer主要是负责去broker中拉取消息，然后将拉取到的消息，交给消费者去处理 consumer本质上也是一个netty客户端，所以，在启动的时候，和producer有很多相似的点，但是…