rocketmq怎么设计
社区干货
RocketMQ 存储机制浅析
RocketMQ 优异的性能表现,绕不开其优秀的存储模型 。下文将从 RocketMQ 存储机制设计展开介绍。可选用 JDBC 做消息持久化,通过简...
打造新一代云原生"消息、事件、流"统一消息引擎的融合处理平台 | 社区征文
云原生架构可以理解为是云计算中天生的设计模式,它的“生命力”源自云计算技术,没有云计算,谈论云原生架构就如同空谈理论。# RocketMQ的云原生架构实现在过去的数年中,RocketMQ基于大规模云计算环境的实践经验... 比如RabbitMQ无法水平扩展单队列能力、Kafka扩容需要大量数据拷贝和均衡。这些现有解决方案都不适用于为大规模客户提供弹性服务的公共云环境。
> > > 字节跳动开发套件数据集成团队(DTS ,Data Transmission Service)在字节跳动内基于 Flink 实现了流批一体的数据集成服务。其中一个典型场景是 Kafka/ByteMQ/RocketMQ -> HDFS/Hive 。Kafka/ByteMQ/RocketMQ -> HDFS/Hive(下面均称之为 MQ dump,具体介绍可见> 字节跳动基于Flink的MQ-Hive实时数据集成> 在数仓建设第一层,对数据的准确性和实时性要求比较高。> > > > , producer.WithCredentials(primitive.Cre...
特惠活动
rocketmq怎么设计-优选内容
rocketmq怎么设计-相关内容
CreateAuthKey
RocketMQ 密钥。 注意事项请求频率:该接口请求频率限制为 10 次/秒;单用户请求频率限制为 2 次/秒。 使用说明消息队列 RocketMQ版支持开源 ACL 权限控制,通过密钥提供 Topic 资源级别的访问控制与权限管理,不同的密钥具备不同的 Topic 访问权限。密钥由 AccessKey ID 与对应的 AccessKey Secret 组成。目前每个实例最多可创建 100 个密钥。 请求参数参数 参数类型 是否必选 示例值 说明 InstanceId String 必选 MQ_INST_...
API 概览
消息队列 RocketMQ版提供以下相关 API 接口。 实例管理API 说明 CreateInstance 调用 CreateInstance 接口创建RocketMQ实例。 DeleteInstance 调用 DeleteInstance 接口删除实例。 GetInstance 调用 GetInstance 接口查看指定RocketMQ实例的详细信息。 ListInstances 调用 ListInstances 接口查看当前账号在当前地域下的所有RocketMQ实例信息。 ScaleInstance 调用 ScaleInstance 接口变更实例规格。 EnablePublicN...
配置 RocketMQ 数据源
RocketMQ 数据源为您提供实时读取 RocketMQ 的单向通道能力,实现从 RocketMQ 读取数据,实时同步至不同目标数据源中,进行数据传输。本文为您介绍 DataSail 的 RocketMQ 数据同步的能力支持情况。 1 支持的 RocketMQ... 您需将独享集成资源组和 RocketMQ 数据库节点网络打通,详见网络连通解决方案。 若通过 VPC 网络访问,则独享集成资源组所在 VPC 中的 IPv4 CIDR 地址,需加入到 BMQ 访问白名单中:确认集成资源组所在的 VPC: 查看 VP...
CreateTopic
调用 CreateTopic 接口创建 Topic。本接口会在实例下创建一个 RocketMQ 的 Topic,用户可使用该 Topic 发布和订阅消息。 注意事项请求频率:该接口请求频率限制为 100 次/秒;单用户请求频率限制为 20 次/秒。 请求参数参数 参数类型 是否必选 示例值 说明 InstanceId String 必选 MQ_INST_******** 实例 ID。 TopicName String 必选 需创建的 Topic 的名称,取值说明如下:长度限制为3~64个字符,只能包含英文字母、数...
创建密钥
消息队列 RocketMQ版支持开源 ACL 权限控制,通过密钥提供 Topic 资源级别的访问控制与权限管理,不同的密钥具备不同的 Topic 访问权限。 背景信息权限控制(ACL)主要为 RocketMQ 实例提供 Topic 资源级别的用户访问控制。火山引擎消息队列 RocketMQ版通过密钥管理 Topic 权限,密钥由 AccessKey ID 与对应的 AccessKey Secret 组成,用于访问实例、生产消费时的鉴权与身份认证。创建密钥时需要指定密钥的默认权限,默认权限对实例中所...
RocketMQ 存储机制浅析
RocketMQ 优异的性能表现,绕不开其优秀的存储模型 。下文将从 RocketMQ 存储机制设计展开介绍。可选用 JDBC 做消息持久化,通过简...
GetInstance
请求参数参数 参数类型 是否必选 示例值 说明 InstanceId String 必选 MQ_INST_******* 实例 ID。 响应参数参数 参数类型 说明 Instance InstanceDetail RocketMQ实例的详细信息。详细信息请参考 InstanceDetail。 示例 请求示例json POST https://rocketmq.volcengineapi.com/?Action=GetInstance&Version=2021-04-01 HTTP/1.1Accept: application/jsonContent-Type: application/jsonHost: rocketmq.volcen...
消息队列 RocketMQ版生成消息轨迹
前言 在本教程中,您将学习如何使用JAVA开源SDK在火山消息队列 RocketMQ版上生成消息轨迹。 关于实验 预计部署时间:30分钟级别:初级相关产品:消息队列 RocketMQ版 云服务器受众: 通用 环境说明 如果还没有火山引擎账... 配置文件MqConfig文件如下 undefined /** * * Licensed under the Apache License, Version 2.0 (the License ); * you may not use this file except in compliance with the License. * You may obtain a copy ...
设置公网访问与 SSL 认证策略
通过公网访问 RocketMQ 实例之前,需要先开启该实例的公网访问功能。如果创建实例时未开启公网访问,请参考本文档设置。 背景信息开启公网访问后,消息队列 RocketMQ版为实例提供公网接入点,用于客户端通过公网访问 RocketMQ 实例。开启公网访问时,支持设置 SSL 连接策略,可以同时支持 SSL 连接和非 SSL 连接。目前支持客户端对服务端证书的 SSL 单向认证,数据加密传输,相较于普通公网访问方式具备更高的安全性,但实例性能会有所下降...
