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 的情况下,发现这个文件是存...
打造新一代云原生"消息、事件、流"统一消息引擎的融合处理平台 | 社区征文
在RocketMQ 5.0中,大量的逻辑被下沉到服务端,使得SDK的代码行数减少了60%。这种下沉的设计使得开发和维护多语言SDK的成本大幅度降低。同时,这也使得RocketMQ的SDK变得更加轻量化,更容易被Service Mesh、Dapr等云原生代表技术集成。通过将逻辑下沉到服务端,RocketMQ能够提供更简洁且高效的SDK,为开发人员带来更好的开发和集成体验。##### 可分合化的存算分离架构用户根据不同的场景诉求,既可以同一进程启动存储和计算的功能,也...
干货|字节跳动流式数据集成基于Flink Checkpoint两阶段提交的实践和优化(2)
> > > 字节跳动开发套件数据集成团队(DTS ,Data Transmission Service)在字节跳动内基于 Flink 实现了流批一体的数据集成服务。其中一个典型场景是 Kafka/ByteMQ/RocketMQ -> HDFS/Hive 。Kafka/ByteMQ/RocketMQ... 目前线上比较常见的一个 case 是任务在关闭一段时间后再开启。由于 HDFS TTL 的设置小于任务关闭的时长,临时目录中写入的文件被 HDFS TTL 策略清除。这个结果实际是符合预期的。#### **前向兼容性**预期中...
特惠活动
rocketmq启动-优选内容
rocketmq启动-相关内容
CreateInstance
调用 CreateInstance 接口创建 RocketMQ 实例。 注意事项请求频率:该接口请求频率限制为 100 次/秒;单用户请求频率限制为 20 次/秒。 使用说明实例是消息队列 RocketMQ版的基本服务单位,用以管理和存储 Topic、Group 资源。 说明 通过 API 创建接口时暂不支持同时开启公网访问功能,如果需要开启实例的公网访问,建议在创建实例完成后,实例状态为运行中(Running)时,调用 EnablePublicNetwork 开启实例的公网访问。 默认情况下,您可...
步骤三:生产消费普通消息
消息队列 RocketMQ版提供常见场景的消息生产与消费示例代码,您也可以参考示例代码中的注释,了解各个关键参数。详细信息请参考SDK 参考。 前提条件已配置开发环境,并创建了 RocketMQ 实例等相关资源。详细操作步骤请准备环境、创建资源。 如果需要通过公网访问 RocketMQ 实例,需要提前为实例开启公网访问,同时绑定一个相同地域的 EIP,建议该 EIP 的带宽上限大于预估的公网业务流量峰值。操作步骤请参考开启公网访问。 下载 SDKRo...
参数说明
例如实例 ID为MQ_INST_1111313,Group 名称为 Demo,则拼接后为 MQ_INST_1111313%Demo 。 producer.WithGroupName("demo-group") WithInstanceName 在单个进程启动多个客户端时必选 客户端标识(Client ID)。一个进程中需要创建多个 RocketMQ 客户端连接不同实例时,需要通过 InstanceName 区分客户端连接。 producer.WithInstanceName("instance") WithSendMsgTimeout 可选 发送消息的超时时间。 producer.WithSendMsgTimeout(3 ...
设置公网访问与 SSL 认证策略
通过公网访问 RocketMQ 实例之前,需要先开启该实例的公网访问功能。如果创建实例时未开启公网访问,请参考本文档设置。 背景信息开启公网访问后,消息队列 RocketMQ版为实例提供公网接入点,用于客户端通过公网访问 RocketMQ 实例。开启公网访问时,支持设置 SSL 连接策略,可以同时支持 SSL 连接和非 SSL 连接。目前支持客户端对服务端证书的 SSL 单向认证,数据加密传输,相较于普通公网访问方式具备更高的安全性,但实例性能会有所下降...
消息轨迹
成功接入消息队列 RocketMQ版,并在 3 天内有消息生产和消费行为。 在控制台查看消息轨迹之前,需要先在生产者和消费者客户端开启消息轨迹。 开启消息轨迹在生产者和消费者客户端中开启消息轨迹,开启后才能在控制台中查看消息轨迹。构造函数的参数 enableMsgTrace 指定为 true,表示开启消息轨迹。 说明 暂不支持 customizedTraceTopic 参数,即 customizedTraceTopic 参数应传 null 或者传空。 示例代码如下。 生产者开启消息轨迹...
API 概览
RocketMQ实例。 DeleteInstance 调用 DeleteInstance 接口删除实例。 GetInstance 调用 GetInstance 接口查看指定RocketMQ实例的详细信息。 ListInstances 调用 ListInstances 接口查看当前账号在当前地域下的所有RocketMQ实例信息。 ScaleInstance 调用 ScaleInstance 接口变更实例规格。 EnablePublicNetwork 调用 EnablePublicNetwork 接口开启实例公网访问功能。 DisablePublicNetwork 调用 DisablePublicNetwor...
创建密钥
火山引擎消息队列 RocketMQ版与开源 RocketMQ 的 ACL 权限逻辑相同,同样将 ACL 权限类型定义为以下四种: 权限 说明 拒绝(DENY) 不具备发布或订阅权限。 发布(PUB) 仅具备发布权限,不具备订阅权限。 订阅(SUB) 仅具备订阅权限,不具备发布权限。 订阅、发布(ANY) 同时具备发布和订阅权限。 注意事项所有 RocketMQ 实例默认开启 ACL 访问控制,无需手动开启或关闭。 创建密钥后,密钥默认为已启用状态。若不再使用此密钥,建...
查看 Group 消费状态
成功创建 Group 并启动消费之后,消息队列 RocketMQ版会记录并在控制台展示消费的相关信息,例如消费速度等基础消费信息、客户端IP等客户端信息、订阅的 Topic 等订阅信息。 操作入口登录消息队列 RocketMQ版控制台。 在顶部菜单栏中选择地域。 在实例列表中找到指定 RocketMQ 实例,并单击实例名称。 在Group管理页面单击指定 Group ID。 分别查看消费信息、客户端信息和订阅信息。 查看消费信息消费信息区域展示消费的整体状态、...
创建实例
应用接入消息队列 RocketMQ版之前,需要在控制台创建 RocketMQ 实例。消息队列 RocketMQ版提供多种实例规格,对应不同的计算能力和存储空间,您可以根据实际业务需求选择不同的实例规格。本文档介绍创建 RocketMQ 实例... 网络类型 说明 私有网络 开启实例的 VPC 访问方式。必选。请指定 RocketMQ 实例对应的私有网络和子网。私有网络(VPC,Virtual Private Cloud)是为云上资源构建隔离的、自主配置和管理的虚拟网络环境。若当前账号...
