领域模型概述
点对点模型 点对点模型也叫队列模型，具有如下特点：消费匿名：消息上下游沟通的唯一的身份就是队列，下游消费者从队列获取消息无法声明独立身份。一对一通信：基于消费匿名特点，下游消费者即使有多个，但都没有自己独立的身份，因此共享...
配额与限制
消费者从服务端获取消息时，一次获取到最大消息条数。建议按照实际业务设置合理的参数值，一次获取消息数量过大容易在消费失败时造成大批量消息重复。SimpleConsumer最大不可见时间 默认值：用户必填参数，无默认值。取值范围：最小10秒；...
常见问题
消费端从服务端拉取不到消息或拉取消息缓慢 为什么不推荐使用Sarama Go客户端收发消息？使用云消息队列 Kafka 版时出现“Not authorized to access group”的错误信息 实例问题 实例支持哪些开源版本？VPC实例和公网/VPC实例的区别是什么？...
RAM凭据插件
您在KMS托管RAM用户的AccessKey后，可以安装RAM凭据插件，在使用阿里云SDK时通过引用RAM凭据的名称，获取AccessKey完成API鉴权，无需关注AccessKey的具体信息或者是否被轮转。本文介绍RAM凭据插件的工作原理、安装和使用。工作原理 RAM凭据...
DBMS_OUTPUT
DBMS_OUTPUT内置包用于向消息缓冲区发送消息，或者从消息缓冲区获取消息。DBMS_OUTPUT子程序总览 子程序 说明 ENABLE Procedure 启用消息输出。DISABLE Procedure 禁用消息输出。PUT Procedure 输入消息至缓冲区。PUT_LINE Procedure 输出...
Go-SQL-Driver/MySQL 连接 OceanBase 数据库示例程序
安装 Go 语言 下载 Go 语言安装包：可以从 Go 官网 下载适合自己操作系统的安装包。说明 本文档使用的 Go 安装包名为 go1.20.6.windows-amd64.msi。安装 Go 语言：双击下载的安装包，按照提示进行安装。配置环境变量：将 Go 语言的安装路径...
Account
消费者 从MNS的消息队列获取消息的角色。主题模型 主题所有者 开通MNS服务的Account通过 CreateTopic 接口创建出一个主题，这个Account就是该主题的所有者，主题所有者拥有该主题的所有操作权限。发布者 向MNS的主题发布消息的角色。订阅者...
使用Confluent-Kafka-Go实现Kafka消费
本文介绍如何使用Confluent-Kafka-Go实现Kafka消费。参数说明 参数 描述 示例 bootstrap.servers 初始连接的集群地址，格式为${project}.${endpoint}:${port}，请根据实际的Project名称及其所在的Endpoint进行配置。更多信息，请参见 服务...
应用接入常见问题
获取凭据值时出现This operation for key-xxxxxx is forbidden by permission system报错 问题描述 获取凭据值时，KMS返回的错误描述或SDK异常消息中包含：This operation for key-xxxxxx is forbidden by permission system。以下是KMS...
DingRtcEngine
int JoinChannel(const RtcEngineAuthInfo&authInfo,const char*userName)=0 参数说明 参数 类型 描述 authInfo RtcEngineAuthInfo&认证信息，从AppServer获取。userName const char*任意用于显示的用户名称。不是UserID。返回说明 0：成功...
DingRtcEngine接口
加入频道后，必须要调用该方法离开频道，否则无法加入其他频道。返回说明 0：成功；失败。重要 失败原因错误码见回调函数：onLeaveChannelResult。如果调用了 leaveChannel 后立刻调用 destroy 方法，SDK将会无法触发 onLeaveChannelResult...
通信消息相关问题
在物联网平台控制台发送的消息和调用云端API发送的消息均属于服务端发送的消息，不会转发到MNS队列，只有设备发出的消息（设备上报消息、设备状态变化通知、设备标签变更等）才会转发到MNS队列里。如何判断MNS服务端收到的消息是来自哪个...
指标说明
go_memstats_sys_bytes 该指标用于衡量Go从系统中总共获取了多少字节的内存。go_memstats_last_gc_time_seconds 上一次GC完成时的时间戳。go_memstats_heap_sys_bytes 该指标显示从操作系统中为堆分配的内存字节数。它包括已保留但尚未使用...
指标说明
go_memstats_sys_bytes 该指标用于衡量Go从系统中总共获取了多少字节的内存。go_memstats_last_gc_time_seconds 上一次GC完成时的时间戳。go_memstats_heap_sys_bytes 该指标显示从操作系统中为堆分配的内存字节数。它包括已保留但尚未使用...
AliRtcEngine接口
加入频道成功后，如果中途需要加入其他频道，必须先调用 leaveChannel 离开当前频道，如果加入频道失败，需要重试时，无需先调用 leaveChannel。参数说明 参数 类型 描述 token String 单参数入会的鉴权信息。channelId String 入会频道，...
Go SDK接入示例
本文介绍使用AMQP协议的Go客户端接入阿里云物联网平台，接收服务端订阅消息的示例。前提条件 已获取消费组ID，并订阅Topic消息。管理消费组：您可使用物联网平台默认消费组（DEFAULT_GROUP）或创建消费组。配置AMQP服务端订阅：您可通过...
迁移上云操作
前提条件 创建消息队列RocketMQ版5.0系列实例 创建服务关联角色 角色名称：AliyunServiceRoleForRMQMigration 权限策略：AliyunServiceRolePolicyForRMQMigration 权限说明：允许 云消息队列 RocketMQ 版 使用该角色获取访问专有网络VPC的...
AliRtcEngine接口
如果当前不在频道内，调用 leaveChannel 不会对实例产生任何影响，但会产生消息，通知频道内其他用户。switchChannel：切换频道。(int)switchChannel:(AliRtcAuthInfo*_Nonnull)authInfo;参数说明 名称 类型 描述 authInfo AliRtcAuthInfo ...
小程序配置
说明 如商家搭建过试用版小程序，在切回独立（自有）域名后，需要重新添加小程序服务器域名白名单，并在添加完成后，将搭建试用版小程序时所添加的域名从白名单中删除，详细操作请参考 域名切换。获取需要加白的域名。在运营控制台 多端>小...
MNS如何保证多个消费者访问同一消息队列，不会丢失...
当队列中的某条消息被取出后，在不可见时间段内，其他消费者将无法获取到该条消息。如果消费者在不可见时间内完成了消费，则需要通过临时句柄（ReceiptHandle）进行消息的删除。如果消费者在不可见时间内未完成消费，则需要发送不可见时间...
表格智能解析
如下示例为打印返回的业务id格式#获取属性值均以小写开头，print(response.body.data.id)except Exception as error:#如有需要，请打印 error UtilClient.assert_as_string(error.message)Go import("fmt""os"openClient"github....
版本说明
本文介绍Apache RocketMQ Go SDK的版本信息，以便您获取合适的Go SDK收发消息。推荐版本 云消息队列 RocketMQ 版 5.x系列实例完全兼容Apache RocketMQ Go SDK，以下版本经由阿里云工程师进行测试验证，建议您使用以下SDK版本进行消息收发。...
4.x和5.x版本差异及兼容性说明
若您的客户端使用4.x版本对应的SDK，则基础消息收发功能支持，部分监控指标、消息轨迹数据无法获取。服务端版本 客户端版本 兼容性 约束限制 5.x版本实例 RocketMQ 5.x SDK 兼容 云消息队列 RocketMQ 版 5.x版本实例的所有功能完全支持。...
4.x和5.x版本差异及兼容性说明
若您的客户端使用4.x版本对应的SDK，则基础消息收发功能支持，部分监控指标、消息轨迹数据无法获取。服务端版本 客户端版本 兼容性 约束限制 5.x版本实例 RocketMQ 5.x SDK 兼容 云消息队列 RocketMQ 版 5.x版本实例的所有功能完全支持。...
API使用说明
消息服务MNS 提供了以下API接口：队列接口 队列接口适用于点对点的消息收发，当接收消息时，需要应用端自行轮询获取消息（拉模式）。主题接口 主题接口适用于一对多的消息收发，应用端只需要在某个地址上启动监听，服务端就会主动将消息推...
子设备禁用、启用、删除
子设备通过网关订阅该Topic获取消息。Alink请求数据格式 {"id":"123","version":"1.0","params":{},"method":"thing.disable"} Alink响应数据格式 {"id":"123","code":200,"data":{} } 参数说明 参数 取值 说明 id String 消息ID号。String...
版本说明
本文介绍HTTP协议下Go SDK的版本信息，包括各版本的发布时间、发布内容以及下载链接，以便您按需获取适用的Go SDK收发消息。1.0.3 发布时间 发布内容 下载 2021-01-05 新特性 支持顺序消息。功能优化 支持设置timeout；在收发消息的返回...
默认接入点收发消息
本文以Java SDK为例介绍如何在VPC环境下使用SDK接入 云消息队列 Kafka 版 的默认接入点并收发消息。前提条件 步骤三：创建资源 安装1.8或以上版本JDK 安装2.5或以上版本Maven 安装编译工具。本文以 IntelliJ IDEA Ultimate 为例。安装Java...
如何处理消息堆积
消费空闲情况下消费线程都会处于WAITING状态等待从消费任务队中获取消息。示例二：消费逻辑有抢锁休眠等待等情况。消费线程阻塞在内部的一个睡眠等待上，导致消费缓慢。示例三：消费逻辑操作数据库等外部存储卡住。消费线程阻塞在外部的...
使用实例接入点收发消息
当使用应用程序与Kafka集群建立连接时，可通过实例接入点接入 云消息队列 Kafka 版 并收发消息。Kafka实例提供默认接入点、SSL接入点和SASL接入点，以满足您不同的连接和安全需求。默认接入点适用于在保密性较高的VPC环境收发消息；SASL接...
API接口常见问题
3）外呼业务ID 4）RocketMQ消息队列实例信息 9、配置好RocketMQ消息队列后，无法获取外呼任务完成消息是怎么回事？需要检查自己建立的RocketMQ实例是否为公网实例，如果所建RocketMQ实例非公网实例则无法获取外呼任务完成的消息队列信息 10...
消息堆积和延迟问题
SDK客户端使用Push模式消费消息时，分为以下两个阶段：阶段一：获取消息，SDK客户端通过长轮询批量拉取的方式从 云消息队列 RocketMQ 版 服务端获取消息，将拉取到的消息缓存到本地缓冲队列中。SDK获取消息的方式为批量拉取，常见内网环境...
消费者分类
} SimpleConsumer主要涉及以下几个接口行为：接口名称 主要作用 可修改参数 ReceiveMessage 消费者主动调用该接口从服务端获取消息。说明 由于服务端存储为分布式，可能会出现服务端实际有消息，但是返回为空的现象。一般可通过重新发起...
直播互动消息简介
消息收发 支持发送消息、获取消息、消息存储、消息审核等功能。消息组管理 支持创建消息组、人数获取、消息组禁言等管理功能。产品优势 支持跨多终端消息收发。支持消息默认存储及服务端消息获取。支持消息安全审核及按需发送。适用场景 ...
队列模型基本概念
消费者（Consumer）从 消息服务MNS 的消息队列获取消息的角色。Endpoint 消息服务MNS 的访问域名地址，格式如下：http://$AccountId.mns.$Region.aliyuncs.com mns.<Region>.aliyuncs.com ： Region是 消息服务MNS 服务部署的地域，您可以...
API概览
您需要再调用OnsTraceGetResult接口，传入返回的查询任务ID，获取消息轨迹的详细结果。OnsTraceQueryByMsgKey 根据Message Key创建轨迹查询任务 通过传入Topic名称和Message Key创建轨迹查询任务，得到该查询任务的ID。您需要再调用...
输入弹窗
获取消息 TextView*/public TextView getMsg();获取底部按钮的 LinearLayout*/public LinearLayout getBottomLayout();获取弹窗最外层的 RelativeLayout*/public RelativeLayout getDialogBg();设置确认按钮监听*/public void ...
延时消息
因为 云消息队列 RabbitMQ 版 的消息是分布式存储的，如果您使用pull模式的 basic.get 方法获取消息，并不能保证正好从存储的节点获取消息。常见问题 为什么实际的延时时间大于设置的延时时间？因为客户端使用了pull模式的basic.get方法...
SOFAMQ 常见问题
您可以通过调用 message.getReconsumeTimes()方法来获取消息的重试次数。每次重试的间隔时间如下：第几次重试 每次重试间隔时间 1 10 秒 2 30 秒 3 1 分钟 4 2 分钟 5 3 分钟 6 4 分钟 7 5 分钟 8 6 分钟 9 7 分钟 10 8 分钟 11 9 分钟 12 ...
消息重试
获取消息重试次数 Consumer收到消息后，可按照以下方式获取消息的重试次数，消息重试间隔时间一般不需要获取。public class MessageListenerImpl implements MessageListener {@Override public Action consume(Message message,...
- 产品推荐
- 这些文档可能帮助您