搜索[队列]结果-低调大师优秀个人博客

精选列表

搜索[队列]，共9229篇文章

xtools-boot一款基于JDK25,SpringBoot4的通用Spring工具库

verdana,arial,sans-serif;}异常异步异步存储持久化序列化HTTP请求过滤器链日志追踪Filter公共FilterController层Service层全局异常处理器Redis缓存数据库消息队列日志总线

2026-06-09

最近线上的rm crash了一次，查看日志，发现有如下报错： 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 2015 - 01 - 05 18 : 00 : 11 , 523 ERRORorg.apache.hadoop.yarn.server.resourcemanager.scheduler.fair.FairScheduler:Request for appInfoofunknownattemptappattempt_1418702129929_2281200_000001 2015 - 01 - 05 18 : 00 : 11 , 524 ERRORorg.apache.hadoop.yarn.server.resourcemanager.scheduler.fair.FairScheduler:Request for appInfoofunknownattemptappattempt_1418702129929_2281200_000001 2015 - 01 - 05 18 : 00 : 11 , 526 ERRORorg.apache.hadoop.yarn.server.resourcemanager.scheduler.fair.FairScheduler:Request for appInfoofunknownattemptappattempt_1418702129929_2281200_000001 2015 - 01 - 05 18 : 00 : 11 , 527 FATALorg.apache.hadoop.yarn.server.resourcemanager.ResourceManager:ErrorinhandlingeventtypeAPP_ADDEDtothescheduler org.apache.hadoop.metrics2.MetricsException:MetricssourceQueueMetrics,q0=rootalreadyexists! atorg.apache.hadoop.metrics2.lib.DefaultMetricsSystem.newSourceName(DefaultMetricsSystem.java: 126 ) atorg.apache.hadoop.metrics2.lib.DefaultMetricsSystem.sourceName(DefaultMetricsSystem.java: 107 ) atorg.apache.hadoop.metrics2.impl.MetricsSystemImpl.register(MetricsSystemImpl.java: 217 ) atorg.apache.hadoop.yarn.server.resourcemanager.scheduler.fair.FSQueueMetrics.forQueue(FSQueueMetrics.java: 94 ) atorg.apache.hadoop.yarn.server.resourcemanager.scheduler.fair.FSQueue.<init>(FSQueue.java: 61 ) atorg.apache.hadoop.yarn.server.resourcemanager.scheduler.fair.FSLeafQueue.<init>(FSLeafQueue.java: 59 ) atorg.apache.hadoop.yarn.server.resourcemanager.scheduler.fair.QueueManager.createLeafQueue(QueueManager.java: 199 ) atorg.apache.hadoop.yarn.server.resourcemanager.scheduler.fair.QueueManager.getLeafQueue(QueueManager.java: 144 ) atorg.apache.hadoop.yarn.server.resourcemanager.scheduler.fair.FairScheduler.addApplication(FairScheduler.java: 581 ) atorg.apache.hadoop.yarn.server.resourcemanager.scheduler.fair.FairScheduler.handle(FairScheduler.java: 998 ) atorg.apache.hadoop.yarn.server.resourcemanager.scheduler.fair.FairScheduler.handle(FairScheduler.java: 108 ) atorg.apache.hadoop.yarn.server.resourcemanager.ResourceManager$SchedulerEventDispatcher$EventProcessor.run(ResourceManager.java: 378 ) atjava.lang.Thread.run(Thread.java: 662 ) 这其实是yarn的一个bug，在提交的job queue为空时会触发这个bug,导致rm抛出异常而退出， bug id:https://issues.apache.org/jira/browse/YARN-2863 可以通过如下命令重现： 1 yarnjarhadoop-mapreduce-examples- 2.0 . 0 -cdh4. 6.0 .jarpi-Dmapreduce.job.queuename= 20 10 在bug 描述中可以看到通过设置yarn.scheduler.fair.allow-undeclared-pools为false是可以修复这个问题的，但是在cdh4.6.0中是没有这个配置的，可以通过 https://issues.apache.org/jira/browse/YARN-1213 增加一个配置。在queue为空时会使用default的queue。这个bug在cdh5.2.0已经fix 在5.2.0的yarn中增加了下面两个如下配置 1 2 yarn.scheduler.fair.allow-undeclared-pools //是否允许有不存在的queue，默认为true yarn.scheduler.fair.user-as- default -queue //当queue不存在时，是否使用用户名来代替default，默认为true 本文转自菜菜光 51CTO博客，原文链接：http://blog.51cto.com/caiguangguang/1602231，如需转载请自行联系原作者

2017-11-15

BlazingMQ —— 现代高性能消息队列

BlazingMQ 是一个分布式消息队列平台，专注于现代工作流程的效率、可靠性和丰富的功能集。

2023-07-31

taskq —— Golang 异步任务 / 作业队列

taskq是一个带有 Redis、SQS、IronMQ 和内存后端的 Golang 异步任务/作业队列。特性： Redis、SQS、IronMQ 和内存后端。

2022-05-21

消息队列的应用场景

一般这里我们会使用一个组件那就是消息队列。消息队列是什么消息队列的概念以及有什么作用，前面有讲到相关中间件的时候提到过(消息中间件能干什么？

2021-04-13

redis做消息队列，香吗？

Redis消息队列在程序员这个圈子打拼了太多年，见过太多的程序员使用redis，其中一部分喜欢把redis做缓存（cache）使用，其中最典型的当属存储用户session，除此之外，把redis作为消息队列使用也不在少数

2020-12-16

PHP + Redis 实现简单消息队列

Redis做消息队列的好处在于它的轻量级，高并发，延迟敏感，应用场景有即时数据分析、秒杀计数器、缓存等 Redis做消息队列待解决的问题： 1、消息的可靠性：没有相应的机制保证消息的消费，当消费者消费失败的时候

2020-08-15

玩转redis-延时消息队列

上一篇基于redis的list实现了一个简单的消息队列：玩转redis-简单消息队列源码地址使用demo 产品经理经常说的一句话，我们不光要有X功能，还要Y功能，这样客户才能更满意。

2020-05-05

JAVA并发之阻塞队列浅析

JAVA并发之阻塞队列浅析背景因为在工作中经常会用到阻塞队列，有的时候还要根据业务场景获取重写阻塞队列中的方法，所以学习一下阻塞队列的实现原理还是很有必要的。

2019-08-03

分布式队列Celery入门

它是一个专注于实时处理的任务队列，同时也支持任务调度。Celery 是语言无关的，虽然它是用 Python 实现的，但他提供了其他常见语言的接口支持。

2019-03-19

分布式消息队列kafka

kafka是Linkedin开源的分布式发布-订阅消息系统（消息队列） kafka特点 1 高吞吐率、低延迟，每秒处理几十万消息，延迟最低几毫秒 2 可扩展性，支持动态扩展节点数据 3 持久性与可靠性，

2019-03-11

创建消息队列（Kafka）源表

自建kafka 与阿里云Kafka消息队列一样，DDL定义相同。

2018-11-13

RocketMQ如何支持更多队列（翻译）

消费队列存储用户实际消费位置信息，这些消息也可以以顺序方式刷到磁盘。优势每个消息队列都是轻量级的，并且包含有限的元数据。

2018-10-29

Android 多线程之阻塞队列

Android 多线程系列 Android 多线程之几个基本问题阻塞队列阻塞队列常用于生产者和消费者的场景，生产者是往队列里添加元素的线程，消费者是从队列里取元素的线程。

2018-10-03

干货 | 解读 Java 并发队列 BlockingQueue

是因为 BlockingQueue 支持当获取队列元素但是队列为空时，会阻塞等待队列中有元素再返回；也支持添加元素时，如果队列已满，那么等到队列可以放入新元素时再放入。

2018-08-21

架构文摘：消息队列设计精要

本文不会一一介绍这些消息队列的所有特性，而是探讨一下自主开发设计一个消息队列时，你需要思考和设计的重要方面。过程中我们会参考这些成熟消息队列的很多重要思想。

2018-06-02

Java中的阻塞队列（2）

6、同步队列SynchronousQueue 同步队列是一个不存储元素的阻塞队列，每一个put操作必须等待一个take操作，否则就不能继续添加元素。

2018-05-28

Java中的阻塞队列（1）

队列（Queue）：FIFO 双端队列（Deque）：两端都可以进出，当我们约束从队列的一端进出队列时，就形成了一种存取模式，它遵循先进后出的原则，就是所谓栈结构阻塞队列（BlockingQueue）

2018-05-27

消息队列ActiveMQ的使用详解

通过上一篇文章《消息队列深入解析》，我们已经消息队列是什么、使用消息队列的好处以及常见消息队列的简单介绍。这一篇文章，主要带大家详细了解一下消息队列ActiveMQ的使用。

2018-04-23

ActiveMQ队列消息积压问题调研

摘要公司运维同事针对ActiveMQ提出了两个问题，其中一个是“队列长时间无人监听时，自动删除该队列”。调研提出了三种方案。这里是相关记录和说明。

2017-12-11

资源下载

更多资源

腾讯云软件源

为解决软件依赖安装时官方源访问速度慢的问题，腾讯云为一些软件搭建了缓存服务。您可以通过使用腾讯云软件源站来提升依赖包的安装速度。为了方便用户自由搭建服务架构，目前腾讯云软件源站支持公网访问和内网访问。

Nacos

Nacos /nɑ:kəʊs/ 是 Dynamic Naming and Configuration Service 的首字母简称，一个易于构建 AI Agent 应用的动态服务发现、配置管理和AI智能体管理平台。Nacos 致力于帮助您发现、配置和管理微服务及AI智能体应用。Nacos 提供了一组简单易用的特性集，帮助您快速实现动态服务发现、服务配置、服务元数据、流量管理。Nacos 帮助您更敏捷和容易地构建、交付和管理微服务平台。

Spring

Spring框架（Spring Framework）是由Rod Johnson于2002年提出的开源Java企业级应用框架，旨在通过使用JavaBean替代传统EJB实现方式降低企业级编程开发的复杂性。该框架基于简单性、可测试性和松耦合性设计理念，提供核心容器、应用上下文、数据访问集成等模块，支持整合Hibernate、Struts等第三方框架，其适用范围不仅限于服务器端开发，绝大多数Java应用均可从中受益。

WebStorm

WebStorm 是jetbrains公司旗下一款JavaScript 开发工具。目前已经被广大中国JS开发者誉为“Web前端开发神器”、“最强大的HTML5编辑器”、“最智能的JavaScript IDE”等。与IntelliJ IDEA同源，继承了IntelliJ IDEA强大的JS部分的功能。