消息服务MNS_消息服务MNS文档介绍内容-天翼云

Websocket接入
node环境安装依赖$ npm install mqtt --savejs代码示例const mqtt = require('mqtt') ...服务器地址。

来自：
帮助文档
分布式消息服务MQTT
最佳实践
Websocket接入
使用限制
您需要根据业务流量规划提前开通微服务引擎-云原生网关实例,并在多活产品控制台进行集成管理。数据库双向同步应用容灾多活通过集成数据传输服务产品能力,支持数据库双向同步功能。您需要到DTS产品控制台开通实例和创建数据同步任务,并在多活产品控制台进行集成管理。消息双向同步应用容灾多活通过集成分布式消息服务RocketMQ产品能力,支持消息双向同步功能。您可以在多活产品控制台进行集成配置,也可以到分布式消息服务RocketMQ产品控制台进行任务管理。

来自：
帮助文档
应用高可用
产品简介
应用容灾多活
使用限制
重启实例
步骤 3 在管理控制台左上角单击,选择“企业中间件”-“分布式消息服务”-“Kafka专享版”,进入分布式消息服务Kafka专享版页面。步骤 4 通过以下任意一种方法,重启Kafka实例。勾选Kafka实例名称左侧的方框,可选一个或多个,单击信息栏左上侧的“重启”。在待重启Kafka实例所在行,单击“重启”。单击Kafka实例名称,进入实例详情页面。单击右上角的“重启”。步骤 5 在“重启实例”对话框中,单击“是”,完成重启Kafka实例。重启Kafka实例大约需要3到15分钟。

来自：
帮助文档
分布式消息服务Kafka
用户指南
实例管理
重启实例
集群监控
操作步骤 1、天翼云官网点击控制中心,选择产品分布式消息服务RocketMQ。 2、登录分布式消息服务RocketMQ控制台,点击右上角地域选择对应资源池。进入实例列表,点击【管理】按钮进入管理菜单。 3、进入监控菜单,下拉选择broker和brokerID,查看集群的监控信息:

来自：
帮助文档
分布式消息服务RocketMQ
用户指南
监控与告警
集群监控
创建Topic
操作场景 Topic,即消息主题,消息发送与接收的基本单元。购买RocketMQ实例成功后,需要手动创建Topic,然后才能进行生产消息和消费消息。前提条件已购买RocketMQ实例。操作步骤登录分布式消息服务RocketMQ控制台。单击RocketMQ实例的名称,进入实例详情页面。在左侧导航栏,单击“Topic管理”,进入“Topic管理”页面。单击“创建Topic”,弹出“创建Topic”页面。参考表1,填写Topic名称和配置信息。

来自：
帮助文档
分布式消息服务RocketMQ
快速入门
创建Topic
MQTT触发器
MQTT触发器可以订阅分布式消息服务MQTT并根据消息触发关联的函数,借此能力,使得函数可以消费指定Topic的消息,执行自定义处理逻辑。前提条件已创建函数。已创建MQTT实例操作步骤登录函数计算控制台,点击目标函数,进入函数详情。选择详情下顶部的配置选项卡。在配置选项卡中,选择左边的触发器选项卡。点击创建触发器,在弹出的右抽屉中选择MQTT触发器,配置参数解释如下:配置项操作示例触发器类型选择MQTT触发器。MQTT触发器名称填写自定义的触发器名称。

来自：
帮助文档
函数计算
用户指南
事件触发
MQTT触发器
创建数据订阅任务
注意数据订阅功能数据类型支持指标数据、事件数据及告警数据,订阅方式支持分布式消息服务及API方式。指标数据订阅支持分布式消息服务(kafka)及remotewrite-api方式。事件数据订阅/告警数据订阅支持分布式消息服务(kafka)及api-push方式。分布式消息服务(kafka)需要客户提前部署资源,在云监控平台创建订阅任务时填写相关客户端配置信息。操作步骤登录控制中心。在控制中心页面左上角点击,选择区域,本文我们选择华东1。

来自：
帮助文档
云监控服务
用户指南
数据订阅
创建数据订阅任务
构造请求
请求消息体可选,格式统一为JSON,具体内容参见各个API接口说明。

来自：
帮助文档
弹性IP
API参考
如何调用API
构造请求
构造请求
请求消息体可选,格式统一为JSON,具体内容参见各个API接口说明。

来自：
帮助文档
共享带宽
API参考
如何调用API
构造请求
构造请求
请求消息体可选,格式统一为JSON,具体内容参见各个API接口说明。

来自：
帮助文档
VPC终端节点
API参考
如何调用API
构造请求
Kafka触发器
Kafka触发器Kafka触发器可以订阅天翼云提供的分布式消息队列Kafka实例,并根据消息触发关联的工作流,借此能力,使得工作流可以消费指定topic的消息,执行特定工作流处理逻辑。注意事项Kafka触发器订阅的Kafka实例必须和工作流在相同地域。前提条件已创建工作流。已开通分布式消息Kafka实例(KAFKA引擎版),详情请参考创建分布式消息服务Kafka实例。

来自：
帮助文档
函数计算
用户指南
云工作流
控制台操作
工作流调度
Kafka触发器
准备环境
在创建VPC和子网时应注意如下要求: 创建的VPC与使用的分布式消息服务RocketMQ应在相同的区域。创建VPC和子网时,配置参数建议使用默认配置。在创建RocketMQ实例前,确保已存在可用的安全组。创建方法,请参考创建安全组。如果您已有安全组,可重复使用,不需要多次创建。在创建安全组时应注意如下要求: 创建安全组时,“模板”选择“自定义”。使用分布式消息服务RocketMQ必须添加表1所示安全组规则,其他规则请根据实际需要添加。

来自：
帮助文档
分布式消息服务RocketMQ
快速入门
准备环境
配置告警
创建联系人组进入分布式消息服务RocketMQ管理控制台,在实例列表页点击管理进入实例详情页,左侧菜单点击告警管理点击通知组菜单,右侧点击新建联系人组,输入联系人信息信息,点击保存创建通知策略进入分布式消息服务RocketMQ管理控制台,在实例列表页点击管理进入实例详情页,左侧菜单点击告警管理点击通知策略菜单,右侧点击创建通知策略,输入信息,点击确认创建告警规则进入分布式消息服务RocketMQ管理控制台,在实例列表页点击管理进入实例详情页,左侧菜单点击告警管理点击告警规则菜单

来自：
帮助文档
分布式消息服务RocketMQ
用户指南
监控与告警
配置告警
实例列表
介绍分布式消息服务MQTT实例列表内容。操作说明 1、进入控制台查看已购买的实例列表,若列表为空,可点击右上角【创建实例】进入购买页面,创建实例详情见具体操作步骤。 2、支持按照实例ID查询,输入查询内容,点击【查询】按钮即可展示需要的实例数据。 3、查看实例基本信息,包括实例ID、规格、计费模式、创建时间、到期时间、状态。其中状态说明见下文。运行状态 1、登录管理控制台。 2、进入MQTT管理控制台。

来自：
帮助文档
分布式消息服务MQTT
用户指南
实例管理
实例列表
删除实例
步骤 3 在管理控制台左上角单击,选择“应用服务 > 分布式消息服务 Kafka”,进入分布式消息服务Kafka专享版页面。步骤 4 若当前存在创建失败的Kafka实例,界面信息栏会显示“创建失败任务”及失败数量信息。说明创建失败的实例,不会占用其他资源。步骤 5 单击“创建失败任务”或者此参数后图标/数量,弹出“创建失败任务”对话框。步骤 6 在“创建失败任务”界面删除创建失败的Kafka实例。单击“清理失败任务”,一键式删除所有创建失败的Kafka实例。

来自：
帮助文档
分布式消息服务Kafka
用户指南
实例管理
删除实例
修改配置参数
操作场景天翼云分布式消息服务Kafka为实例、主题、消费组的几个常用配置提供了默认值,在实例开通时默认配置,并支持在控制台手动修改,您可以根据具体的业务需求,自行修改。这几种常用的配置参数,根据是否需要重启Kafka实例,可以分为动态参数和静态参数: 动态参数:修改成功后,无需重启实例,立即生效静态参数:修改成功后,只有重启实例才能生效自定义参数使用限制已开通天翼云Kafka集群版实例,实例的运行状态为“运行中”。单机版不支持修改配置参数。

来自：
帮助文档
分布式消息服务Kafka
用户指南
实例管理
修改配置参数
修改用户信息
介绍分布式消息服务Kafka修改用户的功能操作内容。场景描述当前主要支持重置用户密码:当用户忘记密码或需要更改密码时,可以通过修改用户密码来实现。这有助于保护用户账户的安全性,防止未经授权的访问和操作。操作步骤 (1)登录管理控制台。 (2)进入Kafka管理控制台。 (3)在实例列表页在操作列,目标实例行点击“管理”。 (4)点击“用户管理”后进入应用用户管理页面,点击“修改”。 (5)点击“修改”后,在弹窗中可以修改密码和对应描述。

来自：
帮助文档
分布式消息服务Kafka
用户指南
用户管理
修改用户信息
产品定义
事件总线总体架构事件总线EventBridge的总体架构如下图所示:事件源:事件的来源,将天翼云服务、自定义应用、SaaS应用等应用程序产生的事件消息投递至事件总线。事件总线:存储接收到的事件消息,并根据事件规则将事件消息路由到事件目标。事件目标:消费事件消息。应用场景事件总线EventBridge的典型应用场景如下:构建事件驱动型架构:借助事件总线EventBridge,您无需了解事件源,就可以直接筛选并发布事件。

来自：
帮助文档
事件总线
产品简介
产品定义
步骤4：查看实时日志
查看实时日志在云日志服务管理控制台,单击“日志管理”。在日志组列表中,单击已创建的日志组名称。在日志流列表中,单击已创建的日志流名称。在日志流详情页面,单击“实时日志”,查看实时日志。日志每隔大约5秒钟上报一次,在日志消息区域,您最多需要等待5秒钟左右,即可查看实时上报的日志。同时,您还可以通过页面右上方的“清屏”、“暂停”对日志消息区域进行操作。清屏:清除日志消息区域已经显示出来的日志。暂停:暂停日志消息的实时显示,页面定格在当前已显示的日志。

来自：
帮助文档
云日志服务
快速入门
步骤4：查看实时日志
扩容
场景描述当需要处理大量消息时,RocketMQ实例的扩容是一种常见的解决方案。扩容可以增加RocketMQ集群的吞吐量、存储能力和高可用性。分布式消息服务RocketMQ提供三类扩容方案,分别为节点、规格和磁盘扩容,更好满足用户不同场景下的扩容需求。节点扩容:指向RocketMQ集群中添加更多的节点以增加系统的吞吐量和可靠性。通过扩容,可以将消息的发送和消费负载分摊到更多的节点上,从而提高系统的并发处理能力。规格扩容:指通过增加RocketMQ的资源配置来提升系统的处理能力和性能。

来自：
帮助文档
分布式消息服务RocketMQ
用户指南
实例管理
扩容
服务
本章节为您介绍服务相关的内容。服务通常指的是 API 网关要连接和转发请求的目标服务。在微服务架构中 ,这些目标服务可以是各种不同的后端服务 , 比如数据库服务、用户服务、支付服务等。服务可以是内部的私有服务 ,也可以是外部的第三方服务。本系统还提供服务发现、负载均衡、健康检查等功能。创建服务1.登录API安全网关。2.在左侧导航栏选择“资源 > 服务”,进入服务列表页面。3.单击页面左上方的“新增”按钮,在左侧弹出的“新增服务”对话框中填写相关内容。

来自：
帮助文档
数据安全专区
用户指南
API安全网关操作指导
资源
服务
Kafka消费者poll的优化
代码示例对Kafka消费者的 poll()方法进行优化时,可以考虑以下几个方面: 批量拉取:通过增加 max.poll.records属...消息,减少与Kafka服务器的网络通信次数。异步提交偏移量:使用 commitAsync()方法异步提交消费者的偏移量,避免阻塞消费者的消息拉取。多线程消费:可以使用多个消费者线程并发消费消息,提高消费吞吐量。

来自：
帮助文档
分布式消息服务Kafka
最佳实践
Kafka消费者poll的优化
异常
步骤 2 单击左侧,选择“应用性能管理 APM”,进入APM服务页面。步骤 3 在左侧导航栏选择“应用监控 > 指标”。步骤 4 在界面左侧树单击待查看接口调用的环境后的。步骤 5 单击“异常”,切换至异常页签。页面默认展示所“全部实例”的“异常日志”异常日志信息。异常指标包括:类名、异常类型、日志类型、总次数、消息以及以及异常堆栈。请参照下表日志版本指标包括:logType以及版本。

来自：
帮助文档
应用性能管理
用户指南
应用指标监控
应用监控详情
异常
入门指引
本文将为您介绍分布式消息服务Kafka入门的基本流程,主要包括控制台创建Kafka专享版实例、使用弹性云主机连接实例的操作,帮助您快速上手Kafka。您还可以通过API方式创建Kafka实例、在业务代码中连接Kafka实例。操作流程图Kafka使用流程环境准备 Kafka实例运行于虚拟私有云中,在创建实例前需要确保有可用的虚拟私有云。 Kafka实例创建后,您需要在弹性云主机中下载和安装Kafka开源客户端,然后才能进行生产消息和消费消息。

来自：
帮助文档
分布式消息服务Kafka
快速入门
入门指引
系统配置
外发配置配置邮件外发邮件服务器,为改密提示和消息告警等通知提供邮件发送服务。根据需求设置私有邮箱服务器或是公共邮箱服务器,并可测试所填写服务器信息是否有效。目前支持两种发送方式,分别为SMTP和Exchange,其中Exchange仅支持Exchange2010版本。本小节主要介绍如何配置系统邮件外发。前提条件已获取“系统”模块管理权限。操作步骤 1 登录云堡垒机系统。 2 选择“系统 > 系统配置 > 外发配置”,进入系统外发配置管理页面。

来自：
帮助文档
运维安全中心（云堡垒机）
用户指南
系统管理
系统配置
消费幂等
RocketMQ无法避免消息重复,原因主要有以下几点: 签收的偏移量是定时(每5秒/次)同步到服务端的。为保证消息不丢失,SDK每次提交的总是队列未签收的最小偏移量(比如无序消费,offset为1,2,3,4,5 的消息,1,3,4,5消费并已签收,2未签收,签收时最后提交的偏移量将会是2,如果此时,客户端重启,会从2这个位置开始消费)。有网络交互就不能确保每一次的交互数据都是送达的,为保证数据不丢失就要进行重试,有重试就存在重复的可能。

来自：
帮助文档
分布式消息服务RocketMQ
最佳实践
消费幂等
实例概览
实例概览展示分布式消息服务RabbitMQ实例详情信息,包括基本信息、统计信息、节点、端口等,并提供导出服务、元数据导入服务等功能。场景描述实例概览展示分布式消息服务RabbitMQ实例详情信息,包括基本信息、统计信息、节点、端口等,并提供导出服务、元数据导入服务等功能。基本信息:展示实例订购选择的参数信息,支持安全组修改和绑定公网弹性IP。统计信息:统计实例连接数、信道数、交换器数、队列数、消费者数等数据。节点:列表展示实例节点信息。端口:列表展示实例端口信息。

来自：
帮助文档
分布式消息服务RabbitMQ
用户指南
实例管理
实例概览
与其他产品的关系
配置数据连接统一身份认证服务(Identity and Access Management) 统一身份认证服务(IAM)为MRS提供了鉴权功能。创建用户并授权使用MRSMRS自定义策略IAM用户同步MRS 消息通知服务(SMN) MRS联合消息通知服务(SMN),采用主题订阅模型,提供一对多的消息订阅以及通知功能,能够实现一站式集成多种推送通知方式。

来自：
帮助文档
翼MapReduce
产品简介
与其他产品的关系
Java客户端Pull和Push的选择：Java客户端必须使用Push Consumer
Push其实是长轮询的Pull(依然是由客户端发起),在客户端通过配置参数是可以实现流控的,并不会出现服务端的流量压垮客户端的情况。

来自：
帮助文档
分布式消息服务RocketMQ
最佳实践
Java客户端Pull和Push的选择：Java客户端必须使用Push Consumer
SDK概述
本文介绍了分布式消息服务RabbitMQ提供的SDK语言版本。 SDK列表下表提供了分布式消息服务RabbitMQ支持的SDK列表。编程语言参考文档 Java 开发指南-Java Python 开发指南-Python

来自：
帮助文档
分布式消息服务RabbitMQ
SDK参考
SDK概述
总体说明
短信服务支持基于Restful的POST方式发送HTTP/HTTPS请求。请求参数需要包含在Body中,请求及返回结果都使用 UTF8 编码。短信发送流程在控制台中添加签名、模板并经审核通过。调用短信服务的短信发送接口。短信服务成功收到请求后转发请求给运营商,运营商发送短信。用户收到短信后,短信服务会有最终的状态消息确认,即消息回执。对应的协议是: 支持HTTP或HTTPS协议请求通信。为了获得更高的安全性,推荐您使用HTTPS协议发送请求。

来自：
帮助文档
云通信-短信（文档停止维护）
API参考
公共参数
总体说明
查看流控监控
步骤 3 在管理控制台左上角单击,选择“企业中间件”-“分布式消息服务”-“Kafka专享版”,进入分布式消息服务Kafka专享版页面。步骤 4 单击Kafka实例的名称,进入实例详情页面。步骤 5 在左侧导航栏单击“流控管理 > 流控监控”,进入流控监控页面。步骤 6 设置查询流控的参数。表查询流控的参数说明参数说明统计方式设置流控的统计方式。

来自：
帮助文档
分布式消息服务Kafka
用户指南
流控管理
查看流控监控

天翼云最新活动

12.12年度钜惠

爆款云主机2核2G仅需28.8元/年，X实例35.1元/半年起！ 8代机+XSSD新客专享2.5折！

免费体验DeepSeek，上天翼云息壤

新老用户均可免费体验2500万Tokens，限时两周

云上钜惠

爆款云主机全场特惠，更有万元锦鲤券等你来领！

算力套餐

让算力触手可及

天翼云AI产品特惠

人脸识别+文字识别焕新，新用户免费试用

中小企业服务商合作专区

国家云助力中小企业腾飞，高额上云补贴重磅上线

出海产品促销专区

爆款云主机低至2折，高性价比，不限新老速来抢购！

天翼云电脑专场

移动办公新选择，爆款4核8G畅享1年3.5折起，快来抢购！

息壤智算

应用商城

定价

合作伙伴

开发者

支持与服务

了解天翼云

天翼云最新活动

产品推荐

多活容灾服务

GPU云主机

轻量型云主机

弹性伸缩服务

弹性高性能计算

AI Store

模型推理服务

科研助手

一站式智算服务平台

推荐文档

关于天翼云

订购

如何修改发票抬头

产品价格

法律法规

其他问题