• 从RocketMQ的Broker源码层面验证一下这两个点

    时间:2024-01-28 19:12:23

    本篇博客会从源码层面,验证在RocketMQ基础概念剖析,并分析一下Producer的底层源码中提到的结论,分别是:Broker在启动时,会将自己注册到所有的Nam...

  • Rocketmq学习4——Broker消息持久化原理源码浅析

    时间:2024-01-28 16:33:00

    一丶前言在《Rocketmq学习3——消息发送原理源码浅析》中,我们学习了消息发送的要点:本地缓存+rpc 请求namesever + 定时刷新,topic路由信息负载均衡的选择一个Broker进行发送,还支持【故障转移(即支持规避短时间内发送失败的broker)】基于netty实现的rpc进行消息...

  • rocketMq 消息偏移量 Offset

    时间:2024-01-27 19:16:06

    消息偏移量 Offsetqueue0offset 0   0-20  offset 4  20-40纠错:每条消息的tag对应的HashCode.queue...

  • RocketMQ源码分析 broker启动,commitlog、consumequeue、indexfile、MappedFileQueue、MappedFile之间的关系以及位置说明

    时间:2024-01-27 18:42:21

    目录1.MappedFile类属性说明1.1.MappedFile类属性如下1.2.MappedFile构造器说明2.MappedFileQueue类说明2...

  • 消息队列 ActiveMQ 、RocketMQ 、RabbitMQ 和 Kafka 如何选择?

    时间:2024-01-25 19:13:12

     「 预计阅读 6 分钟 」旁白:这是一篇拖更了N久的文章...0.0(看不见我~)往期回顾前端框架 jQuery 和 Vue 如何选择?安全框架 Shiro 和 Spring Security 如何选择?正文 消息队列(MQ)在百度百科中,消息队列(MQ)是这么解释的:“消息队列”是在消息...

  • rocketmq学习(二) rocketmq集群部署与图形化控制台安装

    时间:2024-01-25 16:21:20

    1.rocketmq图形化控制台安装虽然rocketmq为用户提供了使用命令行管理主题、消费组以及broker配置的功能,但对于不够熟练的非运维人员来说,命令行的管理界面还是较难使用的。为此,我们可以使用图形化的管理界面来简化管理操作。rocketmq官方推荐的图形化控制台目前还处在不成熟的孵化阶段...

  • Spring Cloud异步场景分布式事务怎样做?试试RocketMQ

    时间:2024-01-25 12:19:15

    一、背景在微服务架构中,我们常常使用异步化的手段来提升系统的 吞吐量 和 解耦 上下游,而构建异步架构最常用的手段就是使用 消息队列(MQ),那异步架构怎样才能实现...

  • rocketMQ部署

    时间:2024-01-25 07:33:30

     rocketMQ部署(单机) 1、          环境:CentOS7 64  &  JDK1.8+ 64  & 用户:www2、          下载binary文件包:wget http://mirror.rise.ph/apache/rocketmq/4.3.0...

  • RocketMQ(2)---Docker部署RocketMQ集群

    时间:2024-01-24 22:06:09

    RocketMQ(2)—Docker集群部署RocketMQ =前言=1、因为自己只买了一台阿里云服务器,所以RocketMQ集群都部署在单台服务器上只是端口不同,如果实际开发,可以分别部署在多台服务器上。2、这里有关 Broker 和 NameServer 分别都做了了集群部署(各部署两个),且B...

  • RocketMQ快速入门

    时间:2024-01-23 19:46:06

    前面几篇文章介绍了为什么选择RocketMQ,以及与kafka的一些对比: 阿里 RocketMQ 优势对比,方便大家对于RocketMQ有一个简单的整体了解,之后介绍了:MQ 应用场景,让我们知道MQ在什么时候可以使用,可以解决什么问题,之后介绍了:RocketMQ集群部署配置;本篇文章接着上篇内...

  • Rocketmq学习3——消息发送原理源码浅析

    时间:2024-01-22 08:20:32

    一丶概述RocketMQ 消息发送的原理流程可以分为以下几个步骤:1. 创建生产者在发送消息前,客户端首先需要创建一个消息生产者(Producer)实例,并设置必要的配置参数,如NameServer地址、生产组名称、消息发送失败的重试次数等。2. 启动生产者创建生产者后,需要调用启动方法来初始化生产...

  • spring--集成RocketMQ

    时间:2024-01-21 21:18:54

    在Spring Boot中集成RocketMQ通常涉及以下步骤:添加依赖:首先,需要在项目的pom.xml文件中添加RocketMQ的Spring Boot Starter依赖。<dependency> <groupId>org.apache.rocketmq</...

  • 聊一聊顺序消息(RocketMQ顺序消息的实现机制)

    时间:2024-01-21 17:49:50

    当我们说顺序时,我们在说什么?日常思维中,顺序大部分情况会和时间关联起来,即时间的先后表示事件的顺序关系。比如事件A发生在下午3点一刻,而事件B发生在下午4点,那么我们认为事件A发生在事件B之前,他们的顺序关系为先A后B。上面的例子之所以成立是因为他们有相同的参考系,即他们的时间是对应的同一个物理时...

  • docker 安装 mysql、redis、rabbitmq、RocketMQ、Nacos 等中间件-五、Nacos 2.1.

    时间:2024-01-21 13:52:46

    docker run \-d -p 8848:8848 \-p 9848:9848 \--name nacos2 \-e MODE=standalone \-e TIME_ZONE='Asia/Shanghai' \nacos/nacos-server:v2.1.2 运行成功,稍等几秒启动时间,浏...

  • Linux安装RocketMQ

    时间:2024-01-19 13:19:59

    本文介绍Linux安装RocketMQ。1.RocketMQ简介RocketMQ是阿里巴巴中间件开发的分布式消息系统,曾经经历过很多阿里巴巴大型项目的实际检验。在去年已经正式捐献给Apache开源基金会,成为孵化项目。今年正式升级成为了apache的顶级项目。RocketMQ官网地址为:http:/...

  • Kafka vs RocketMQ—— Topic数量对单机性能的影响

    时间:2024-01-15 14:33:09

    引言上一期我们对比了三类消息产品(Kafka、RabbitMQ、RocketMQ)单纯发送小消息的性能,受到了程序猿们的广泛关注,其中大家对这种单纯的发送场景感到并不过瘾,因为没有任何一个网站的业务只有发送消息。本期,我们就来模拟一个真实的场景:消息的发送和订阅一定是共存的要支持多个订阅端订阅自己感...

  • rocketMQ(二 )Centos7 集群

    时间:2024-01-14 14:24:07

    rocketMQ集群:在运用中流程一般 是在程序中使用代码编辑生产者,将所需要的消息发送到rocketmq中,然后另一个程序编辑消费者从rocketmq里面获取消息。rocketmq集群 需要对nameServer 和Broker 集群准备两台服务器,两台机器都是master,如果要搞一主N备,修改...

  • RocketMQ实战快速入门

    时间:2024-01-13 19:14:50

    转自:https://www.jianshu.com/p/824066d70da8一、RocketMQ 是什么     Github 上关于 RocketMQ 的介绍:RcoketMQ 是一款低延迟、高可靠、可伸缩、易于使用的消息中间件。具有以下特性:支持发布/订阅(Pub/Sub)和点对点(P2P...

  • 使用RocketMQ实现分布式事务

    时间:2024-01-13 12:17:25

    。。todorefhttps://blog.csdn.net/zhejingyuan/article/details/79480128

  • RocketMQ-事务消费

    时间:2024-01-04 15:46:38

    理论部分在https://www.jianshu.com/p/453c6e7ff81c中的 “三、事务消息”。下面从代码层面看一下rockemq的事务消息一、事务消费端。从代码中看到跟其他模式的消费端没有什么两样。package org.hope.lee.consumer.transaction;i...