什么是消息服务MNS
海量并发访问 支持多个生产者和消费者并发访问同一队列，并能确保某条消息在取出之后的特定时间内，无法被其他消费者获得。您可以根据业务需求自由伸缩并发访问数。消息投递保障 在消息有效期内，确保消息至少能被成功消费一次。消息服务...
超大消息传输
当消息内容大于64 KB以至于无法直接存入MNS队列时，不做...注意事项 大消息主要消费网络带宽，用该方案发送大消息时，生产者和消费者的网络带宽可能会是瓶颈。大消息网络传输时间较长，受网络波动影响的概率更大，建议在上层做必要的重试。
发送消息（多线程）
您可以在服务器上（或者多台服务器）部署多个生产者和消费者实例，也可以在同一个生产者或消费者实例里采用多线程发送或接收消息，从而提高消息发送或接收TPS。重要 请避免为每个线程创建一个客户端实例。顺序消息不建议使用多线程发送。云...
发送消息（多线程）
您可以在服务器上（或者多台服务器）部署多个生产者和消费者实例，也可以在同一个生产者或消费者实例里采用多线程发送或接收消息，从而提高消息发送或接收 TPS 的能力。请避免为每个线程创建一个客户端实例。在多线程之间共享 Producer 的...
配置消息灰度
因为消费者过滤的方式会在每个环境都处理全量的消息，对消息的生产者和消费者压力都比较大，不推荐在生产中使用此模式。开启消息灰度 登录 MSE治理中心控制台，并在顶部菜单栏选择地域。在左侧导航栏，选择 治理中心>应用治理。在 应用列表...
用户洞察概述
随着互联网技术的发展，企业通过各种途径积累了消费者资产，Quick Audience用户洞察模块旨在通过丰富的用户洞察模型和便捷的策略配置，帮助企业完成消费者多维洞察分析，为后续的消费者运营和触达奠定人群基础。功能简介 用户洞察模块提供...
名词解释
生产者和消费者连接 云消息队列 RabbitMQ 版 需要指定一个Vhost。X 消费者 消息消费者，即接收消息的程序。消息存活时间 消息在Queue中的有效期。某条消息在Queue中的留存时间超过配置的消息存活时间时，则该消息过期。消息存活时间的值...
概述
生产者集群 用来表示发送消息应用，一个生产者集群下包含多个生产者实例，可以是多台机器，也可以是一台机器的多个进程，或者一个进程的多个生产者对象。一个生产者集群可以发送多个 Topic 消息。发送分布式事务消息时，如果生产者中途意外...
如何提升写入效率
本文介绍如何通过优化写入的策略提升TSDB 写入效率：请使用“并发+批量”的方式写入数据。推荐并发大于 256，推荐批量数大于 400。如果通过SDK提交可以遵循一下写入优化的方面和原则：SDK实例创建和销毁：TSDB SDK在一个进程中只需要创建...
快速入门Java线程栈分析
本文将演示如何通过ATP的Java线程栈分析...请注意火焰图是按照栈的数量进行聚合，越宽不一定代表是热点方法，比如很多线程阻塞在同一个Java方法上是正常的现象。3.结论 通过ATP Java线程栈分析功能，可以帮助开发者分析应用中线程的运行情况。
基于消息队列RocketMQ版实现全链路灰度
cloud-b 1/1 1 1 5m deployment.apps/spring-cloud-c 1/1 1 1 5m deployment.apps/spring-cloud-zuul 1/1 1 1 5m 步骤三：为应用开启RocketMQ消息灰度 假设spring-cloud-c、spring-cloud-a应用分别为消息的生产者和消费者，为其开启...
删除Group后仍然收到消息堆积的告警信息
解决方案 删除 Group 后，如果您不希望继续收到消息堆积的告警信息，请参见以下操作进行处理：确认服务端版本，请根据服务端版本情况执行以下操作：2.2.0及以上版本，请根据以下方式操作：若 Group 中没有存活的消费者线程（存活的消费者...
Spring集成
背景信息 云消息队列 RocketMQ 版 支持以下消息类型的生产者和消费者与Spring集成：普通消息的生产者和消费者 事务消息的生产者和消费者 顺序消息的生产者和消费者 说明 云消息队列 RocketMQ 版 暂不支持Spring框架下定时消息和延时消息的...
社区Knative简介
事件模型可以有效地解耦生产者和消费者的依赖关系。生产者可以在消费者启动之前产生事件，消费者也可以在生产者启动之前监听事件。Serving：管理Serverless工作负载，提供了应用部署、多版本管理、基于请求的自动弹性、灰度发布等能力，...
基本概念
和消费者不同，消费者分组并不是运行实体，而是一个逻辑资源。在 云消息队列 RocketMQ 版 中，通过消费者分组内初始化多个消费者实现消费性能的水平扩展以及高可用容灾。更多信息，请参见 消费者分组（ConsumerGroup）。消费者（Consumer）...
应用概述
线程分析 提供线程粒度的CPU耗时和每类线程数量的统计，可真实还原代码执行过程，当发现集群的CPU使用率过高，或者出现大量慢方法时，可以通过线程分析功能找到消耗CPU最多的线程或方法。Arthas诊断 利用字节码增强技术，可以在不重启JVM...
顺序消息
顺序消息为 云消息队列 RocketMQ 版 中的高级特性消息，本文为您介绍顺序消息的应用场景、功能原理、使用限制、使用方法和使用建议。应用场景 在有序事件处理、撮合交易、数据实时增量同步等场景下，异构系统间需要维持强一致的状态同步，...
动态过滤器（Dynamic Filter）
动态过滤器是一个典型的生产者和消费者模式，示意图如下。DFP（Dynamic Filter Producer）算子：动态过滤器的生产者（Producer），利用小表侧的数据生成Bloom Filter及获取JOIN Key对应的 min、max 值（Range Filter），然后发送至DFC。DFC...
消息负载均衡策略
云消息队列 RocketMQ 版 的消息负载均衡策略针对生产者和消费者有所差异。对消费者而言，消息负载均衡策略在一定程度上影响消息堆积。背景信息 随着SDK版本的升级，云消息队列 RocketMQ 版 的负载均衡策略也有所优化，根据SDK版本，负载...
动态过滤器（Dynamic Filter）
动态过滤器是一个典型的生产者和消费者模式，示意图如下。DFP（Dynamic Filter Producer）算子：动态过滤器的生产者（Producer），利用小表侧的数据生成Bloom Filter及获取JOIN Key对应的 min、max 值（Range Filter），然后发送至DFC。DFC...
消费者（Consumer）
使用建议 不建议在单一进程内创建大量消费者 云消息队列 RocketMQ 版 的消费者在通信协议层面支持非阻塞传输模式，网络通信效率较高，并且支持多线程并发访问。因此，大部分场景下，单一进程内同一个消费分组只需要初始化唯一的一个消费者...
Knative概述
事件模型可以有效地解耦生产者和消费者的依赖关系。生产者可以在消费者启动之前产生事件，消费者也可以在生产者启动之前监听事件。Serving：管理Serverless工作负载，提供了应用部署、多版本管理、基于请求的自动弹性、灰度发布等能力，...
收发普通消息
普通消息是指 云消息队列 RocketMQ 版 中无特性的消息，区别于有特性的定时和延时消息、顺序消息和事务消息。本文提供使用TCP协议下的.NET SDK收发普通消息的示例代码。前提条件 您已完成以下操作：下载.NET SDK。更多信息，请参见 版本...
收发顺序消息
顺序消息（FIFO 消息）是 云消息队列 RocketMQ 版 提供的一种严格按照顺序来发布和消费的消息类型。本文提供使用TCP协议下的.NET SDK收发顺序消息的示例代码。顺序消息分类 顺序消息分为两类：全局顺序：对于指定的一个Topic，所有消息按照...
实例规格配置和管理
您可以按照业务需求调整流量规格、网络类型、消息保留时长、最大消息大小和消费位点保留时间。前提条件 您已购买 云消息队列 Kafka 版 V3系列Serverless实例，且实例处于 服务中 状态。规格配置说明 配置项 含义 变更方式 流量规格 发送...
消息轨迹
场景四：查看生产者、消费者身份信息和机器信息，进一步排查问题原因。轨迹参数说明 云消息队列 RocketMQ 版 提供的轨迹参数如下：属性分类 轨迹参数 说明 生产者 生产者信息 生产者发送消息时使用的RocketMQ账号或Access Key ID。主机名 ...
Knative概述
事件模型可以有效地解耦生产者和消费者的依赖关系。生产者可以在消费者启动之前产生事件，消费者也可以在生产者启动之前监听事件。Function:Knative Functions为您提供了一个简单的方式来创建、构建和部署Knative服务。您无需深入了解底层...
SOFAMQ 常见问题
暂不支持，消息的生产者和消费者需要和消息队列所在的 region 网络处于联通状态。新创建的 Group ID 从哪里开始消费？如果这个 Group ID 是第一次启动，对于最近新建且消息量较少的 Topic，会从头开始消费，所有的历史消息有可能重复消费一...
顺序消息
如果发送方有多个生产者或者有多个线程并发发送消息，则此时只能以到达 云消息队列 RocketMQ 版 服务端的时序作为消息顺序的依据，和业务侧的发送顺序未必一致。顺序消息常见问题 同一条消息是否可以既是顺序消息，又是定时消息和事务消息...
创建资源
创建Topic Topic是 云消息队列 RocketMQ 版 里对消息的一级归类，例如创建名称为Topic_Trade的Topic来识别交易类消息，消息生产者将消息发送到Topic_Trade，而消息消费者则通过订阅该Topic来获取和消费消息。Topic的使用说明如下：Topic不...
消息（Message）
生产者将业务数据的负载和拓展属性包装成消息发送到 云消息队列 RocketMQ 版 服务端，服务端按照相关语义将消息投递到消费端进行消费。云消息队列 RocketMQ 版 的消息模型具备如下特点：消息不可变性 消息本质上是已经产生并确定的事件，...
创建资源
创建Topic Topic是 云消息队列 RocketMQ 版 里对消息的一级归类，例如创建名称为Topic_Trade的Topic来识别交易类消息，消息生产者将消息发送到Topic_Trade，而消息消费者则通过订阅该Topic来获取和消费消息。Topic的使用说明如下：Topic不...
普通消息
功能原理 什么是普通消息 定义：普通消息是 云消息队列 RocketMQ 版 基本消息功能，支持生产者和消费者的异步解耦通信。普通消息生命周期 初始化 消息被生产者构建并完成初始化，待发送到服务端的状态。待消费 消息被发送到服务端，对消费...
功能特性
线程分析 提供线程粒度的CPU耗时和每类线程数量的统计，可真实还原代码执行过程，当发现集群的CPU使用率过高，或者出现大量慢方法时，可以通过线程分析功能找到消耗CPU最多的线程或方法。日志分析 配合业务日志，精准定位业务异常。Arthas...
Knative
事件模型可以有效地解耦生产者和消费者的依赖关系。生产者可以在消费者启动之前产生事件，消费者也可以在生产者启动之前监听事件。使用说明 如何使用Knative，请参见 部署Knative。关于Knative的更多信息，请参见 Knative概述。变更记录 ...
开发场景：基于消息队列RocketMQ版实现环境隔离
步骤一：为应用开启RocketMQ消息灰度 Demo中的spring-cloud-c、spring-cloud-a应用分别为消息的生产者和消费者，通过添加启动参数-Dprofiler.micro.service.mq.gray.enable=true，在 SAE 上为其开启RocketMQ消息灰度。说明 RocketMQ消息...
查询消息轨迹
消息轨迹是指一条消息从生产者发送到消息队列服务端，再到消费者消费处理，整个过程中的各个相关节点的时间、状态等数据汇聚而成的完整链路信息。本文介绍如何快速查询消息轨迹。前提条件 您的消息已从生产者发送。操作步骤 登录 SOFAStack...
消费进度管理
背景信息 云消息队列 RocketMQ 版 的生产者和消费者在进行消息收发时，必然会涉及以下场景，消息先生产后订阅或先订阅后生产。这两种场景下，消费者客户端启动后从哪里开始消费？如何标记已消费的消息？这些都是由 云消息队列 RocketMQ 版 ...
MNS回调事件通知
MNS提供了队列模型，支持多个生产者和消费者并发访问同一个队列，并能确保某条消息在取出之后的特定时间段内，无法被其他消费者获得。消息被消费后一段时间内不可见，需要用户主动删除，否则该消息会被再次消费。视频点播服务VOD支持通过...
事务消息
使用规则 生产消息规则 事务消息发送完成本地事务后，可在 execute 方法中返回以下三种状态：TransactionStatus.CommitTransaction：提交事务，允许消费者消费该消息。TransactionStatus.RollbackTransaction：回滚事务，消息将被丢弃不...
- 产品推荐
- 这些文档可能帮助您