活动
天翼云最新优惠活动，涵盖免费试用，产品折扣等，助您降本增效！
- 续订和退订场景描述 分布式消息服务RocketMQ为用户提供全面周到的服务,支持用户续订和退订的需求。 ● 续订:针对包周期消息实例服务,用户可在到期前进行服务周期延长操作,即续订操作。 ● 退订:用户如不需要继续使用该分布式消息服务RocketMQ实例,可进行删除实例操作,即退订操作。 续订 1、登录RocketMQ消息控制台,可以看到当前租户下面的实例列表。 2、点击需要变更实例栏 > 更多 > 续订。 3、 进入到续订页面,在弹出来的确认窗口选择续订时长,点击确认即可。
- 设置Topic权限步骤 3 在管理控制台左上角单击,选择“企业中间件”-“分布式消息服务”-“Kafka专享版”,进入分布式消息服务Kafka专享版页面。 步骤 4 单击Kafka实例名称,进入实例详情页面。 步骤 5 在导航栏单击“Topic管理”,进入Topic列表页面。 步骤 6 在需要设置用户权限的Topic所在行,单击“设置用户权限”,弹出“设置用户权限”对话框。 在“设置用户权限”对话框顶部显示Topic的信息,包括Topic名称、分区数、老化时间、副本数和是否同步落盘。
- 天翼云官方事件源接入流程点击default总线,进入云服务专用事件总线详情页,单击左侧事件源按钮。单击名为ctyun.zos的事件源,查看事件示例,如图2。图2 查看对象存储官方事件源的事件列表步骤四:结果验证登录分布式消息服务Kafka管理控制台。在左侧导航栏,单击实例列表,选择目标实例。在左侧导航栏点击消息查询页面,点击按位点查询,查看事件内容与步骤三中查看的示例是否相符。图3 查看分布式消息服务Kafka管理控制台中的消息详情
- 消息问题本章节主要介绍消息类问题的解决方法。 RabbitMQ实例支持延时消息队列么? RabbitMQ可以通过设置消息的有效期和死信队列来实现延迟消息。同时,也提供安装插件实现延迟消息。
- 创建RocketMQ实例本文介绍分布式消息服务RocketMQ入门指引的创建RocketMQ实例内容。 实例介绍 RocketMQ实例订购支持用户自定义规格和自定义特性,采用物理隔离的方式部署。租户独占RocketMQ实例,可根据业务需要可定制相应规格的RocketMQ实例。在新的资源池节点上,还支持选择主机类型和存储规格等丰富用户选项。 操作步骤 1、在产品详情页点击立即开通按钮,或者进入消息管理控制台创建实例,进入订购分布式消息RocketMQ页面。 2、创建实例,注意选择产品规格。
- 修改用户信息介绍分布式消息服务Kafka修改用户的功能操作内容。 场景描述 当前主要支持重置用户密码:当用户忘记密码或需要更改密码时,可以通过修改用户密码来实现。这有助于保护用户账户的安全性,防止未经授权的访问和操作。 操作步骤 (1)登录管理控制台。 (2)进入Kafka管理控制台。 (3)在实例列表页在操作列,目标实例行点击“管理”。 (4)点击“用户管理”后进入应用用户管理页面,点击“修改”。 (5)点击“修改”后,在弹窗中可以修改密码和对应描述。
- 查看示例代码本章节指导您在控制台查看Java、Go和Python生产消费消息的示例代码。 操作步骤 步骤 1 登录管理控制台。 步骤 2 在管理控制台右上角单击,选择区域。 说明 请选择Kafka实例所在的区域。 步骤 3 在管理控制台左上角单击,选择“企业中间件”-“分布式消息服务”-“Kafka专享版”,进入分布式消息服务Kafka专享版页面。 步骤 4 单击Kafka实例的名称,进入实例详情页面。 步骤 5 选择“Topic管理”页签,显示已创建的Topic详情。
- 云审计服务支持的MQTT操作列表本页面主要介绍分布式消息服务MQTT对接的云审计服务使用和查看方法。 操作场景本服务现已对接天翼云云审计服务,云审计服务提供对各种云资源操作的记录和查询功能,用于支撑合规审计、安全分析、操作追踪和问题定位等场景,同时提供事件跟踪功能,将操作日志转储至对象存储实现永久保存。云审计可提供的功能服务具体如下:● 记录审计日志:支持用户通过管理控制台或API接口发起的操作,以及各服务内部自触发的操作。
- 天翼云分布式融合数据库HTAP服务等级协议本页介绍天翼云分布式融合数据库HTAP服务等级协议。 天翼云分布式融合数据库HTAP服务等级协议(SLA)获取地址:天翼云分布式融合数据库HTAP服务等级协议。
- 产品规格本文为您介绍分布式消息服务MQTT产品规格。 注意通用型规格已调整为白名单特性,如需了解该规格参数请联系技术支持。单机版实例面向用户体验和业务测试场景,无法保证性能和高可用。如果需要在生产环境使用MQTT实例,建议购买集群版实例。
- 创建Topic事务发起者可以将事务消息发送到该主题,而事务消费者可以订阅该主题以进行事务的处理和确认。 总的来说,创建主题的场景可以根据具体的业务需求来确定。主题可以帮助将消息进行逻辑分类和管理,实现不同的消息传递模式和业务场景 新建Topic 1、 天翼云官网点击控制中心,选择产品分布式消息服务RocketMQ。 2、 登录分布式消息服务RocketMQ控制台,点击右上角地域选择对应资源池。 3、 进入实例列表,点击【管理】按钮进入管理菜单。
- 查询消费组信息步骤 3 在管理控制台左上角单击,选择“企业中间件”-“分布式消息服务”-“Kafka专享版”,进入分布式消息服务Kafka专享版页面。 步骤 4 单击Kafka实例的名称,进入实例详情页面。 步骤 5 在左侧导航栏选择“消费组管理”,进入消费组列表页面。 步骤 6 单击待查看消费者列表的消费组名称,进入消费组详情页。 步骤 7 在“消费者列表”页签,查看消费者列表。 在消费者列表中,可以查看消费者ID、消费者地址和客户端ID。
- 配置Kafka实例的公网访问在管理控制台左上角单击,选择“应用中间件 分布式消息服务Kafka”,进入分布式消息服务Kafka专享版页面。 单击Kafka实例的名称,进入实例的“基本信息”页面。 在“公网访问”后,单击,完成公网访问的关闭。 您可以在实例的“后台任务管理”页面,查看当前任务的操作进度。任务状态为“成功”,表示操作成功。 关闭公网访问后,需要设置对应的安全组规则(请见表2),才能通过内网成功连接Kafka。
- RocketMQ PHP SDK说明分布式消息服务RocketMQ兼容了社区版 HTTP SDK,您可以使用社区版 HTTP SDK接入分布式消息服务RocketMQ。 前提条件: 在PHP安装目录下的composer.json文件中加入社区PHP SDK 依赖。 使用Composer安装依赖。 composer install 发送普通消息生产消费验证消费者验证:RocketMQ的消费者可以订阅特定的消息主题,从而消费这些主题下的消息。在验证阶段,消费者应该能够正确地从Broker节点拉取消息并进行消费处理。消费者还可以验证消息的顺序性、重试机制以及消息过滤等功能。 操作步骤 1、 天翼云官网点击控制中心,选择产品分布式消息服务RocketMQ。 2、 登录分布式消息服务RocketMQ控制台,点击右上角地域选择对应资源池。 进入实例列表,点击【管理】按钮进入管理菜单。 3、 进入实例列表,点击【管理】按钮进入管理菜单。实例列表介绍分布式消息服务MQTT实例列表内容。 操作说明 1、 进入控制台查看已购买的实例列表,若列表为空,可点击右上角【创建实例】进入购买页面,创建实例详情见具体操作步骤。 2、 支持按照实例ID查询,输入查询内容,点击【查询】按钮即可展示需要的实例数据。 3、 查看实例基本信息,包括实例ID、规格、计费模式、创建时间、到期时间、状态。其中状态说明见下文。 运行状态 1、 登录管理控制台。 2、 进入MQTT管理控制台。购买分布式数据库实例本节介绍如何购买分布式关系型数据库实例 操作步骤 1、在RDS管理控制页面单击服务列表,选择“分布式数据库 DRDS”,进入DRDS管理控制台。 2、在实例管理页面,单击页面右上方的“购买分布式数据库实例”。 3、在数据库中间件实例页面,按需设置实例相关信息。 参数说明 参数 说明 可用区 可选择的可用区。当前部分区域支持跨可用区部署,以增强DRDS实例高可用性。如果您的实例需要跨可用区部署,可以选择多个可用区,DRDS实例的节点将部署在不同的可用区中。keepalive一般设置为多少秒比较好？本文介绍分布式消息服务MQTT的keepalive设置推荐 在MQTT中,Keep Alive是一个用于保持客户端和服务器之间的活动连接的机制。它是通过客户端定期发送PINGREQ消息来实现的,以确保连接保持活动状态。当服务器接收到PINGREQ消息后,会回复PINGRESP消息,表示连接仍然活动。 Keep Alive的设置取决于你的应用需求和网络环境。资源报表本文为您介绍分布式消息服务MQTT的操作指南-资源报表。 分布式消息服务MQTT提供连接数、订阅关系数、主题数、收发tps历史指标数据的查询。 连接数、订阅关系数、主题数查询 统计MQTT连接数、订阅关系数、主题数可以帮助: 性能监控: 连接数、订阅关系数、主题数统计可以帮助您监控MQTT代理服务器的性能。通过实时查看连接数、订阅关系数、主题数,您可以确定代理服务器是否正常运行,以及是否需要进行性能调整或升级硬件资源。安全方案访问控制 权限控制 购买分布式消息服务RocketMQ实例之后,您可以使用CTIAM为企业中的员工设置不同的访问权限,以达到不同员工之间的权限隔离,通过CTIAM进行精细的权限管理。 VPC和子网 虚拟私有云(Virtual Private Cloud,VPC)为分布式消息服务RocketMQ构建隔离、私密的虚拟网络环境,提升数据库的安全性,并简化用户的网络部署。导出Topic步骤 3 在管理控制台左上角单击,选择“企业中间件”-“分布式消息服务”-“Kafka专享版”,进入分布式消息服务Kafka专享版页面。 步骤 4 单击Kafka实例的名称,进入实例详情页面。 步骤 5 选择“Topic管理”页签,显示已创建的Topic详情。 步骤 6 在页面右上角单击,导出Topic列表到本地。 Topic列表中包含如下信息:Topic名称、分区数、副本数、老化时间、是否同步复制或同步落盘。删除流控步骤 3 在管理控制台左上角单击,选择“企业中间件”-“分布式消息服务”-“Kafka专享版”,进入分布式消息服务Kafka专享版页面。 步骤 4 单击Kafka实例的名称,进入实例详情页面。 步骤 5 在左侧导航栏单击“流控管理 > 流控列表”,进入流控列表页面。 步骤 6 在待删除的流控所在行,单击“删除”,弹出“删除流控”对话框。 步骤 7 单击“是”,跳转到“后台任务管理”页面,当流控任务的“状态”为“成功”时,表示成功删除流控。API使用说明关于用户如何使用分布式消息服务RocketMQ产品API的详细介绍,请参见使用API。您可以在OpenAPI门户可以了解到具体的调用前必知、API概览、如何调用API以及具体的API的接口详细说明。 说明分布式消息服务RocketMQ提供两种版本接口供用户调用4.0版本:适用于 华东1、华北2、西南1、华南2、上海36、青岛20、长沙42、南昌5、武汉41、杭州7、西南2-贵州、太原4、郑州5、西安7 资源池存量实例调用。按需转包周期介绍 分布式消息服务RocketMQ的按需转包周期 本节适用于南京3、重庆2、晋中、上海7、北京5、内蒙6、石家庄20 节点。 场景描述 RocketMQ的按需转包周期的场景描述如下: 在使用RocketMQ时,可能会遇到需要设置按需转包周期的场景,例如: 消息积压处理:当RocketMQ中的消息积压较多时,可能会导致消息的消费速度跟不上消息的生产速度,进而影响系统的性能和稳定性。为了解决这个问题,可以设置按需转包周期,即将一定数量的消息打包成一个批次进行消费,以提高消费的效率和吞吐量。查看消费者连接地址步骤 3 在管理控制台左上角单击,选择“企业中间件”-“分布式消息服务”-“Kafka专享版”,进入分布式消息服务Kafka专享版页面。 步骤 4 单击Kafka实例的名称,进入实例详情页面。 步骤 5 在左侧导航栏选择“消费组管理”,进入消费组列表页面。 步骤 6 单击待查看消费者连接地址的消费组名称,进入消费组详情页。 步骤 7 在“消费者列表”页签,查看消费者连接地址。 图 消费者列表 方法二:在Kafka Manager中查看消费者连接地址 步骤 1 登录Kafka Manager。连接实例2、 登录分布式消息服务RocketMQ控制台,点击右上角地域选择对应资源池。 进入实例列表,点击【管理】按钮进入管理菜单。 3、 进入实例列表,点击【管理】按钮进入管理菜单。 4、 进入主题管理菜单,点击【拨测】按钮,进行生产消费的拨测验证,验证开通的消息实例和主题。 5、 用户应用按照规范接入RocketMQ,发送、消费消息。Kafka支持多可用区？本节介绍分布式消息服务Kafka高可用能力 Kafka支持在单个可用区或者多个可用区进行部署和配置。 在单个可用区部署的情况下,所有的Kafka节点都在同一个可用区内。这种配置适用于对高可用性要求不是特别高的场景,例如开发环境或者小规模应用。 在多个可用区部署的情况下,Kafka集群的节点分布在不同的可用区内。这种配置可以提供更高的可用性和容错性,以应对可用区级别的故障。通常,多可用区部署需要使用复制机制来提供数据冗余和故障恢复。 对于多可用区部署,常见的配置是使用三个可用区。删除认证用户本文为您介绍分布式消息服务MQTT的API-认证授权-删除认证用户。查看实例介绍分布式消息服务Kafka查看实例操作内容。 场景描述 Kafka实例是Kafka消息队列系统的一个概念。在Kafka中,一个实例代表了一个独立的Kafka集群。它包含了一组Kafka broker,这些broker协同工作以提供高可用性和可伸缩性。每个实例都有一个唯一的标识符,可以用来在集群中进行区分。实例可以包含多个主题(topics),并且可以配置不同的分区和副本数。通过创建多个实例,可以实现多个独立的Kafka集群,从而满足不同的业务需求。 操作步骤 (1)登录管理控制台。事件源概述作为事件源接入时,您可以配置消息类事件提供方,把事件主动拉取到事件总线EventBridge。例如,当您配置事件提供方为分布式消息服务Kafka时,事件总线EventBridge会把分布式消息服务Kafka对应资源产生的消息主动拉取到自定义总线中,经过事件模式过滤后把事件路由到事件目标。如何实现RabbitMQ的高性能当生产者发送太多消息给服务端处理时,RabbitMQ会将压力传递到TCP连接上。如果在同一个TCP连接上消费,服务端可能不会收到来自客户端的消息确认,从而影响消费性能。若消费速度过低,服务端将不堪重负。 大量的连接和通道可能会影响RabbitMQ管理接口的性能 RabbitMQ会收集每个连接和通道的数据进行分析和显示,大量连接和通道会影响RabbitMQ管理接口的性能。查看监控数据前提条件 已创建Kafka实例,且实例中有可消费的消息。 操作步骤 步骤 1 登录管理控制台。 步骤 2 在管理控制台右上角单击,选择区域。 说明 请选择Kafka实例所在的区域。 步骤 3 在管理控制台左上角单击,选择“企业中间件”-“分布式消息服务”-“Kafka专享版”,进入分布式消息服务Kafka专享版页面。 步骤 4 通过以下任意一种方法,查看监控数据。 在Kafka实例名称后,单击。跳转到云监控页面,查看实例、节点、队列和消费组的监控数据,数据更新周期为1分钟。
天翼云最新活动
售前咨询热线
400-810-9889转1
关注天翼云
©2025
天翼云科技有限公司版权所有 增值电信业务经营许可证A2.B1.B2-20090001
公司地址：北京市东城区青龙胡同甲1号、3号2幢2层205-32室
