PaaS应用场景
RetailBot会根据消费者问题、上下文、知识库、机器人配置等多个因素，智能计算最优解并返回给开发者，由开发者结合其他服务策略/工具，为消费者提供即时响应。公测MVP版本主要支持的业务场景包括：行业高频场景识别、消费者情绪识别、直连...
ListGatewayAuthConsumer-获取网关鉴权消费者列表
gw-5017305290e14centbrveca*Type string 鉴权类型：JWT JWT Description string 鉴权消费者描述。描述 GmtCreate string 创建时间。2021-09-13 19:24:23 GmtModified string 修改时间。2022-01-07 18:07:57 示例 正常返回示例 JSON 格式 {...
UpdateGatewayAuthConsumer-更新网关鉴权消费者
abcd Description string 否 鉴权消费者描述。这是描述 Id long 是 鉴权消费者 ID。63 AcceptLanguage string 否 返回信息的语言类型：zh：中文 en：英文 zh 返回参数 名称 类型 描述 示例值 object RestResult<List >RequestId string 请求...
配置消费者鉴权
云原生网关支持为路由配置认证，并对指定的消费者进行鉴权，以允许对应消费者访问路由。本文介绍如何配置消费者鉴权。背景信息 相比全局认证鉴权适用于统一登录认证等ToC场景，路由认证和消费者鉴权模式适用于授权API给合作伙伴等ToB场景。...
AddGatewayAuthConsumer-新增网关鉴权消费者
abcd Description string 否 鉴权消费者描述。description AcceptLanguage string 否 返回信息的语言类型：zh：中文 en：英文 zh 返回参数 名称 类型 描述 示例值 object RestResult<List >RequestId string 请求 ID。69AD2AA7-DB47-449B-...
Dubbo服务消费者调用HSF服务提供者失败
问题描述 Dubbo服务消费者调用HSF服务提供者失败，具体报错信息如下：java.lang.Exception:[HSF-Provider-192.168.XX.XX]Error log:[HSF-Provider]App[xxxxxxx-3b6f-42d3-xxxx-0ad2434xxxxx]failed to verify the caller signature[null]...
消息负载均衡策略
云消息队列 RocketMQ 版 的消息负载均衡策略针对生产者和消费者有所差异。对消费者而言，消息负载均衡策略在一定程度上影响消息堆积。背景信息 随着SDK版本的升级，云消息队列 RocketMQ 版 的负载均衡策略也有所优化，根据SDK版本，负载...
社区Knative简介
生产者可以在消费者启动之前产生事件，消费者也可以在生产者启动之前监听事件。Serving：管理Serverless工作负载，提供了应用部署、多版本管理、基于请求的自动弹性、灰度发布等能力，而且在没有服务需要处理的时候可以缩容到零个实例。
名词解释
Connection TCP连接，生产者或消费者与 云消息队列 RabbitMQ 版 间的物理TCP连接。具体信息，请参见 Connection和Channel。E Exchange 生产者将消息发送到Exchange，由Exchange将消息路由到一个或多个Queue中。Exchange根据消息的属性或...
常见问题
菜单上没有自定义组件管理平台 问题描述 开发者中心 下的左侧导航栏中没有 自定义组件。解决方案 仅组织管理员可以设置自定义组件。请检查您当前的登录账号是否为组织管理员账号。获取js失败 问题描述 本地调试组件时，弹出 获取/127.0.0.1...
SOFAMQ 常见问题
上述方式可以查询到消息的具体内容以及消费情况，如果需要追踪一条消息从生产者发出到被消费者消费的整个链路中各个相关节点的时间地点，可以使用消息队列最新的消息轨迹查询功能，具体使用方式请参考 查询消息轨迹。消息队列是否能保证...
Group操作
删除Group 警告 删除Group后，由该Group ID标识的生产者和消费者客户端将在客户端发生重新连接时认证失败，已连接生产者和消费者不受影响。进入 Group 管理 页面。在Group列表中，找到需要删除的目标Group，在其 操作 列中，选择 更多>删除...
基础知识
通过消息队列服务SWIFT实现的生产者/消费者模型，iGraph为增量消息的消费者，用户为消息生产者。iGraph为异步更新模式，保证最终一致性。支持通过iGraph客户端、Blink、Porsche以及其他用户自己实现的方式进行数据更新。更新链路如下：使用...
Spring集成
背景信息 云消息队列 RocketMQ 版 支持以下消息类型的生产者和消费者与Spring集成：普通消息的生产者和消费者 事务消息的生产者和消费者 顺序消息的生产者和消费者 说明 云消息队列 RocketMQ 版 暂不支持Spring框架下定时消息和延时消息的...
Knative概述
生产者可以在消费者启动之前产生事件，消费者也可以在生产者启动之前监听事件。Serving：管理Serverless工作负载，提供了应用部署、多版本管理、基于请求的自动弹性、灰度发布等能力，而且在没有服务需要处理的时候可以缩容到零个实例。...
什么是云消息队列 MQTT 版
消息：生产者向Topic发送并最终传送给消费者的数据。规则：云消息队列 MQTT 版 与其他阿里云产品实现数据互通的资源。消息收发模型 云消息队列 MQTT 版 主要包含以下两种消息收发模型：终端与云端服务交互模型 该模型中，云消息队列 MQTT ...
超大消息传输
当消息内容大于64 KB以至于无法直接存入MNS队列时，不做...注意事项 大消息主要消费网络带宽，用该方案发送大消息时，生产者和消费者的网络带宽可能会是瓶颈。大消息网络传输时间较长，受网络波动影响的概率更大，建议在上层做必要的重试。
Knative概述
生产者可以在消费者启动之前产生事件，消费者也可以在生产者启动之前监听事件。Function:Knative Functions为您提供了一个简单的方式来创建、构建和部署Knative服务。您无需深入了解底层技术栈（如Kubernetes、容器和Knative），通过使用...
动态过滤器（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：无法使用动态...
产品优势
消息的生产者与消费者实现隔离，满足生产者大量的并发，消费者稳定消费。安全可靠 权限粒度 实例、Vhost、Queue以及Exchange细粒度权限控制，对每次消息请求进行安全访问控制。主子账号 全面对接阿里云RAM主子账号、黑白名单、STS等功能。...
发送消息（多线程）
云消息队列 RocketMQ 版 的消费者和生产者客户端对象是线程安全的，可以在多个线程之间共享使用。您可以在服务器上（或者多台服务器）部署多个生产者和消费者实例，也可以在同一个生产者或消费者实例里采用多线程发送或接收消息，从而提高...
发送消息（多线程）
SOFAStack 消息队列的消费者和生产者客户端对象是线程安全的，可以在多个线程之间共享使用。您可以在服务器上（或者多台服务器）部署多个生产者和消费者实例，也可以在同一个生产者或消费者实例里采用多线程发送或接收消息，从而提高消息...
迁移上云操作
业务上下游配合：选择Topic后，需要通知所有使用该Topic的上下游业务应用（生产者、消费者应用）准备切换接入点。重要 请务必通知到所有迁移Topic涉及的上下游业务应用，如果业务应用切换实例接入点遗漏，可能会造成消息消费延迟等风险。...
基于消息队列RocketMQ版实现全链路灰度
因为消费者过滤的方式会在每个环境都处理全量的消息，对消息的生产者和消费者压力都比较大，不推荐在生产中使用此模式。登录 MSE治理中心控制台，并在顶部菜单栏选择地域。在左侧导航栏，选择 治理中心>应用治理。在 应用列表 页面，单击...
集群消费和广播消费
由于消费者应用一般是分布式系统，以集群方式部署，因此消息队列约定以下概念：集群：使用相同 Group ID 的消费者属于同一个集群。同一个集群下的消费者消费逻辑必须完全一致（包括 Tag 的使用）。详情请参见 订阅关系一致。集群消费：当...
消费组监控与告警
背景信息 一个消费组包含多个消费者，每个消费者消费Logstore中的一部分Shard。同一个消费组下面的消费者共同消费一个Logstore中的日志数据，消费者之间不会重复消费数据。Shard数据模型可以简单理解为一个队列，新写入的数据被加到队尾，...
Dubbo开发概述
SAE 支持原生Dubbo微服务框架...消费者从提供者地址列表中，基于软负载均衡算法，选择某个提供者进行调用。如果调用失败，则重新调用其他提供者。消费者和提供者在内存中存储累计调用次数和调用时间，定时（每分钟）发送统计数据至监控中心。
应用依赖
在 应用依赖 页面，您可以执行以下操作：查看有依赖关系的所有应用，包括服务提供者和消费者。将鼠标悬浮在应用图标上，可以查看所选应用的依赖关系、节点数、提供的服务数、消费的服务数。单击应用图标可查看提供的服务和消费的服务详情。...
服务
订阅服务 服务消费者使用消费凭证订阅服务API，经服务发布者审批通过后订阅生效，之后服务消费者也可以选择退订以及重新订阅该API，重新订阅时仍需要服务发布者审批。调用服务 订阅生效后，服务消费方应用以订阅所用的消费凭证来访问服务...
API 概览
消费管理 API 描述 QueryMqSofamqConsumerAccumulate 查询消费者消息积压 GetMqSofamqConsumerStatus 查询消费端详细状态 GetMqSofamqConsumerJStack 查询消费端堆栈信息 QueryMqSofamqConsumerConnection 查询消费者连接信息 ...
0003-00000906
问题描述 Bucket所有者发生变化导致操作失败。问题原因 您对某个Bucket发起某种请求，但是在该请求处理过程中Bucket所有者发生变化，导致操作终止，引起请求失败。问题示例 比如您发起了UploadObject请求上传文件，但是在文件上传的过程中...
消息重试
消息在 云消息队列 RocketMQ 版 服务端已就绪，可以被消费者消费。Inflight：处理中状态。消息被消费者客户端获取，处于消费中还未返回消费结果的状态。WaitingRetry：待重试状态。当消费者消息处理失败或消费超时，会触发消费重试逻辑判断...
通过命令行管理多集群服务
方式一：通过新的Service名称访问 服务消费者集群ACK Cluster 2创建ServiceImport后，Fleet实例会在服务消费者集群ACK Cluster 2中，创建一个以 amcs-为前缀的Kubernetes服务代表多集群Service。在服务消费者集群ACK Cluster 2的Client Pod...
容灾大屏
服务层 消费者调用总QPM 消费者用户请求的次数/分钟，即QPM=（并发数/平均响应时间）×60。同城多活容灾 说明 仅限同城多活SpringCloud服务、同城多活Dubbo服务和同城多活EDAS服务。异地双活容灾 说明 仅限异地应用多活SpringCloud服务和...
通过控制台管理多集群服务
管理员在服务提供者集群（ACK Cluster 1）和服务消费者集群（ACK Cluster 2）中，创建应用相关资源，包含Namespace、Deployment和Service；创建多集群Service资源，包括ServiceExport和ServiceImport。多集群舰队Fleet监听子集群的...
Dubbo概述
消费者基于软负载均衡算法，从提供者地址列表中选一个提供者进行调用。Dubbo应用托管到EDAS的含义 Dubbo应用托管到EDAS的核心是三个中心的托管：注册中心、配置中心和元数据中心。托管前后架构如下图所示：托管到EDAS前：您需要自行搭建、...
接口和参数说明
表 2.Push方式特有参数（批量消费）参数 说明 ConsumeMessageBatchMaxSize 批量消费的最大消息数量，缓存的消息数量达到设置的参数值，云消息队列 RocketMQ 版 会将缓存的消息统一推送给消费者进行批量消费。默认值：32，取值范围：1~1024...
查询MNS日志
查询结果如下图所示，当前查询时段内，生产者向logtest主题发布了3条消息。查询某个客户端消息处理量 登录 日志服务控制台。在Project列表区域，单击目标Project。在控制台左侧，单击 日志存储，在 日志库 列表中单击目标Logstore。输入...
配置AMQP服务端订阅
如果需要所有消费者收到消息，当消费者数量较少时，可以为每个消费者单独创建一个消费组，当消费者数量较多时，可以使用云产品流转将消息 转发到消息队列RocketMQ，然后 使用广播消费。前提条件 已创建产品。已创建消费组。您可使用物联网...
- 产品推荐
- 这些文档可能帮助您