rocketmq应用案例
社区干货
使用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 存储机制浅析
ActiveMQ(默认采用的 KahaDB 做消息存储)可选用 JDBC 做消息持久化,通过简单的 xml 配置信息即可实现 JDBC 消息存储。使用文件系统做持久化的情况下,可获得更高效的 I/O 读写。* Broker Store 目录结构``` storePathRootDir=/cache1/rocketmq/broker/data ├── abort // 该文件在 Broker 启动后会自动创建,正常关闭 Broker,该文件会自动消失。若在没有启动 Broker 的情况下,发现这个文件是存...
如何解决使用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基于大规模云计算环境的实践经验(例如,阿里(双十一、双十二)、携程(过年高峰期)),辅助了成千上万的企业完成数字化转型,从而实现了从互联网消息中间件到云原生消息中间件的发展变革。RocketMQ与其他消息中间...
特惠活动
rocketmq应用案例-优选内容
rocketmq应用案例-相关内容
CreateInstance
调用 CreateInstance 接口创建 RocketMQ 实例。 注意事项请求频率:该接口请求频率限制为 100 次/秒;单用户请求频率限制为 20 次/秒。 使用说明实例是消息队列 RocketMQ版的基本服务单位,用以管理和存储 Topic、Gr... 响应参数参数 参数类型 示例值 说明 InstanceId String MQ_INST_******** 实例 ID。 OrderId String 订单 ID。 示例 请求示例json POST https://rocketmq.volcengineapi.com/?Action=CreateInstan...
创建实例
应用接入消息队列 RocketMQ版之前,需要在控制台创建 RocketMQ 实例。消息队列 RocketMQ版提供多种实例规格,对应不同的计算能力和存储空间,您可以根据实际业务需求选择不同的实例规格。本文档介绍创建 RocketMQ 实例的操作步骤。 说明 默认情况下,您可以在每个地域中创建 5 个 RocketMQ 实例,且每个账号在每个地域中的所有实例存储容量总和最大为 10TiB,否则创建实例时报错 The InstanceNum/StorageSum has exceeded quota。如需提...
通过 RocketMQ 消费 Canal Proto 格式的订阅数据
数据库传输服务 DTS 的数据订阅服务支持使用 RocketMQ 客户端消费 Canal Proto 格式的订阅数据。本文以订阅云数据库 MySQL 版实例为例,介绍如何使用 Go 和 Java 语言消费 Canal Proto 格式的数据。 前提条件已注册... import org.apache.rocketmq.client.consumer.DefaultMQPushConsumer; import org.apache.rocketmq.client.consumer.listener.*; import org.apache.rocketmq.common.message.MessageExt; import org.apache.rocke...
DescribeInstanceDetail
调用 DescribeInstanceDetail 接口查看指定实例的详情。 注意事项请求频率:该接口请求频率限制为 100 次/秒;单用户请求频率限制为 20 次/秒。 使用说明创建 RocketMQ 实例后,您可以调用 DescribeInstanceDetail 接口查看指定实例的名称、网络类型等详细信息。请求参数 参数 参数类型 是否必选 示例值 说明 InstanceId String 是 rocketmq-cnai1f0c29ca**** 待查询详情的实例 ID。 响应参数参数 参数类型 示例值 说...
DescribeAccessKeys
调用 DescribeAccessKeys 接口查询 RocketMQ 密钥列表。 注意事项请求频率:该接口请求频率限制为 40 次/秒;单用户请求频率限制为 8 次/秒。 使用说明此接口用于查看指定实例的 RocketMQ 密钥列表,也可用于查看某一... "AclConfigJson": "{\"topicPerms\":{\"RMQ_SYS_TRACE_TOPIC\":\"PUB\",\"rocketmq123\":\"PUBSUB\"},\"groupPerms\":{\"GID_test\":\"PUBSUB\"}}", "Actived": true, ...
为白名单绑定实例
白名单与 RocketMQ 实例绑定之后,仅配置在白名单中的 IP 地址与地址段才能访问消息队列 RocketMQ版实例。本文介绍为白名单绑定实例的操作步骤。 注意事项实例绑定多个白名单时,支持的 IP 地址范围取多个白名单的并集。 每个白名单最多绑定 200 个 RocketMQ 实例。 每个实例最多被 100 个白名单绑定。实例绑定的所有白名单的 IP 地址和 CIDR 格式的 IP 地址段之和不超过 1000。 如果 RocketMQ 实例从创建之日起,从未绑定过任何白名...
API 概览
消息队列 RocketMQ版提供以下相关 API 接口。 实例管理API 说明 CreateInstance 调用 CreateInstance 接口创建RocketMQ实例。 DeleteInstance 调用 DeleteInstance 接口删除实例。 GetInstance 调用 GetInstance 接口查看指定RocketMQ实例的详细信息。 ListInstances 调用 ListInstances 接口查看当前账号在当前地域下的所有RocketMQ实例信息。 ScaleInstance 调用 ScaleInstance 接口变更实例规格。 EnablePublicN...
转包年包月
创建按量计费实例之后,您可以根据业务需求,在控制台中变更计费模式为包年包月。本文介绍按量计费实例转包年包月实例的操作步骤。 前提条件RocketMQ实例的状态为运行中。 实例的计费方式为按量计费。 注意事项按量计费转包年包月时,您需要结算此按量计费实例的账单,并预付包年包月的金额。请确保账户中余额充足。 变更实例的计费类型对实例的运行不会有任何影响。 目前仅支持按量计费转包年包月,一旦转移成功则不可逆转,请谨慎操作...
定时消息和延时消息
火山引擎消息队列 RocketMQ版提供了两种发送延时消息的方式,一种是特定延时时间,另一种是任意延时时间。您可以通过消息属性中的定时时间实现消息的定时发送,其中任意精度的延时消息包括以下两种。 特定精度延时消息,只支持特定的 18 个等级。 Python messageDelayLevel=1s 5s 10s 30s 1m 2m 3m 4m 5m 6m 7m 8m 9m 10m 20m 30m 1h 2h 任意精度延时消息:对于 2023年2月21日之后创建的 RocketMQ 实例,建议通过属性 __STARTDELIVERTI...
