活动
天翼云最新优惠活动，涵盖免费试用，产品折扣等，助您降本增效！
- 名词解释本文介绍了使用分布式消息服务RocketMQ过程中涉及的基本概念,方便您查询和了解相关概念。 Broker 消息中转角色,负责存储消息,转发消息,一般也称Server。在 JMS规范中称为 Provider。RocketMQ一般在多个服务器部署broker集群,从而达到分布式、高可用、可横向扩展的目的。 Name Server Name Server是一个几乎无状态节点,可集群部署,节点之间无同步信息。它主要提供broker注册、Topic路由管理等功能。
- 计费模式适用于消息资源需求波动的场景,可以随时开通,随时删除。 变更配置:天翼云分布式消息服务支持计费模式变更,更多操作内容请参考按需转包周期。
- 修改消费组参数本章节介绍了如何修改分布式消息服务RocketMQ实例的消费组参数。 操作场景 消费组创建成功后,您可以根据业务需要修改以下参数:最大重试次数、广播消费。 操作步骤 登录分布式消息服务RocketMQ控制台。 单击RocketMQ实例的名称,进入实例详情页面。 在左侧导航栏,单击“消费组管理”,进入“消费组管理”页面。 选择以下任意一种方法修改消费组参数。 在待修改的消费组所在行,单击“编辑”,弹出“编辑消费组”页面。 单击待修改的消费组名称,进入消费组详情页面。
- 实例常见问题Kafka服务端支持版本是多少? 分布式消息服务Kafka支持2.13-2.8.2版本服务端。 Kafka实例是否支持修改访问端口? 分布式消息服务Kafka不支持修改访问端口。主要是考虑以下几个原因: 稳定性和安全性: Kafka 在运行过程中需要保持高可靠性和稳定性。允许动态修改访问端口可能会引入不必要的风险和不稳定性,可能导致服务中断或安全问题。 集群通信机制: Kafka 是基于分布式的集群架构工作的,各个节点之间需要在特定的端口上进行通信和数据交换。
- 监控指标说明生产者指标 指标名称 指标说明 单位 生产TPS 统计Topic的消息生产速率,计算方式:1分钟内的最大值 条/秒 生产消息量峰值 统计消息生产速率的最大值 条/秒 累计生产消息量 统计所选时间段内所选topic累计生产的消息总量 条 消费者指标 指标名称 指标说明 单位 处理中消息量 计算选定的topic和group当前消费者客户端正在消费但是还没有返回消费成功响应到服务端的消息数。
- RocketMQ .NET SDK说明分布式消息服务RocketMQ兼容了社区版 HTTP SDK,您可以使用社区版 HTTP SDK接入分布式消息服务RocketMQ。 前提条件 下载社区 C# SDK到本地并解压。 使用Visual Studio打开sln文件导入工程。
- 概述本文为您介绍分布式消息服务MQTT的API参考-调用前须知。 本说明提供了分布式消息服务MQTT产品API的描述、语法、参数说明及示例等内容。
- 告警配置告警策略模板 登录ECX控制台,点击【服务管理>告警管理>告警模板】。 点击【+创建告警模板】可以创建告警策略模板。 通过创建告警策略模板,可以在创建告警策略时,选择对应的模板,快速创建告警策略。 告警消息 登录ECX控制台,点击【服务管理>告警管理>告警消息】。 告警消息版块可以查看所有的告警消息。 如果触发告警的问题已修复,可以对告警消息点击【处理】,告警消息将被标记为【已恢复】。
- 创建的Kafka实例是集群模式么？本节介绍分布式消息服务Kafka集群模式 是的,Kafka实例通常是以集群模式创建的。Kafka集群由多个Kafka节点组成,每个节点负责存储和处理消息。集群模式可以提供高可用性、容错性和扩展性。 Kafka集群中的每个节点都可以承担多个分区的领导者或副本角色,从而实现数据的冗余和故障恢复。通过复制机制,Kafka可以提供高可用性和容错性,即使在节点故障的情况下也能保证数据的可靠性和可用性。 注意 Kafka集群的规模和配置取决于应用的需求和可用的资源。
- 使用AMQProxy解决PHP等客户端Connection复用问题背景 部分语言的客户端,例如PHP客户端,无法使用长连接,会频繁地开启或关闭Connection,消耗大量的网络资源和分布式消息服务RabbitMQ资源,从而对分布式消息服务RabbitMQ造成巨大压力。 AMQProxy AMQProxy是Cloud AMQP提供的开源AMQP代理服务。客户端可以通过该代理服务与分布式消息服务RabbitMQ保持长连接。
- 消费失败由于 Kafka 自身没有处理失败消息的设计,实践中通常会打印失败的消息、或者存储到某个服务(比如创建一个 Topic 专门用来放失败的消息),然后定时 check 失败消息的情况,分析失败原因,根据情况处理。
- 计费项本节介绍了分布式消息服务RabbitMQ产品的计费项。 RabbitMQ包括2个计费项:RabbitMQ队列实例费用、RabbitMQ队列存储空间费用,具体费用详情可参考产品资费。 目前天翼云对分布式消息服务RabbitMQ产品支持包年包月、按需两种计费方式。
- 概述开发指南详细介绍Java、Go和Python客户端访问分布式消息服务RocketMQ的示例代码,具体如表1所示。 表1 示例代码 客户端语言 示例代码 Java 收发普通消息收发顺序消息收发事务消息发送定时/延时消息 Go(TCP协议) 收发普通消息 收发顺序消息收发事务消息 发送定时/延时消息 Python(TCP协议) 收发普通消息 收发顺序消息收发事务消息 发送定时/延时消息
- 认证鉴权介绍分布式消息服务MQTT认证鉴权内容。 认证鉴权 AK/SK认证:通过AK(Access Key ID)/SK(Secret Access Key)加密调用请求。 AK/SK认证就是使用AK/SK对请求进行签名,在请求时将签名信息添加到消息头,从而通过身份认证。 AK(Access Key ID):访问密钥ID。与私有访问密钥关联的唯一标识符;访问密钥ID和私有访问密钥一起使用,对请求进行加密签名。 SK(Secret Access Key):私有访问密钥。
- RocketMQ PHP SDK说明分布式消息服务RocketMQ兼容了社区版 HTTP SDK,您可以使用社区版 HTTP SDK接入分布式消息服务RocketMQ。 前提条件: 在PHP安装目录下的composer.json文件中加入社区PHP SDK 依赖。 使用Composer安装依赖。 composer install 发送普通消息队列管理背景信息 分布式消息服务RabbitMQ版的消息都会被投入到一个或多个队列中。Consumer Tag是消费者客户端的标识符。您可以在分布式消息服务 RabbitMQ 版的消费者客户端设置Consumer Tag。 操作步骤 创建队列 1.登录管理控制台。 2.进入RabbitMQ管理控制台。 3.在实例列表页在操作列,目标实例行点击“管理”。 4.点击“队列”后,点击“新建”按钮。 5.点击“新建”后出现以下窗口,选择虚拟主机,输入队列名字,选择存储节点,然后点击确定即可创建队列。连接实例2、 登录分布式消息服务RocketMQ控制台,点击右上角地域选择对应资源池。 进入实例列表,点击【管理】按钮进入管理菜单。 3、 进入实例列表,点击【管理】按钮进入管理菜单。 4、 进入主题管理菜单,点击【拨测】按钮,进行生产消费的拨测验证,验证开通的消息实例和主题。 5、 用户应用按照规范接入RocketMQ,发送、消费消息。重置实例密码步骤 3 在管理控制台左上角单击,选择“企业中间件”-“分布式消息服务”->“RabbitMQ专享版”,进入分布式消息服务RabbitMQ专享版页面。 步骤 4 通过以下任意一种方法,重置实例密码。 在待重置密码的实例所在行,单击“更多 -> 重置密码”。 单击RabbitMQ实例名称,进入实例详情页面。单击右上角的“更多 -> 重置密码”。 步骤 5 输入“新密码”和“确认密码”,单击“确定”完成密码重置。 重置密码成功,界面提示重置实例的密码成功。编译工程生产消费完成以上所有步骤后,就成功接入了RabbitMQ服务,可以用消息队列进行消息发送和订阅了。设置实例的公网访问步骤 3 在管理控制台左上角单击,选择“企业中间件”-“分布式消息服务”->“RabbitMQ专享版”,进入分布式消息服务RabbitMQ专享版页面。 步骤 4 单击待开启公网访问的实例名称,进入实例详情页面。 步骤 5 单击“公网访问”右侧的,打开公网访问开关。 步骤 6 从“弹性IP地址”下拉列表中选择一个弹性IP,然后单击,开启公网访问功能。 如果“弹性IP地址”下拉列表没有值,可单击“创建弹性IP”,跳转到弹性IP页面,您可以申请一个新的弹性IP。产品规格本文为您介绍分布式消息服务MQTT产品规格。 注意通用型规格已调整为白名单特性,如需了解该规格参数请联系技术支持。单机版实例面向用户体验和业务测试场景,无法保证性能和高可用。如果需要在生产环境使用MQTT实例,建议购买集群版实例。安全方案这样可以确保消息的持久性、可靠性和一致性,提供稳定可靠的消息传输和存储服务。 服务韧性 RocketMQ服务的韧性是指其在面对各种故障和异常情况时能够保持可用性和可靠性的能力。以下是保障RocketMQ服务韧性的关键方面: AZ内实例容灾:在一个可用区内部署多个RocketMQ实例,以提供高可用性和容灾能力。当一个实例发生故障或不可用时,其他实例可以接管工作,确保消息服务的连续性。 数据容灾:在RocketMQ中,数据容灾是指保护消息数据免受损失的能力。计费项本章节介绍了分布式消息服务RocketMQ的计费项。 分布式消息服务RocketMQ的费用计算分为两部分,一部分为实例费用,一部分为存储空间费用。 表 分布式消息服务RocketMQ计费项 计费项 计费说明 实例费用 对您选择的实例规格计费,具体请参见表2。RocketMQ实例提供包年包月、按需两种计费方式。 存储空间费用 对您选择的实例存储空间计费(每个实例规格您都可以选择高IO和超高IO两种不同的云硬盘类型以满足您的业务需求)。存储空间范围见表2,步长100GB。操作策略管理一旦消息超过指定的时间限制,可以选择将其丢弃或者转发到其他队列。● 内存限制:管理员可以设置队列或交换机的最大内存使用量,以防止RabbitMQ服务器的内存资源被过度消耗。当达到指定的内存限制时,可以选择丢弃消息或者拒绝新的连接。● 消息优先级:管理员可以为消息设置优先级,以确保重要的消息能够优先处理。可以通过操作策略管理来定义消息优先级的规则和行为。● 连接限制:管理员可以设置连接的最大数量,以限制同时连接到RabbitMQ服务器的客户端数量。这可以用于控制系统的负载和资源消耗。使用限制介绍分布式消息服务Kafka产品功能的使用限制。 限制项 使用说明 实例 开通后,不支持修改VPC/子网/可用区,不支持变更地域属性 扩缩容 当前只支持节点、规格、磁盘扩容,不支持缩容 版本 当前服务端版本为2.13-2.8.2。创建应用用户和密码本文介绍分布式消息服务RocketMQ入门指引的创建应用用户和密码内容。 背景信息 新建消息实例后,必须新建应用用户,然后应用才能在此消息实例上发送、消费消息。 应用用户:指MQ客户端,连接服务器生产消费时,需要进行权限校验,所以MQ客户端的用户,称为应用用户;除了用户密码的校验,还可以为用户指定topic,代表该用户只能生产消费指定的topic,其他topic不能生产消费。 操作步骤 1、 天翼云官网点击控制中心,选择产品分布式消息服务RocketMQ。与RabbitMQ、RocketMQ的差异分布式消息服务Kafka与RabbitMQ、RocketMQ的对比。 表1 分布式消息服务Kafka与开源Kafka的差异说明 功能项 RocketMQ Kafka RabbitMQ 优先级队列 不支持 不支持 支持。建议优先级大小设置在0-10之间。修改实例操作步骤 1、 天翼云官网点击控制中心,选择产品分布式消息服务RocketMQ。 2、 登录分布式消息服务RocketMQ控制台,点击右上角地域选择对应资源池。 进入实例列表,在实例名称点击修改按钮,直接修改实例名称字段。 3、 点击【管理】按钮进入管理菜单。点击修改配置,在弹出窗口修改实例描述和消息保存时长等信息。 注意: 实例描述长度限制为0~256个字符。 您可以调整消息保存时长参数,实现消息容量消耗的控制。安全生产和稳定性保障限制,消息需要至少保留24小时。删除用户本章节介绍了如何删除分布式消息服务RocketMQ实例的用户。 操作场景 用户无需继续使用,需要清理时,参考本章节删除用户。 须知 : 删除用户后会删除授权关系,原来使用该用户认证的请求将无法访问。 操作步骤 登录分布式消息服务RocketMQ控制台。 单击RocketMQ实例的名称,进入实例详情页面。 在左侧导航栏,单击“用户管理”,进入“用户管理”页面。 在待删除的用户所在行,单击“删除”,弹出“删除用户”对话框。 单击“是”,完成用户的删除。入门指引本文主要介绍分布式消息服务RabbitMQ的入门指引。 本文将为您介绍分布式消息服务RabbitMQ入门的基本流程,主要包括控制台创建RabbitMQ实例、使用弹性云主机连接实例的操作,帮助您快速上手RabbitMQ。 操作流程 图1 RabbitMQ使用流程 环境准备 RabbitMQ实例运行于虚拟私有云中,在创建实例前需要确保有可用的虚拟私有云。 创建RabbitMQ实例 在创建实例时,您可以选择是否开启SSL访问,开启后,数据加密传输,安全性更高。连接RabbitMQ 管理地址本文主要介绍如何连接分布式消息服务RabbitMQ的管理地址。 在浏览器中输入RabbitMQ管理地址,访问开源RabbitMQ的集群管理工具。 操作步骤 一、获取实例管理地址。 登录管理控制台。 在管理控制台右上角单击,选择区域。 说明 此处请选择与您的应用服务相同的区域。 在管理控制台左上角单击,选择“企业中间件 -> 分布式消息服务 -> RabbitMQ专享版”,进入分布式消息服务RabbitMQ专享版页面。产品优势Kafka专享实例支持跨AZ部署,节点部署在不同的AZ,进一步保障服务高可用。无忧运维公有云提供一整套完整的监控告警等运维服务,故障自动发现和告警,避免7*24小时人工值守。Kafka专享实例自动上报相关监控指标,如分区数、主题数、堆积消息数等,并支持配置监控数据发送规则,您可以在第一时间通过短信、邮件等获得业务消息队列的运行使用和负载状态。海量消息堆积与弹性扩容内建的分布式集群技术,使得服务具有高度扩展性。
天翼云最新活动
售前咨询热线
400-810-9889转1
关注天翼云
©2025
天翼云科技有限公司版权所有 增值电信业务经营许可证A2.B1.B2-20090001
公司地址：北京市东城区青龙胡同甲1号、3号2幢2层205-32室
