rocketmq服务治理
社区干货
打造新一代云原生"消息、事件、流"统一消息引擎的融合处理平台 | 社区征文
Apache RocketMQ经历了12年的发展历程,可以被划分为两个阶段:互联网时期的诞生和云计算时期的成长。### 互联网时期的诞生RocketMQ是2011年诞生于淘宝核心电商系统,一开始是定位于服务集团业务,面向单一超大规模... 比如RabbitMQ无法水平扩展单队列能力、Kafka扩容需要大量数据拷贝和均衡。这些现有解决方案都不适用于为大规模客户提供弹性服务的公共云环境。可选用 JDBC 做消息持久化,通过简单的 xml 配置信息即可实现 JDBC 消息存储。使用文件系统做持久化的情况下,可获得更高效的 I/O 读写。* Broker Store 目录结构``` storePathRootDir=/cache1/rocketmq/broker/data ├── abort // 该文件在 Broker 启动后会自动创建,正常关闭 Broker,该文件会自动消失。若在没有启动 Broker 的情况下,发现这个文件是存...
干货|字节跳动流式数据集成基于Flink Checkpoint两阶段提交的实践和优化(2)
> > > 字节跳动开发套件数据集成团队(DTS ,Data Transmission Service)在字节跳动内基于 Flink 实现了流批一体的数据集成服务。其中一个典型场景是 Kafka/ByteMQ/RocketMQ -> HDFS/Hive 。Kafka/ByteMQ/RocketMQ... 目前已通过火山引擎数据产品大数据研发治理套件 DataLeap 向[外部企业输出](http://mp.weixin.qq.com/s?__biz=MzkwMzMwOTQwMg==&mid=2247484008&idx=1&sn=11617fd316f5a36f87362d0ab974229e&chksm=c099735df7eefa...
干货|字节跳动流式数据集成基于Flink Checkpoint两阶段提交的实践和优化(1)
> > 字节跳动开发套件数据集成团队(DTS ,Data Transmission Service)在字节跳动内基于 Flink 实现了流批一体的数据集成服务。其中一个典型场景是 Kafka/ByteMQ/RocketMQ -> HDFS/Hive 。Kafka/ByteMQ/RocketMQ ->... **火山引擎大数据研发治理套件DataLeap**一站式数据中台套件,帮助用户快速完成数据集成、开发、运维、治理、资产、安全等全套数据中台建设,帮助数据团队有效的降低工作成本和数据维护成本、挖掘数据价值、为企...
特惠活动
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版是火山引擎基于 Apache RocketMQ 构建的低延迟、高并发、高可用、高可靠的分布式消息中间件。本文介绍使用消息队列 RocketMQ版进行消息收发之前,需要完成的准备工作。 1 准备账号开通服务之前,您需要注册一个火山引擎账号,并完成企业实名认证。对于计费类型为“按量计费”类型的 RocketMQ 实例,需要保证账户余额不低于 100 元才能正常创建和使用。 创建火山引擎账号。详细操作请参考注册账号。 完成企业认证。...
跨服务访问授权
首次使用消息队列 RocketMQ版之前,您需要进行跨服务授权,允许消息队列 RocketMQ版访问当前账号下的其他服务资源,例如 VPC 等。本文介绍跨服务访问授权的相关操作步骤。 注意事项仅首次创建 RocketMQ 实例之前需要进行跨服务访问授权,完成授权后 RocketMQ 可以持续访问其他服务中的资源,直至删除服务关联角色。 服务关联角色的权限由系统生成,无法变更权限。若您需要取消授权,请删除角色。 建议通过火山引擎主账号完成跨服务访问授...
定时消息和延时消息
消息队列 RocketMQ版提供 TCP 协议下的 RocketMQ 开源 Go SDK 的相关说明,本文档介绍收发定时消息和延时消息的示例代码。 背景信息如果发送消息到消息队列 RocketMQ版服务端后,不希望立即投递消息,可以使用定时或延时消息,根据消息中指定的属性延迟一定时间投递或指定时间点投递至消费端。其中,推迟到后续的某个指定时间再投递到消费端进行消费的消息为定时消息。推迟一定时间再投递到消费端进行消费的消息为延时消息,例如指定在...
消息轨迹
本文介绍如何查看消息轨迹。 背景信息当一条消息从生产者发送到消息队列 RocketMQ版服务端,再由消费者进行消费,消息队列 RocketMQ版会完整记录消息的全链路流转过程,并以消息轨迹的形式呈现在消息队列 RocketMQ版控... DefaultMQProducer producer = new DefaultMQProducer("ProducerGroupName", aclHook,true,null); 消费者开启消息轨迹: Java AclClientRPCHook aclHook = new AclClientRPCHook(new SessionCredentials(ACL_ACCESS...
定时消息和延时消息
消息队列 RocketMQ版提供 TCP 协议下的 RocketMQ 开源 Python SDK 的相关说明,本文档介绍收发定时消息和延时消息的示例代码。 背景信息如果发送消息到消息队列 RocketMQ版服务端后,不希望立即投递消息,可以使用定时或延时消息,根据消息中指定的属性延迟一定时间投递或指定时间点投递至消费端。其中,推迟到后续的某个指定时间再投递到消费端进行消费的消息为定时消息。推迟一定时间再投递到消费端进行消费的消息为延时消息,例如指...
基于 IAM 管理权限
访问控制 IAM(Identity and Access Management)是火山引擎提供的权限管理服务,用于控制不同身份对云资源的访问权限。本文档介绍通过 IAM 服务管理消息队列 RocketMQ版资源的方式。 应用场景企业用户使用火山引擎消息队列 RocketMQ版时,如果需要集中或统一管理某些资源,会选择在一个火山引擎账号下创建所有需要的资源。企业中各个岗位需要使用的火山引擎服务和资源不同,出于数据安全与权限隔离的的考虑,火山引擎账号下的所有资源应...
迁移概述
本指南主要为用户提供 RocketMQ 的迁移方案建议与操作指导。 背景信息火山引擎基于Apache RocketMQ 构建了稳定、安全的消息队列 RocketMQ版。与和开源 RocketMQ 相比,消息队列 RocketMQ版支持 VPC 访问,免部署免运... RocketMQ版集群中,迁移时可以通过云监控检查每个步骤的执行情况,确保无消息堆积、业务无影响无感知。 迁移方案如果您的 RocketMQ 为集群化部署,建议采用分批发布方案来迁移消息服务,即通过逐台操作的方式进行迁移,...
定时消息和延时消息
消息队列 RocketMQ版提供 TCP 协议下的 RocketMQ 开源 Java SDK 的相关说明,本文档介绍收发定时消息和延时消息的示例代码。 背景信息如果发送消息到消息队列 RocketMQ版服务端后,不希望立即投递消息,可以使用定时或延时消息,根据消息中指定的属性延迟一定时间投递或指定时间点投递至消费端。其中,推迟到后续的某个指定时间再投递到消费端进行消费的消息为定时消息。推迟一定时间再投递到消费端进行消费的消息为延时消息,例如指定...
