腾讯云开发者社区-腾讯云

开发者社区

文档建议反馈控制台

文章/答案/技术大牛

发布

综合排序丨最热优先丨最新优先

【RocketMQ系列】RocketMQ集群，RocketMQ-on-DLedger集群

本文RocketMQ系列第四篇，主要介绍RocketMQ集群及如何部署自动容灾切换的 RocketMQ-on-DLedger Group。 ? 在一台虚拟机上安装RocketMQ 在RocketMQ入坑系列第一篇中，已经有安装方法了，很简单，这里不再赘述。【RocketMQ系列】RocketMQ中的角色详解及实操基本使用 2. RocketMQ-Console 为了能够方便的查看RocketMQ的集群状态，我们安装一下RocketMQ-Console。代码仓库「GitHub」 github.com/xblzer/JavaJourney 往期推荐【RocketMQ系列（三）】基于RocketMQ的分布式事务 RocketMQ入坑系列（二）近距离感受 RocketMQ如何收发消息 RocketMQ入坑系列（一）角色介绍及基本使用

2020-12-02

4.4K0

标签:

有序性分类根据有序范围的不同，RocketMQ可以严格地保证两种消息的有序性：分区有序与全局有序。 2、在RocketMQ可视化控制台中手动创建Topic时指定Queue数量。 3、使用mqadmin命令手动创建Topic时指定Queue数量。配置文件在RocketMQ安装目录下的conf目录中。 RocketMQ中事务消息的Producer充当着TM。 RM Resource Manager，资源管理器。消息重复在RocketMQ中是无法避免的问题。消息重复在一般情况下不会发生，当出现消息量大、网络抖动，消息重复就会成为大概率事件。

2021-11-23

3.3K0

标签:

消息队列 CMQ 版

还有个重要功能是挡住前端的数据洪峰，保证后端系统的稳定性，这就要求消息中间件具有一定的消息堆积能力 rocket相比其他mq的优点能够保证严格的消息顺序提供丰富的消息拉取模式实时的消息订阅机制亿级消息堆积能力 rocketmq 使用同步复制可以保证消息100%不丢失（但是性能下降10%） rocketmq节点 Name Server Broker 部署相对复杂，Broker 分为 Master 与 Slave 一个 Master 由于 RocketMQ 所有消息都是持久化的，所以如果按照优先级来排序，开销会非常大，因此 RocketMQ 没有特意支持消息优先级，但是可以通过变通的方式实现类似功能，即单独配置一个优先级高的队列，和一个普通优先级的队列每个优先级可以用不同的 topic 表示，发消息时，指定不同的 topic 来表示优先级，这种方式可以解决绝大部分的优先级问题，但是对业务的优先级精确性做了妥协刷盘方式 rocketmq 建议使用多主多从同步复制

2022-08-12

2.7K0

标签:

RocketMQ实战（一）What is RocketMQ?初步理解ProducerConsumer Groupinstall RocketMQ

在实际项目中已经领教过RocketMQ的强大，本人计划写一个RocketMQ实战系列，将涵盖RocketMQ的简介，环境搭建，初步使用、API详解、架构分析、管理员集群操作等知识。 What is RocketMQ? 1.要知道RocketMQ原生就是支持分布式的，而ActiveMQ原生存在单点性。 2.RocketMQ可以保证严格的消息顺序，而ActiveMQ无法保证！（注意RocketMQ只有一种模式，即发布订阅模式。）进程与端口第八步：RocketMQ Console 把rocketmq-console.war部署到Tomcat下即可。 ? 解压WAR包 ?

2018-08-21

1.6K0

标签:

RocketMQ 基本概念消息模型 RocketMQ由Producer、Broker、Consumer组成 Producer 生产消息，同步/异步发送，顺序/单向发送。为什么RocketMQ没有这么做因为RocketMQ 是java 实现的，要是缓存过多消息，GC是很严重的问题。所以多文件并发写入，性能比RocketMQ好。 RocketMQ只有一个commitLog物理文件，单文件写入，性能比KafKa差。支持Slave 自动切换为Master；开源版本RocketMQ不支持Slave自动切换为Master，而阿里云版本RocketMQ支持自动切换特性。不支持分布式事务消息 RocketMQ支持分布式事务消息过滤 kafka不支持代理端消息过滤 RocketMQ支持代理端消息过滤 KafKa不支持延迟消息，而RocketMQ支持重点 ActiveMQ

2022-05-20

1.7K0

标签:

消息队列 CMQ 版

RocketMQ快速入门 RocketMQ是阿里巴巴2016年MQ中间件，使用Java语言开发，在阿里内部，RocketMQ承接了例如“双11”等高并发场景的消息流转，能够处理万亿级别的消息。 192.168.25.138 rocketmq-nameserver2 # broker 192.168.25.135 rocketmq-master1 192.168.25.135 rocketmq-slave2 ROCKETMQ_HOME=/usr/local/rocketmq/rocketmq-all-4.4.0-bin-release PATH=$PATH:$ROCKETMQ_HOME/bin export /rocketmq/store/commitlog mkdir /usr/local/rocketmq/store/consumequeue mkdir /usr/local/rocketmq/store =E:\\RocketMQ\\data\\rocketmq\\dataDir\\index # checkpoint文件路径 storeCheckpoint=E:\\RocketMQ\\data\\rocketmq

2023-11-27

2.5K0

标签:

RocketMQ-初体验RocketMQ(02)_单节点RocketMQ的安装

---- RocketMQ的安装（单节点）接下来，我们从无到有，搭建一个RocketMQ的环境吧，单节点走起。 ---- JDK 和 RocketMQ RocketMQ 是个纯java、分布式、队列模型的开源消息中间件，所以JDK必不可少了。 RocketMQ 版本及JDK的对应关系 RocketMQ 版本及JDK的对应关系：戳这里 ? 将下载好的 rocketmq-all-4.3.2-bin-release.zip 使用unzip命令，解压到 /usr/local/rocketmq目录下如下所示 [root@artisan rocketmq /rocketmq/rocketmq-all-4.3.2-bin-release export PATH=$ROCKETMQ_HOME/bin:$PATH 第二步：刷新环境变量 source /etc

2021-08-17

2.2K0

标签:

【RocketMQ】001-RocketMQ 概述

其吞吐量较 Kafka 与 RocketMQ 要低，且由于其不是 Java 语言开发，所以公司内部对其实现定制化开发难度较大。 RocketMQ：RocketMQ 是使用 Java 语言开发的一款 MQ 产品。经过数年阿里双 11 的考验，性能与稳定性非常高。其没有遵循任何常见的 MQ 协议，而是使用自研协议。对于 Spring Cloud Alibaba，其支持 RabbitMQ、Kafka，但提倡使用 RocketMQ。二、RocketMQ 概述 1、简介 RocketMQ 是一个统一消息引擎、轻量级数据处理平台。RocketMQ是一款阿里巴巴开源的消息中间件。 2016 年双十一，RocketMQ 承载了万亿级消息的流转，跨越了一个新的里程碑。

2025-01-06

1.1K0

标签:

RocketMQ详解(2)——RocketMQ核心概念

RocketMQ详解(2)——RocketMQ核心概念一. RocketMQ专业术语 Producer 消息生产者，负责产生消息，一般由业务系统负责产生消息。 RocketMQ的消费方式广播消息一条消息被多个Consumer消费，即使这些Consumer属于同一个Consumer Group，消息也会被Consumer Group中的每一个Consumer 在JMS规范中，类似于P2P模型，但是RocketMQ的集群消费功能大于等于JMS的P2P消费。因为集群消费模式下，RocketMQ单个Consumer Group内的消费类似于P2P，但是一个Topic/Queue可以被多个Consumer Group消费。在RocketMQ中，该顺序主要指局部顺序，即一类消费为满足顺序性，必须Producer单线程发送，且发送到同一个队列，这样Consumer就可以按照Producer的发送顺序来消费消息。

2020-09-03

1.6K0

标签:

【RocketMQ】003-Windows 安装 RocketMQ

【RocketMQ】003-Windows 安装 RocketMQ 一、准备工作 1、环境要求 64位JDK 1.8+; Maven 3.2.x; 64位操作系统系统，本文档在Windows上安装 2、 RocketMQ 的环境变量值根据实际目录设置。变量名：ROCKETMQ_HOME 变量值：D:\MySoft\Environment\RocketMQ\rocketmq-all-5.1.0-bin-release 二、启动 1、启动 NameServer 功能 RocketMQ 自带了发送与接收消息的脚本 tools.cmd，用来验证 RocketMQ 的功能是否正常。四、RocketMQ 控制台第一步：克隆项目到本地 https://github.com/apache/rocketmq-dashboard 第二步：使用 IDEA 打开项目非必要，直接使用 maven

2025-01-06

6.2K3

标签: