rocketmq丁威
社区干货
RocketMQ 存储机制浅析
ActiveMQ(默认采用的 KahaDB 做消息存储)可选用 JDBC 做消息持久化,通过简单的 xml 配置信息即可实现 JDBC 消息存储。使用文件系统做持久化的情况下,可获得更高效的 I/O 读写。* Broker Store 目录结构``` storePathRootDir=/cache1/rocketmq/broker/data ├── abort // 该文件在 Broker 启动后会自动创建,正常关闭 Broker,该文件会自动消失。若在没有启动 Broker 的情况下,发现这个文件是存...
使用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 正常生产和消费消息,但是消费轨迹无法查看的问题该如何排查?# 问题分析此类问题原因一般如下: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与其他消息中间... 比如RabbitMQ无法水平扩展单队列能力、Kafka扩容需要大量数据拷贝和均衡。这些现有解决方案都不适用于为大规模客户提供弹性服务的公共云环境。
特惠活动
rocketmq丁威-优选内容
rocketmq丁威-相关内容
DescribeAccessKeys
调用 DescribeAccessKeys 接口查询 RocketMQ 密钥列表。 注意事项请求频率:该接口请求频率限制为 40 次/秒;单用户请求频率限制为 8 次/秒。 使用说明此接口用于查看指定实例的 RocketMQ 密钥列表,也可用于查看某一... "AclConfigJson": "{\"topicPerms\":{\"RMQ_SYS_TRACE_TOPIC\":\"PUB\",\"rocketmq123\":\"PUBSUB\"},\"groupPerms\":{\"GID_test\":\"PUBSUB\"}}", "Actived": true, ...
CreateInstance
调用 CreateInstance 接口创建 RocketMQ 实例。 注意事项请求频率:该接口请求频率限制为 100 次/秒;单用户请求频率限制为 20 次/秒。 使用说明实例是消息队列 RocketMQ版的基本服务单位,用以管理和存储 Topic、Group 资源。 如果是首次创建 RocketMQ 实例,您需要先完成跨服务访问授权,建议通过火山引擎主账号操作。详细说明请参考跨服务访问授权。 如果需要通过私有网络访问消息队列 RocketMQ版实例,请先在相同地域创建 ECS 云服...
RocketMQ 客户端使用建议
本文档介绍 RocketMQ 客户端的使用建议,推荐在使用消息队列 RocketMQ版进行消息生产与消费之前,阅读以下使用建议,提高接入效率和业务稳定性。 日志配置RocketMQ 的日志一般是单独配置的,业务日志独立管理。日志默认保存在 ${user.home}/logs/rocketmqlogs 目录的 10 个文件中,每个文件大小为 1G,日志文件名为 rocketmq_client.log。有些业务的用户目录的磁盘空间不大,很容易造成磁盘空间不足。您可以通过设置系统变量的方式配置 ...
ModifyAccessKeyAllAuthority
调用 ModifyAccessKeyAllAuthority 接口修改 RocketMQ 密钥的默认权限。 注意事项请求频率:该接口请求频率限制为 40 次/秒;单用户请求频率限制为 8 次/秒。 使用说明此接口用于修改指定 RocketMQ 密钥的默认权限,此权限默认对实例中所有的 Topic 生效。如果您需要更为精细的权限粒度管控,也可以通过 ModifyAccessKeyAuthority 接口为密钥添加自定义权限,设置该密钥对于指定 Topic 的权限策略。 请求参数参数 参数类型 是否必选...
DeleteAccessKey
调用 DeleteAccessKey 接口删除 RocketMQ 密钥。 注意事项请求频率:该接口请求频率限制为 20 次/秒;单用户请求频率限制为 4 次/秒。 使用说明无需使用某个 RocketMQ 密钥时,出于业务和数据安全,建议您及时删除密钥。 请求参数参数 参数类型 是否必选 示例值 说明 InstanceId String 是 rocketmq-cnai1f0c29ca**** 实例 ID。 AccessKey String 是 2QdEgrGc97AL1p38Fq13**** 待删除的 RocketMQ 密钥 AccessKey ID。创...
为消息队列 RocketMQ 版集成 DNS 高可用插件
本文档介绍如何在火山引擎消息队列 RocketMQ 版的 Golang 客户端中集成 dns-stale-cache 插件。 前提条件您的 Golang 必须是 1.18 或更高版本。 您的 RocketMQ 客户端使用的 rocketmq-client-go SDK 必须是 v2 版本... ( "fmt" "os" "github.com/apache/rocketmq-client-go/v2/producer" . "github.com/volcengine/dns-stale-cache/common" . "github.com/volcengine/dns-stale-cache/rocketmq/v2")func NewMQ() { ...
设置公网访问与 SSL 认证策略
通过公网访问 RocketMQ 实例之前,需要先开启该实例的公网访问功能。如果创建实例时未开启公网访问,请参考本文档设置。 背景信息开启公网访问后,消息队列 RocketMQ版为实例提供公网接入点,用于客户端通过公网访问 RocketMQ 实例。开启公网访问时,支持设置 SSL 连接策略,可以同时支持 SSL 连接和非 SSL 连接。目前支持客户端对服务端证书的 SSL 单向认证,数据加密传输,相较于普通公网访问方式具备更高的安全性,但实例性能会有所下降...
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 消费 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...
