消息中间件mq原理

_相关内容

接入点设置说明

在左侧导航栏,选择 中间件 消息队列 概览。在页面底部的 接入配置 找到 内网接入点 及 实例 ID。将该 TCP 协议内网接入点 配置到客户端 SDK 代码的 ENDPOINT 参数。将该 实例 ID 配置到客户端 SDK 代码的 INSTANCE_ID 参数。

查询消息轨迹

在左侧导航栏,选择 中间件 消息队列 消息轨迹。单击 创建查询任务,您可选择以下查询维度,然后按页面提示输入相应信息。按 Message ID 查询:该方式属于精确查询,速度快,精确匹配,推荐使用。按 Message Key 查询:该方式属于模糊查询...

创建和管理 Group ID

在左侧导航栏,选择 中间件 消息队列 Group 管理。单击 创建 Group ID,然后在 创建 Group ID 对话框配置 Group ID 信息:Group ID:必填。命名以“GID_”或者“GID-”开头。只能包含字母、数字、短横线和下划线。长度限制在 7-64 字符之间...

资源大盘

在左侧导航栏,选择 中间件 消息队列 资源大盘。选择或自定义时间范围,默认范围是最近 1 小时,支持的最长时间间隔为 1 天。单击 刷新,即可获取并查看目标时间范围内的各项资源数据:资源统计数据 Topic 生产报表 Group 消费报表 资源...

创建和管理 Topic

在左侧导航栏,选择 中间件 消息队列 Topic 管理。单击 创建 Topic,然后在 创建 Topic 对话框配置 Topic 信息:Topic:Topic 名称。Topic 只能包含英文、数字、短横线(-)和下划线(_),其中英文和数字必须要有一种,短横线(-)和...

消费托管MQ接口

消费托管MQ接口主要用于获取托管MQ中的消息以及消息成功后进行确认的功能。获取消息 获取托管MQ中的消息,方法名称:consumeMQMessage。函数原型 ConsumeMQMessageResponse consumeMQMessage(final ConsumeMQMessageRequest request)请求...

如何处理消息堆积

问题现象 在使用 云消息队列 RocketMQ 版 实例时收到消息堆积告警,登录 云消息队列 RocketMQ 版 控制台 后发现了下列现象:在 Group 详情 页面,看到Group ID的 实时消息堆积量 的值高于预期。导航栏中选择 消息轨迹,单击 创建查询任务,...

数据加密

存储加密 加密原理消息队列 RocketMQ 版 支持在服务器端对消息数据进行加密。客户端发送消息数据到服务端,云消息队列 RocketMQ 版 利用加密云盘持久化保存数据;客户端订阅数据时,云消息队列 RocketMQ 版 从云盘中读取解密后的数据,...

权限策略

API Resource命名格式 Resource命名示例 Action描述 RevokeToken acs:mq:*:*:*acs:mq:*:*:*mq:MqttInstanceAccess mq:RevokeToken QueryToken acs:mq:*:*:*acs:mq:*:*:*mq:MqttInstanceAccess mq:QueryToken ApplyToken 实例:acs:mq:*:*:...

开源身份验证和权限管理

功能原理消息队列 RabbitMQ 版 支持以Vhost为维度通过configure、write和read对实例资源(Exchange和Queue)操作权限进行细粒度控制。其中对configure、write和read的配置通过正则表达式(Regex)来实现,规则如下:.*表示所有资源。...

获取MQTT客户端在线状态

消息队列 MQTT 版 提供同步查询和异步上下线事件通知两种方式,来获取MQTT客户端在线状态。本文介绍这两种方式的基本原理、应用场景、具体差异以及实现方式。基本原理消息队列 MQTT 版 服务端(下文简称为MQTT服务端)提供以下方式...

查看应用拓扑图

MQ消息队列),代表当前节点为 MQ 应用,不支持查看节点的监控概览信息。DB(数据库),代表当前节点为 DB 应用,不支持查看节点的监控概览信息。Cache(缓存),代表当前节点为缓存应用,不支持查看节点的监控概览信息。应用节点连线,...

智能对话分析服务关联角色介绍

应用场景 智能对话分析的多种消息、事件需要通过消息队列Rocket MQ来推送给您,通过服务关联角色功能获取您消息队列Rocket MQ服务的发送消息的权限。AliyunServiceRoleForSCA介绍 角色名称:AliyunServiceRoleForSCA 角色权限策略:...

加密解密与签名验签的原理

加密SDK(Encryption SDK)支持加密解密、签名验签,了解其工作原理可以帮助您更好地使用加密SDK。加密解密原理 加密原理 加密SDK使用数字信封对数据进行加密。加密SDK支持通过用户主密钥(CMK)保护数据密钥(DataKey),使用数据密钥加密...

权限策略

MqttInstanceAccess mq:QueryToken ApplyToken mq:MqttInstanceAccess mq:ApplyToken CreateGroupId mq:MqttInstanceAccess mq:CreateGroupId DeleteGroupId mq:MqttInstanceAccess mq:DeleteGroupId ListGroupId mq:MqttInstanceAccess mq...

节点分组

消息队列(MQ):数据流转到MQ的Topic。调试转发 当 数据出口 为 阿里云物联网平台 时,出现此参数。用于控制调试开关。开:数据流转至基础Topic和物模型Topic。关:数据仅流转至物模型Topic。数据目的地 当 数据出口 为 阿里云物联网平台 ...

全局事务服务(文档停止维护)

全局事务服务(Global Transaction Service,简称 GTS)是一款高性能、高可靠、接入简单的分布式事务中间件,用于解决分布式环境下的事务一致性问题。在单机数据库下很容易维持事务的 ACID(Atomicity、Consistency、Isolation、Durability...

什么是RRPC

RRPC原理 具体流程如下:(可选)设备端订阅RRPC相关Topic。物联网平台根据MQTT协议,仅定制了RRPC消息的请求和响应机制。设备端若要获取物联网平台下发的RRPC消息数据,并做应对处理,需要在设备端先订阅Topic,然后开发数据处理逻辑。...

消息存储和清理机制

消息存储机制 原理机制 云消息队列 RocketMQ 版 使用存储时长作为消息存储的依据,即每个节点对外承诺消息的存储时长。在存储时长范围内的消息都会被保留,无论消息是否被消费;超过时长限制的消息则会被清理掉。消息存储机制主要定义以下...

搭建与管理网络

凭证入网 网关配置完成,并分配入网凭证给自己后,您就可以用这个凭证来使用网络,并且可以将消息队列(MQ)作为数据出口。登录 物联网络管理平台控制台。在左侧导航栏,选择 节点管理 节点分组。在 节点分组 页面,单击 创建分组。在 创建...

QueryMqttTraceMessagePublish-查询消息发送轨迹

查询指定消息的发送轨迹。当消息的收发不符合预期时,您可以通过该接口查看消息的发布时间、发布客户端等详细信息,帮助您快速定位异常原因。接口说明 每成功调用一次 QueryMqttTraceMessagePublish 接口,都会计算为一次消息 TPS,从而...

API接口常见问题

2、任务完成消息消息中会返回任务Id怎么和调用方发起的任务返回参数对应 任务完成消息不需要与AssignJobs接口的返回值进行关联。AssignJobs接口的入参中的phoneNumber和referenceId可以与消息体中对应的值做关联。一个Job对应一个联系人...

API 概览

本节给出BaaS REST的所需的SDK列表,具体接口信息请参阅相关文档。...针对两种模式,有对应的配套的API,分别介绍如下。...消费托管MQ接口 接口 描述 consumeMQMessage 获取托管MQ中的消息 ackMQMessage 消费托管MQ消息成功后,进行确认

常见问题

平台提供网管服务,对网关维度收取云资源费用,传感器节点通讯次数或流量不在此产品计费,用户可选择阿里云物联网平台或消息队列(MQ)处理数据,按照其产品收费方式计价。LoRa节点与LoRaWAN网关有绑定关系吗?没有,与Wi-Fi网络架构不同,...

2025年7月31日产品更新动态

兼容事件推送MQ 描述:目前消息推送MQ已升级到5.0,为了提升客户使用产品的体验满意度,降低客户成本,现阶段新增MQ5.0与MQ4.0到兼容,客户可根据自己实际需要进行配置对应版本的MQ,可以在语音业务设置菜单中找到事件推送即可完成配置。...

MQTT数据流出规则的实现

如果您的云端应用需要使用 云消息队列 RocketMQ 版 产品的某些功能,例如顺序消息特性、事务消息特性等,您可以通过消息流入或流出规则将 云消息队列 MQTT 版 和 云消息队列 RocketMQ 版 数据进行流转。本文介绍如何将 云消息队列 MQTT 版 ...

回执消息简介与配置流程

工作原理 用户在 语音服务控制台 启用轻量消息队列(原 MNS)订阅指定的消息类型(MessageType)时,系统会自动生成该类型的独立消息队列及名称(QueueName)。用户可使用此消息队列名称(QueueName)和消息类型(MessageType),通过阿里...

消费者分类

消息队列 RocketMQ 版 支持Push型消费者和Simple型消费者这两种类型的消费者,本文分别从使用方式、实现原理、可靠性重试和适用场景等方面为您介绍这两种类型的消费者。背景信息 云消息队列 RocketMQ 版 面向不同的业务场景提供了不同...

概述

SOFAStack 消息队列(SOFAStack MQ,简称 SOFAMQ)是基于 Apache RocketMQ 构建的分布式消息中间件,并与金融分布式架构 SOFAStack 深度集成,为分布式应用系统提供异步解耦和削峰填谷的能力,支持事务消息、顺序消息、定时消息等多种消息...

QueryMqSofamqMessageByKey

Key String 是 messageKey1 需查询的消息的 Message Key Topic String 是 test-mq_topic 需查询的消息的 Topic 返回数据 名称 类型 示例值 描述 Data Array 查询结果 Body String SGVsbG8gTVEg5raT7oWf5p6D5ai05ayt55iv 消息体 BodyCrc ...

GetMqSofamqMessageById

10911 存储该消息的服务器实例 BornTimestamp Long 1570761026630 生成时间戳 InstanceId String MQ_INST_111111111111_DOxxxxxx 实例 ID Body String SGVsbG8gTVEg5raT7oWf5p6D5ai05ayt55iv 消息体 MsgId String 1E0578FE110F18B4AAC235C0...

QueryMqSofamqMessageByTopic

Topic String 是 test-mq_topic 需查询的消息的 Topic 名称 返回数据 名称 类型 示例值 描述 Data Struct 分页查询Message Content Array 消息的详细信息 Body String SGVsbG8gTVEg5raT7oWf5p6D5ai05ayt55iv 消息体 BodyCrc Long 914112295...

GetMqSofamqDLQMessageById

BornHost String 42.120.*.*:64646 生成该消息的客户端实例 BornTimestamp Long 1570761026630 生成时间戳 InstanceId String MQ_INST_111111111111_DOxxxxxx 实例 ID MsgId String 1E0578FE110F18B4AAC235C0C8460BA2 消息 ID,即 Message ...

QueryMqSofamqDLQMessageByGroupId

Value String TagA 值 ReconsumeTimes Long 1 消息重试消费的次数 StoreHost String 11.220.*.*:10911 存储该消息的服务器实例 StoreSize Long 407 消息大小 StoreTimestamp Long 1570761026708 被服务端存储的时间戳 Topic String test-mq_...

报警信息说明

MessageCountForwardedThroughRuleEngine_MQ 规则引擎消息流转次数(MQ),即规则引擎流转数据到消息队列(RocketMQ)的次数。MessageCountForwardedThroughRuleEngine_OTS 规则引擎消息流转次数(OTS),即规则引擎流转数据到表格存储...

公共错误码

诊断 400 ConsumerProgress.NotSupport PullConsumer or broadcast message subscription does not support the query of consumer progress.PullConsumer或者广播消息订阅不支持消费进度查询。诊断 400 ConsumerStatus.QueryError Failed ...

查询调用链路

选择 MQ:新增 消息类型、topic 这两个查询项。选择 NoSQL:新增 NoSQL 类型、调用方法 这两个查询项。自定义业务 Tag 输入自定义的业务 Tag。仅支持 JSON 格式。单击 查询。在查询结果列表中,查看链路的 Trace ID、调用时间、响应时长、...

什么是Chat App 消息服务

工作原理 Chat App 消息服务 是一个多通道消息发送平台,通过统一的 API 网关接收请求,并由通道适配器将请求转换为符合各目标通道(如 WhatsApp、Viber)协议的格式进行发送。平台内置消息队列以实现高吞吐量下的异步处理和失败重试,并...

鉴权概述

本文主要介绍 云消息队列 MQTT 版 客户端鉴权的原理和分类,以便您使用相应的鉴权功能。鉴权原理 使用 云消息队列 MQTT 版 的客户端收发消息时,服务端会根据MQTT客户端设置的UserName和Password参数来进行鉴权。针对不同的权限验证场景,...

分账规则及最佳实践

分账原理:云消息队列 RocketMQ 版 的分账基于标签管理实现。您需要给实例绑定相关标签,然后在查看费用账单时,可通过绑定的实例标签筛选出不同维度的明细账单。分账最佳实践 应用场景 某公司使用一个阿里云账号,该账号下拥有很多 云消息...
< 1 2 3 4 ... 127 >
共有127页 跳转至: GO
新人特惠 爆款特惠 最新活动 免费试用