什么是消息演练
定位故障根源：经过消息演练之后，积累了消息系统的处理经验，对于未来的系统诊断定位有参考和提升作用。消息的演练场景 消息服务通常是由不同的模块组成。例如，RocketMQ分为生产者Producer、消费者Consumer、服务集群Broker和注册中心...
接入 iOS
iOS 10 以下系统，通知栏消息处理方法-(void)application:(UIApplication*)application didReceiveRemoteNotification:(NSDictionary*)userInfo fetchCompletionHandler:(void(^)(UIBackgroundFetchResult result))completionHandler {/...
产品功能
消息队列分布式事务 在多次调用消息系统的场景中，通过 GTS，应用可轻松具备消息事务的处理能力。混合的分布式事务 GTS 可将各个资源加入事务范畴，实现同时跨服务、数据库、跨消息系统的事务处理能力。多种事务模式 提供了标准事务模式、...
应用场景
本文为您介绍 SOFAStack 消息队列的适用场景，以便您更好地判断如何在业务中使用消息队列。在互联网金融场景里，其业务涉及广泛，如支付交易、收费计息、商户结算、业务营销、会员积分、风险核查等；同时，也会涉及许多业务峰值时刻，如双 ...
迁移上云概述
消息收发无大量重复 保证迁移过程中不会出现大量的消息重复，业务方无需为迁移方案单独处理系统性重复消息。消息收发无明显延迟 保证迁移过程中消息收发端到端延迟不会有明显变化，不会因迁移导致大量消息接收不到。方案设计原理 为满足...
消费端挂载NFS是否会影响消费速度？
问题现象 消费端在消费消息的主线程里同步将拉取的消息存储在NFS，导致消费端处理消息的速度变慢，阻塞消息处理。可能原因 NFS本身速度就不太理想。NFS是网络共享存储，虽然有多机器共享访问的能力优势，但多台机器访问是争抢的，消费者...
消息超时和重试机制
本文介绍 云消息队列 RabbitMQ 版 服务端默认的消息重试机制，帮助您理解消费失败后的消息处理逻辑，并选择合适的消息处理策略。重试机制 云消息队列 RabbitMQ 版 服务端有默认的消息重试机制，不支持您在Consumer客户端重新配置消息重试...
消息轨迹
按消息处理耗时：在 按消息处理耗时 页签中，选择要查询消息的Queue，输入消息处理耗时时间（单位为秒），设置查询 时间范围，然后单击 查询。在查询的消息列表，选择要查询消息轨迹的消息，在其 操作 列，单击 轨迹详情。在消息轨迹详情...
监控报警
监控项说明 说明 消息堆积量、消息处理延迟时间、已就绪消息量、已就绪消息排队时间等消息堆积场景相关的指标的详细说明，请参见 堆积场景指标说明。指标分类 监控指标 MetricName 统计方法 单位 Instance 实例API调用TPS InstanceApi...
消息处理时长自适应
本文介绍如何使消息处理时长自适应。背景信息 消息服务MNS 的规范中，每条消息都有个默认的VisibilityTimeout，Worker在接收到消息后，Timeout就开始计时了。如果Worker在Timeout时间内没能处理完消息，那么消息就有可能被其他Worker接收到...
消费重试
例如，您预设消息处理耗时最多20 ms，但实际业务中20 ms内消息处理不完，您可以修改消息不可见时间，延长消息处理时间，避免消息触发重试机制。修改消息不可见时间需要满足以下条件：消息处理未超时 消息处理未提交消费状态 如下图所示，...
查看消息
消息中心：消息中心的消息提醒您云电脑的变化更新和执行结果。同时您可通过以下分类快速找到该账号下或该台云电脑的使用操作记录。管控消息：主要传达管理员对您的云电脑进行管理操作的相关信息，包括设置定时任务、授权云电脑或云盘、更改...
消息过滤
使用 云消息队列 RocketMQ 版 的消息过滤功能，可以帮助消费者更高效地过滤自己需要的消息集合，避免大量无效消息投递给消费者，降低下游系统处理压力。云消息队列 RocketMQ 版 主要解决的单个业务域即同一个主题内不同消息子集的过滤问题...
新零售电子价签解决方案（MQTT）
电子价签管控服务通过接收 云消息队列 RocketMQ 版 消息，处理分析当前系统中在线的价签节点的状态，并将数据记录到SLS。更新屏显 电子价签管控服务发送改价的 云消息队列 RocketMQ 版 消息，触发改价操作。MQTT服务端会路由该 云消息队列 ...
队列使用手册
并且在消息处理过程中，也可以调用changeMessageVisibility这个函数来延长消息的VisibilityTimeout时间。Console.WriteLine("DeleteMessage Failed!ErrorCode:"+me.ErrorCode);} catch(Exception ex){ Console.WriteLine("Delete message ...
监控报警
监控项 单位 MetricName Dimensions Statistics 消息堆积量（Group）count ConsumerLag userId、instanceId、groupId Sum 消息处理延迟时间（GroupId）millisecond ConsumerLagLatencyPerGid userId、instanceId、groupId Maximum 消息处理...
仪表盘
业务背景 云消息队列 RocketMQ 版 的消息收发流程中，队列的堆积情况、缓冲情况以及消息处理各关节的耗时等，会直接反映当前业务处理的性能和服务端运行的状态。因此，云消息队列 RocketMQ 版 的重点指标主要涉及以下业务场景。消息堆积...
队列使用手册
并且在消息处理过程中，也可以调用changeMessageVisibility这个函数来延长消息的VisibilityTimeout时间。echo"DeleteMessage Failed:".$e;return;} 步骤五：删除队列 Sample里最后会删除这个测试队列。try {$this->client->deleteQueue($...
主题使用手册
并且在消息处理过程中，也可以调用changeMessageVisibility这个函数来延长消息的VisibilityTimeout时间。Console.WriteLine("DeleteMessage Failed!ErrorCode:"+me.ErrorCode);} catch(Exception ex){ Console.WriteLine("Delete message ...
内容分割
背景信息 数据清洗功能提供常见的消息处理模板，包括内容分割、动态路由、内容富化和内容映射等。您可以直接利用模板处理消息，也可以根据业务情况在模板基础上修改代码。消息数据清洗任务提供基本的算子能力，底层逻辑使用函数计算。支持...
内容映射
背景信息 数据清洗功能提供常见的消息处理模板，包括内容分割、动态路由、内容富化和内容映射等。您可以直接利用模板处理消息，也可以根据业务情况在模板基础上修改代码。消息数据清洗任务提供基本的算子能力，底层逻辑使用函数计算。支持...
内容富化
背景信息 数据清洗功能提供常见的消息处理模板，包括内容分割、动态路由、内容富化和内容映射等。您可以直接利用模板处理消息，也可以根据业务情况在模板基础上修改代码。消息数据清洗任务提供基本的算子能力，底层逻辑使用函数计算。支持...
动态路由
背景信息 数据清洗功能提供常见的消息处理模板，包括内容分割、动态路由、内容富化和内容映射等。您可以直接利用模板处理消息，也可以根据业务情况在模板基础上修改代码。消息数据清洗任务提供基本的算子能力，底层逻辑使用函数计算。支持...
订阅消息
class ExampleMessageListener:public MessageListener { public:Action consume(Message&message,ConsumeContext&context){/此处为具体的消息处理过程，确认消息被处理成功请返回CommitMessage。如果有消费异常，或者期望重新消费，可以...
日志管理
本案例要查询某个客户端消息处理量，即输入客户端IP地址，查询语句格式为$ClientIP，例如 10.10.10.0。如果您要查询某个客户端的某类操作日志，可使用多个关键字组合方式，例如$ClientIP and(SendMessage or BatchSendMessage)。查询结果...
延时消息
若延时时间超过延时消息最大延时时间，则当作普通消息处理，即消息发送后被立即投递给消费者消费。最大延时时间根据实例类型不同有所差异，具体数值，请参见 集群限制。若您为延时消息设置了消息存活时间，则 延时消息的实际存活时间＝min{...
消息队列
任务A作为生产者循环向消息队列发送消息，任务B作为消费者循环从消息队列接收消息，一般情况下，消费者处理数据是要花费很长时间，所以会导致消息产生的速度大于消息处理的速度，使得消息队列溢出。所以可以通过调整任务B优先级大于任务A来...
订阅者最佳实践
消费失败 云消息队列 Kafka 版 是按分区逐条消息顺序向前推进消费的，如果消费端拿到某条消息后执行消费逻辑失败，例如应用服务器出现了脏数据，导致某条消息处理失败，等待人工干预，那么有以下两种处理方式：失败后一直尝试再次执行消费...
从自建MySQL同步至云消息队列 Kafka 版
通过数据传输服务DTS（Data Transmission Service），您可以将自建MySQL同步至 云消息队列 Kafka 版，扩展消息处理能力。前提条件 您已完成以下操作：自建MySQL数据库且数据库版本为5.1、5.5、5.6、5.7或8.0版本。购买并部署 云消息队列 ...
常见问题
本文汇总了使用 云消息队列 RocketMQ 版 时的常见问题。产品功能常见问题 消息队列RocketMQ版5.x系列相比4.x系列实例有什么优势？消息队列RocketMQ版5.x系列实例兼容哪些版本客户端？消息队列RocketMQ版支持哪些语言客户端？消息队列...
订阅消息
批量消息处理。return Action.CommitMessage;} });启动batchConsumer。batchConsumer.start();System.out.println("Consumer start success.");等待固定时间防止进程退出。try { Thread.sleep(200000);} catch(InterruptedException e){ e....
什么是云消息队列 Confluent 版？
云消息队列 Confluent 版 阿里云和Apache Kafka的原厂创始公司Confluent合作，在ApacheKafka能力基础上支持消息流式处理以及大数据系统的集成的一站式解决方案—— 云消息队列 Confluent 版。您可以购买适合您生产集群规模的企业版Kafka ...
常见问题
本文汇总了使用 云消息队列 RocketMQ 版 时的常见问题。产品功能常见问题 云消息队列 RocketMQ 版5.0系列相比4.0系列实例有什么优势？云消息队列 RocketMQ 版5.0系列实例兼容哪些版本客户端？云消息队列 RocketMQ 版支持哪些语言客户端？云...
步骤三：调用SDK收发消息
业务方自行实现消息处理，并主动调用接口返回消费结果。消费并发度管理 由SDK管理消费并发度。由业务方消费逻辑自行管理消费线程。接口灵活度 高度封装，不够灵活。原子接口，可灵活自定义。适用场景 适用于无自定义流程的开发场景。适用于...
收发事务消息
go ConsumeHalfMsg(&mqTransProducer)/发送4条事务消息，1条发送完就提交，其余3条通过检查半事务消息处理。for i:=0;i;i+{ msg:=mq_http_sdk.PublishMessageRequest{ MessageBody:"I am transaction msg!Properties:map[string]string{...
Exactly-Once投递语义
什么是Exactly-Once投递语义 Exactly-Once是指发送到消息系统的消息只能被消费端处理且仅处理一次，即使生产端重试消息发送导致某消息重复投递，该消息在消费端也只被消费一次。Exactly-Once语义是消息系统和流式计算系统中消息流转的最...
示例代码
class ExampleMessageListener:public MessageListener { public:Action consume(Message&message,ConsumeContext&context){/此处为具体的消息处理过程，确认消息被处理成功请返回CommitMessage。如果有消费异常，或者期望重新消费，可以...
查看系统消息
本文为您介绍如何查看并处理消息中心的消息。查看消息中心的消息 在Dataphin界面，按照下图操作指引，进入 消息中心。在 消息中心 页面，您可以查看所有未读消息及全部的消息。同时您可以单击某个消息 操作 列下的 图标查看消息的详细内容...
查看系统消息
本文为您介绍如何查看并处理消息中心的消息。查看消息中心的消息 在Dataphin界面，按照下图操作指引，进入 消息中心。在 消息中心 页面，您可以查看所有未读消息及全部的消息。同时您可以单击某个消息 操作 列下的 图标查看消息的详细内容...
调用TCP协议的SDK收发普通消息
class MyMsgListener:public MessageListener { public:MyMsgListener(){ } virtual~MyMsgListener(){ } virtual Action consume(Message&message,ConsumeContext&context){/自定义消息处理细节。return CommitMessage;CONSUME_SUCCESS;} }...
- 产品推荐
- 这些文档可能帮助您