队列使用手册

并且在消息处理过程中,也可以调用changeMessageVisibility这个函数来延长消息的VisibilityTimeout时间。echo"DeleteMessage Failed:".$e;return;} 步骤五:删除队列 Sample里最后会删除这个测试队列。try {$this->client->deleteQueue($...

消费者分类

建议使用SimpleConsumer消费类型,可以在消费时自定义消息的预估处理时长,若实际业务中预估的消息处理时长不符合预期,也可以通过接口提前修改。需要异步化、批量消费等高级定制场景:SimpleConsumer在SDK内部没有复杂的线程封装,完全由...

主题使用手册

} catch(MnsException$e){/可能因为网络错误,或者Topic已经存在等原因导致CreateTopic失败,这里CatchException并做对应的处理。echo"CreateTopicFailed:".$e;return;} 步骤三:创建队列 如果之前未创建队列,那么首先需要创建队列。默认...

从Oracle迁移应用至阿里云PolarDB全流程指南

Oracle数据库的业务是OLTP还是OLAP?计划迁移多少套?等等。针对这些具体的需求,给企业客户介绍专业的解决方案,让企业客户对迁移Oracle的步骤有大致的了解。数据库和应用采集 登录阿里云官方网站,在 ADAM官网 下载 数据库采集器 和 ...

消费重试

由于不可见时间为预分配的,可能和实际业务的消息处理时间差别较大,您可以通过API接口修改不可见时间。例如,您预设消息处理耗时最多20 ms,但实际业务中20 ms内消息处理不完,您可以修改消息不可见时间,延长消息处理时间,避免消息...

死信消息

应用场景 典型死信消息处理场景 消息重试失败后,您可以选择将死信消息存储到指定的死信Topic中,通过另外创建一个ConsumerGroup消费这些死信消息来处理异常链路或分析死信消息。典型错误使用死信消息场景 处理死信消息时,如果将死信消息...

队列使用手册

并且在消息处理过程中,也可以调用changeMessageVisibility这个函数来延长消息的VisibilityTimeout时间。Console.WriteLine("DeleteMessage Failed!ErrorCode:"+me.ErrorCode);} catch(Exception ex){ Console.WriteLine("Delete message ...

使用Canal和RocketMQ实现数据库变更订阅处理

Canal可以将变更记录可靠地投递到 云消息队列 RocketMQ 版 中,借助 云消息队列 RocketMQ 版 丰富的消息处理策略实现多样化的业务逻辑。Canal是一个开源项目,仓库地址请参见 Canal。方案介绍 基于Binlog日志实现增量订阅和消费的典型业务...

使用Canal和RocketMQ实现数据库变更订阅处理

Canal可以将变更记录可靠地投递到 云消息队列 RocketMQ 版 中,借助 云消息队列 RocketMQ 版 丰富的消息处理策略实现多样化的业务逻辑。Canal是一个开源项目,仓库地址请参见 Canal。方案介绍 基于Binlog日志实现增量订阅和消费的典型业务...

主题使用手册

并且在消息处理过程中,也可以调用changeMessageVisibility这个函数来延长消息的VisibilityTimeout时间。Console.WriteLine("DeleteMessage Failed!ErrorCode:"+me.ErrorCode);} catch(Exception ex){ Console.WriteLine("Delete message ...

TCP协议客户端大版本发布

堆积消息量(已就绪消息+处理中消息)top20 GroupIDs:统计堆积的消息量最多的前20个Group。处理中消息量 top20 GroupIDs:统计处理中的消息量最多的前20个Group。消费处理耗时 top20 GroupIDs:统计消费处理耗时最长的前20个Group。在消费...

为什么选择节省计划

以下几种业务模型适用选择节省计划付费模式:共振型业务 共振型业务:指各个业务间有关联,流量增长后各业务对资源的诉求同时增长。典型业务:电商大促、热点事件等泛互联网流量高峰。适合的付费模式:节省计划+按量付费。混部型业务 混部...

核心概念

同一个板块内的业务实体(业务对象或业务活动)间有直接或间接的业务联系(业务对象参与业务活动,业务活动之间存在流转关系)。数据板块内的数据是完整的,即一个板块内可以独立完成从数据采集到最后的数据加工。例如,某多元化经营的企业...

消息超时和重试机制

本文介绍 云消息队列 RabbitMQ 版 服务端默认的消息重试机制,帮助您理解消费失败后的消息处理逻辑,并选择合适的消息处理策略。重试机制 云消息队列 RabbitMQ 版 服务端有默认的消息重试机制,不支持您在Consumer客户端重新配置消息重试...

使用Canal将MySQL的数据同步至云消息队列 Kafka 版

说明 kafka.batch.size 与 kafka.linger.ms 参数都是控制批量处理消息的条件,满足其中一个参数的条件,客户端就攒批完成,消息进入待发送状态。kafka.linger.ms 是 客户端数据块攒批的最大时长。单位:ms。客户端设定攒批消息的延迟时间,...

仪表盘

上图表示指定主题的某一队列中各消息的状态,云消息队列 RocketMQ 版 将处于不同处理阶段的消息数量和耗时进行统计,这些指标可直接反映队列中消息的处理速率和堆积情况,通过观察这些指标可初步判断业务的消费是否异常。具体的指标含义和...

应用场景

其高性能的消息处理能力可以承接流量脉冲而不被击垮,在确保系统可用性的同时,通过快速有效的请求响应技术提升用户体验。其海量消息堆积能力确保下游业务在安全水位内平滑稳定地运行,避免流量高峰的冲击。分布式缓存同步 大量并发访问...

函数计算

利用函数实现业务消息的处理,通过函数计算平台开发、运行业务消息处理逻辑,订单处理,任务执行。利用函数对消息进行快速加工处理,ETL清洗。利用函数计算灵活扩展将消息转储到指定VPC中的其它下游系统。利用函数链接消息系统和其他阿里云...

函数计算

利用函数实现业务消息的处理,通过函数计算平台开发、运行业务消息处理逻辑,订单处理,任务执行。利用函数对消息进行快速加工处理,ETL清洗。利用函数计算灵活扩展将消息转储到指定VPC中的其它下游系统。利用函数链接消息系统和其他阿里云...

使用Exactly-Once投递语义收发消息

本文主要介绍如何使用 云消息队列 RocketMQ 版 的Exactly-Once投递语义收发消息,以保证消息的最终处理结果写入到数据库有且仅有一次。背景信息 重要 目前Exactly-Once投递语义仅在Java SDK中支持。相关SDK下载,请参见 版本说明。云消息...

消息数、活跃消息数、延迟消息数分别表示哪些消息

本文介绍控制台上的消息数、活跃消息数、延迟消息数分别表示哪些类型的消息。各消息数的概念如下:消息数:成功发送的和没有发送的所有消息数。活跃消息数:未经处理的消息数。延迟消息数:设置了延迟时间的消息数。

创建FC Sink Connector

利用函数实现业务消息的处理,通过函数计算平台开发、运行业务消息处理逻辑,订单处理,任务执行。利用函数对消息进行快速加工处理,ETL清洗。利用函数计算灵活扩展将消息转储到指定VPC中的其他下游系统。利用函数连接消息系统和其他阿里云...

带宽扩展包

本文介绍什么是业务带宽,如何评估和查看业务带宽,以及业务带宽超限后的处理方法。什么是业务带宽 业务带宽指WAF实例支持处理的网站正常业务流量的峰值带宽大小,单位为Mbps。每100 Mbps业务带宽对应约4,000 QPS(Query Per Second,即每...

节省计划适配客户业务最佳实践

场景一:平稳型业务 场景说明:业务常年处于一个相对平稳的趋势,虽然可能会释放和创建实例,但是较长时间内的使用量是相对稳定的。平稳型业务特点如下:总体业务负载量比较稳定,无明显的波峰波谷,同时所有业务线使用都比较稳定。平稳型...

什么是弹性伸缩ESS

您可以通过弹性伸缩调整ECS实例或ECI实例(该实例主要负责处理客户端请求)数量,从而自动调整业务请求的处理能力。更多信息,请参见 工作原理。产品计费 弹性伸缩本身不收取任何费用,但使用ECS实例、ECI实例、RDS实例、负载均衡服务...

接口和参数说明

该参数表示当TCP连接关闭时,消费者还可以继续处理消息的时间。消息发送接口 接口名称:sendMessage 类名称:com.alibaba.mqtt.server.ServerProducer 表 1.消息发送参数 参数 说明 mqttTopic 云消息队列 MQTT 版 的Topic,包括父级Topic和...

步骤三:调用SDK收发消息

false,"ConsumerTag",new DefaultConsumer(channel){@Override public void handleDelivery(String consumerTag,Envelope envelope,AMQP.BasicProperties properties,byte[]body)throws IOException {/接收到的消息,进行业务逻辑处理。...

数据同步简介

增量有序 数据同步保证同一个通道内到达客户端的消息顺序一定是与业务服务器调用数据同步服务器的顺序一致,并且所有消息以增量方式同步至客户端。高实时性 当客户端连接的网络状况良好时,数据同步可以保证非常高的推送实时性,消息推送...

仪表盘

20_ms le_50_ms le_200_ms le_500_ms le_overflow uid instance_id topic client_id invocation_status 消费者Metrics指标 Metrics类型 Metrics name 单位 指标说明 Label Histogram rocketmq_process_time ms PushConsumer的消息处理耗时...

消费幂等

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

欠费说明

消息服务MNS 处于欠费状态...当您的账户余额不足以支付账单金额,消息服务MNS 处于欠费状态超过7天,阿里云将停止 消息服务MNS 的服务,即您不能再访问API,未处理的消息数据将按队列设置的消息过期时间自动过期释放,被释放的数据不可恢复。

开源SDK接入(跨云账号授权)

本文以调用Java SDK为例,介绍在RAM角色跨账号授权场景,通过开源SDK实现消息收发的操作过程,帮助您更好地理解消息收发的完整过程,其他语言或框架的SDK消息收发过程相似。前提条件 创建实例 创建Vhost 背景信息 当您需要通过RAM STS角色...

共享订阅

使用场景 服务端负载均衡 当大量设备接入物联网平台并向物联网平台发送消息时,需要有多个业务服务端来处理这些消息,物联网平台的共享订阅特性可以帮助客户将消息分发到多个业务服务端,实现负载均衡。在下图中,业务服务端A、B使用相同的...

故障发现

7*24监控值班 对于有条件的企业,可以设立全球...抑制周期性误报,当跌落异常在同一时刻持续多天时抑制该报警,对应每天大促或消息型任务每天定时跌落的业务场景。建议重点覆盖成功(总)量、成功(失败)率、失败量三类场景的业务指标。

消息队列Kafka版删除Group后仍然收到消息堆积的告警...

问题描述 使用阿里云消息队列Kafka版时,删除Group后,仍然收到消息堆积的告警信息,如何过滤某个Group的消费堆积告警。问题原因 发生消息堆积告警信息的原因如下:2.2.0以前的Kafka服务端版本,开源Kafka未提供删除Group和消费位点的Open...

删除Group后仍然收到消息堆积的告警信息

问题现象 使用阿里云 云消息队列 Kafka 版 时,删除 Group 后,仍然收到消息堆积的告警信息。可能原因 发生消息堆积告警信息的原因如下:2.0.0以前的Kafka服务端版本,开源Kafka未提供删除 Group 和消费位点的OpenAPI,因此删除 Group,...

消息幂等

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

欠费说明

欠费后如果超过了24小时,您不能再访问MNS的API,未处理的消息数据将按队列设置的消息过期时间自动过期释放,被释放的数据不可恢复。MNS欠费说明 密钥管理服务KMS 媒体处理MPS中的标准加密、私有加密任务可以使用KMS来实现密钥的生成和管理...

现代IM系统中的消息系统—架构

本章节主要介绍现代IM系统中的消息系统架构以及基于表格存储(Tablestore)自研的Timeline模型构建的消息系统。基于Timeline构建的现代消息系统能够同时支持消息系统的多种特性,包括多端同步、消息漫游和在线检索,在性能和规模上能够实现...

概述

概念介绍—消息流入(Source)消息流入是消息的数据集成组件。消息流入能够在多种数据源(消息、Log日志、关系数据和非关系数据等)之间进行灵活、快速、无侵入式的数据集成。可以实现跨机房、跨数据中心、跨云的数据集成方案,并能...
共有200条 < 1 2 3 4 ... 200 >
跳转至: GO
产品推荐
云服务器 安全管家服务 安全中心
这些文档可能帮助您
云数据库 Redis 版 物联网无线连接服务 对象存储 云服务器 ECS 弹性公网IP 短信服务
新人特惠 爆款特惠 最新活动 免费试用