权限策略和示例

消息队列RocketMQ版的权限管理是通过阿里云的访问控制RAM(Resource Access Management)产品实现的。使用RAM可以让您避免与其他用户共享云账号密钥,即AccessKey(包含AccessKey ID和AccessKey Secret),按需为用户分配最小权限。本文...

客户端无法通过TCP协议的内网接入点连接消息队列...

问题描述 使用消息队列Rocket MQ版时,客户端无法通过TCP协议的内网接入点连接到Broker。问题原因 客户端所在环境不同,对应的问题原因不同,详情如下: 客户端在阿里云环境中客户端在阿里云ECS实例、轻量应用服务器、函数计算等产品中时,...

版本说明

支持使用Message ID查询消息轨迹。支持消息属性。mq-http-java-sdk-1.0.0 发布时间 版本号 下载 2019-01-23 V1.0.0 mq-http-java-sdk-1.0.0.zip 新特性 首次发布。暂不支持高级特性消息,包括顺序消息、事务消息、定时和延时消息。已支持...

版本说明

优化消息拉取流程,避免特殊情况下拉取异常造成的消息堆积。优化顺序消息重试间隔。修复顺序消息重试时,重试次数不准确的问题。修复某些条件下客户端生成Message ID重复的问题。ons-.net v1.1.3 发布时间 版本号 Windows版下载 2019-02-01...

消费者连接消息队列Rocket MQ版时提示Group ID不存在

问题描述 消费者(Consumer)连接消息队列Rocket MQ版时提示Group ID不存在。问题原因 使用的Group ID错误或者未创建该Group ID,导致连接Broker时,未通过服务器校验。解决方案 参考下列步骤进行排查:登录消息队列Rocket MQ版的控制台。...

使用消息队列RocketMQ版实例时订阅关系不一致

问题描述 在使用消息队列RocketMQ版实例时,可能会出现订阅关系不一致的情况,具体的问题现象如下: 消息队列RocketMQ版控制台中订阅关系是否一致显示为否。消费者(Consumer)实例未收到订阅的消息。问题原因 确保订阅关系一致的要求是同...

OnsConsumerTimeSpan

调用OnsConsumerTimeSpan查询当前Group ID订阅的Topic可重置的时间范围,即该Topic中储存的最早的和最晚的一条消息的生产时间。使用说明 使用本接口可以查询某个Topic在当前服务器上存储的最早和最晚的一条消息的时间,以及查询消费端最近...

OnsMessageGetByKey

调用OnsMessageGetByKey根据Topic和Message Key模糊查询消息信息列表。使用说明 使用本接口根据Message Key查询消息的方式属于模糊查询。由于业务方的Key可能不唯一,所以查询结果可能为多条。本接口在业务方无法获取Message ID的场景,...

OnsMessageGetByMsgId

消息消费有问题,则可通过该接口查询具体发送的消息内容来排查问题。根据Message ID查询消息的方式属于精确查询,查询条件需要的Message ID从每次消息发送成功的SendResult中获取,因此业务方必须存储每次发送消息的结果。查询到的信息...

版本说明

支持使用Message ID查询消息轨迹。支持消息属性。支持Python 3。mq-http-python-sdk 发布时间 版本号 下载 2019-01-23 V1.0.0 mq-http-python-sdk-1.0.0.zip 新特性 首次发布。暂不支持高级特性消息,包括顺序消息、事务消息、定时和延时...

OnsMessageTrace

调用OnsMessageTrace根据Message ID来判断目标消息是否曾被消费过。使用说明 本接口一般在消费异常,需要判断消息消费状态,初步排查原因时使用。本接口的实现基于消息队列RocketMQ版的内部位点机制,在大部分场景下判断结果可信,但如果...

OnsDLQMessageGetById

调用OnsDLQMessageGetById通过传入Message ID查询指定的死信消息使用说明 根据Message ID查询死信消息的方式属于精确查询。查询条件需要的Message ID从消息发送成功的SendResult中获取,或者从批量查询的接口中获取。查询到的信息包括...

版本说明

支持使用Message ID查询消息轨迹。支持消息属性。mq-http-csharp-sdk-1.0.0 发布时间 版本号 下载 2019-01-23 V1.0.0 mq-http-csharp-sdk-1.0.0.zip 新特性 首次发布。暂不支持高级特性消息,包括顺序消息、事务消息、定时和延时消息。已...

版本说明

本文介绍HTTP协议下C++ SDK的版本信息,包括发布时间、发布版本、下载链接及更新内容等,以便您按需...暂不支持高级特性消息,包括顺序消息、事务消息、定时和延时消息。已支持集群消费模式,暂不支持广播消费模式。暂不支持查询消息轨迹。

版本说明

支持使用Message ID查询消息轨迹。支持消息属性。mq-http-nodejs-sdk-1.0.0 发布时间 版本号 下载 2019-01-23 V1.0.0 mq-http-nodejs-sdk-1.0.0.zip 新特性 首次发布。暂不支持高级特性消息,包括顺序消息、事务消息、定时和延时消息。已...

版本说明

支持使用Message ID查询消息轨迹。支持消息属性。mq-http-go-sdk-1.0.0 发布时间 版本号 下载 2019-06-10 V1.0.0 mq-http-go-sdk-1.0.0.zip 新特性 首次发布。暂不支持高级特性消息,包括顺序消息、事务消息、定时和延时消息。已支持集群...

版本说明

支持使用Message ID查询消息轨迹。支持消息属性。mq-http-php-sdk-1.0.0 发布时间 版本号 下载 2019-01-23 V1.0.0 mq-http-php-sdk-1.0.0.zip 新特性 首次发布。暂不支持高级特性消息,包括顺序消息、事务消息、定时和延时消息。已支持...

版本说明

本文通过介绍C++ SDK的版本信息,包含下载链接、发布时间、更新点等,以便您按需获取相应C++ SDK收发消息。获取了C++ SDK后,您需按照SDK的使用说明来准备相应环境。不同版本的SDK的环境准备步骤有所不同,具体说明如下: 针对v2.0.0及以上...

收发普通消息

普通消息是指消息队列RocketMQ版中无特性的消息,区别于有特性的定时和延时消息、顺序消息和事务消息。本文提供使用HTTP协议下的Python SDK收发普通消息的示例代码。前提条件 您已完成以下操作:安装Python SDK。更多信息,请参见准备环境...

收发定时消息和延时消息

延时消息:Producer将消息发送到消息队列RocketMQ版服务端,但并不期望立马投递这条消息,而是延迟一定时间后才投递到Consumer进行消费,该消息即延时消息。定时消息:Producer将消息发送到消息队列RocketMQ版服务端,但并不期望立马投递这...

收发顺序消息

顺序消息(FIFO消息)是消息队列RocketMQ版提供的一种严格按照顺序来发布和消费的消息类型。本文提供使用HTTP协议下的Python SDK收发顺序消息的示例代码。背景信息 顺序消息分为两类:全局顺序:对于指定的一个Topic,所有消息按照严格的先...

消息队列Rocket MQ版客户端的状态出现异常

问题描述 使用消息队列Rocket MQ版时,客户端的状态出现异常。问题原因 客户端状态异常的部分原因如下: 创建消费者(Consumer)或生产者(Producer)之后,程序未调用start()方法启动客户端。创建Consumer或Producer之后,程序调用start()...

OnsMessagePush

调用OnsMessagePush向指定的消费者推送消息使用说明 本接口主要用于消费验证的场景。通过传入的MsgId获取指定消息消息体,再将消息体重新进行封装推送给消费者。此时重新发送的这条消息和原消息消息内容相同,但并不是同一条消息且...

OnsConsumerResetOffset

mq:ResetConsumerOffset cs:mq:*:*:{instanceId}%{topic} acs:mq:*:*:{topic} 调试 您可以在OpenAPI Explorer中直接运行该接口,免去您计算签名的困扰。运行成功后,OpenAPI Explorer可以自动生成SDK代码示例。请求参数 名称 类型 是否必选...

OnsMessagePageQueryByTopic

调用OnsMessagePageQueryByTopic分页查询指定时间段内指定Topic内存在的所有消息使用说明 按Topic查询消息的方式属于范围查询,查询结果会通过分页的方式展示给调用方,仅适用于没有任何搜索条件(Message ID和Message Key)的查询场景。...

收发普通消息

普通消息是指消息队列RocketMQ版中无特性的消息,区别于有特性的定时和延时消息、顺序消息和事务消息。本文提供使用HTTP协议下的C# SDK收发普通消息的示例代码。前提条件 您已完成以下操作:安装C#SDK。更多信息,请参见准备环境。创建资源...

准备环境

使用C#SDK收发消息前,您需按照本文提供的内容来准备环境。环境要求 安装.NET。更多信息,请参见安装.NET。安装Visual Studio 2015或以上版本,更多信息,请参见安装Visual Studio。安装完成后,您可以执行dotnet-version命令查看....

OnsConsumerAccumulate

调用OnsConsumerAccumulate查询指定Group ID的消息消费堆积情况,包括当前消息堆积数量和消费延迟时间等。使用说明 消费堆积查询一般在生产环境中需要关注Group ID消费进度时使用,用于粗略判断消息消费情况和延迟情况。您不仅可以到该...

收发事务消息

背景信息 事务消息的交互流程下图所示。更多信息,请参见事务消息。前提条件 您已完成以下操作:安装Python SDK。更多信息,请参见准备环境。创建资源。代码中涉及的资源信息,例如实例、Topic和Group ID等,需要在控制台上提前创建。更...

OnsInstanceBaseInfo

调用OnsInstanceBaseInfo接口查询实例基本信息和收发消息的接入点。使用说明 客户端需要通过接入点接入消息队列RocketMQ版完成消息的收发,可通过调用本接口查询实例接入点。QPS限制 本接口的单用户QPS限制为50次/秒。超过限制,API调用会...

调用HTTP协议的SDK收发普通消息

消息内容。MessageTag:"",/消息标签。Properties:map[string]string{},/消息属性。}/设置Key。msg.MessageKey="MessageKey"/设置属性。msg.Properties["a"]=strconv.Itoa(i)} else { msg=mq_...

启动消息队列Rocket MQ版的客户端时提示Group ID重复

问题描述 启动消息队列Rocket MQ版的Producer(生产者)实例或Consumer(消费者)实例时,提示Group ID重复。问题原因 单个JVM进程中出现下列情况时,会导致客户端启动失败,提示Group ID重复:启动了一个以上的Producer实例,并且这些实例...

收发定时消息和延时消息

延时消息:Producer将消息发送到消息队列RocketMQ版服务端,但并不期望立马投递这条消息,而是延迟一定时间后才投递到Consumer进行消费,该消息即延时消息。定时消息:Producer将消息发送到消息队列RocketMQ版服务端,但并不期望立马投递这...

OnsDLQMessagePageQueryByGroupId

调用OnsDLQMessagePageQueryByGroupId分页查询指定时间段内指定Group ID内存在的所有死信消息使用说明 按Group ID查询死信消息的方式属于范围查询,查询结果会通过分页的方式展示给调用方,仅适用于没有任何搜索条件Message ID查询场景。...

收发顺序消息

顺序消息(FIFO消息)是消息队列RocketMQ版提供的一种严格按照顺序来发布和消费的消息类型。本文提供使用HTTP协议下的C# SDK收发顺序消息的示例代码。背景信息 顺序消息分为两类:全局顺序:对于指定的一个Topic,所有消息按照严格的先入先...

ListTagResources

调用ListTagResources查询资源绑定的标签列表。使用说明 调用ListTagResources接口时,标签键Tag.N.Key和资源ID ...除了调用ListTagResources接口,您还可以通过消息队列RocketMQ版控制台查看资源的标签信息。具体操作,请参见标签概述。

OnsGroupSubDetail

调用OnsGroupSubDetail查看Group订阅了哪些Topic。使用说明 该接口用于查询Group ID和Topic之间的订阅关系。如果Group ID对应的消费者实例不在线则不到数据。QPS限制 本接口的单用户QPS限制为10次/秒。超过限制,API调用会被限流,这可能...

使用消息队列RocketMQ版时message类的userproperties...

概述 使用消息队列RocketMQ版时,message类的userproperties属性如何自定义。详细信息 userproperties属性是Properties类型,您可以根据自己的需求添加Key-Value类型的属性到message中,示例如下:Message message=new Message(MqConfig....

OnsGroupConsumerUpdate

调用OnsGroupConsumerUpdate配置指定Group ID对应的消费集群的消息读取权限。使用说明 您可以使用本接口根据您指定的消息队列RocketMQ版地域(Region)以及Group ID名称,配置该Group ID读取消息的开关。本接口一般用于禁止特定Group ID...

OnsTraceQueryByMsgKey

Key查询该消息的投递轨迹信息,即可使用本接口创建查询任务。该接口返回任务ID后,再根据OnsTraceGetResult接口传入任务ID即可获取查询结果。QPS限制 本接口的单用户QPS限制为30次/分钟。超过限制,API调用会被限流,这可能会影响您的业务...
< 1 2 3 4 ... 143 >
跳转至: GO

新品推荐

你可能感兴趣

热门推荐

新人福利专场 阿里云试用中心 企业支持计划 飞天会员助力企业低成本上云 智能财税30天免费试用 云解析DNS新用户首购低至36元/年起 ECS限时升级特惠6.5折