如何快速使用消息队列RabbitMQ版的Java SDK收发消息

本文提供使用 云消息队列 RabbitMQ 版 的Java SDK收发消息的快速入门视频。

如何快速使用微消息队列MQTT版的Java SDK收发消息?

本文提供使用 微消息队列MQTT版 的Java SDK收发消息的快速入门视频。

如何快速使用消息队列RocketMQ版的TCP Java SDK收发...

本文提供使用 消息队列RocketMQ版 的TCP Java SDK收发消息的快速入门视频。

如何快速使用云消息队列 Kafka 版的Java SDK收发消息

六分钟上手 云消息队列 Kafka 版。文档教程 快速入门

准备环境

使用Java SDK收发消息前,您需按照本文提供的内容来准备环境。环境要求 安装JDK 1.6或以上版本。更多信息,请参见 安装JDK。安装Maven。更多信息,请参见 安装Maven。安装Java SDK 通过Maven方式引入依赖,在 pom.xml 中添加以下依赖。...

概述

本文介绍使用社区版TCP协议的Java SDK访问阿里云 云消息队列 RocketMQ 版 来收发消息的流程。使用说明 社区版SDK仅在开源RocketMQ迁移上云且不希望修改代码时使用,其他场景推荐您使用阿里云 云消息队列 RocketMQ 版 提供的商业版SDK进行接...

MQTT和RocketMQ进行数据互通(客户端上下线通知)

MQTT客户端的上下线事件将会触发MQTT服务端生成一条通知消息,云消息队列 MQTT 版 支持将该条消息数据导出至其他阿里云产品,并使用MQTT的Java SDK实现MQTT客户端与后端应用收发消息。本文以当前仅支持的 云消息队列 RocketMQ 版 数据互通...

收发事务消息

本文提供使用TCP协议下的Java SDK收发事务消息的示例代码。云消息队列 RocketMQ 版 提供类似XA或Open XA的分布式事务功能,通过 云消息队列 RocketMQ 版 事务消息,能达到分布式事务的最终一致。说明 对于新手用户,建议在正式收发消息前,...

收发顺序消息

本文提供使用TCP协议下的Java SDK收发顺序消息的示例代码。前提条件 您已完成以下操作:下载1.2.7或以上版本的Java SDK。更多信息,请参见Java SDK 版本说明。准备环境。更多信息,请参见 准备环境。(可选)日志配置。更多信息,请参见 ...

收发普通消息

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

收发延时消息

本文提供使用TCP协议下的Java SDK收发延时消息的示例代码供您参考。前提条件 您已完成以下操作:安装Java SDK。更多信息,请参见 准备环境。创建资源。代码中涉及的资源信息,例如实例、Topic和Group ID等,需要在控制台上提前创建。更多...

收发定时消息

本文提供使用TCP协议下的Java SDK收发定时消息的示例代码。背景信息 定时消息可以做到在指定时间戳之后才可被消费者消费,适用于对消息生产和消费有时间窗口要求,或者利用消息触发定时任务的场景。定时消息的概念介绍及使用过程中的注意...

查看实例风险

消费流量 Group与Topic的订阅关系 服务端小版本升级 消费位点提交频率 存在Rebalance的Group 消费客户端主动离开队列 使用Sarama Go客户端 操作步骤 登录 云消息队列 Kafka 版 控制台,在 概览 页面的 资源分布 区域,选择地域。...

消费者负载均衡

} 队列粒度负载均衡 使用范围 对于历史版本(服务端4.x/3.x版本)的消费者,包括PullConsumer、DefaultPushConsumer、DefaultPullConsumer、LitePullConsumer等,默认且仅能使用队列粒度负载均衡策略。策略原理 队列粒度负载均衡策略中,同...

MQTT快速入门

作为使用和熟悉产品功能的入门指导,本文提供如何快速使用 云消息队列 MQTT 版 通过默认支持的MQTT协议收发消息的步骤。对于非MQTT协议的接入,例如新能源,您必须首先购买 云消息队列 MQTT 版 企业铂金版,并通过专属通道享受对应的文档和...

SDK FAQ

本文记录通过SDK收发消息时常见的问题。开源客户端是否可以直接访问云上服务?云消息队列 RabbitMQ 版 完全兼容开源...您可以使用Java客户端库中 queuePurge 方法删除某个队列的所有消息。示例代码如下:channel.queuePurge("queue-name");

概述

本文旨在以简单明了的方式引导您快速上手 云消息队列 Kafka 版。操作流程 根据网络类型不同,快速入门的操作流程有所不同,详情请参见 云消息队列 Kafka 版快速入门操作流程。...如何快速使用云消息队列 Kafka 版的Java SDK收发消息

消息收发功能

本文提供单独使用 云消息队列 MQTT 版 收发消息以及与 云消息队列 RocketMQ 版 结合使用时需使用的代码示例的链接。单独使用 云消息队列 MQTT 版 收发消息 语言 链接 Java ...

快速使用MQTT的Java SDK收发消息(终端和终端消息收发...

本文以公网环境为例,说明如何使用Java SDK完成消息收发。接入点说明 终端和云端服务与 云消息队列 MQTT 版 通信时,需要在各自的SDK代码中设置 云消息队列 MQTT 版 实例的接入点信息,通过接入点和 云消息队列 MQTT 版 服务端连接。终端...

快速使用MQTT的Java SDK收发消息(终端和云端消息收发...

本文以公网环境为例,介绍使用Java SDK实现消息收发。更多消息收发示例代码,请参见 终端Demo工程 或 云端Demo工程。接入点说明 终端和云端服务与 云消息队列 MQTT 版 通信时,需要在各自的SDK代码中设置 云消息队列 MQTT 版 实例的接入点...

删除队列消息

本文介绍如何删除某个队列的所有消息。您可以使用Java客户端库中 queuePurge 方法删除某个队列的所有消息。示例代码如下:channel.queuePurge("queue-name");

消息堆积和延迟问题

本文主要介绍 云消息队列 RocketMQ 版 TCP协议的Java客户端使用过程中,经常会出现的消息堆积和消息延迟的问题。通过了解 云消息队列 RocketMQ 版 客户端的消费原理和消息堆积的主要原因,帮助您可以在业务部署前更好的规划资源和配置,或...

视频专区

本文为您介绍 云消息队列 RocketMQ 版 的操作视频。云消息队列 RocketMQ 版5.x系列 快速使用 云消息队列 RocketMQ 版5.x系列的Java SDK收发消息 云消息队列 RocketMQ 版4.x系列 快速使用云消息队列 RocketMQ 版4.x系列的Java SDK收发消息

参数说明

本文介绍您在使用社区版Java SDK接入阿里云 云消息队列 RocketMQ 版 时,需要配置的参数。通用参数 参数名 参数说明 NAMESRV_ADDR 设置TCP协议接入点,从 云消息队列 RocketMQ 版 控制台 的 实例详情 页面获取。AccessKey AccessKey ID,...

开通服务并授权

在阿里云官方网站开通消息队列服务后方可开始使用 云消息队列 MQTT 版。如果您的账号为RAM用户,必须先为RAM用户进行授权,才能通过控制台或API访问相应的 云消息队列 MQTT 版 资源,并使用SDK收发消息。前提条件 您已注册阿里云账号并完成...

获取SDK

本文介绍如何获取和使用...语言 下载地址 说明文档 Java Alibaba Cloud AMQP SDK for Java 开始使用 Go Alibaba Cloud AMQP SDK for Go 开始使用 Python Alibaba Cloud AMQP SDK for Python 开始使用 PHP Alibaba Cloud AMQP for PHP 开始使用

SSL接入点PLAIN机制收发消息

本文以Java SDK为例介绍如何在公网环境下使用SDK接入 云消息队列 Kafka 版 的SSL接入点并使用PLAIN机制收发消息。前提条件 步骤三:创建资源 安装1.8或以上版本JDK 安装2.5或以上版本Maven 安装Java依赖库 在 pom.xml 中添加以下依赖。...

Spring集成

云消息队列 RocketMQ 版 支持集成Spring框架的Java SDK收发消息,本文为您介绍如何使用 云消息队列 RocketMQ 版 提供的Spring框架的Demo工程。背景信息 云消息队列 RocketMQ 版 支持以下消息类型的生产者和消费者与Spring集成:普通消息的...

日志配置

Java SDK 1.7.8.Final及以上版本:默认支持,无需设置 云消息队列 RocketMQ 版 的Java SDK 1.7.8.Final已内置了日志实现,您无需在客户端应用中添加日志实现依赖即可打印 云消息队列 RocketMQ 版 的客户端日志。针对Java SDK 1.7.8.Final...

生产者负载均衡

生产者发送消息到 云消息队列 RocketMQ 版 服务端时,云消息队列 RocketMQ 版 将根据生产者负载均衡策略将消息均匀的存储在多个队列中,避免产生热点队列和性能瓶颈。本文介绍 云消息队列 RocketMQ 版 生产者的负载均衡策略。背景信息 了解...

快速入门概述

云消息队列 MQTT 版 支持使用多种...调用SDK收发消息 快速使用MQTT的Java SDK收发消息(终端和终端消息收发)快速使用MQTT的Java SDK收发消息(终端和云端消息收发)操作视频 该视频以终端和终端交互流程为例演示如何使用Java SDK收发消息。

接口和参数说明

本文介绍 云消息队列 MQTT 版 云端Java SDK提供的接口和相关的参数说明。使用说明 公共参数和网络参数可在 ChannelConfig.class 中设置。ChannelConfig.class 路径为 server-sdk-{SDK Version}\com\alibaba\mqtt\server\config ,其中 {SDK...

消息队列Kafka版删除Group后仍然收到消息堆积的告警...

问题描述 使用阿里云消息队列Kafka版时,删除Group后,仍然收到消息堆积的告警信息,如何过滤某个Group的消费堆积告警。问题原因 发生消息堆积告警信息的原因如下:2.2.0以前的Kafka服务端版本,开源Kafka未提供删除Group和消费位点的Open...

服务端订阅(MNS)

准备开发环境,本示例使用Java开发环境如下:操作系统:Windows 10 64位 JDK版本:JDK8 集成开发环境:IntelliJ IDEA社区版 背景信息 数据流转流程如下图所示。配置服务端订阅 首先在物联网平台控制台创建MNS服务端订阅,选择要订阅的消息...

版本说明

推荐版本 云消息队列 RocketMQ 版 支持使用Apache RocketMQ开源SDK访问。同时支持以下历史版本:rocketmq-client 5.x版本 rocketmq-client 4.x版本 rocketmq-client 3.x版本 推荐您使用Apache RocketMQ 5.x版本的SDK获取更高的性能和更全面...

概述

本文介绍使用RocketMQ 4.x/3.x系列的Java SDK访问阿里云 云消息队列 RocketMQ 版 实例收发消息的流程。重要 推荐您使用最新的RocketMQ 5.x系列SDK,5.x系列SDK作为主力研发版本,和 云消息队列 RocketMQ 版 5...使用Java SDK收发消息 示例代码

TCP协议客户端大版本发布

重要 若您使用存量 云消息队列 RocketMQ 版 实例并通过经典网络访问,请勿将Java SDK升级到V2.x.x.Final版本,否则将无法访问 云消息队列 RocketMQ 版 实例。C++ SDK V3.x.x:无网络限制。实例命名空间限制 Java SDK 2.x.x.Final:仅支持有...

版本说明

若您使用存量 云消息队列 RocketMQ 版 实例并通过经典网络访问,请勿将Java SDK升级到V2.x.x.Final版本,否则将无法访问 云消息队列 RocketMQ 版 实例。Java SDK 2.x.x.Final仅支持有命名空间的实例,若您使用的实例无命名空间,请勿将客户...

基本概念

本文主要对 云消息队列 RocketMQ 版 涉及的专有名词及术语进行定义和解析,方便您更好地理解相关概念并使用 云消息队列 RocketMQ 版。Topic 消息主题,一级消息类型,通过Topic对消息进行分类。更多信息,请参见 Topic与Tag最佳实践。消息...

常见问题

本文汇总了使用 云消息队列 Kafka 版 实例时的常见问题。计费问题 为什么购买了按量付费实例后不使用也要收费?为什么按流量峰值收费?按流量峰值收费的依据是什么?为什么额外增加分区要收费?我使用的Connector组件如何计费?客户端报错 ...
共有200条 < 1 2 3 4 ... 200 >
跳转至: GO
产品推荐
云服务器 安全管家服务 安全中心
这些文档可能帮助您
云消息队列 RocketMQ 版 云消息队列 Kafka 版 阿里邮箱 商标服务 弹性公网IP 短信服务
新人特惠 爆款特惠 最新活动 免费试用