为什么不推荐使用Sarama Go客户端收发消息

当Sarama Go客户端同时订阅两个以上的Topic时,有可能会导致部分分区无法正常消费消息。当Sarama Go客户端的消费位点重置策略设置为Oldest(earliest)时,如果客户端宕机或服务端版本升级,由于Sarama Go客户端自行实现OutOfRange机制,有...

消息服务MNS

阿里云消息服务MNS(Message Service)是一种高效、可靠、安全、便捷、可弹性扩展的分布式消息服务。MNS能够帮助应用开发者在他们应用的分布式组件上自由的传递数据、通知消息,构建松耦合系统。

消息队列RabbitMQ版

消息队列RabbitMQ版是阿里云消息队列(MQ)团队基于AMQP 0-9-1协议研发的分布式、高吞吐、低延迟、高可扩展的云消息队列服务。消息队列RabbitMQ版完全兼容开源RabbitMQ社区、开箱即用、无需部署、免运维,帮助您快速上云。

消息队列RocketMQ版

消息队列RocketMQ版(原名开放消息服务,简称ONS)是阿里云基于Apache RocketMQ构建的低延迟、高并发、高可用、高可靠的分布式消息中间件。

消息队列Kafka版

消息队列Kafka版(MQ for Apache Kafka)秉持开放的原则拥抱开源,全面融合Kafka开源生态,做到无缝迁移,打造更安全、更可靠、更易运维的Kafka企业级消息服务。

消息队列MQTT版

消息队列MQTT版广泛应用移动互联网以及物联网领域,覆盖互动直播、车联网、金融支付、智能餐饮、即时聊天、移动App等多种应用场景。

智能推荐

智能推荐(AIRec)基于阿里巴巴领先的大数据和人工智能技术,结合在电商、内容、新闻资讯、视频直播和社交等多个行业领域的积累,为全球企业及开发者提供个性化推荐服务。

查询消息

背景信息 您可根据具体情况按以下推荐方式查询消息:如果您确定消息所在Topic的分区ID以及消息位点,则推荐您使用按位点查询消息。位点的相关概念,请参见名词解释。如果您不确定消息的位置,但确定消息发送的时间段,则推荐您使用按时间...

消息查询

推荐查询过程 推荐按照以下流程查询消息。操作步骤 登录消息队列RocketMQ版控制台。在左侧导航栏,单击实例列表。在顶部菜单栏,选择地域,如华东1(杭州)。在实例列表页面,找到目标实例,在其操作列,单击更多,然后在下拉菜单中,选择...

收发事务消息

如果要求消息绝对不重复,推荐做法是对消息体body使用crc32或MD5来防止重复消息。TransactionStatus transactionStatus=Unknow;try { boolean isCommit=本地事务执行结果;if(isCommit){/本地事务成功、提交消息。transactionStatus=...

查询消息轨迹

消息轨迹是指一条消息从生产者发送到消息队列RocketMQ版服务端,再到消费者消费处理,整个过程中的各个相关节点的时间、状态等数据汇聚而成的完整链路信息。该轨迹可作为生产环境中排查问题强有力的数据支持。本文介绍消息轨迹的使用场景、...

收发事务消息

如果要求消息绝对不重复,推荐做法是对消息体body使用crc32或MD5来防止重复消息。TransactionStatus transactionStatus=TransactionStatus.Unknow;try { boolean isCommit=本地事务执行结果;if(isCommit){/本地事务成功则提交消息。...

MQTT与RocketMQ的应用场景对比

选型推荐 场景 部署端 微消息队列MQTT版 消息队列RocketMQ版 设备端上报状态数据 移动终端√接收并处理分析设备的上报数据 移动终端×对多个设备下发控制指令 服务器×直播、弹幕、聊天App收发消息 应用√服务端接收并分析聊天消息 服务器...

收发事务消息

如果要求消息绝对不重复,推荐做法是对消息体使用crc32或MD5来防止重复消息。Object businessServiceArgs=new Object();TransactionStatus transactionStatus=TransactionStatus.Unknow;try { boolean isCommit=businessService....

延时消息

原生延时消息方案(推荐)✖ ✔️ 原生延时消息方案 消息队列RabbitMQ版通过对消息设置delay来实现延时效果。消息队列RabbitMQ版原生延时消息的流转过程如下:生产者向Exchange发布设置了delay的消息。Exchange将消息路由至Queue。在设置的...

迁移概述

根据推荐意见,购买并部署消息队列Kafka版实例。迁移自建Kafka集群的Topic到消息队列Kafka版实例。详情请参见迁移Topic上云。迁移自建Kafka集群的Group到消息队列Kafka版实例。详情请参见迁移Group上云。可选:迁移自建Kafka集群的数据到...

消息重试

消息投递失败后需要重试集群消费模式下,消息消费失败后期望消息重试,需要在消息监听器接口的实现中明确进行配置(三种方式任选一种):方式1:返回Action.ReconsumeLater(推荐)方式2:返回Null 方式3:抛出异常 示例代码public class ...

名词解释

消息堆积 Producer已经将消息发送到消息队列RocketMQ版的服务端,但由于Consumer消费能力有限,未能在短时间内将所有消息正确消费掉,此时在消息队列RocketMQ版的服务端保存着未被消费的消息,该状态即消息堆积。消息过滤 Consumer可以根据...

顺序消息1.0

顺序消息可以保证消息的消费顺序和发送的顺序一致,即先发送的先消费,后发送的后消费,常用于金融证券、电商业务等对消息指令顺序有严格要求的场景。本文介绍消息队列RocketMQ版顺序消息1.0的概念、适用场景、实现原理以及使用过程中的...

死信队列

死信队列用于处理无法被正常消费的消息,即死信消息。本文介绍如何查询、导出和重新发送进入死信队列的死信消息,以便您按需管理死信消息,避免消息漏处理。背景信息 当一条消息初次消费失败,消息队列RocketMQ版会自动进行消息重试,达到...

顺序消息2.0

消息消费即使同一逻辑分区的消息被存储在不同的物理分区中且没有保持消息的顺序,但是基于顺序消息2.0的保序协议,消息队列RocketMQ版服务端在投递消息时,最终还是会按照消息在逻辑队列中存储的顺序投递给Consumer,Consumer消费消息时,...

过滤消息

本文介绍消息服务MNS如何通过消息过滤标签把消息推送到不同的推送目标。背景信息 通常情况下,在主题中创建订阅消息服务MNS可以把消息推送到订阅的推送目标。即消息和订阅没有设置消息过滤标签,所有消息都可以被成功推送到推送目标。使用...

概述

使用说明 社区版SDK仅在开源RocketMQ迁移上云且不希望修改代码时使用,其他场景推荐您使用阿里云消息队列RocketMQ版提供的商业版SDK进行接入。和社区版SDK相比,商业版SDK提供了更加丰富的功能特性并具有更高的稳定性保障。更多信息,请...

事务消息

半事务消息:暂不能投递的消息,发送方已经成功地将消息发送到了消息队列RocketMQ版服务端,但是服务端未收到生产者对该消息的二次确认,此时该消息被标记成“暂不能投递”状态,处于该种状态下的消息即半事务消息消息回查:由于网络闪断...

消息收发流程变更

消息队列MQTT版V2.x.x版本强依赖消息队列RocketMQ版作为消息存储,因此微消息队列MQTT版消息消息队列RocketMQ版天然打通,创建了Topic后即可天然使用消息队列RocketMQ版和微消息队列MQTT版的SDK相互通信。微消息队列MQTT版V3.x.x版本...

长轮询

LongPolling是消息服务MNS的推荐用法。LongPolling参数设置,请参见ReceiveMessage。LongPolling需要HTTP层的长连接保持在服务器上,而对于服务器来说,HTTP层的长连接的资源是有限的。为了避免受到恶意攻击,消息服务MNS对单用户的每个...

功能与特性概述

消息类型 普通消息消息队列RocketMQ版中无特性的消息,区别于有特性的定时和延时消息、顺序消息和事务消息。事务消息:实现类似XA或Open XA的分布事务功能,以达到事务最终一致性状态。定时和延时消息:允许消息生产者对指定消息进行定时...

名词解释

如需实现消息幂等,即如果消息重试多次,消费端对该重复消息消费多次与消费一次的结果是相同的,并且多次消费没有对系统产生副作用,在为每条消息设置唯一Message ID的基础上,您还需要在消息队列RabbitMQ版的Consumer客户端对消息进行幂等...

MQTT快速入门

注意事项 微消息队列MQTT版需搭配后端消息存储队列一起使用,具体说明如下:微消息队列MQTT版实例是一个无状态网关类型实例,用来完成IoT移动场景下的客户端连接维持和消息转发,本身并不提供消息数据持久化功能,具体的消息存储和消息数据...

定时和延时消息

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

Demo工程

针对初次接触消息队列RocketMQ版的工程师,本文以TCP协议下的Java为例,提供操作示例帮助您从零开始搭建消息队列RocketMQ版测试工程。Demo工程包含普通消息、顺序消息、事务消息、定时和延时消息的测试代码,以及相关Spring的配置。前提...

队列模型名词解释

本文对消息服务MNS的队列模型涉及的专有名词及术语进行定义和解析,方便您更好地理解相关概念并使用队列模型。Account 用户的阿里云账号ID。队列(Queue)消息存储的目的地,分成普通队列和延时队列两类。消息包含数据和属性,可以分成普通...

收发普通消息

普通消息是指消息队列RocketMQ版中无特性的消息,区别于有特性的定时和延时消息、顺序消息和事务消息。不同消息类型所属的Topic不能混用,例如收发普通消息的Topic不能用来收发其他类型的消息。本文提供使用TCP协议下的C/C++ SDK收发普通...

QueueMessage

本文介绍队列消息消息属性、消息类型、消息状态。队列消息 用户发送消息到队列。发送消息时可以指定消息体、消息延时时长、消息优先级。消息属性 MessageId 消息编号。(batch)send message、receive message和peek message操作返回该...

普通消息

普通消息是指消息队列RocketMQ版中无特性的消息,区别于有特性的定时和延时消息、顺序消息和事务消息。说明 您在调用SDK收发消息时需注意,消息队列RocketMQ版提供的四种消息类型所对应的Topic不能混用,例如,您创建的普通消息的Topic只能...

直播互动解决方案

本文以单直播间、一名老师、两名学生的场景为例,说明如何使用微消息队列MQTT版实现直播互动消息、禁言、成员上下线通知以及系统消息通知,其中,老师和学生的客户端以HTML网页为例,后端应用以Java为例。背景信息 在直播互动的场景下,您...

什么是消息服务MNS

消息投递 消息服务MNS支持消息推送到队列:推送到队列 广播拉取消息模型 消息投递保障 在消息有效期内,保证发布到主题中的消息会按照指定的策略和格式推送给用户端程序。推送策略包括:退避重试(BACKOFF_RETRY)重试3次。每次重试的间隔...

事务消息

本文介绍如何使用消息服务MNS的延时消息功能,实现本地操作和消息发送的事务一致性。前提条件 您已创建以下队列,具体操作,请参见创建队列。事务消息队列 消息存活时间小于消息延时时间。当消息发送成功、事务操作成功时,生产者修改消息...

常见问题

消费者(订阅者)的最佳实践 客户端首次接入消息队列Kafka版时出现异常的排查方法 使用消息队列Kafka版时出现消息堆积 使用消息队列Kafka版时消费客户端频繁出现Rebalance 消费端从服务端拉取不到消息或者拉取消息缓慢 为什么不推荐使用...

直播互动解决方案

本文以单直播间、一名老师、两名学生的场景为例,说明如何使用微消息队列MQTT版实现直播互动消息、禁言、成员上下线通知以及系统消息通知,其中,老师和学生的客户端以HTML网页为例,后端应用以Java为例。背景信息 使用微消息队列MQTT版需...
< 1 2 3 4 ... 200 >
跳转至: GO
产品推荐
云服务器 物联网无线连接服务 商标 轻量应用服务器 SSL证书 短信服务 对象存储
这些文档可能帮助您
什么是消息队列Kafka版? 什么是消息服务MNS 发送普通消息(三种方式) Java SDK版本说明 Demo工程 订阅关系一致

新品推荐

你可能感兴趣

热门推荐

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