基本概念

业务维度 同步的业务维度分为⽤户维度和设备维度,用户维度指根据 userId 来推送数据,设备维度指根据 utdId 来推送数据。页面 页面即智能搭建的产物,一个页面对应一个 URL,对外投放后,用户可以通过手机访问。页面是应用的可视化界面,...

Web端接入

教室 上课与下课 设备开关与选择 白板涂鸦与文档分享 共享屏幕 多媒体插播(目前仅支持视频播放)聊天互动与管理 全员禁言(或解除)删除群消息 成员管理 展示教室中成员及状态(在教室中/已离开/被移除/连麦状态)将学生移除出教室 连麦...

Web端接入

aliyun-interaction-sdk plugin.ts 中引入了 aliyun-interaction-sdk 用于直播间互动消息的收发,Appserver所提供的 token接口会返回互动sdk认证所需的token,详细内容请参见 Web端集成。alivc-live-push plugin.ts 中引入了 alivc-live-...

全球消息路由

全球消息路由功能可用于跨地域间的消息同步,通过路由规则将消息从源实例的Topic中同步到目标实例的Topic,并支持过滤规则,按照指定的Tag将消息过滤后再进行同步。在容灾备份或异地多活场景下,您可以创建全球消息路由任务,确保跨地域间...

修改预约重启时间

在 计划内运维事件 列表中,在 云服务器 页签下,找到已经设置了重启计划的ECS实例,在 操作 列,单击 预约重启。在 预约重启时间 页面,选择 预约日期 和 预约时间。说明 预约重启时间不能超过 最晚可预约时间。其中,最晚可预约时间 比 ...

为什么发送给Topic的消息在分区中分布不均衡

问题现象 发送消息到某个Topic后,该Topic下部分分区消息比较多,部分分区消息少,甚至没有。分区中消息量可以在 Topic详情 页面的 分区状态 页签查看,位点数即是消息数。以下图为例,分区 2 消息比较多,其他分区消息少甚至没有,消息...

边缘网络自治

具备网络自治能力的节点,即使在边缘节点和云端管控网络断连等异常情况下,业务重启还是节点重启后,节点内或者跨节点间的业务应用通信都将自动恢复。适用于边缘计算的弱网络连接状态下应用跨节点通信的场景。功能说明 无论业务应用选择...

迁移上云操作

步骤五:迁移消息业务 迁移消息业务需要按照Topic粒度对每个Topic进行切流操作,将消息读写流量分阶段切换到目标集群上。注意事项 执行切流操作时,每切换一次Topic状态,请及时观察消息收发是否符合预期,若无异常再执行下一步切换操作,...

主题(Topic)

消息业务是否关联:如果业务没有直接关联,比如,淘宝交易消息和盒马物流消息没有业务交集,需要使用不同的消息主题;同样是淘宝交易消息,女装类订单和男装类订单可以使用同一个主题。当然,如果业务量较大或其他子模块应用处理业务时需要...

TopicMessage

用户发布消息到主题时,可以指定消息体、消息标签和消息额外属性。主题消息的最长保留时间为1天,超过这个时间,不论消息是否成功推送给用户都将被垃圾回收器回收。消息属性 MessageId 消息的编号。一个主题中每个消息都有唯一的MessageId...

消息过滤

消息服务MNS 的消息过滤功能是指将一个主题的消息通过不同的标签推送到不同的订阅渠道。本文介绍消息过滤的功能以及如何设置消息过滤标签。背景信息 通常情况下,在主题中创建订阅可以将消息推送至已订阅的推送目标。即消息没有设置消息...

Topic与Tag最佳实践

消息队列RocketMQ版 中,Topic与Tag都是业务上用来归类的标识,区分在于Topic是一级分类,而Tag可以理解为是二级分类。您可通过本文了解如何搭配使用Topic和Tag来实现消息过滤。背景信息 Topic和Tag的定义如下:Topic 消息主题,通过...

消息处理时长自适应

一个Worker接收到了消息M1,但是Worker在处理完消息之后,进程发生了Crash或者机器发生了重启。那么M1这条消息至少在6个小时之后才会被另一个Worker接收到并处理。而自己写代码处理Failover的情况的话,程序又会变得比较复杂。目标 在一些...

Spring集成

消息队列 RabbitMQ 版 支持Spring框架的SDK,本文介绍如何集成Spring框架的SDK客户端收发消息。前提条件 您已在 云消息队列 RabbitMQ 版控制台 创建实例、Vhost、Exchange、Queue等相关资源,具体操作,请参见 步骤二:创建资源。安装...

队列模型基本概念

本文对 消息服务MNS 的队列模型涉及的专有名词及术语进行定义和解析,方便您更好地理解相关概念并使用队列模型。Account 用户的阿里云账号ID。队列(Queue)消息存储的目的地,分成普通队列和延时队列两类。消息包含数据和属性,可以分成...

配置消息灰度

背景信息 虽然绝大多数业务场景下对于消息的灰度的要求并不像RPC的要求得这么严格,但是在以下两个场景中,还是会对消息的全链路有一定的诉求。当消息的消费逻辑进行了修改时,这时候希望通过小流量的方式来验证新的消息消费逻辑的正确性,...

基本概念

消息堆积 生产者已经将消息发送到 云消息队列 RocketMQ 版 的服务端,但由于消费者的消费能力有限,未能在短时间内将所有消息正确消费掉,此时在 云消息队列 RocketMQ 版 的服务端保存着未被消费的消息,该状态即消息堆积。事务消息 事务...

回执消息简介与配置流程

云通信的所有业务消息都支持MNS消息服务向外发送。用户在 语音服务控制台 启用MNS消息服务订阅指定的消息类型(MessageType)时,系统会自动生成该类型的独立消息队列及名称(QueueName)。用户可使用此消息队列名称(QueueName)和消息...

回执消息简介与配置流程

云通信的所有业务消息都支持MNS消息服务向外发送。用户在 智能联络中心控制台 启用MNS消息服务订阅指定的消息类型时,系统会自动生成该类型的独立消息队列及名称(QueueName)。您可以使用此消息队列名称和消息类型,通过阿里云 获取...

使用异常

无法连接 Broker 客户端启动失败,出现“Can not find name server with endpoint”报错 启动 Producer、Consumer 失败,Group ID 重复 主动订阅消息,获取队列列表失败 消息显示 Consumed,但消费端未感知到 无法连接 Broker 可能的原因:...

Topic 与 Tag

在 SOFAStack 消息队列中,Topic 与 Tag 都是业务上用来归类的标识,区分在于 Topic 是一级分类,而 Tag 可以理解为是二级分类。您可通过本文了解如何搭配使用 Topic 和 Tag 来实现消息过滤。背景信息 Topic 和 Tag 的定义如下:Topic:...

消息(Message)

系统默认的消息最大限制如下:普通和顺序消息:4 MB 事务和定时或延时消息:64 KB 使用建议 单条消息不建议传输超大负载 作为一款消息中间件产品,云消息队列 RocketMQ 版 一般传输的是都是业务事件数据。单个原子消息事件的数据大小需要...

消费幂等

为了防止消息重复消费导致业务处理异常,消息队列RocketMQ版 的消费者在接收到消息后,有必要根据业务上的唯一Key对消息做幂等处理。本文介绍消息幂等的概念、适用场景以及处理方法。什么是消息幂等 当出现消费者对某条消息重复消费的情况...

函数计算

本文介绍如何在 云消息队列 RocketMQ 版 控制台创建流出目标为 云消息队列 Kafka 版 的消息流出任务。前提条件 您已购买 云消息队列 RocketMQ 版 实例,且实例处于 服务中 状态。具体步骤,请参见 创建资源。您已开通函数计算服务,具体...

函数计算

本文介绍如何在 云消息队列 RocketMQ 版 控制台创建流出目标为 云消息队列 Kafka 版 的消息流出任务。前提条件 您已购买 云消息队列 RocketMQ 版 实例,且实例处于 服务中 状态。具体步骤,请参见 创建资源。您已开通函数计算服务,具体...

延时消息

如果您希望消息被投递后延迟一段时间被消费者消费,您可以使用 云消息队列 RabbitMQ 版 的延时消息。云消息队列 RabbitMQ 版 原生支持延时消息,使用方式比开源RabbitMQ更简单。什么是延时消息 延时消息是指在指定时间段之后才被消费者消费...

确认消息API

使用确认消息API确认消息消费状态。请求构造 请求行 DELETE/topics/TopicName/messages?ns=INSTANCE_ID&consumer=GID HTTP/1.1 参数说明如下。参数 是否必选 说明 TopicName 是 将消息发送至的Topic名称。ns 否 实例ID,针对有命名空间的...

创建FC Sink Connector

本文介绍如何在 云消息队列 RocketMQ 版 控制台创建流出目标为函数计算的消息流出任务。前提条件 您已购买并部署 云消息队列 Kafka 版 实例,且实例处于 服务中 状态。具体步骤,请参见 步骤二:购买和部署实例。您已开通函数计算服务,...

应用场景

物联网设备无时无刻不在产生海量的设备状态数据和业务消息数据,这些数据有助于进行设备监控、业务分析预测和故障诊断。背景信息 设备将原始数据通过 MQTT 协议发送到物联网平台,经由物联网平台将数据转发到消息服务系统,继而通过流计算...

消息幂等

如果消息重复消费会影响您的业务处理,请对消息做幂等处理。本文介绍消息幂等的概念、适用场景以及处理方法。什么是消息幂等 在数学与计算机学中,幂等操作的特点是其任意多次执行所产生的影响均与一次执行的影响相同。在消息领域,幂等是...

消息幂等

为了防止消息重复消费导致业务处理异常,SOFAStack 消息队列的消费者在接收到消息后,有必要根据业务上的唯一 Key 对消息做幂等处理。本文介绍消息幂等的概念、适用场景以及处理方法。什么是消息幂等 当出现消费者对某条消息重复消费的情况...

事务消息

半事务消息:暂不能投递的消息,生产者已经成功地将消息发送到了 云消息队列 RocketMQ 版 服务端,但是 云消息队列 RocketMQ 版 服务端未收到生产者对该消息的二次确认,此时该消息被标记成“暂不能投递”状态,处于该种状态下的消息即半...

配额与限制

消息队列 RocketMQ 版 对实例的资源配额、实例规格和相关参数进行了约束和规范,您在使用 云消息队列 RocketMQ 版 时不要超过对应的限制值,避免应用出现异常。参数限制 以下参数中各资源的命名及备注等限制值不支持调整,请严格按照规范...

元数据导入

本文介绍如何在 云消息队列 Kafka 版 控制台创建元数据导入任务,将元数据迁移至 云消息队列 Kafka 版 已有实例。前提条件 下载JDK 8 购买并部署云消息队列 Kafka 版实例:购买并部署VPC实例 购买并部署公网/VPC实例 说明 购买实例的规格可...

RESTful API概览

BatchSendMessage 批量发送消息 API调用 ReceiveMessage 消费消息 控制台、API调用 BatchReceiveMessage 批量消费消息 API调用 DeleteMessage 删除消息 控制台、API调用 BatchDeleteMessage 批量删除消息 API调用 PeekMessage 查看消息 API...

集群消费和广播消费

集群消费和广播消费是 云消息队列 RocketMQ 版 的基本消费模式,您可以在消费者客户端将消费模式设置为集群消费或者广播消费,用于控制同一条消息只能被集群内一个消费者消费到,还是会被集群内每个消费者都消费到。背景信息 云消息队列 ...

RESTful API概览

本文列举了消息服务MNS主题模式提供的API。主题管理 API 说明 CreateTopic 创建主题 SetTopicAttributes 修改主题属性 GetTopicAttributes 获取主题属性 DeleteTopic 删除主题 ListTopic 获取主题列表 订阅管理 API 说明 Subscribe 创建...

弹性业务带宽计费方式

弹性业务带宽表示在实例业务带宽的基础上,为实例弹性增加业务带宽,用于解决在业务高峰期间,正常业务流量波动(超出实例业务带宽规格)导致业务被限流的问题。开启弹性业务带宽后,您只需在实际流量峰值超出业务带宽规格时,为超量使用的...

RDS

RAM用户通过控制台重启RDS实例 以下示例表示,在北京时间2021年08月04日10:54:38,RAM用户 Alice 调用RestartDBInstance接口重启了杭州地域ID为 rm-bp15hkr5tb57v*的RDS实例。{"apiVersion":"2014-08-15","requestId":"532F2CED-F931-57FC-...

迁移上云概述

业务入侵小、易实施 迁移过程中仅需要相关业务应用更改接入点配置并重启应用一次,后续切流全部由 云消息队列 RocketMQ 版 服务端动态配置生效。消息的上下游链路可自由升级,无需梳理收发链路依赖。整个操作流程影响范围小,便于上下游...
共有200条 < 1 2 3 4 ... 200 >
跳转至: GO
产品推荐
云服务器 安全管家服务 安全中心
这些文档可能帮助您
物联网无线连接服务 云数据库 Redis 版 云服务器 ECS 内容安全 弹性公网IP 短信服务
新人特惠 爆款特惠 最新活动 免费试用