rocketmq配置实例
社区干货
使用golang调用RocketMQ SDK
# 前言本文档介绍使用go语言调用火山引擎RocketMQ SDK。# 关于实验- 预计部署时间:30分钟- 级别:初级- 相关产品:中间件-RocketMQ- 受众: 通用# 实验说明## 第一步、创建RocketMQ实例在控制台创建RocketMQ实例,并配置Topic、Group、以及秘钥,详见[RocketMQ创建文档](https://www.volcengine.com/docs/6410/70793)## 第二步 、配置golang代码```go/*Licensed to the Apache Software Foundation (ASF) under one or m...
RocketMQ 存储机制浅析
RocketMQ/Kafka/RabbitMQ 均采用的是消息刷盘至所部署虚拟机/物理机的文件系统做持久化。ActiveMQ(默认采用的 KahaDB 做消息存储)可选用 JDBC 做消息持久化,通过简单的 xml 配置信息即可实现 JDBC 消息存储。使用文... RocketMQ Broker 单个实例下所有的 Topic 都使用同一个 CommitLog 来存储,即单个实例消息整体有序。CommitLog 单个文件大小默认 1G,文件文件名是起始偏移量,总共 20 位,左边补零,起始偏移量是 0。假设文件按照默认...
如何解决使用RocketMQ的消息轨迹信息无法查看问题
友商阿里的迁移的代码中有会 AccessChannel.CLOUD 的配置,设置后也会导致查询异常,这个在友商云迁移过来的客户需要做代码的适配调整。# 代码示例1.在Java项目的pom.xml中添加以下依赖。指定版本 4.8.0```java org.apache.rocketmq rocketmq-client 4.8.0 org.apache.rocketmq rocketmq-acl 4.8.0 ```2. 生产者示例代码```javapackage org.example;import java.util.Date;import org.apache.rocketmq.acl.common.Acl...
mq元数据中的Topic和Group的名称导出到excel
# 问题描述如何将 RabbitMQ 元数据中的 Topic 和 Group 的名称导出到 excel。# 解决方案我们可以使用 API 脚本导出,您可以参考如下示例:```pythonimport datetimeimport hashlibimport hmacimport jsonfrom urllib.parse import quoteimport pandas as pdimport requestsService = "rocketmq"Version = "2021-04-01"#实例对应地域、host信息Region = "cn-beijing"Host = "rocketmq.volcengineapi.com"#配置对...
特惠活动
rocketmq配置实例-优选内容
rocketmq配置实例-相关内容
创建实例
创建实例后,不可更改实例所在的私有网络和子网。 如果需要通过公网访问消息队列 RocketMQ版实例,请先申请同地域的 EIP,建议该 EIP 的带宽上限大于预估的公网业务流量峰值。详细操作步骤请参考申请公网 IP。 操作步骤登录消息队列 RocketMQ版控制台。 在顶部菜单栏中选择需要创建实例的地域。 在实例列表页面左上角单击创建实例。 填写RocketMQ实例的基本配置信息。 参数 说明 实例名称 RocketMQ实例的名称。需满足以下要求...
参数说明
本文介绍您在使用 C++ SDK 接入火山引擎消息队列 RocketMQ版时,需要配置的参数。 消息发送参数参数 是否必选 说明 配置方式 setInstanceName 在单个进程启动多个客户端时必选 客户端标识(Client ID)。一个进程中需要创建多个 RocketMQ 客户端连接不同实例时,需要通过 InstanceName 区分客户端连接。 producer.setInstanceName("instance") setSendMsgTimeout 可选 发送消息的超时时间,时间单位 ms,默认 3000 ms。 pro...
延时消息
消息队列 RocketMQ版提供 TCP 协议下的 RocketMQ 开源 C++ SDK 的相关说明,本文档介绍收发延时消息的示例代码。 前提条件已完成准备工作。 已阅读参数说明,了解常用参数的配置方式与填写格式。 背景信息火山引擎提供了两种发送延时消息的方式,一种是特定延时时间,另一种是任意延时时间,其中任意精度的延时消息包括以下两种: 特定精度延时消息,只支持特定的 18 个等级。 C++ messageDelayLevel=1s 5s 10s 30s 1m 2m 3m 4m 5m 6m ...
为白名单绑定实例
白名单与 RocketMQ 实例绑定之后,仅配置在白名单中的 IP 地址与地址段才能访问消息队列 RocketMQ版实例。本文介绍为白名单绑定实例的操作步骤。 注意事项实例绑定多个白名单时,支持的 IP 地址范围取多个白名单的并集。 每个白名单最多绑定 200 个 RocketMQ 实例。 每个实例最多被 100 个白名单绑定。实例绑定的所有白名单的 IP 地址和 CIDR 格式的 IP 地址段之和不超过 1000。 如果 RocketMQ 实例从创建之日起,从未绑定过任何白名...
限制说明
消息队列 RocketMQ版对一些指标和性能进行了限制,请您在使用过程中注意不要超过相应的限制值,避免出现异常。 限制类型 配额 说明 实例数量 5 个 单个地域(Region)内的消息队列 RocketMQ版实例数。您也可以通过... 可配置为 1~72 小时。默认为 72 小时,即 3 天。 超出保留时长限制的消息将被过期清理。 死信消息最大保留时长 72 小时 死信消息在服务端的最大保留时长。 可配置为 1~72 小时。默认为 72 小时,即 3 天。 超出保...
创建 RocketMQ 触发器
函数服务支持对接火山引擎的 消息队列 RocketMQ 版。 通过创建 RocketMQ 触发器,函数服务将作为消费者消费 RocketMQ 中的消息,并将消息传递给用户函数,触发函数代码逻辑。您无需关心函数服务消费消息的细节,只需编写处理消息的函数。本文为您介绍如何创建 RocketMQ 触发器。 前提条件函数已开启 VPC 访问功能,详细操作可参见 更新函数配置。 函数至少完成一次全量发布,详细操作可参见 发布函数。 已创建 RocketMQ 实例、 Topi...
使用golang调用RocketMQ SDK
前言 本文档介绍使用go语言调用火山引擎RocketMQ SDK。 关于实验 预计部署时间:30分钟 级别:初级 相关产品:中间件-RocketMQ 受众: 通用 实验说明 第一步、创建RocketMQ实例在控制台创建RocketMQ实例,并配置Topic、Group、以及秘钥,详见RocketMQ创建文档 第二步 、配置golang代码go /*Licensed to the Apache Software Foundation (ASF) under one or morecontributor license agreements. See the NOTICE file distributed with...
跨可用区部署 RocketMQ 实例
跨可用区部署可提高实例的可用性,本文档介绍跨可用区部署方式对于实例的影响。 注意事项创建跨可用区部署的 RocketMQ 实例前,应确认以下问题: 部署 RocketMQ 客户端的 ECS 和 RocketMQ 实例所在的可用区应尽量一致,避免故障域不对等的问题。 跨可用区部署的实例可能会出现 2ms~3ms 的网络延迟,确认单请求时延上升对业务是否有影响。 客户端使用同步方式调用接口的情况下,实例的吞吐性能可能会下降,需要考虑预留一定的性能空间、升...
CreateInstance
调用 CreateInstance 接口创建 RocketMQ 实例。 注意事项请求频率:该接口请求频率限制为 100 次/秒;单用户请求频率限制为 20 次/秒。 使用说明实例是消息队列 RocketMQ版的基本服务单位,用以管理和存储 Topic、Gr... 例如提高每个地域下的最大实例数量(InstanceNum),最高可调整至 10 个。 请求参数参数 参数类型 是否必选 示例值 说明 ZoneId String 是 cn-shanghai-a 实例所在的可用区 ID。消息队列 RocketMQ版实例支持...
