rocketmq使用配置
社区干货
使用golang调用RocketMQ SDK
# 前言本文档介绍使用go语言调用火山引擎RocketMQ SDK。# 关于实验- 预计部署时间:30分钟- 级别:初级- 相关产品:中间件-RocketMQ- 受众: 通用# 实验说明## 第一步、创建RocketMQ实例在控制台创建RocketMQ实例,并配置Topic、Group、以及秘钥,详见[RocketMQ创建文档](https://www.volcengine.com/docs/6410/70793)## 第二步 、配置golang代码```go/*Licensed to the Apache Software Foundation (ASF) under one or m...
如何解决使用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 存储机制浅析
ActiveMQ(默认采用的 KahaDB 做消息存储)可选用 JDBC 做消息持久化,通过简单的 xml 配置信息即可实现 JDBC 消息存储。使用文件系统做持久化的情况下,可获得更高效的 I/O 读写。* Broker Store 目录结构``` storePathRootDir=/cache1/rocketmq/broker/data ├── abort // 该文件在 Broker 启动后会自动创建,正常关闭 Broker,该文件会自动消失。若在没有启动 Broker 的情况下,发现这个文件是存...
打造新一代云原生"消息、事件、流"统一消息引擎的融合处理平台 | 社区征文
RocketMQ基于大规模云计算环境的实践经验(例如,阿里(双十一、双十二)、携程(过年高峰期)),辅助了成千上万的企业完成数字化转型,从而实现了从互联网消息中间件到云原生消息中间件的发展变革。RocketMQ与其他消息中间... 比如RabbitMQ无法水平扩展单队列能力、Kafka扩容需要大量数据拷贝和均衡。这些现有解决方案都不适用于为大规模客户提供弹性服务的公共云环境。
特惠活动
rocketmq使用配置-优选内容
rocketmq使用配置-相关内容
参数说明
本文介绍您在使用社区版 Java SDK 接入火山引擎消息队列 RocketMQ版时,需要配置的参数。 通用参数 参数名 参数说明 NAMESRV_ADDR 设置 TCP 协议接入点,从火山引擎控制台的实例详情页面获取。 AccessKey 您在火山引擎控制台-实例页面的密钥管理页面,创建的 AccessKey ID,用于身份认证。 SecretKey 您在火山引擎控制台-实例页面的密钥管理页面,创建的 AccessKey Secret,用于身份认证。 消息发送参数 参数名 参数说明 ProducerG...
创建 RocketMQ 触发器
函数服务支持对接火山引擎的 消息队列 RocketMQ 版。 通过创建 RocketMQ 触发器,函数服务将作为消费者消费 RocketMQ 中的消息,并将消息传递给用户函数,触发函数代码逻辑。您无需关心函数服务消费消息的细节,只需编写处理消息的函数。本文为您介绍如何创建 RocketMQ 触发器。 前提条件函数已开启 VPC 访问功能,详细操作可参见 更新函数配置。 函数至少完成一次全量发布,详细操作可参见 发布函数。 已创建 RocketMQ 实例、 Topi...
限制说明
消息队列 RocketMQ版对一些指标和性能进行了限制,请您在使用过程中注意不要超过相应的限制值,避免出现异常。 限制类型 配额 说明 实例数量 5 个 单个地域(Region)内的消息队列 RocketMQ版实例数。您也可以通过... 可配置为 1~72 小时。默认为 72 小时,即 3 天。 超出保留时长限制的消息将被过期清理。 死信消息最大保留时长 72 小时 死信消息在服务端的最大保留时长。 可配置为 1~72 小时。默认为 72 小时,即 3 天。 超出保...
延时消息
了解常用参数的配置方式与填写格式。 背景信息火山引擎提供了两种发送延时消息的方式,一种是特定延时时间,另一种是任意延时时间,其中任意精度的延时消息包括以下两种: 特定精度延时消息,只支持特定的 18 个等级。 C++ messageDelayLevel=1s 5s 10s 30s 1m 2m 3m 4m 5m 6m 7m 8m 9m 10m 20m 30m 1h 2h 任意精度延时消息:对于 2023年2月21日之后创建的 RocketMQ 实例,建议通过属性 __STARTDELIVERTIME 来使用任意精度的延时消息。...
步骤一:准备环境
详细操作请参考注册账号。 完成企业认证。详细操作请参考企业认证。 2 创建私有网络和子网RocketMQ 实例默认开通私有网络(VPC)访问,VPC 为实例提供网络隔离的虚拟网络环境,只有在 VPC 中才能访问 RocketMQ 实例。在创建 RocketMQ 实例前,请确保目标地域下有可用的 VPC 和子网,如果没有,请参考创建私有网络和创建子网创建一个。 说明 创建 VPC 时,请注意: VPC 和 RocketMQ 实例必须在同一地域中,跨地域时无法访问。 应配置合理的安...
配置密钥权限
详细操作请参考创建 Topic。 如果需要取消某个密钥的发布或者订阅的权限,请确认没有正在运行的应用使用了此密钥,以免影响线上业务的正常运行。 背景信息消息队列 RocketMQ版支持 ACL 权限控制,通过密钥实现 Topic... 配置密钥的自定义权限默认权限对于实例中的所有 Topic 生效,如果需要更细粒度的权限策略,可以为密钥添加自定义权限。例如密钥 A 的默认权限为拒绝,自定义权限为 Topic 1 和 Topic 2 的权限为发布,表示客户端使用...
步骤二:创建资源
RocketMQ版实例,请先申请同地域的 EIP,建议该 EIP 的带宽上限大于预估的公网业务流量峰值。详细操作步骤请参考申请公网 IP。 1 创建实例说明 如果是首次创建 RocketMQ 实例,您需要先完成跨服务访问授权,建议通过火山引擎主账号操作。详细说明请参考跨服务访问授权。 登录消息队列 RocketMQ版控制台。 在顶部菜单栏,选择地域。 在实例列表页面左上角,单击创建实例。 请根据页面提示选择实例规格和基础配置,并单击确认订单。详细...
CreateGroup
调用 CreateGroup 创建一个新的消费组(Group)。 注意事项请求频率:该接口请求频率限制为 20 次/秒;单用户请求频率限制为 4 次/秒。 使用说明在消息队列 RocketMQ版中,您需要创建 Group,并通过 Group ID 标识不同类别的生产者或消费者。 每个实例的 Topic 数量配额与实例规格有关,例如各个规格实例可创建的 Topic 数量请参考产品规格。 消费者必须配置 Group ID,生产者可以忽略 Group ID 配置。 目前支持的客户端协议为 TCP。 请...
创建实例
如果需要通过公网访问消息队列 RocketMQ版实例,请先申请同地域的 EIP,建议该 EIP 的带宽上限大于预估的公网业务流量峰值。详细操作步骤请参考申请公网 IP。 操作步骤登录消息队列 RocketMQ版控制台。 在顶部菜单栏中选择需要创建实例的地域。 在实例列表页面左上角单击创建实例。 填写RocketMQ实例的基本配置信息。 参数 说明 实例名称 RocketMQ实例的名称。需满足以下要求: 只能包含中文、字母、数字、下划线(_)和连字符...
