函数计算
利用函数实现业务消息的处理，通过函数计算平台开发、运行业务消息处理逻辑，订单处理，任务执行。利用函数对消息进行快速加工处理，ETL清洗。利用函数计算灵活扩展将消息转储到指定VPC中的其它下游系统。利用函数链接消息系统和其他阿里云...
函数计算
利用函数实现业务消息的处理，通过函数计算平台开发、运行业务消息处理逻辑，订单处理，任务执行。利用函数对消息进行快速加工处理，ETL清洗。利用函数计算灵活扩展将消息转储到指定VPC中的其它下游系统。利用函数链接消息系统和其他阿里云...
创建FC Sink Connector
利用函数实现业务消息的处理，通过函数计算平台开发、运行业务消息处理逻辑，订单处理，任务执行。利用函数对消息进行快速加工处理，ETL清洗。利用函数计算灵活扩展将消息转储到指定VPC中的其他下游系统。利用函数连接消息系统和其他阿里云...
调用HTTP协议的SDK收发普通消息
前提条件 创建资源 说明 本文以普通消息为例进行说明，因此您创建的普通消息的Topic不能用来收发其他类型的消息，包括定时、延时、顺序和事务消息。换言之，切勿混用不同消息类型的Topic。创建AccessKey 下载并安装HTTP协议的SDK 云消息...
消息概览
本文列举 企业商城 LinkedMall 企业购的消息类型，企业购分销商入驻以后，渠道商家的商品、订单类的回调将通过消息发送到kafka，分销商可以消费kafka消息进行业务处理。接入消息时需要注意product、order两个topic都是顺序消息。TOPIC ...
开源SDK接入（跨云账号授权）
本文以调用Java SDK为例，介绍在RAM角色跨账号授权场景，通过开源SDK实现消息收发的操作过程，帮助您更好地理解消息收发的完整过程，其他语言或框架的SDK消息收发过程相似。前提条件 创建实例 创建Vhost 背景信息 当您需要通过RAM STS角色...
消费重试
例如，您预设消息处理耗时最多20 ms，但实际业务中20 ms内消息处理不完，您可以修改消息不可见时间，延长消息处理时间，避免消息触发重试机制。修改消息不可见时间需要满足以下条件：消息处理未超时 消息处理未提交消费状态 如下图所示，...
死信消息
应用场景 典型死信消息处理场景 消息重试失败后，您可以选择将死信消息存储到指定的死信Topic中，通过另外创建一个ConsumerGroup消费这些死信消息来处理异常链路或分析死信消息。典型错误使用死信消息场景 处理死信消息时，如果将死信消息...
手机规格
规格说明 规格名称 规格标识 规格配置 说明 基础型 ecp.cs.large CPU：2核 内存：4G 系统盘：32G 一般性APP应用，计算能力需求均衡，如微信、微博等 移动办公场景：典型办公场景消息流处理、流程审批等 普通型 ecp.ce.large CPU：2核 内存...
消费幂等
为了防止消息重复消费导致业务处理异常，消息队列RocketMQ版 的消费者在接收到消息后，有必要根据业务上的唯一Key对消息做幂等处理。本文介绍消息幂等的概念、适用场景以及处理方法。什么是消息幂等 当出现消费者对某条消息重复消费的情况...
MySQL分库分表实践
实时同步DDL消息处理策略 根据业务情况为任务设置DDL消息处理策略。本示例DDL消息处理策略设置如下所示。单击 下一步。运行资源设置 根据业务情况进行运行资源设置，包括资源组、连接数，并发数等。单击 完成配置。运行任务 配置完成之后，...
性能测试技术指南
业务模型 分析 系统有很多业务，每种业务逻辑和业务量是不一样的，消耗系统的资源也不一样，因此业务种类、业务占比决定了系统的处理能力，业务模型在性能测试中起着关键性的作用。以电商场景为例，不同的促销形式和主推的类目决定了不同的...
AMQP客户端接入说明
消息处理 AMQP客户端接收到消息后，业务层处理该消息的逻辑和方法，由您自行完成开发。消息策略 实时消息直接推送。进入堆积列队的消息：由于消费客户端离线、消息消费慢等原因，消息不能实时消费，而进入堆积队列。消费客户端重新上线并...
使用Exactly-Once投递语义收发消息
云消息队列 RocketMQ 版 的Exactly-Once投递语义适用于接收消息>处理消息>结果持久化到数据库的流程，能够保证您的每一条消息消费的最终处理结果写入到您的数据库有且仅有一次，保证消息消费的幂等。更多Exactly-Once投递语义的概念和典型...
直播互动解决方案
订阅了 云消息队列 RocketMQ 版 Topic的后端应用消费该消息以实现业务处理，例如内容审核。后端应用将处理后的消息再次发送至 云消息队列 RocketMQ 版 的Topic。云消息队列 RocketMQ 版 根据创建的数据流入规则将该消息转发至 云消息队列 ...
收发顺序消息
顺序消息（FIFO消息）是阿里云 云消息队列 RocketMQ 版 提供的一种严格按照顺序来发布和消费的消息类型。本文提供使用TCP协议下的社区版C++ SDK收发顺序消息的示例代码供您参考。顺序消息分为两类：全局顺序：对于指定的一个Topic，所有...
实例规格族
根据系统架构以及使用场景，ECS实例规格族可以分为：企业级x86计算规格族群 推荐 其他在售（如果售罄，建议使用推荐规格族）通用型实例规格族g8a 通用型实例规格族g8i 通用平衡增强型实例规格族g8ae 存储增强通用型实例规格族g7se 通用型...
ECS主机状态变化事件的自动化运维
操作步骤 云监控将ECS主机所有的状态变化事件投递到消息服务MNS，消息服务MNS获取消息并进行消息处理。实践一：对所有ECS主机的创建和释放事件进行记录。目前ECS控制台无法查询已经释放的实例。如果您有查询需求，可以通过ECS主机状态变化...
ECS主机状态变化事件的自动化运维
操作步骤 云监控将ECS主机所有的状态变化事件投递到消息服务MNS，消息服务MNS获取消息并进行消息处理。实践一：对所有ECS主机的创建和释放事件进行记录。目前ECS控制台无法查询已经释放的实例。如果您有查询需求，可以通过ECS主机状态变化...
新功能发布记录
您可以根据告警消息及时提前申请提升配额，避免业务受到影响。创建NLB配额告警 NLB 调度算法支持加权最小连接数 更新 网络型负载均衡NLB 调度算法支持加权最小连接数。功能特性 创建和管理服务器组 2024年01月 功能名称 变更类型 功能概述 ...
云服务集成简介
连接消息队列 RocketMQ 通过集成消息队列 RocketMQ服务，云服务集成会根据配置，将区块链上的事件可靠、自动地发布到消息队列 RocketMQ的特定主题上，其它应用可以订阅MQ中的这些事件消息，做进一步的处理。详细示例可以参考 链上事件发送...
什么是弹性伸缩ESS
弹性伸缩（Elastic Scaling Service，简称ESS），也称为Auto Scaling，其能根据您设定的策略自动调整计算资源数量（即业务所需的实例数量），帮助您应对业务流量波动的同时，提高资源利用率，有效降低成本。本视频以ECS实例为例介绍弹性...
通过RocketMQ客户端消费设备消息
在物联网应用场景中，如果需要将设备上报至物联网平台的数据转发至您业务服务器的应用中进行消费（例如过滤、分析、存储等），可以使用物联网平台提供的云产品流转服务，例如通过云消息队列RocketMQ版（以下简称RocketMQ）实现设备数据流转...
消费者分类
如何实现同步、异步消息处理：对于不同的集成场景，消费者获取消息后可能会将消息异步分发到业务逻辑中处理，此时，消息异步化处理如何实现？如何实现消息可靠处理：消费者处理消息时如何返回响应结果？如何在消息异常情况进行重试，保证...
通过RocketMQ客户端消费设备消息
在物联网应用场景中，如果需要将设备上报至物联网平台的数据转发至您业务服务器的应用中进行消费（例如过滤、分析、存储等），可以使用物联网平台提供的云产品流转服务，例如通过云消息队列RocketMQ版（以下简称RocketMQ）实现设备数据流转...
示例代码
云消息队列 RocketMQ 版 5.x版本实例可兼容4.x/3.x SDK客户端接入，您可以使用4.x/3.x版本的SDK接入5.x实例进行消息收发。本文为您介绍4.x/3.x版本下的C++ SDK消息收发示例代码。重要 推荐您使用最新的RocketMQ 5.x系列SDK，5.x系列SDK作为...
阿里云电子政务云产品全家福
阿里云电子政务云平台提供弹性计算类、网络、数据库、存储、大数据、中间件、IoT等品类丰富的产品及高标准的安全合规服务，用以支撑多种政务类业务场景，例如：城市大脑，合规应用平台等。截至文档发布时间，阿里云电子政务云共计上线95款...
消息幂等
如果消息重复消费会影响您的业务处理，请对消息做幂等处理。本文介绍消息幂等的概念、适用场景以及处理方法。什么是消息幂等 在数学与计算机学中，幂等操作的特点是其任意多次执行所产生的影响均与一次执行的影响相同。在消息领域，幂等是...
为什么选择节省计划
以下几种业务模型适用选择节省计划付费模式：共振型业务 共振型业务：指各个业务间有关联，流量增长后各业务对资源的诉求同时增长。典型业务：电商大促、热点事件等泛互联网流量高峰。适合的付费模式：节省计划+按量付费。混部型业务 混部...
消息幂等
为了防止消息重复消费导致业务处理异常，SOFAStack 消息队列的消费者在接收到消息后，有必要根据业务上的唯一 Key 对消息做幂等处理。本文介绍消息幂等的概念、适用场景以及处理方法。什么是消息幂等 当出现消费者对某条消息重复消费的情况...
消费端挂载NFS是否会影响消费速度？
问题现象 消费端在消费消息的主线程里同步将拉取的消息存储在NFS，导致消费端处理消息的速度变慢，阻塞消息处理。可能原因 NFS本身速度就不太理想。NFS是网络共享存储，虽然有多机器共享访问的能力优势，但多台机器访问是争抢的，消费者...
消费者（Consumer）
消费者通常被集成在业务系统中，从 云消息队列 RocketMQ 版 服务端获取消息，并将消息转化成业务可理解的信息，供业务逻辑处理。在消息消费端，可以定义如下传输行为：消费者身份：消费者必须关联一个指定的消费者分组，以获取分组内统一...
哪些企业需要办理EDI证？
企业凡经营以下在线数据处理与交易处理业务，则建议需要办理EDI证：交易处理业务 电子数据交换业务 网络/电子设备数据处理业务。特别需要指出，有交易处理业务，如电子商务平台、众筹收费平台等的业务内容，则非常建议办理，以免造成不必要...
节省计划适配客户业务最佳实践
场景一：平稳型业务 场景说明：业务常年处于一个相对平稳的趋势，虽然可能会释放和创建实例，但是较长时间内的使用量是相对稳定的。平稳型业务特点如下：总体业务负载量比较稳定，无明显的波峰波谷，同时所有业务线使用都比较稳定。平稳型...
消息超时和重试机制
本文介绍 云消息队列 RabbitMQ 版 服务端默认的消息重试机制，帮助您理解消费失败后的消息处理逻辑，并选择合适的消息处理策略。重试机制 云消息队列 RabbitMQ 版 服务端有默认的消息重试机制，不支持您在Consumer客户端重新配置消息重试...
消息发送重试和流控机制
消息重复问题：因远程调用的不确定性，当 云消息队列 RocketMQ 版 客户端因请求超时触发消息发送重试流程，此时客户端无法感知服务端的处理结果，客户端进行的消息发送重试可能会产生消息重复问题，业务逻辑需要自行处理消息重复问题。消息...
消息服务MNS中删除消息时报“message not exist”的...
本文介绍了当MNS删除消息时返回“message not exist”的问题描述、问题原因和解决方案。问题描述 消息服务MNS中删除消息时报如下错误。...如果 VisibilityTimeout 设置得太大，当消息处理失败时，将不能在短时间内再次处理该条消息。
通知点击处理
自定义消息处理 如需处理消息，可以重写 MPPushMsgServiceAdapter 的 onMessageReceive 和 onChannelMessageClick 方法：public class MyPushMsgService extends MPPushMsgServiceAdapter {/*自建通道收到消息的回调（非厂商通道）*@param ...
什么是在线数据处理与交易处理业务许可证（EDI）？
在线数据处理与交易业务经营许可证（简称：EDI证）是指经营含有相关业务的网站主办者向当地区县申请的证书证明，即《中华人民共和国增值电信业务经营许可证》，其中业务种类为：在线数据处理与交易处理业务。在线数据处理与交易处理业务是...
Topic与Tag最佳实践
在 消息队列RocketMQ版 中，Topic与Tag都是业务上用来归类的标识，区分在于Topic是一级分类，而Tag可以理解为是二级分类。您可通过本文了解如何搭配使用Topic和Tag来实现消息过滤。背景信息 Topic和Tag的定义如下：Topic 消息主题，通过...
- 产品推荐
- 这些文档可能帮助您