深入理解Java线程编程中的阻塞队列容器-深入理解Java线程编程中的阻塞队列容器文档介绍内容-阿里云

告警规则指标说明

在多线程编程中，当队列大小过小时，可能会导致任务排队等待的时间过长，从而降低程序的性能；而当队列大小过大时，可能会导致系统资源的消耗过多，从而导致系统崩溃或者性能下降。当前线程数是正在运行或等待运行的线程数量。已执行任务...

使用云消息队列 Kafka 版时出现消息堆积

使用云消息队列 Kafka 版时，可能会发现Group中出现消息堆积。本文介绍如何判断消息堆积是否属于正常情况，以及处理方法。客户端消费流程了解客户端消费流程，有助于理解消息是否堆积。一般情况下，客户端消费流程大致如下：判断消息...

发送普通消息（三种方式）

TopicTestMQ",/Message Tag可理解为Gmail中的标签，对消息进行再归类，方便Consumer指定过滤条件在消息队列RocketMQ版的服务器过滤。Tag的具体格式和设置方法，请参见Topic与Tag最佳实践。TagA",/Message Body可以是任何二进制形式的数据...

示例代码

云消息队列 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作为主力...

快速入门Java线程栈分析

本文将演示如何通过ATP的Java线程栈分析功能，分析Java应用中线程的运行情况。1.生成数据源，上传到ATP a.用户可以通过JDK中自带的jstack命令创建Java应用的线程快照，如下：#生成线程快照并输出到 jstack.log$jstack<进程号>>jstack.log b...

历史功能发布记录（2023年）

全部 ack-fluid ack-kube-queue组件发布v0.3.3版本 ack-kube-queue是云原生AI套件提供的任务队列组件，在v0.3.3版本中，通过环境变量设置全局阻塞队列时，将会全局刷新所有Queue的阻塞队列模式。全部 ack-kube-queue 容器服务 Edge 版 ...

发送消息（多线程）

TopicTestMQ",/Message Tag可理解为Gmail中的标签，对消息进行再归类，方便Consumer指定过滤条件在消息队列RocketMQ版的服务器过滤。TagA",/Message Body可以是任何二进制形式的数据，消息队列RocketMQ版不做任何干预。需要Producer与...

ECI Pod生命周期

Pending 否启动中（Pending）ECI Pod中有一个或多个容器还在启动中，并且没有处于运行中的容器。Pending 是运行中（Running）ECI Pod中所有容器均已经创建成功，并且至少有一个容器正在运行中，或者正在重启。Running 是重启中...

顺序消息

本文介绍云消息队列 RocketMQ 版顺序消息的概念、适用场景、实现原理以及使用过程中的注意事项。什么是顺序消息顺序消息是云消息队列 RocketMQ 版提供的一种对消息发送和消费顺序有严格要求的消息。对于一个指定的Topic，消息严格按照...

基本概念

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

连接ECI实例

部署容器后，您可以通过弹性容器实例控制台，使用Workbench连接ECI实例中的容器，执行命令进行调试。本文介绍如何连接ECI实例。前提条件实例中的容器处于运行中状态。操作步骤登录弹性容器实例控制台。在顶部菜单栏左上角处选择地域。...

ack-kube-queue

2023年12月版本号变更内容变更时间变更影响 v0.3.3 新增通过环境变量设置全局阻塞队列时将会全局刷新所有Queue的阻塞队列模式。2023年12月26日此次升级不会对业务造成影响。2023年09月版本号变更内容变更时间变更影响 v0.3.1 修复...

功能特性

应用接入功能功能说明容器服务Kubernetes版中的应用自动接入适合部署在容器服务Kubernetes版中的Java应用，通过安装组件ack-onepilot实现自动接入。手动接入适合所有非容器化方式部署的Java应用，包括运行在线下IDC以及其他云上的Java...

如何处理消息堆积

问题现象在使用云消息队列 RocketMQ 版实例时收到消息堆积告警，登录云消息队列 RocketMQ 版控制台后发现了下列现象：在 Group 详情页面，看到Group ID的实时消息堆积量的值高于预期。导航栏中选择消息轨迹，单击创建查询任务，...

生产者负载均衡

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

Pod安全

在容器服务 Kubernetes 版中，您可以通过限制容器以特权模式运行、限制应用程序进程以root身份运行以及禁用Service Account令牌自动挂载等方式，防止容器中运行的进程逃离容器的隔离边界并获得对宿主机的访问权限。通过正确配置Pod安全...

死信队列

对于消费失败且重试后依然失败的消息，云消息队列 RocketMQ 版不会立丢弃，而是将消息转发至指定的队列中，即死信队列，这些消息即为死信消息。当消费失败的原因排查并解决后，您可以重发这些死信消息，让消费者重新消费；若您暂时无法...

仪表盘

在PushConsumer消费场景下，本地缓冲队列相关指标如下：本地缓冲队列中的消息量：本地缓冲队列中的消息总条数。本地缓冲队列中的消息大小：本地缓冲队列中所有消息大小的总和。消息等待处理时间：消息暂存在本地缓冲队列中的时间。Metrics...

消费者负载均衡

消费者从云消息队列 RocketMQ 版获取消息消费时，通过消费者负载均衡策略，可将主题内的消息分配给指定消费者分组中的多个消费者共同分担，提高消费并发能力和消费者的水平扩展能力。本文介绍云消息队列 RocketMQ 版消费者的负载均衡...

实例监控

线程池支持的框架线程池监控支持Tomcat、HSF、Dubbo、Vert.x和Undertow1.x框架，采集的指标如下：指标名称指标线程池核心线程数 arms_threadpool_core_size 线程池最大线程数 arms_threadpool_max_size 线程池活跃线程数 arms_...

领域模型概述

队列（MessageQueue）：云消息队列 RocketMQ 版消息传输和存储的实际单元容器，类比于Kafka中的分区。云消息队列 RocketMQ 版通过流式特性的无限队列结构来存储消息，消息在队列内具备顺序性存储特征。消息（Message）：云消息队列 ...

设置容器启动命令和参数

ECI实例通过容器镜像中的预设参数来启动容器。如果您在构建镜像时没有设置启动命令和参数，或者想要变更启动命令和参数，可以在创建ECI实例时设置。本文介绍如何为容器设置启动时要执行的命令和参数。功能说明如果您想覆盖镜像中设置的...

线程状态

Java线程和对应的操作系统线程的具体状态的含义。每个Java线程都1:1对应操作系统的原生线程，所以线程状态又分为 Java线程状态和操作系统线程状态。注意，由于JVM对OS线程也做了简单的抽象，所以它可以识别出一些JVM的特性（比如当前OS...

消息队列RabbitMQ版

本文介绍如何在云消息队列 RocketMQ 版控制台创建流出目标为云消息队列 RabbitMQ 版的消息流出任务。前提条件您已购买云消息队列 RocketMQ 版实例，且实例处于服务中状态。具体步骤，请参见创建资源。您已购买并部署云消息队列 ...

消费进度管理

云消息队列 RocketMQ 版通过消费位点管理消费进度，本文为您介绍云消息队列 RocketMQ 版的消费进度管理机制。背景信息云消息队列 RocketMQ 版的生产者和消费者在进行消息收发时，必然会涉及以下场景，消息先生产后订阅或先订阅后生产...

消息服务MNS

本文介绍如何在云消息队列 RocketMQ 版控制台创建流出目标为消息服务MNS 的消息流出任务。前提条件您已购买云消息队列 RocketMQ 版实例，且实例处于服务中状态。具体步骤，请参见创建资源。您已创建消息服务MNS 队列。具体步骤，...

云消息队列 RabbitMQ 版

本文介绍如何在云消息队列 RabbitMQ 版控制台创建流入任务，将指定云消息队列 RabbitMQ 版实例中的数据快速导入至另外的云消息队列 RabbitMQ 版实例中。前提条件您已购买云消息队列 RabbitMQ 版实例，且实例处于服务中状态。...

消息存储和清理机制

消息在队列中的存储情况如下：消息存储管理粒度说明云消息队列 RocketMQ 版按照服务端节点粒度管理存储时长而非队列或主题，原因如下：消息存储优势权衡：云消息队列 RocketMQ 版基于统一的物理日志队列和轻量化逻辑队列的二级组织方式...

消息队列RabbitMQ版

本文介绍如何在云消息队列 RocketMQ 版控制台创建流入任务，实现将其他数据源中的数据快速导入云消息队列 RabbitMQ 版。前提条件您已购买云消息队列 RocketMQ 版实例，且实例处于服务中状态。具体步骤，请参见创建资源。您已购买...

云消息队列 RabbitMQ 版

本文介绍如何在云消息队列 RocketMQ 版控制台创建流入任务，实现将云消息队列 RabbitMQ 版中的数据快速导入至云消息队列 RocketMQ 版。前提条件您已购买云消息队列 RocketMQ 版实例，且实例处于服务中状态。具体步骤，请参见 ...

消息堆积和延迟问题

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

消息服务MNS

本文介绍如何在云消息队列 RocketMQ 版控制台创建消息流出任务，以实现将云消息队列 RocketMQ 版的消息流出至消息服务MNS。前提条件您已购买云消息队列 RocketMQ 版实例，且实例处于服务中状态。具体步骤，请参见创建资源。您已...

消费者分类

云消息队列 RocketMQ 版支持PushConsumer和SimpleConsumer这两种类型的消费者，本文分别从使用方式、实现原理、可靠性重试和适用场景等方面为您介绍这两种类型的消费者。背景信息云消息队列 RocketMQ 版面向不同的业务场景提供了不同...

功能与特性概述

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

设置容器启动命令和参数

ECI Pod（即ECI实例）通过容器镜像中的预设参数来启动容器。如果您在构建镜像时没有设置启动命令和参数，或者想要变更启动命令和参数，可以在创建ECI Pod时设置。通过设置容器启动命令和参数，可以定义容器的启动行为和初始化过程，保证...

设置容器启动命令和参数

ECI Pod（即ECI实例）通过容器镜像中的预设参数来启动容器。如果您在构建镜像时没有设置启动命令和参数，或者想要变更启动命令和参数，可以在创建ECI Pod时设置。通过设置容器启动命令和参数，可以定义容器的启动行为和初始化过程，保证...

消息服务MNS

本文介绍如何在云消息队列 RabbitMQ 版控制台创建消息流出任务，将云消息队列 RabbitMQ 版的数据导出至消息服务MNS。前提条件您已购买云消息队列 RabbitMQ 版实例，且实例处于服务中状态。具体步骤，请参见创建资源。您已创建 ...

可观测性体系概述

只要为部署在容器服务Kubernetes版中的Java应用安装ARMS应用监控组件，您无需修改任何代码，就能借助ARMS对Java应用进行全方位监控，以便您更快速地定位出错接口和慢接口、重新调用参数、检测内存泄漏、发现系统瓶颈，从而大幅提升线上问题...

消息（Message）

定义消息是云消息队列 RocketMQ 版中的最小数据传输单元。生产者将业务数据的负载和拓展属性包装成消息发送到云消息队列 RocketMQ 版服务端，服务端按照相关语义将消息投递到消费端进行消费。云消息队列 RocketMQ 版的消息模型具备...

顺序消息

顺序消息为云消息队列 RocketMQ 版中的高级特性消息，本文为您介绍顺序消息的应用场景、功能原理、使用限制、使用方法和使用建议。应用场景在有序事件处理、撮合交易、数据实时增量同步等场景下，异构系统间需要维持强一致的状态同步，...

深入理解Java线程编程中的阻塞队列容器

新品推荐