Subscription

订阅者通过Subscribe接口创建订阅,消息服务MNS 根据订阅的描述给用户端推送消息,推送的起点是订阅时Topic中最新的消息。订阅创建成功后,消息服务MNS 会向指定的Endpoint推送消息。如果Endpoint不可用,消息服务MNS 会按照指定的重试策略...

Subscription

订阅者通过Subscribe接口创建订阅,消息服务MNS 根据订阅的描述给用户端推送消息,推送的起点是订阅时Topic中最新的消息。订阅创建成功后,消息服务MNS 会向指定的Endpoint推送消息。如果Endpoint不可用,消息服务MNS 会按照指定的重试策略...

队列模型基本概念

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

消息加密传输

本文介绍如何进一步提高您与 消息服务MNS 服务之间的网络链路上的安全性。背景信息 消息服务MNS 提供在公网HTTPS上进行消息加密传输的服务。对于包含敏感信息的消息,进一步提高您与阿里云服务之间的网络链路上的安全性,目前有以下两种...

如何确认消息服务MNS推送请求中的公钥证书地址是阿里...

概述 本文主要介绍在使用消息服务MNS时,如何确认推送请求中 x-mns-signing-cert-url 参数的公钥证书地址为阿里云官方的。详细信息 目前,消息服务MNS的公钥证书在名为“mnstest”的OSS Bucket中,公钥证书地址如下。...确认是该Bucket地址后...

Endpoint签名认证

您可以通过推送请求头中的 x-mns-signing-cert-url 获取签名证书,并根据相应的方法来验证该请求是否由 消息服务MNS 系统发出,防止恶意请求造成负面影响。在 消息服务MNS 推送请求头中,Authorization字段的值是 消息服务MNS 根据待签名...

队列使用手册

Endpoint 访问 消息服务MNS 的接入地址,请登录 MNS控制台 查看。具体操作,请参见 获取接入点。不同地域的接入地址不同。CreateQueueAndSendMessage的代码最上方有一些设置,使用SDK的时候进行同样的设置。require SDK里自带的一个...

队列使用手册

Endpoint 访问 消息服务MNS 的接入地址,请登录 MNS控制台 查看。具体操作,请参见 获取接入点。不同地域的接入地址不同。步骤二:创建队列 如果之前未创建队列,那么首先需要创建队列。默认创建的队列名称是myqueue,也可以修改代码指定...

常见问题

消息消费失败是否会重新消费?消息队列RocketMQ版5.x系列实例支持广播消费吗?消息队列RocketMQ版定时消息最大可定时多长时间?客户端连接常见问题 客户端连接时出现“signature validate by dauth failed”错误 客户端连接时出现...

常见问题

消息消费失败是否会重新消费?云消息队列 RocketMQ 版5.0系列实例支持广播消费吗?云消息队列 RocketMQ 版定时消息最大可定时多长时间?实例的Topic数量和Group数量有限制吗?云消息队列 RocketMQ 版存储需要挂载磁盘吗?客户端连接常见...

消息服务消息批量操作注意事项

消息服务MNS 提供了批量发送和批量接收消息的接口,既大大提升了QPS,又降低了请求次数,节省了费用。批量操作注意事项:BatchSendMessage一次最多发送16条消息,所有消息的大小加起来,总和不能超过64 KB。如果您不指定,那么默认消息会做...

产品架构

集群级别的高可用,是 云消息队列 RocketMQ 版 跟其他的消息服务器的主要区别,消息生产者发送一条消息消息服务器,消息服务器会随机的选择一个消费者,只要这个消费者消费成功就认为是成功了。重要 文中所提及的 云消息队列 RocketMQ 版...

产品概述

本文介绍 云消息队列 Kafka 版 的产品动态、产品简介及产品计费。云消息队列 Kafka 版 动态与公告 产品简介 产品计费 云消息队列 Confluent 版 什么是消息队列 Confluent 版?产品计费

发布者最佳实践

导致这种失败的原因可能是消息已经发送成功,但是ACK失败,也有可能是确实没发送成功。云消息队列 Kafka 版 是VIP网络架构,长时间不进行通信连接会被主动断开,因此,不是一直活跃的客户端会经常收到 connection reset by peer 错误,建议...

P2P消息收发模式(MQTT)

什么是P2P模式 P2P,顾名思义,是一对一的消息收发模式,即只有一个消息发送者和一个消息接收者。而Pub/Sub模式通常用于一对多或多对多的消息群发场景,即拥有一个或多个消息发送者和多个消息接收者的场景。在P2P模式中,发送者发送消息时...

P2P消息收发模式(MQTT)

什么是P2P模式 P2P,顾名思义,是一对一的消息收发模式,即只有一个消息发送者和一个消息接收者。而Pub/Sub模式通常用于一对多或多对多的消息群发场景,即拥有一个或多个消息发送者和多个消息接收者的场景。在P2P模式中,发送者发送消息时...

延时消息

什么是延时消息 延时消息是指在指定时间段之后才被消费者消费的消息。应用场景 延时消息适用于以下场景:对消息生产和消费有时间窗口要求的场景。例如,在电商交易中超时未支付关闭订单的场景,在订单创建时会发送一条延时消息。这条消息将...

消息 Mesh

本文将从以下几个方面对消息 Mesh 进行解读:消息 Mesh 介绍:解答消息 Mesh 在整个 Service Mesh 中的地位是什么,它又能为业务带来哪些价值。消息 Mesh 的价值:介绍消息 Mesh 所能带来的价值和收益。消息 Mesh 化改造:结合蚂蚁集团消息...

同城多活常见问题

消息的主备容灾细节点是什么?MSHA能给客户业务带来什么价值?假设数据库主备,ECS双可用区部署,是否就是同城多活?不是。此方案仅做到同城“资源”双活,业务流量存在南北走向流量HTTP,东西走向流量RPC、消息、分布式任务等。资源双活在...

顺序消息

什么是顺序消息 顺序消息是 云消息队列 RocketMQ 版 提供的一种对消息发送和消费顺序有严格要求的消息。对于一个指定的Topic,消息严格按照先进先出(FIFO)的原则进行消息发布和消费,即先发布的消息先消费,后发布的消息后消费。顺序消息...

消息存储和清理机制

因此,在实际使用中需要考虑以下问题,消息服务端中的存储以什么维度为判定条件?消息存储以什么粒度进行管理?消息存储超过限制后如何处理?这些问题都是由消息存储和过期清理机制来定义的。了解消息存储和过期清理机制,可以从以下方面...

定时/延时消息

功能原理 什么是定时消息 定时消息是 云消息队列 RocketMQ 版 提供的一种高级消息类型,消息被发送至服务端后,在指定时间后才能被消费者消费。通过设置一定的定时时间可以实现分布式场景的延时调度触发效果。定时时间设置原则 云消息队列 ...

函数计算

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

如何设置Message ID

什么是Message ID Message ID(消息标识符)是消息的可选属性,类型为short string。Message ID在业务上通常被设置为唯一,适用于追踪和识别销售单、工单等需要保证消息唯一的场景。云消息队列 RabbitMQ 版 服务端不会对消息进行幂等处理。...

函数计算

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

如何设置Message ID

什么是Message ID Message ID(消息标识符)是消息的可选属性,类型为short string。Message ID在业务上通常被设置为唯一,适用于追踪和识别销售单、工单等需要保证消息唯一的场景。云消息队列 RabbitMQ 版 服务端不会对消息进行幂等处理。...

普通消息

功能原理 什么是普通消息 定义:普通消息是 云消息队列 RocketMQ 版 基本消息功能,支持生产者和消费者的异步解耦通信。普通消息生命周期 初始化 消息被生产者构建并完成初始化,待发送到服务端的状态。待消费 消息被发送到服务端,对消费...

创建FC Sink Connector

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

消息发送重试和流控机制

消息重复问题:因远程调用的不确定性,当 云消息队列 RocketMQ 版 客户端因请求超时触发消息发送重试流程,此时客户端无法感知服务端的处理结果,客户端进行的消息发送重试可能会产生消息重复问题,业务逻辑需要自行处理消息重复问题。...

什么是全局事务服务GTS

什么需要全局事务服务 一个完整的业务往往需要调用多个子业务服务,随着业务的不断增多,涉及的服务及数据也越来越多,越来越复杂。传统的系统难以支撑,出现了应用和数据库等的分布式系统。分布式系统又带来了数据一致性的问题,从而...

事务消息

功能原理 什么是事务消息 事务消息是 云消息队列 RocketMQ 版 提供的一种高级消息类型,支持在分布式场景下保障消息生产和本地事务的最终一致性。事务消息处理流程 事务消息交互流程如下图所示。生产者将消息发送至 云消息队列 RocketMQ 版...

回执消息配置

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

语音服务使用FAQ

通话是否接通可以登录 语音服务控制台,在 业务统计>语音记录查询 页面,通过主叫或被叫进行查询确认,或者调用 QueryCallDetailByCallId 接口和 消息回执 进行确认。语音服务呼叫失败怎么办?请您提供具体案例的主叫号码+被叫号码+时间,...

什么是消息队列 RocketMQ 版?

业务消息 异步解耦、削峰填谷 云消息队列 RocketMQ 版 初始于阿里巴巴双十一核心链路,广泛应用于物流、购物车、积分等微服务业务系统,有效承载系统间异步解耦和流量削峰填谷的作用。通过使用 云消息队列 RocketMQ 版,可有效实现如下作用...

API&SDK常见问题

语音服务呼叫回了408处理超时是什么原因?错误码408一般为被叫侧长时间未接起导致的或者被叫服务器问题。语音服务外呼拨号返回487是什么情况?请您登录 语音服务控制台,在 业务统计>语音记录查询 页面查看失败原因。如果无结果请提供对应...

死信消息

示例如下:messageBuilder.addProperty("originalTopic","testTopic")死信消息和主业务区分处理 死信消息是正常业务流程中消息重试仍然失败的消息,需要和主业务流程分开处理,避免影响正常业务。死信Topic和原消息发送Topic不能相同,避免...

收发事务消息

本文提供使用TCP协议下的C/C++ SDK收发事务消息的示例代码供您参考。云消息队列 RocketMQ 版 提供类似XA或Open XA的分布式事务功能,通过 云消息队列 RocketMQ 版 事务消息,能达到分布式事务的最终一致。交互流程 事务消息交互流程如下图...

消费幂等

什么是消息幂等 当出现消费者对某条消息重复消费的情况时,重复消费的结果与消费一次的结果是相同的,并且多次消费并未对业务系统产生任何负面影响,那么这个消费者的处理过程就是幂等的。例如,在支付场景下,消费者消费扣款消息,对一笔...

消息队列 Kafka 版何时删除旧消息

当往Kafka Topic中写入数据提示...相关文档 如果消息超过 消息保留时长 还未被删除,具体原因,请参见 为什么消息已经过期还未被删除?当磁盘空间已满时,除了等待自动删除过期数据,也可以通过升配购买磁盘容量,详情请参见 升级实例配置。

消息幂等

什么是消息幂等 在数学与计算机学中,幂等操作的特点是其任意多次执行所产生的影响均与一次执行的影响相同。在消息领域,幂等是指Consumer重复消费某条消息时,重复消费的结果与消费一次的结果是相同的,并且多次消费并未对业务系统产生...
共有200条 < 1 2 3 4 ... 200 >
跳转至: GO
产品推荐
云服务器 安全管家服务 安全中心
这些文档可能帮助您
商标服务 短信服务 物联网无线连接服务 云服务器 ECS 弹性公网IP 人工智能平台 PAI
新人特惠 爆款特惠 最新活动 免费试用