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

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

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

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

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

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

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

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

订阅消息

本文介绍如何通过 SOFAStack 消息队列Java SDK 订阅消息。订阅方式 消息队列支持以下两种订阅方式:集群订阅同一个 Group ID 所标识的所有 Consumer 平均分摊消费消息。例如某个 Topic 有 9 条消息,一个 Group ID 有 3 个 Consumer ...

订阅消息

本文介绍如何通过 云消息队列 RocketMQ 版 的Java SDK订阅消息。订阅方式 云消息队列 RocketMQ 版 支持以下两种订阅方式:集群订阅 同一个Group ID所标识的所有Consumer平均分摊消费消息。例如某个Topic有9条消息,一个Group ID有3个...

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

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

概述

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

接口和参数说明

消息队列 RocketMQ 版 提供Java SDK实现消息发送与订阅,订阅方可通过Push或Pull的方式从 云消息队列 RocketMQ 版 获取消息。本文介绍消息发送和订阅的接口和参数说明。背景信息 云消息队列 RocketMQ 版 支持以下两种消息获取方式:Push...

接口和参数说明

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

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

本文介绍如何快速使用 云消息队列 MQTT 版 的Java SDK实现MQTT终端与终端消息的收发。前提条件 创建资源 获取AccessKey 安装 IDE。您可以使用IntelliJ IDEA或者Eclipse,本文以IntelliJ IDEA为例。下载安装 JDK。背景信息 云消息队列 MQTT ...

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

本文介绍如何快速使用 云消息队列 MQTT 版 的Java SDK实现MQTT终端和云端服务的消息收发。前提条件 创建资源 获取AccessKey 安装 IDE。您可以使用IntelliJ IDEA或者Eclipse,本文以IntelliJ IDEA为例。下载安装 JDK。背景信息 MQTT终端和...

概述

本文介绍使用RocketMQ 4.x/3.x系列的Java SDK访问阿里云 云消息队列 RocketMQ 版 实例收发消息的流程。重要 推荐您使用最新的RocketMQ 5.x系列SDK,5.x系列SDK作为主力研发版本,和 云消息队列 RocketMQ 版 5.x服务端完全兼容,提供了更...

并发测试示例代码

本文介绍基于Java SDK提供的队列消息发送以及消费的并发测试用例。在并发测试中,您可以:指定并发度、运行时间。通过发送总请求数除以运行时间计算得到QPS。步骤一:初始化 在运行目录创建 perf_test_config.properties 文件,按照如下...

版本说明

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

版本说明

本文介绍 云消息队列 MQTT 版 提供的云端Java SDK的版本信息,包括发布时间、版本号、下载链接及发布说明等。说明 建议您使用最新版本的SDK,以获取更高的性能和更全面的能力。Maven依赖<dependency><groupId>...

收发事务消息

消息队列 RocketMQ 版 提供类似XA或Open XA的分布式事务功能,通过 云消息队列 RocketMQ 版 事务消息,能达到分布式事务的最终一致。说明 对于新手用户,建议在正式收发消息前,阅读 Demo工程 来了解搭建 云消息队列 RocketMQ 版 工程的...

参数说明

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

发布者最佳实践

本文介绍 云消息队列 Kafka 版 发布者的最佳实践,帮助您降低发送消息的错误率。本文最佳实践基于Java客户端。对于其他语言的客户端,其基本概念与思想是相通的,但实现细节可能存在差异。发送消息 发送消息的示例代码如下:Future...

示例代码

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

消息收发功能

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

示例代码

消息类型 发送消息示例代码 订阅消息示例代码 PushConsumer SimpleConsumer 普通消息 同步发送:ProducerNormalMessageExample.java 异步发送:AsyncProducerExample.java PushConsumerExample.java 同步订阅:SimpleConsumerExample.java ...

准备工作

重要 推荐您使用最新的RocketMQ 5.x系列SDK,5.x系列SDK作为主力研发版本,和 云消息队列 RocketMQ 版 5.x服务端完全兼容,提供了更全面的功能并支持更多增强特性。更多信息,请参见 5.x系列SDK。RocketMQ 4.x/3.x系列SDK和ONS系列SDK后续...

收发定时消息

说明 对于新手用户,建议在正式收发消息前,阅读 Demo工程 来了解搭建 云消息队列 RocketMQ 版 工程的具体步骤。前提条件 您已完成以下操作:安装Java SDK。更多信息,请参见 准备环境。创建资源。代码中涉及的资源信息,例如实例、Topic和...

SSL接入点PLAIN机制收发消息

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

收发顺序消息

顺序消息(FIFO消息)是 云消息队列 RocketMQ 版 提供的一种严格按照顺序来发布和消费的消息类型。本文提供使用TCP协议下的Java SDK收发顺序消息的示例代码。前提条件 您已完成以下操作:下载1.2.7或以上版本的Java SDK。更多信息,请参见...

步骤三:调用SDK收发消息

消息队列 RocketMQ 版 提供多种语言的SDK用于收发不同类型的消息,本文以Java SDK为例,说明如何调用SDK连接 云消息队列 RocketMQ 版 服务端,完成普通消息的收发流程。前提条件 步骤二:创建资源 安装IDEA 您可以使用IntelliJ IDEA或者...

收发定时消息和延时消息

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

收发普通消息

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

准备工作

重要 推荐您使用最新的RocketMQ 5.x系列SDK,5.x系列SDK作为主力研发版本,和 云消息队列 RocketMQ 版 5.x服务端完全兼容,提供了更全面的功能并支持更多增强特性。更多信息,请参见 5.x系列SDK。RocketMQ 4.x/3.x系列SDK和ONS系列SDK后续...

收发事务消息

消息队列 RocketMQ 版 提供类似XA或Open XA的分布式事务功能,通过 云消息队列 RocketMQ 版 事务消息,能达到分布式事务的最终一致。本文提供使用HTTP协议下的Java SDK收发事务消息的示例代码。背景信息 事务消息的交互流程如下图所示。...

版本说明

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

收发延时消息

背景信息 延时消息用于指定消息发送到 云消息队列 RocketMQ 版 的服务端后,延时一段时间才被投递到客户端进行消费(例如3秒后才被消费),适用于解决一些消息生产和消费有时间窗口要求的场景,或者通过消息触发延迟任务的场景,类似于延迟...

收发顺序消息

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

收发定时消息和延时消息

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

默认接入点收发消息

本文以Java SDK为例介绍如何在VPC环境下使用SDK接入 云消息队列 Kafka 版 的默认接入点并收发消息。前提条件 步骤三:创建资源 安装1.8或以上版本JDK 安装2.5或以上版本Maven 安装编译工具。本文以 IntelliJ IDEA Ultimate 为例。安装Java...

队列使用手册

本文介绍如何使用Java SDK中的Sample,完成创建队列、发送消息、接收和删除消息、以及删除队列。步骤一:准备工作 下载最新版Java SDK,解压到 aliyun-sdk-mns-samples 文件夹。用Eclipse导入Maven工程,选择 aliyun-sdk-mns-samples 文件...

收发顺序消息

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

收发事务消息

LocalTransactionState.UNKNOW:无法判断状态,期待阿里云 云消息队列 RocketMQ 版 的Broker向发送方再次询问该消息对应的本地事务的状态。import org.apache.rocketmq.client.producer.LocalTransactionState;import org.apache.rocketmq....

准备环境

在使用Java SDK收发消息前,您需按照本文提供的内容来准备环境。环境要求 安装JDK 1.6或以上版本。更多信息,请参见 安装JDK。安装Maven。更多信息,请参见 安装Maven。安装Java SDK 通过Maven方式引入依赖,在 pom.xml 中添加以下依赖。...
共有200条 < 1 2 3 4 ... 200 >
跳转至: GO
产品推荐
云服务器 安全管家服务 安全中心
这些文档可能帮助您
云消息队列 RocketMQ 版 云消息队列 Kafka 版 全局事务服务 (文档停止维护) 弹性公网IP 短信服务 人工智能平台 PAI
新人特惠 爆款特惠 最新活动 免费试用