PaaS应用场景
RetailBot会根据消费者问题、上下文、知识库、机器人配置等多个因素，智能计算最优解并返回给开发者，由开发者结合其他服务策略/工具，为消费者提供即时响应。公测MVP版本主要支持的业务场景包括：行业高频场景识别、消费者情绪识别、直连...
开发HSF应用（SDK）
消费者订阅服务从代码编写的角度分为两个部分。Spring的配置文件使用标签定义好一个Bean。在使用的时候从Spring的context中将Bean取出来。说明 Demo工程中的 detail 文件夹为消费者服务的示例代码。与生产者相同，消费者的服务属性配置分为...
开发HSF应用（SDK）
消费者订阅服务从代码编写的角度分为两个部分。Spring的配置文件使用标签定义好一个Bean。在使用的时候从Spring的context中将Bean取出来。说明 Demo工程中的 detail 文件夹为消费者服务的示例代码。与生产者相同，消费者的服务属性配置分为...
消息负载均衡策略
云消息队列 RocketMQ 版 的消息负载均衡策略针对生产者和消费者有所差异。对消费者而言，消息负载均衡策略在一定程度上影响消息堆积。背景信息 随着SDK版本的升级，云消息队列 RocketMQ 版 的负载均衡策略也有所优化，根据SDK版本，负载...
社区Knative简介
生产者可以在消费者启动之前产生事件，消费者也可以在生产者启动之前监听事件。Serving：管理Serverless工作负载，提供了应用部署、多版本管理、基于请求的自动弹性、灰度发布等能力，而且在没有服务需要处理的时候可以缩容到零个实例。
Group操作
删除Group 警告 删除Group后，由该Group ID标识的生产者和消费者客户端将在客户端发生重新连接时认证失败，已连接生产者和消费者不受影响。进入 Group 管理 页面。在Group列表中，找到需要删除的目标Group，在其 操作 列中，选择 更多>删除...
基础知识
通过消息队列服务SWIFT实现的生产者/消费者模型，iGraph为增量消息的消费者，用户为消息生产者。iGraph为异步更新模式，保证最终一致性。支持通过iGraph客户端、Blink、Porsche以及其他用户自己实现的方式进行数据更新。更新链路如下：使用...
Knative概述
生产者可以在消费者启动之前产生事件，消费者也可以在生产者启动之前监听事件。Serving：管理Serverless工作负载，提供了应用部署、多版本管理、基于请求的自动弹性、灰度发布等能力，而且在没有服务需要处理的时候可以缩容到零个实例。...
什么是云消息队列 MQTT 版
消息：生产者向Topic发送并最终传送给消费者的数据。规则：云消息队列 MQTT 版 与其他阿里云产品实现数据互通的资源。消息收发模型 云消息队列 MQTT 版 主要包含以下两种消息收发模型：终端与云端服务交互模型 该模型中，云消息队列 MQTT ...
Knative概述
生产者可以在消费者启动之前产生事件，消费者也可以在生产者启动之前监听事件。Function:Knative Functions为您提供了一个简单的方式来创建、构建和部署Knative服务。您无需深入了解底层技术栈（如Kubernetes、容器和Knative），通过使用...
创建和管理 Topic
Topic 是 SOFAStack 消息队列里对消息的一级归类，消息生产者将消息...重要 Topic 删除之后，相关的生产者、消费者将会立即停止服务，且将在 10 分钟后完成所有相关资源的清理，请谨慎操作。后续操作 查看订阅关系 查看消费者状态 消息查询
动态过滤器（Dynamic Filter）
对于不同类型的JOIN语义，JOIN对象可担任的角色不同：A JOIN B：A或B都能作为生产者、消费者。A LEFT JOIN B：A只能作为生产者，B只能作为消费者。A RIGHT JOIN B：A只能作为消费者，B只能作为生产者。A FULL OUTER JOIN B：无法使用动态...
动态过滤器（Dynamic Filter）
对于不同类型的JOIN语义，JOIN对象可担任的角色不同：A JOIN B：A或B都能作为生产者、消费者。A LEFT JOIN B：A只能作为生产者，B只能作为消费者。A RIGHT JOIN B：A只能作为消费者，B只能作为生产者。A FULL OUTER JOIN B：无法使用动态...
将应用从HSF架构迁移到Dubbo（Ali-Tomcat）
Dubbo服务消费者在订阅的时候，同时订阅HSF和Dubbo格式的数据，保证Dubbo的消费者也能发现HSF的服务。前提条件 迁移过程中需要依赖以下组件：启动轻量级配置及注册中心 Dubbo 2.7.3 EDAS-container V3.5.5 edas-dubbo-extension 2.0.6 假设...
基本概念
通过消息轨迹，您能清晰定位消息从生产者发出，经由 云消息队列 RocketMQ 版 服务端，投递给消费者的完整链路，方便定位排查问题。消息堆积 生产者已经将消息发送到 云消息队列 RocketMQ 版 的服务端，但由于消费者的消费能力有限，未能在...
创建和管理 Group ID
创建完 Topic 后，您需要为消息的消费者（或生产者）创建客户端 ID，即 Group ID 作为标识。Group ID 和 Topic 的关系是 N：N，即一个消费者可以订阅多个 Topic，同一个 Topic 也可以被多个消费者订阅；一个生产者可以向多个 Topic 发送...
迁移上云操作
业务上下游配合：选择Topic后，需要通知所有使用该Topic的上下游业务应用（生产者、消费者应用）准备切换接入点。重要 请务必通知到所有迁移Topic涉及的上下游业务应用，如果业务应用切换实例接入点遗漏，可能会造成消息消费延迟等风险。...
SendMessage
如果生产者发送一个消息不想立即被消费者消费（典型的使用场景为定期任务），生产者可以在发送消息时设置 DelaySeconds 参数。发送带 DelaySeconds 参数值大于0的消息初始状态为Delayed，此时消息不能被消费者消费，只有等 DelaySeconds ...
实例化支持
Group管理：取消原Producer ID的申请，与原Consumer ID统一为Group ID，即对应控制台上，取消原 生产者管理，与原 消费者管理 统一为 Group管理。取消原申请Producer ID或Consumer ID时需要指定Topic的关联约束，只需申请Group ID即可在...
查询MNS日志
例如：计算某个队列中，Top 10消息的产生者和消费者；计算生产和消费的速度，确认是否均衡；计算某些消费者的处理延时，确认是否存在瓶颈等。离线计算：使用MaxCompute、E-MapReduce、Hive进行长时间跨度的计算，例如：计算最近一周内消息...
消息轨迹
场景四：查看生产者、消费者身份信息和机器信息，进一步排查问题原因。轨迹参数说明 云消息队列 RocketMQ 版 提供的轨迹参数如下：属性分类 轨迹参数 说明 生产者 生产者信息 生产者发送消息时使用的RocketMQ账号或Access Key ID。主机名 ...
迁移消费者程序
若您创建消费者程序时使用Assign方式消费消息，请先在源集群停止旧消费者程序，旧消费者程序停止后，迁移组件也会停止同步旧消费者程序所用的消费组的消费位点，然后再在目标实例启动新消费者程序。若您无法确定消费者程序使用哪种消费方式...
延时消息
这条消息将会在30分钟以后投递给消费者，消费者收到此消息后需要判断对应的订单是否已完成支付。如支付未完成，则关闭订单。如已完成支付则忽略。通过消息触发延时任务的场景。例如，在指定时间段之后向用户发送提醒消息。延时时间设置规则...
Control Center设置告警
消费滞后 消费者应用程序在从生产者应用程序消费时落后多久。消费者滞后是结束偏移量和当前偏移量之间的差值。消费超前 消费者应用程序在从生产者应用程序消费时提前多少。消费者提前是当前偏移量和开始偏移量之间的差值。例如，从偏移量 0...
Control Center设置告警
Consumer lag 消费者应用程序在从生产者应用程序消费时落后多久。消费者滞后是结束偏移量和当前偏移量之间的差值。Consumer lead 消费者应用程序在从生产者应用程序消费时提前量。消费者提前是当前偏移量和开始偏移量之间的差值。例如，从...
消息过滤
消费者：消费者在初始化及后续消费流程中通过调用订阅关系注册接口，向服务端上报需要订阅指定主题的哪些消息，即过滤条件。服务端：消费者获取消息时会触发服务端的动态过滤计算，云消息队列 RocketMQ 版 服务端根据消费者上报的过滤条件...
概念建模概述
扩大客户（消费者）体量问题，有营销活动、消费券等业务实体;内容域提供资源。提高客户（消费者）的粘性,有各种内容实体。供应链 域的一系列业务实体，保障商品的供应，有供应商、采购、运输、仓储等业务实体。履约域的业务实体将商品送到...
什么是新零售智能助理
产品原理 新零售智能助理基于自然语言处理（NLP）技术，根据消费者输入的问题（文本、表情或图片），结合上下文信息、业务数据（知识图谱、商家、商品、订单、消费者行为等），通过机器学习算法精准识别消费者意图，返回知识库精准答案或...
事务消息
在断网或者是生产者应用重启的特殊情况下，若服务端未收到发送者提交的二次确认结果，或服务端收到的二次确认结果为Unknown未知状态，经过固定时间后，服务端将对消息生产者即生产者集群中任一生产者实例发起消息回查。说明 服务端回查的...
查询消息轨迹
消息轨迹是指一条消息从生产者发送到消息队列服务端，再到消费者消费处理，整个过程中的各个相关节点的时间、状态等数据汇聚而成的完整链路信息。本文介绍如何快速查询消息轨迹。前提条件 您的消息已从生产者发送。操作步骤 登录 SOFAStack...
MNS回调事件通知
MNS提供了队列模型，支持多个生产者和消费者并发访问同一个队列，并能确保某条消息在取出之后的特定时间段内，无法被其他消费者获得。消息被消费后一段时间内不可见，需要用户主动删除，否则该消息会被再次消费。视频点播服务VOD支持通过...
普通消息
功能原理 什么是普通消息 定义：普通消息是 云消息队列 RocketMQ 版 基本消息功能，支持生产者和消费者的异步解耦通信。普通消息生命周期 初始化 消息被生产者构建并完成初始化，待发送到服务端的状态。待消费 消息被发送到服务端，对消费...
消费者负载均衡
对非对等消费者更友好 对于线上生产环境，由于网络机房分区延迟、消费者物理资源规格不一致等原因，消费者的处理能力可能会不一致，如果按照队列分配消息，则可能出现部分消费者消息堆积、部分消费者空闲的情况。消息粒度负载均衡策略按需...
什么是消息服务MNS
海量并发访问 支持多个生产者和消费者并发访问同一队列，并能确保某条消息在取出之后的特定时间内，无法被其他消费者获得。您可以根据业务需求自由伸缩并发访问数。消息投递保障 在消息有效期内，确保消息至少能被成功消费一次。消息服务...
顺序消息
顺序消息可以保证消息的消费顺序和发送的顺序一致，即先发送的先消费，后发送的后消费，常用于金融证券、电商业务等对消息指令顺序有严格要求的场景。本文介绍 云消息队列 RocketMQ 版 顺序消息的概念、适用场景、实现原理以及使用过程中的...
定时/延时消息
应用场景 说明 定时消息和延时消息本质相同，都是服务端根据消息设置的定时时间在某一固定时刻将消息投递给消费者消费。因此，下文统一用定时消息描述。在分布式定时调度触发、任务超时处理等场景，需要实现精准、可靠的定时事件触发。使用...
队列（MessageQueue）
模型关系 在整个 云消息队列 RocketMQ 版 的领域模型中，队列所处的流程和位置如下：云消息队列 RocketMQ 版 默认提供消息可靠存储机制，所有发送成功的消息都被持久化存储到队列中，配合生产者和消费者客户端的调用可实现至少投递一次的...
收发定时消息
定时消息可以做到在指定时间戳之后才可被消费者消费，适用于对消息生产和消费有时间窗口要求，或者利用消息触发定时任务的场景。定时消息的概念介绍及使用过程中的注意事项，请参见 定时和延时消息。前提条件 下载.NET SDK。更多信息，请...
收发定时消息
定时消息可以做到在指定时间戳之后才可被消费者消费，适用于对消息生产和消费有时间窗口要求，或者利用消息触发定时任务的场景。定时消息的概念介绍及使用过程中的注意事项，请参见 定时和延时消息。前提条件 您已完成以下操作：下载C/C++ ...
生产者会建立多少个到Broker的连接？
每个生产者通常会建立2个到Broker的TCP连接。每个生产者通常会建立2个到Broker的TCP连接，一个TCP连接用于更新元数据，一个TCP连接用于发送消息。更多信息，请参见 How are TCP Connections managed by kafka-clients scala library。
- 产品推荐
- 这些文档可能帮助您