云端Demo工程

使用Demo工程收发消息,需要提前在控制台创建资源信息,包括 创建实例、创建Topic、创建Group、获取AccessKey(包括AccessKey ID和AccessKey Secret)以及 获取接入点。运行Demo工程 下载并解压Demo工程。下载地址,请参见 Demo工程。解压...

消息查询

重要 消费验证功能仅用于验证客户端的消费逻辑是否正常,并会影响正常的收消息流程,因此消息的消费状态等信息在消费验证后并不会改变。相关文档 您可以根据消息查询结果进一步查看消息的轨迹信息,查看消息的消费状态和消费结果。具体...

管理自建Dataphin成员

删除:删除成员后,Dataphin将禁止该用户登录,且用户将收不到监控告警消息。建议您先转交需要删除用户账号下的资产。删除成员只是将RAM用户从Dataphin成员列表中移除,并没有删除该RAM用户。如果您已确认不再使用该RAM用户开发数据,您...

实例规格

消息队列 RocketMQ 版 实例按照规格分为企业铂金版和标准版,您可以参照以下版本对比信息,选择所需实例规格。企业铂金版和标准版对比如下表所示:项目 企业铂金版 标准版 付费方式 包年包月(预付费)按量付费(开通服务,默认后付费)...

收到退信怎么处理?

2、件人地址存在或者是书写规范,导致找件地址;3、找到对方服务器(件人域存在);4、件人地址允许接收外域来信;5、对方域名解析稳定,找到对方服务器;如还有其它问题可发送邮件到 alimail_voc@alibaba-inc....

管理Dataphin成员

删除:删除成员后,Dataphin将禁止该用户登录,且用户将收不到监控告警消息。建议您先转交需要删除用户账号下的资产。删除成员只是将RAM用户从Dataphin成员列表中移除,并没有删除该RAM用户。如果您已确认不再使用该RAM用户开发数据,您...

业务开通

填写 基本信息、商户信息、法人信息 等,阅读 并勾选同意,单击 提交。说明 请渠道商务必保证填写信息的正确和有效性,以免影响审核与收款。使用签约的企业支付宝账号登录 支付宝商家中心,在 账号中心>签约管理 界面完成 支付宝单结算...

消费端从服务端拉取消息或拉取消息缓慢

问题现象 Topic中有消息并且Consumer未消费到最新的位置,出现消费端从服务端拉取消息或拉取消息缓慢的情况(特别是公网消费时)。可能原因 可能的原因包括:消费流量达到网络带宽。单个消息大小超过网络带宽。Consumer每次拉取的消息...

消息查询

在使用Kafka的过程中遇到无法正确消费消息消息丢失、消息延迟等消费问题时,您可通过消息查询功能查看指定消息的详细内容和相关属性,帮助您排查异常原因。若确定消息所在Topic的分区ID以及消息位点,可采用按位点查询消息;若确定消息...

消息队列RocketMQ版是否能保证消息不重复?

绝大多数情况下,消息重复的。作为一款分布式消息中间件,在网络抖动、应用处理超时等异常情况下,无法保证消息不重复,但是能保证消息不丢失。

常见问题

客户端报错 使用云消息队列 Kafka 版时客户端的报错及解决方案 使用云消息队列 Kafka 版时出现“Not authorized to access group”的错误信息 网络问题 无法ping通云消息队列 Kafka 版的接入点 在同一可用区内的ECS实例如何访问云消息...

收发定时消息和延时消息

背景信息 定时消息:Producer将消息发送到 云消息队列 RocketMQ 版 服务端,但并期望立马投递这条消息,而是推迟到在当前时间点之后的某一个时间投递到Consumer进行消费,该消息即定时消息。延时消息:Producer将消息发送到 云消息队列 ...

消费重试

修改消息不可见时间需要满足以下条件:消息处理未超时 消息处理未提交消费状态 如下图所示,消息不可见时间修改后立即生效,即从调用API时刻开始,重新计算消息不可见时间。消息重试间隔 消息重试间隔=可见时间-消息实际处理时长 ...

查询消息轨迹

收集疑似有问题的消息信息,包括Message ID、Message Key、Topic以及大概的发送时间。进入 云消息队列 RocketMQ 版 控制台,根据已有的信息创建查询任务,查询相关的消息的轨迹。查看结果并分析判断原因。如果轨迹显示 尚未消费,则可以...

收发事务消息

阿里云上消息轨迹需要设置为CLOUD方式,在使用云上消息轨迹的时候,需要设置此项,如果开启消息轨迹功能,则运行设置此项。transactionMQProducer.setAccessChannel(AccessChannel.CLOUD);transactionMQProducer....

收发顺序消息

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

为什么发送给Topic的消息在分区中分布均衡

问题现象 发送消息到某个Topic后,该Topic下部分分区消息比较多,部分分区...发送消息时指定了消息Key,按照对应的Key发送消息至对应的分区,导致分区消息不均衡。通过代码重新实现了分区分配策略,但策略逻辑有问题,导致分区消息不均衡。

Queue

如果发送消息指定消息延时,被发送到普通队列的消息立刻可以被消费,而发送到延时队列需要经过设定的延时时间后才能被消费。QueueURL 格式:http://$AccountId.mns.<Region>.aliyuncs.com/queues/$QueueName。mns.<Region>.aliyuncs....

消息检索

背景信息消息队列 Kafka 版 消息检索借助 云消息队列 Kafka 版 的Connector功能及表格存储(Tablestore)实现,通过Connector对Topic中的消息进行转储,发送到表格存储中的数据表中,由表格存储索引功能提供消息检索的能力。开通消息...

云端SDK常见问题

或终端SDK发送消息,云端SDK消费消息支持云端SDK发送消息,云端SDK消费消息。终端SDK发送消息,可以使用终端SDK消费,也可以使用云端SDK消费。云端SDK发送消息后,为什么在控制台查询到?暂支持查询云端SDK发送的消息。云端SDK无法...

收发事务消息

class MyLocalTransactionExecuter:LocalTransactionExecuter { MyLocalTransactionExecuter(){ }~MyLocalTransactionExecuter(){ } virtual TransactionStatus execute(Message&value){/消息ID(有可能消息体一样,但消息ID一样,当前...

Topic管理

例如,您需要创建一个Topic用于收发普通消息,则该Topic的消息类型必须为普通消息类型,能选择顺序消息、事务消息等,否则会导致消息收发失败。计费说明 云消息队列 RocketMQ 版 会对已创建的每一个Topic收取Topic资源占用费,即使Topic...

全球消息路由

为加强网络信息安全管理,提高数据安全性,全球消息路由功能支持跨境及跨国传输,具体规则如下:中国内地的各地域之间可以同步消息,中国内地支持和中国香港及海外地区的所有地域同步消息。中国香港地域仅支持在本地域内同步消息...

示例代码

消息队列 RocketMQ 版 5.x版本实例可兼容4.x/3.x SDK客户端接入,您可以使用4.x/3.x版本的SDK接入5.x实例进行消息收发。本文为您介绍4.x/3.x版本下的Java SDK消息收发示例代码。重要 推荐您使用最新的RocketMQ 5.x系列SDK,5.x系列SDK...

消费者分类

背景信息消息队列 RocketMQ 版 面向不同的业务场景提供了不同消费者类型,每种消费者类型的集成方式和控制方式都一样。了解如下问题,可以帮助您选择更匹配业务场景的消费者类型。如何实现并发消费:消费者如何使用并发的多线程机制...

事务消息

消息队列 RocketMQ 版 服务端将消息持久化成功之后,向生产者返回Ack确认消息已经发送成功,此时消息被标记为“暂能投递”,这种状态下的消息即为半事务消息。生产者开始执行本地事务逻辑。生产者根据本地事务执行结果向服务端提交二次...

实例升降配

实例子系列变更 支持 实例变更允许跨子系列,例如:标准版的单节点版实例>专业版的单节点版实例:支持 标准版的单节点版实例>标准版的集群版实例:支持 消息收发计算规格 支持 支持升配和降配。存储规格 涉及 云消息队列 RocketMQ ...

收发事务消息

本文提供使用TCP协议下的.NET SDK收发事务消息的示例代码。目前支持的地域包括公网、华东1(杭州)、华北2(北京)、华东2(上海)、华南1(深圳)。...订阅事务消息 事务消息的订阅与普通消息订阅一致,更多信息,请参见 订阅消息

收发定时消息和延时消息

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

Quick BI订阅选择邮件的方式,件人中搜索到用户

详细信息 创建订阅任务搜索件人。这是因为该用户没有绑定邮箱。使用该用户登录Quick BI,点击头像,选择个人设置。添加邮箱。设置好邮箱后,刷新浏览器,重新设置订阅,就可以选择到该用户。适用于 Quick BI 说明:本文是基于Quick ...

收发普通消息

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

实例规格

客户端可以通过重试避免消息丢失,已经写入成功的消息不受影响。完全独享。磁盘 如果您购买300 GB磁盘,则实际存储业务的磁盘大小为100 GB,其余200 GB为备份容量。如果您购买300 GB磁盘,则实际存储业务的磁盘大小为300 GB,额外赠送600 ...

主题(Topic)

行为约束 消息类型强制校验 云消息队列 RocketMQ 版 5.x版本将消息类型拆分到主题中进行独立运维和处理,因此系统会对发送的消息类型和主题定的消息类型进行强制校验,若校验通过,则消息发送请求会被拒绝,并返回类型匹配异常。...

收发顺序消息

不同消息类型的Topic能混用,例如普通消息的Topic只能用于收发普通消息能用于收发其他类型的消息。final String topic="${TOPIC};Topic所属的实例ID,在消息队列RocketMQ版控制台创建。若实例有命名空间,则实例ID必须传入;若实例无...

TCP协议客户端大版本发布

重要 其他支持地域请勿将Java SDK升级到V2.x.x.Final版本,否则将无法访问 云消息队列 RocketMQ 版 服务。C++ SDK V3.x.x版本支持地域:所有地域均支持。网络限制 Java SDK V2.x.x.Final:仅支持通过VPC网络访问 云消息队列 RocketMQ 版...

普通消息

说明 您在调用SDK收发消息时需注意,云消息队列 RocketMQ 版 提供的四种消息类型所对应的Topic能混用,例如,您创建的普通消息的Topic只能用于收发普通消息能用于收发其他类型的消息;同理,事务消息的Topic也只能收发事务消息能...

版本管理

消息队列 RocketMQ 版 为您提供全托管的版本管理服务,服务端版本更新后,系统会在后台自动完成升级,影响消息收发,业务侧无感知。您可以根据波峰谷时间修改后台升级的执行时间和可维护时间段。使用限制 仅铂金版实例支持版本管理功能...

队列(MessageQueue)

流式操作语义 云消息队列 RocketMQ 版 基于队列的存储模型可确保消息从任意位点读取任意数量的消息,以此实现类似聚合读取、回溯读取等特性,这些特性是RabbitMQ、ActiveMQ等非队列存储模型具备的。模型关系 在整个 云消息队列 RocketMQ ...

收发定时消息和延时消息

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

MQTT快速入门

注意事项 云消息队列 MQTT 版 需搭配后端消息存储队列一起使用,具体说明如下:云消息队列 MQTT 版 实例是一个无状态网关类型实例,用来完成IoT移动场景下的客户端连接维持和消息转发,本身并提供消息数据持久化功能,具体的消息存储和...
共有200条 < 1 2 3 4 ... 200 >
跳转至: GO
产品推荐
云服务器 安全管家服务 安全中心
这些文档可能帮助您
消息服务 云消息队列 Kafka 版 云消息队列 RocketMQ 版 商标服务 弹性公网IP 短信服务
新人特惠 爆款特惠 最新活动 免费试用