Java中的阻塞队列-Java中的阻塞队列文档介绍内容-阿里云

接口和参数说明

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

版本说明

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

消息负载均衡策略

消费者负载均衡策略无序消息：云消息队列 RocketMQ 版 Broker按照消息维度将Topic中的所有消息平均分配给消费者集群中的多个消费者处理。客户端Java v2.x.x.Final和C++ v3.x.x版本的负载均衡不再按照Queue维度消费，同一Queue的消息可以被...

示例代码

云消息队列 RocketMQ 版时，需要保证使用的SDK版本满足以下要求，并在消息收发代码中补充如下内容：说明其中，InstanceId 需要替换为您实际使用的实例ID。SDK版本：rocketmq-client≥5.2.0 消息发送代码补充：producer.setNamespaceV2(...

Spring集成

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

签名鉴权模式

HMAC-SHA1的算法实现，Java SDK可以参见 Demo工程中的 ConnectionOptionWrapper 和 Tools 类的示例代码。其他语言都有现成的函数库，请自行搜索。使用控制台验证签名云消息队列 MQTT 版控制台提供了签名计算工具，以方便您比对验证自己...

主题（Topic）

本文介绍云消息队列 RocketMQ 版中主题（Topic）的定义、模型关系、内部属性、行为约束、版本兼容性及使用建议。定义主题是云消息队列 RocketMQ 版中消息传输和存储的顶层容器，用于标识同一类业务逻辑的消息。主题的作用主要如下：...

收发定时消息

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

开发参考

本文介绍云消息队列 RocketMQ 版的SDK和API的支持情况，供您进行对应的开发操作。云消息队列 RocketMQ 版消息收发需要通过调用SDK完成，云消息队列 RocketMQ 版的SDK支持Java、C++、.NET、Go等多语言开发。SDK参考提供了各语言的SDK的...

版本说明

本文介绍HTTP协议下Java SDK的版本信息，包括各版本的发布时间、发布内容以及下载链接，以便您按需获取适用的Java SDK收发消息。重要获取Maven依赖，请参见准备环境。1.0.3.2 发布时间发布内容下载 2021-12-24 功能优化去除Log4j依赖...

收发普通消息

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

RAM鉴权

云消息队列 MQTT 版的Resource与Action的对应规则在云消息队列 MQTT 版中，实例、Topic、Group和规则各为一种Resource，对这些Resource授予的权限即为Action。可授权的云消息队列 MQTT 版 OpenAPI 下表列举了云消息队列 MQTT 版中可...

权限策略

本文介绍云消息队列 MQTT 版在RAM中的权限策略。在RAM中，权限策略是用语法结构描述的一组权限的集合，可以精确地描述被授权的Resource（资源集）、Action（操作集）以及授权条件。云消息队列 MQTT 版有以下两类RAM的权限策略：系统...

YARN指标

Capacity UsedCapacity yarn_resourcemanager_queue_usedCapacity ResourceManager Capacity调度器特定队列在父队列中使用的capacity。单位：%。Capacity AbsoluteUsedCapacity yarn_resourcemanager_queue_absoluteUsedCapacity ...

工作队列

步骤8 测试示例说明 CLI命令行输入：workqueue_example 说明关键日志：WORK 0-WORK 1-WORK 1-WORK 2-WORK 4-WORK 3-WORK 6-WORK 5-注意事项当work延时参数为0时，调用aos_work_run()触发多次，则会在对应工作队列中会被执行多次；...

使用实例接入点收发消息

java.security.auth.login.config JAAS配置文件所在路径，将Demo工程中的kafka_client_jaas.conf文件另存至本地路径，用本地路径替换示例代码中的xxxx。例如：/home/ssl/kafka_client_jaas.conf。重要如果是默认接入点实例，该参数不需要...

使用限制

本文为您介绍云消息队列 MQTT 版对某些具体指标的约束和规范，您在使用云消息队列 MQTT 版时请不要超过相应的限制值，以免程序出现异常。具体的限制项和限制值请参见下表。如果您购买了铂金版的云消息队列 MQTT 版实例，则可按需定制...

使用ACL功能进行访问控制

背景信息企业A购买了云消息队列 Kafka 版，企业A希望用户A只能从云消息队列 Kafka 版的所有Topic中消费消息，而不能向云消息队列 Kafka 版的任何Topic生产消息。注意事项 Kafka为公网/VPC类型实例提供默认SASL用户，默认SASL用户仅...

功能发布列表

IP白名单：控制仅在白名单中的客户端拥有访问云消息队列 RocketMQ 版指定实例的权限。身份识别：控制客户端是否能接入指定云消息队列 RocketMQ 版实例；以及是否对实例下的指定Topic或Group有发布订阅权限。新增访问控制概述 IP白名单...

功能与特性概述

本文列举云消息队列 RocketMQ 版所支持的所有功能与特性。概览云消息队列 RocketMQ 版在阿里云多个地域（Region）提供了高可用消息云服务。单个地域内采用多机房部署，可用性极高，即使整个机房都不可用，仍然可以为应用提供消息发布...

开源SDK接入（跨云账号授权）

本文以调用Java SDK为例，介绍在RAM角色跨账号授权场景，通过开源SDK实现消息收发的操作过程，帮助您更好地理解消息收发的完整过程，其他语言或框架的SDK消息收发过程相似。前提条件创建实例创建Vhost 背景信息当您需要通过RAM STS角色...

消费者（Consumer）

消息按照到达云消息队列 RocketMQ 版服务端的顺序存储到主题的指定队列中。消费者按照指定的订阅关系从云消息队列 RocketMQ 版服务端中获取消息并消费。内部属性消费者分组名称定义：当前消费者关联的消费者分组名称，消费者必须关联...

迁移元数据上云

云消息队列 RabbitMQ 版会根据成功导入的元数据在目标云消息队列 RabbitMQ 版实例中创建对应的Vhost、Queue、Exchange、Binding，实现RabbitMQ集群元数据迁移上云。开源RabbitMQ支持导出全部Vhost或某个指定的Vhost元数据。前提条件 ...

产品优势

本文主要介绍云消息队列 RabbitMQ 版相比于自建开源RabbitMQ所具备的优势，以便您更进一步了解云消息队列 RabbitMQ 版。灵活易用开箱即用完全兼容 AMQP 0-9-1 标准协议，完全兼容RabbitMQ开源社区，快速迁移上云。全托管服务一键开通...

准备环境

在使用C#SDK收发消息前，您需按照本文提供的内容来准备环境。...在Aliyun_MQ_SDK工程中可以看到 Samples.cs 文件，该文件中提供了C#SDK消息收发的示例代码，将代码中的示例值替换为您实际业务使用的参数值，然后保存并执行。

收发普通消息

factoryInfo.getPublishTopics(),/Message Tag，可理解为Gmail中的标签，对消息进行再归类，方便Consumer指定过滤条件在消息队列RocketMQ版的服务器过滤。TagA",/Message Body，不能为空，消息队列RocketMQ版不做任何干预，需要Producer与...

SDK概述

SDK列表云消息队列 Kafka 版提供了以下编程语言的SDK，您可以在获取地址中查看更新历史、获取安装包以及查看指导文档。SDK Demo地址适用的协议参考文档说明文件 Java SDK Java SDK Demo PLAINTEXT SASL_SSL/PLAIN SASL_PLAINTEXT/...

RAM鉴权

云消息队列 MQTT 版的Resource与Action的对应规则在云消息队列 MQTT 版中，实例、Topic、Group和规则各为一种Resource，对这些Resource授予的权限即为Action。可授权的云消息队列 MQTT 版OpenAPI 下表列举了云消息队列 MQTT 版中可...

权限策略

本文介绍云消息队列 MQTT 版在RAM中的权限策略。策略类别在RAM中，权限策略是用语法结构描述的一组权限的集合，可以精确地描述被授权的Resource（资源集）、Action（操作集）以及授权条件。云消息队列 MQTT 版有以下两类RAM的权限...

开源SDK接入（主子账号授权）

阿里云的云消息队列 RabbitMQ 版支持AMQP 0-9-1协议，兼容开源的RabbitMQ客户端，您可以使用开源的客户端SDK接入云消息队列 RabbitMQ 版服务端进行消息收发。前提条件创建实例创建Vhost 背景信息借助访问控制RAM的RAM用户，您可以...

HTTP SDK错误码列表

③：在云消息队列 RocketMQ 版中某个参数的下限值。④：在云消息队列 RocketMQ 版中某个参数的上限值。⑤：在URL请求中QueryString的元素。⑥：当前云消息队列 RocketMQ 版单个Topic的QPS上限。具体限制，请参见使用限制。

收发普通消息

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

日志配置

客户端日志用于记录云消息队列 RocketMQ 版客户端运行过程中的异常，帮助您快速定位和修复问题。本文为您介绍如何查看和配置云消息队列 RocketMQ 版 SDK的客户端日志。日志文件默认路径各语言的客户端日志文件的默认路径如下：说明 {$...

收发普通消息

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

收发普通消息

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

收发普通消息

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

OnsDLQMessageResendById-重发指定的死信消息

当前消息队列 RocketMQ 版不管理死信重发的状态，重发后消费成功的消息不会从死信队列中移除。需自行管理、判断消息是否需要重发。避免多次无意义地重发，从而造成重复消费。调试您可以在OpenAPI Explorer中直接运行该接口，免去您计算...

实例限流最佳实践

云消息队列 RabbitMQ 版会对单实例的TPS流量峰值进行限流，本文介绍云消息队列 RabbitMQ 版实例的限流规则、限流后的行为以及限流最佳实践等。限流后行为当云消息队列 RabbitMQ 版实例的TPS流量峰值超过您所购买实例的TPS规格上限时...

领域模型概述

一对一通信：基于消费匿名特点，下游消费者即使有多个，但都没有自己独立的身份，因此共享队列中的消息，每一条消息都只会被唯一一个消费者处理。因此点对点模型只能实现一对一通信。发布订阅模型发布订阅模型具有如下特点：消费独立：...

集群消费和广播消费

集群消费基本概念集群消费模式下，同一Group下的多个消费者消费指定Topic中的消息时，云消息队列 RocketMQ 版会将多条消息投递给不同的消费者处理，同一条消息只会被一个消费者消费到。适用场景消息负载均衡：当业务消息量很大时，可以...

Java中的阻塞队列

新品推荐