rocketmq运行
社区干货
如何解决使用RocketMQ的消息轨迹信息无法查看问题
# 问题描述RocketMQ 正常生产和消费消息,但是消费轨迹无法查看的问题该如何排查?# 问题分析此类问题原因一般如下:1. 客户端 SDK 使用的版本不对, 需要使用 SDK 版本为 4.8.0, 4.7 和 4.9 的版本均会导致前端页... DefaultMQProducer producer = new DefaultMQProducer("ProducerGroupName", aclHook,true,null);```* 消费者开启消息轨迹:```javaAclClientRPCHook aclHook = new AclClientRPCHook(new SessionCredential...
RocketMQ 存储机制浅析
└── lock // 运行期间使用到的全局资源锁 ``` **CommitLog**RocketMQ Broker 单个实例下所有的 Topic 都使用同一个 CommitLog 来存储,即单个实例消息整体有序。CommitLog 单个文件大小默认 1G,文件文件名是起始偏移量,总共 20 位,左边补零,起始偏移量是 0。假设文件按照默认大小 1G 来算:* 第一个文件的文件名为 00000000000000000000 ,当第一个文件被写满之后,开始写入第二个文件;* 第二个文件...
使用golang调用RocketMQ SDK
# 前言本文档介绍使用go语言调用火山引擎RocketMQ SDK。# 关于实验- 预计部署时间:30分钟- 级别:初级- 相关产品:中间件-RocketMQ- 受众: 通用# 实验说明## 第一步、创建RocketMQ实例在控制台创建RocketMQ... //此处填写控制台RocketMQ实例概览中的TCP内网接入点,目前不支持公网接入,示例http://MQ_INST_50392uo8m9em_xxxxx.rocketmq.ivolces.com:9876 producer.WithRetry(2), producer.WithCredentials(primitive.Cre...
打造新一代云原生"消息、事件、流"统一消息引擎的融合处理平台 | 社区征文
RocketMQ基于大规模云计算环境的实践经验(例如,阿里(双十一、双十二)、携程(过年高峰期)),辅助了成千上万的企业完成数字化转型,从而实现了从互联网消息中间件到云原生消息中间件的发展变革。RocketMQ与其他消息中间... 比如RabbitMQ无法水平扩展单队列能力、Kafka扩容需要大量数据拷贝和均衡。这些现有解决方案都不适用于为大规模客户提供弹性服务的公共云环境。
特惠活动
rocketmq运行-优选内容
rocketmq运行-相关内容
CreateInstance
调用 CreateInstance 接口创建 RocketMQ 实例。 注意事项请求频率:该接口请求频率限制为 100 次/秒;单用户请求频率限制为 20 次/秒。 使用说明实例是消息队列 RocketMQ版的基本服务单位,用以管理和存储 Topic、Group 资源。 说明 通过 API 创建接口时暂不支持同时开启公网访问功能,如果需要开启实例的公网访问,建议在创建实例完成后,实例状态为运行中(Running)时,调用 EnablePublicNetwork 开启实例的公网访问。 默认情况下,您可...
RocketMQ 客户端使用建议
本文档介绍 RocketMQ 客户端的使用建议,推荐在使用消息队列 RocketMQ版进行消息生产与消费之前,阅读以下使用建议,提高接入效率和业务稳定性。 日志配置RocketMQ 的日志一般是单独配置的,业务日志独立管理。日志默认保存在 ${user.home}/logs/rocketmqlogs 目录的 10 个文件中,每个文件大小为 1G,日志文件名为 rocketmq_client.log。有些业务的用户目录的磁盘空间不大,很容易造成磁盘空间不足。您可以通过设置系统变量的方式配置 ...
RocketMQ 业务迁移
本文介绍 RocketMQ 业务迁移的操作步骤,您可以参考本文档将自建 RocketMQ 集群或其他云厂商 RocketMQ 集群迁移至火山引擎消息队列 RocketMQ版。 注意事项由于 Producer 和 Consumer 为集群化部署,迁移时可以分批操作,上层业务无感知。分批迁移过程中,可以在火山引擎云监控服务控制台监控业务相关流量数据,确认业务正常运行。 如果有多个 RocketMQ 实例需要迁移到同一个消息队列 RocketMQ版实例中,请依次进行迁移。 如果使用延时...
迁移概述
背景信息火山引擎基于Apache RocketMQ 构建了稳定、安全的消息队列 RocketMQ版。与和开源 RocketMQ 相比,消息队列 RocketMQ版支持 VPC 访问,免部署免运维,具备更高的稳定性和安全性,支持消息查询、全链路消息轨迹查询以及消息回溯等功能,帮助您快速发现和处理系统问题,提高运维效率。RocketMQ 业务迁移是指将自建或其他云厂商的 RocketMQ 迁移到火山引擎消息队列 RocketMQ版。对于消息队列来说,如需在业务运行过程中实现集群迁移...
设置公网访问与 SSL 认证策略
通过公网访问 RocketMQ 实例之前,需要先开启该实例的公网访问功能。如果创建实例时未开启公网访问,请参考本文档设置。 背景信息开启公网访问后,消息队列 RocketMQ版为实例提供公网接入点,用于客户端通过公网访问 R... 前提条件已成功创建 RocketMQ 实例,且实例状态为运行中。 开启公网访问前,请先创建和 RocketMQ 实例相同地域的 EIP,建议该 EIP 的带宽上限大于预估的公网业务流量峰值。详细操作请参考申请公网IP。 开启公网访...
创建 Topic
本文介绍创建 Topic 的操作步骤。 背景信息在RocketMQ 实例中,Topic 是消息发送与接收的基本单元,消息队列 RocketMQ版通过 Topic 对各类消息进行分类管理。消息的生产者将消息发送到 RocketMQ Topic 中,而消息的消费者则通过订阅该 RocketMQ Topic 来消费消息。 说明 每个实例的 Topic 数量配额与实例规格有关,各个规格实例可创建的 Topic 数量请参考产品规格。 前提条件已创建 RocketMQ 实例,且实例状态为运行中,详细操作步骤...
准备工作
在运行 Go SDK 代码收发消息前,您需按照本文提供的步骤来准备开发环境。 前提条件已安装 Go,建议使用 1.17 版本以获得更好的使用体验。 操作步骤 1 创建Go项目在 go.mod 文件中添加 rocketmq-client-go 的依赖。 go module {更换成项目名字}go {这里是你的go版本} 下面是需要添加的内容require ( github.com/apache/rocketmq-client-go/v2 83f60c154236bb92a5d5e3d40276b546b6079f1b) 2 创建资源接入消息队列 RocketMQ版收发消...
步骤三:生产消费普通消息
发送普通消息您可以通过以下方式发送普通消息: 在消息队列 RocketMQ版控制台的Topic管理页签中找到需要测试消息发送的 Topic,并在其对应的操作列单击发送消息。详细说明请参考在线调试。建议仅在业务调试阶段进行普通消息的发送测试。业务正常运行期间通过该方式发送消息可能会产生脏数据。 下载并安装 RocketMQ 客户端 Java SDK 后,运行以下示例代码,异步发送普通消息。 成功发送消息之后,如果可以通过消息查询功能检索到这条消...
通过 RocketMQ 消费 Canal Proto 格式的订阅数据
数据库传输服务 DTS 的数据订阅服务支持使用 RocketMQ 客户端消费 Canal Proto 格式的订阅数据。本文以订阅云数据库 MySQL 版实例为例,介绍如何使用 Go 和 Java 语言消费 Canal Proto 格式的数据。 前提条件已注册火山引擎账号并完成实名认证。详细操作,请参见如何进行账号注册和实名认证。 按需安装运行语言环境。 运行环境 说明 Go 语言 安装 Go,需使用 Go 1.13 或以上版本。 说明 您可以执行 go -version 查看 Go 的版本。...
