rocketmq批量
社区干货
RocketMQ 存储机制浅析
ActiveMQ(默认采用的 KahaDB 做消息存储)可选用 JDBC 做消息持久化,通过简单的 xml 配置信息即可实现 JDBC 消息存储。使用文件系统做持久化的情况下,可获得更高效的 I/O 读写。* Broker Store 目录结构``` storePathRootDir=/cache1/rocketmq/broker/data ├── abort // 该文件在 Broker 启动后会自动创建,正常关闭 Broker,该文件会自动消失。若在没有启动 Broker 的情况下,发现这个文件是存...
打造新一代云原生"消息、事件、流"统一消息引擎的融合处理平台 | 社区征文
RocketMQ基于大规模云计算环境的实践经验(例如,阿里(双十一、双十二)、携程(过年高峰期)),辅助了成千上万的企业完成数字化转型,从而实现了从互联网消息中间件到云原生消息中间件的发展变革。RocketMQ与其他消息中间... 比如RabbitMQ无法水平扩展单队列能力、Kafka扩容需要大量数据拷贝和均衡。这些现有解决方案都不适用于为大规模客户提供弹性服务的公共云环境。![picture.image](https://p6-volc-community-sign.byteimg.com/to...
如何解决使用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...
使用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批量-相关内容
DeleteTopicsFromAuthKey
调用 DeleteTopicsFromAuthKey 接口删除指定 RocketMQ 密钥中的自定义权限。 注意事项请求频率:该接口请求频率限制为 100 次/秒;单用户请求频率限制为 20 次/秒。 使用说明此接口支持批量删除指定 RocketMQ 密钥中的多个自定义权限。 请求参数参数 参数类型 是否必选 示例值 说明 InstanceId String 必选 MQ_INST_******** 实例 ID。 Ak String 必选 ak**** RocketMQ 密钥中的 AccessKey ID。 Topics List 必选...
RocketMQ 消费者使用建议
本文档介绍 RocketMQ 消费者的使用建议,推荐在使用消息队列 RocketMQ版进行消息生产与消费之前,阅读以下使用建议,提高接入效率和业务稳定性。 消费过程幂等RocketMQ 无法保证消息只被消费一次(Exactly-Once),即无法避免消息重复,主要由于以下原因: 消息发送失败时会重试 消费者批量消费,消费进度上报时回上报最小的 offset。 支持重置消费进度如果业务对消费重复非常敏感,务必要在业务层面进行去重处理,例如借助关系数据库进行去...
AssociateAllowList
调用 AssociateAllowList 绑定实例与白名单。 注意事项请求频率:该接口请求频率限制为 100 次/秒;单用户请求频率限制为 20 次/秒。 接口说明此接口用于为实例绑定白名单,支持批量操作。 请求参数名称 类型 是否必选 示例值 描述 AllowListIds Array of String 是 ["acl-90c721ca3f1648e7b9803xxxxxxx"] 需要绑定的白名单 ID 列表。 InstanceIds Array of String 是 ["rocketmq-cnai1f0c29ca****","rocketmq-cnai1f...
DisassociateAllowList
调用 DisassociateAllowList 解绑实例与白名单。 注意事项请求频率:该接口请求频率限制为 100 次/秒;单用户请求频率限制为 20 次/秒。 接口说明此接口用于为实例解绑白名单,支持批量操作。 请求参数名称 类型 是否必选 示例值 描述 AllowListIds Array of String 是 ["acl-90c721ca3f1648e7b9803xxxxxxx"] 待解绑的白名单 ID 列表。 InstanceIds Array of String 是 ["rocketmq-cnai1f0c29ca****","rocketmq-cnai1...
批量导入 Topic
在应用迁移上云或实例备份等场景下,如果需要一次性创建多个 Topic,可以通过控制台上传配置文件的方式批量创建 Topic。本文档介绍批量导入 Topic 的操作步骤。 背景信息在应用迁移上云或实例备份等场景下,需要在新实例中创建一批和源端 Topic 配置相同的 Topic,例如相同的 Topic 名称、描述、队列数、消息类型。消息队列 RocketMQ版支持通过控制台上传模板文件的方式批量创建 Topic。您可以从控制台上下载 Topic 模板文件,然后根据...
批量导入 Group
在应用迁移上云或实例备份等场景下,如果需要一次性创建多个 Group,可以通过控制台上传 Group 模板文件的方式批量创建 Group。本文档介绍批量导入 Group 的操作步骤。 背景信息在应用迁移上云或实例备份等场景下,需要在新实例中创建一批和源端 Group 配置相同的 Group,例如相同的 Group ID 与描述。消息队列 RocketMQ版支持通过控制台上传模板文件的方式批量创建 Group。您可以从控制台上下载 Group 模板文件,然后根据格式填写 Gr...
CreateTopic
调用 CreateTopic 接口创建 Topic。 注意事项请求频率:该接口请求频率限制为 100 次/秒;单用户请求频率限制为 20 次/秒。 使用说明在RocketMQ 实例中,Topic 是消息发送与接收的基本单元,消息队列 RocketMQ版通过 ... 保留字符:RMQ_SYS_TRANS_OP_HALF_TOPIC、BenchmarkTest、TBW102、OFFSET_MOVED_EVENT、SELF_TEST_TOPIC、RMQ_SYS_TRANS_HALF_TOPIC、SCHEDULE_TOPIC_XXXX、RMQ_SYS_TRACE_TOPIC 特殊前缀:rocketmq-broker-、%RETRY...
创建 Topic
本文介绍创建 Topic 的操作步骤。 背景信息在RocketMQ 实例中,Topic 是消息发送与接收的基本单元,消息队列 RocketMQ版通过 Topic 对各类消息进行分类管理。消息的生产者将消息发送到 RocketMQ Topic 中,而消息的消... 保留字符:RMQ_SYS_TRANS_OP_HALF_TOPIC、BenchmarkTest、TBW102、OFFSET_MOVED_EVENT、SELF_TEST_TOPIC、RMQ_SYS_TRANS_HALF_TOPIC、SCHEDULE_TOPIC_XXXX、RMQ_SYS_TRACE_TOPIC 特殊前缀:rocketmq-broker-、%RETRY...
定时消息和延时消息
消息队列 RocketMQ版提供 TCP 协议下的 RocketMQ 开源 Java SDK 的相关说明,本文档介绍收发定时消息和延时消息的示例代码。 背景信息如果发送消息到消息队列 RocketMQ版服务端后,不希望立即投递消息,可以使用定时或... 使用批量方式发送的消息暂不支持设置定时或延迟能力。 发送定时或延时消息RocketMQ 开源 Java SDK 发送定时消息或延时消息的示例代码如下。 Java try { Message msg = new Message("YOUR TOPIC", /...
