rocketmq页面
社区干货
如何解决使用RocketMQ的消息轨迹信息无法查看问题
# 问题描述RocketMQ 正常生产和消费消息,但是消费轨迹无法查看的问题该如何排查?# 问题分析此类问题原因一般如下:1. 客户端 SDK 使用的版本不对, 需要使用 SDK 版本为 4.8.0, 4.7 和 4.9 的版本均会导致前端页面报错如下图:2. 生产端和消费端没有开启消费轨迹功能,enableMsgTrace 需要设置为 true,* ...
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与其他消息中间... 比如RabbitMQ无法水平扩展单队列能力、Kafka扩容需要大量数据拷贝和均衡。这些现有解决方案都不适用于为大规模客户提供弹性服务的公共云环境。
特惠活动
rocketmq页面-优选内容
rocketmq页面-相关内容
跨服务访问授权
首次使用消息队列 RocketMQ版之前,您需要进行跨服务授权,允许消息队列 RocketMQ版访问当前账号下的其他服务资源,例如 VPC 等。本文介绍跨服务访问授权的相关操作步骤。 注意事项仅首次创建 RocketMQ 实例之前需要进... RocketMQ 角色,该角色具备预设的一系列权限策略,允许消息队列 RocketMQ版访问您账号下的其他服务资源。 操作步骤登录消息队列 RocketMQ版控制台。 在顶部菜单栏中选择需要创建实例的地域。 在实例列表页面左上角...
准备工作
在运行 RocketMQ 开源版本 C++ SDK 代码收发消息前,您需按照本文提供的步骤来准备开发环境。 1 安装动态库您可以参考 GitHub 完成 RocketMQ-Client-CPP 的安装部署。 2 创建资源接入消息队列 RocketMQ版收发消息前... 例如MQ_INST_85bclzugcfkd_nxxxx%demo-group。详细说明请参考注意事项。 创建 RocketMQ 实例,并记录接入点地址。详细操作步骤请参考创建实例。创建实例后,您可以在实例的概览页面服务访问区域中查看接入点的信息。...
普通消息
火山引擎消息队列 RocketMQ版提供同步发送和单向(Oneway)发送两种方式来发送普通消息。本文介绍如何通过不同方式发送普通消息。 前提条件已完成准备工作。 已阅读参数说明,了解常用参数的配置方式与填写格式。 发送普通消息发送普通消息的示例代码如下,使用 g++ 命令进行编译。 Shell g++ -o producer producer.cpp -lrocketmq -lpthread -lz -ldl -lrt如果页面提示 undefined reference 相关的编译错误,请先确定是否已安装动态...
创建 Topic
前提条件已创建 RocketMQ 实例,且实例状态为运行中,详细操作步骤请参考创建实例。 实例当前的可用队列数不为 0。如果已创建的 Topic 对应队列数之和已达到此实例规格的最大队列数量,则无法创建新的 Topic,建议删除 Topic 之后重试。 创建 Topic 时可以直接设置密钥权限。如需设置,请提前创建密钥并获取 AccessKey ID,可参见创建密钥。 操作步骤登录消息队列 RocketMQ版控制台。 在实例列表页面,单击目标实例名称。 在Topic...
在线发送消息
消息队列 RocketMQ版支持通过控制台方式在线调试消息发送链路,您可以在控制台中进行普通消息的发送测试,并通过消息查询功能检验该消息是否已成功发送。本文档介绍在线发送普通测试消息的操作步骤。 背景信息成功创... 发送消息登录消息队列 RocketMQ版控制台。 在顶部菜单栏中选择地域。 在实例列表页面单击指定实例名称。 在Topic管理页签中找到指定 Topic,并在其对应的操作列单击发送消息。 填写消息的相关设置。 配置 说...
创建实例
如果需要通过私有网络访问消息队列 RocketMQ版实例,请先在相同地域创建 ECS 云服务器、私有网络和子网。创建实例后,不可更改实例所在的私有网络和子网。 如果需要通过公网访问消息队列 RocketMQ版实例,请先申请同地域的 EIP,建议该 EIP 的带宽上限大于预估的公网业务流量峰值。详细操作步骤请参考申请公网 IP。 操作步骤登录消息队列 RocketMQ版控制台。 在顶部菜单栏中选择需要创建实例的地域。 在实例列表页面左上角单击创...
死信消息管理
消息队列 RocketMQ版会自动为其创建一个对应的死信队列。 死信消息将会根据存储时长被系统定时删除,在查看或导出过程中,可能会存在死信消息失效的情况。 查询死信消息登录消息队列 RocketMQ版控制台。 在顶部菜单栏中选择地域。 在实例列表页面单击实例名称。 在死信管理页签中选择消息查询方式,并指定筛选条件。目前支持按消息ID查询或按时间范围查询,请根据实际业务需求选择查询方式。按消息ID查询。 选择按消息ID查询,指定 G...
设置公网访问与 SSL 认证策略
通过公网访问 RocketMQ 实例之前,需要先开启该实例的公网访问功能。如果创建实例时未开启公网访问,请参考本文档设置。 背景信息开启公网访问后,消息队列 RocketMQ版为实例提供公网接入点,用于客户端通过公网访问 R... RocketMQ 实例的 TCP 协议将提供公网访问地址,您可以根据业务需要选择对应的方式接入。 登录火山引擎消息队列 RocketMQ版控制台。 在实例列表页面,单击目标实例名称。 在实例信息页签的服务访问区域中,单击开启公网...
转包年包月
创建按量计费实例之后,您可以根据业务需求,在控制台中变更计费模式为包年包月。本文介绍按量计费实例转包年包月实例的操作步骤。 前提条件RocketMQ实例的状态为运行中。 实例的计费方式为按量计费。 注意事项按量计... 根据页面提示,确认账单并付费。 执行结果按量计费实例成功转为包年包月实例后,在控制台实例列表中,该实例的计费类型将显示为包年包月,同时显示包年包月实例的到期时间。
