rocketmq实现的协议
社区干货
打造新一代云原生"消息、事件、流"统一消息引擎的融合处理平台 | 社区征文
RocketMQ基于大规模云计算环境的实践经验(例如,阿里(双十一、双十二)、携程(过年高峰期)),辅助了成千上万的企业完成数字化转型,从而实现了从互联网消息中间件到云原生消息中间件的发展变革。RocketMQ与其他消息中间件的一大区别就在于,它采用的是经过实践检验的云原生架构。接下来,我们要探讨RocketMQ在云原生架构领域的关键技术进步。## RocketMQ的云原生发展历程随着消息队列行业的发展,Apache RocketMQ经历了12年的发展历...
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 正常生产和消费消息,但是消费轨迹无法查看的问题该如何排查?# 问题分析此类问题原因一般如下: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实现的协议-优选内容
rocketmq实现的协议-相关内容
设置公网解析
消息队列 RocketMQ版实例的私有网络 VPC 域名支持在公网环境下解析为私网 IP 地址。本文档介绍手动开启公网解析的操作步骤。 背景信息消息队列 RocketMQ版提供各种协议的接入点供您连接使用,访问私有网络 VPC 类型的接入点时,需要对私网域名进行解析,但私网域名默认必须在火山引擎私网环境下才能成功解析为私网 IP 地址。您可以为实例开启公网解析功能,开启后,即使在公网环境下也可以成功将私网域名解析为私网 IP 地址。公网解析...
产品咨询
支持哪些语言的客户端?火山引擎消息队列 RocketMQ版支持 TCP 协议的 Java、Go、Python 多语言客户端 SDK,并为您提供各种语言的代码示例以供参考,详细说明请参考 SDK 参考。 支持的消息体最大是多少?火山引擎消息队列 RocketMQ版服务端支持的最大消息大小为 4MiB,且不支持修改。超出限制的消息无法推送成功。 消息的保留时间是多久?创建 RocketMQ 实例时支持自定义设置消息保留时长,超过保留时长的消息将被过期清理。取值范围为 1...
请求结构
本文介绍消息队列 RocketMQ版 API 请求的组成结构。 请求格式您可以通过发送 POST 请求来调用 RocketMQ 的 API 服务。HTTPS 请求的格式如下: Plain {URI-scheme}://{Endpoint}?Action={Action}&Version={Version}其中: URI-scheme:表示用于传输请求的协议,当前所有 API 均采用 HTTPS 协议。 Endpoint:指定承载服务端点的服务器域名或IP,即服务地址。消息队列 RocketMQ版的 Endpoint 为 rocketmq.volcengineapi.com,详细说明请参考...
请求结构
本文介绍消息队列 RocketMQ版 API 请求的组成结构。 请求格式您可以通过发送 POST 请求来调用 RocketMQ 的 API 服务。HTTPS 请求的格式如下: Plain {URI-scheme}://{Endpoint}?Action={Action}&Version={Version}其中: URI-scheme:表示用于传输请求的协议,当前所有 API 均采用 HTTPS 协议。 Endpoint:指定承载服务端点的服务器域名或IP,即服务地址。消息队列 RocketMQ版的 Endpoint 为 rocketmq.volcengineapi.com,详细说明请参考...
CreateGroup
调用 CreateGroup 创建一个新的消费组(Group)。 注意事项请求频率:该接口请求频率限制为 20 次/秒;单用户请求频率限制为 4 次/秒。 使用说明在消息队列 RocketMQ版中,您需要创建 Group,并通过 Group ID 标识不同类别的生产者或消费者。 每个实例的 Topic 数量配额与实例规格有关,例如各个规格实例可创建的 Topic 数量请参考产品规格。 消费者必须配置 Group ID,生产者可以忽略 Group ID 配置。 目前支持的客户端协议为 TCP。 请...
设置公网访问与 SSL 认证策略
通过公网访问 RocketMQ 实例之前,需要先开启该实例的公网访问功能。如果创建实例时未开启公网访问,请参考本文档设置。 背景信息开启公网访问后,消息队列 RocketMQ版为实例提供公网接入点,用于客户端通过公网访问 R... 请先创建和 RocketMQ 实例相同地域的 EIP,建议该 EIP 的带宽上限大于预估的公网业务流量峰值。详细操作请参考申请公网IP。 开启公网访问开启公网访问后,RocketMQ 实例的 TCP 协议将提供公网访问地址,您可以根据业...
查看实例详情
创建 RocketMQ 实例后,您可以在控制台查看 RocketMQ 实例列表和每个 RocketMQ 实例的详细信息,包括实例状态等基本信息、实例规格和存储空间等实例配置、各个协议的接入点等访问信息等。 查看实例详情登录消息队列 RocketMQ版控制台。 在顶部菜单栏中选择地域。 在实例列表页面查看实例的基本信息。实例列表中展示当前地域下的实例清单,您可以在列表中查看实例名称和 ID、状态、可用区、私有网络、Topic、Group、标签、实例规格、...
ListInstances
调用接口 ListInstances 查看当前账号在当前地域下的所有 RocketMQ 实例信息。 注意事项请求频率:该接口请求频率限制为 20 次/秒;单用户请求频率限制为 5 次/秒。 请求参数参数 参数类型 是否必选 示例值 说明 Offset Integer 必选 0 偏移量。 Limit Integer 必选 10 本次请求返回的条目数。取值范围为 1~50。 SortField String 必选 列表排序方式。支持根据以下方式排序: Name:实例名称。 Protocal:协议。 ...
概述
SDK 类型消息队列 RocketMQ版实例完全兼容开源 RocketMQ 协议,可以直接使用 RocketMQ 开源客户端连接。 SDK类型 用途及说明 开源 RocketMQ SDK 消息队列 RocketMQ版与开源 Apache RocketMQ 完全兼容,支持通过开源 RocketMQ SDK 生产和消费消息。开源 RocketMQ SDK 通常集成在客户端程序中,用于管理 RocketMQ 实例中的资源和数据,例如生产消息、消费消息。消息队列 RocketMQ版提供 Go、Java 等语言的示例项目供您参考,其中包括...
