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://p3-volc-community-sign.byteimg.com/to...
# 前言本文档介绍使用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 正常生产和消费消息,但是消费轨迹无法查看的问题该如何排查?# 问题分析此类问题原因一般如下: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版是火山引擎基于 Apache RocketMQ 构建的分布式消息中间件服务,完全兼容开源 RocketMQ 的各个组件与概念,同时具备低延迟、弹性高可靠、高吞吐等特性优势,业务代码无需改造,帮助用户快速迁移上云。 产品功能多种消费类型:消息队列 RocketMQ版提供灵活、可扩展性强的消费主题模式设置,支持发布/订阅、集群消费和广播消费模式。 多种消息类型:消息队列 RocketMQ版支持丰富的消息类型,支持顺序消息、事务消息、定...
消息队列 RocketMQ版是一款基于 Apache RocketMQ 构建的分布式消息中间件服务,完全兼容开源 RocketMQ 客户端。消息队列 RocketMQ版具备低延迟、弹性高可靠、高吞吐等特性优势,支持顺序、延迟、定时、重投、死信消息等功能,完美适配电商大促等业务场景
本文将为您介绍消息队列 RocketMQ版控制台创建 RocketMQ 实例、Group 和 Topic 的操作步骤。 准备工作已开通消息队列 RocketMQ版,并进行了相关环境准备。创建的 RocketMQ 实例运行于私有网络中,在创建前确保已存在可用的私有网络和子网,详情请参见环境准备。 如果需要通过公网访问消息队列 RocketMQ版实例,请先申请同地域的 EIP,建议该 EIP 的带宽上限大于预估的公网业务流量峰值。详细操作步骤请参考申请公网 IP。 1 创建实例说...
本文档介绍 RocketMQ 客户端的使用建议,推荐在使用消息队列 RocketMQ版进行消息生产与消费之前,阅读以下使用建议,提高接入效率和业务稳定性。 日志配置RocketMQ 的日志一般是单独配置的,业务日志独立管理。日志默认保存在 ${user.home}/logs/rocketmqlogs 目录的 10 个文件中,每个文件大小为 1G,日志文件名为 rocketmq_client.log。有些业务的用户目录的磁盘空间不大,很容易造成磁盘空间不足。您可以通过设置系统变量的方式配置 ...
本文档介绍 RocketMQ 生产者的使用建议,推荐在使用消息队列 RocketMQ版进行消息生产与消费之前,阅读以下使用建议,提高接入效率和业务稳定性。 消息 Tag建议组合使用 Topic 和 tags,以减少 Topic 的使用。 Tag 可以由应用自行设置。 仅当生产者在发送消息时设置了 Tag,消费者在订阅消息时才可以利用 Tag 进行消息过滤,例如 message.setTags("TagA")。消费者在 Broker 侧根据 Tag 的 hashcode 进行初步过滤,在消费端根据字符串过滤...
本文档介绍 RocketMQ 消费者的使用建议,推荐在使用消息队列 RocketMQ版进行消息生产与消费之前,阅读以下使用建议,提高接入效率和业务稳定性。 消费过程幂等RocketMQ 无法保证消息只被消费一次(Exactly-Once),即无法避免消息重复,主要由于以下原因: 消息发送失败时会重试 消费者批量消费,消费进度上报时回上报最小的 offset。 支持重置消费进度如果业务对消费重复非常敏感,务必要在业务层面进行去重处理,例如借助关系数据库进行去...
消息队列 RocketMQ版提供以下相关 API 接口。 实例管理API 说明 CreateInstance 调用 CreateInstance 接口创建RocketMQ实例。 DeleteInstance 调用 DeleteInstance 接口删除实例。 GetInstance 调用 GetInstance 接口查看指定RocketMQ实例的详细信息。 ListInstances 调用 ListInstances 接口查看当前账号在当前地域下的所有RocketMQ实例信息。 ScaleInstance 调用 ScaleInstance 接口变更实例规格。 EnablePublicN...
本文介绍 RocketMQ 业务迁移的操作步骤,您可以参考本文档将自建 RocketMQ 集群或其他云厂商 RocketMQ 集群迁移至火山引擎消息队列 RocketMQ版。 注意事项由于 Producer 和 Consumer 为集群化部署,迁移时可以分批操作,上层业务无感知。分批迁移过程中,可以在火山引擎云监控服务控制台监控业务相关流量数据,确认业务正常运行。 如果有多个 RocketMQ 实例需要迁移到同一个消息队列 RocketMQ版实例中,请依次进行迁移。 如果使用延时...
消息队列 RocketMQ版提供 TCP 协议下的 RocketMQ 开源 Java SDK 的相关说明,本文档介绍收发定时消息和延时消息的示例代码。 背景信息如果发送消息到消息队列 RocketMQ版服务端后,不希望立即投递消息,可以使用定时或延时消息,根据消息中指定的属性延迟一定时间投递或指定时间点投递至消费端。其中,推迟到后续的某个指定时间再投递到消费端进行消费的消息为定时消息。推迟一定时间再投递到消费端进行消费的消息为延时消息,例如指定...