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

精选列表

搜索[消息队列 CKafka 版]，共10000篇文章

迁移Exchange队列至其它服务器继续传送队列邮件

Exchange 2010中，队列也是以数据库文件的方式保存在Exchange 安装目录中，前段时间碰到一个网络问题，队列文件过大将C盘空间占满，而导致服务无启动的问题，排除方法如下：一天早上，接到某用户报障

2017-03-30

鸿蒙内核源码分析(消息队列篇) | 进程间如何异步解耦传递大数据 ? | 中文注解HarmonyOS源码 | v33.01

基本概念队列又称消息队列，是一种常用于任务间通信的数据结构。队列接收来自任务或中断的不固定长度消息，并根据不同的接口确定传递的消息是否存放在队列空间中。

2021-02-15

阻塞队列 — DelayedWorkQueue源码分析

前言线程池运行时，会不断从任务队列中获取任务，然后执行任务。如果我们想实现延时或者定时执行任务，重要一点就是任务队列会根据任务延时时间的不同进行排序，延时时间越短地就排在队列的前面，先被获取执行。

2020-11-26

基于curator的延迟队列

这里不介绍关于curator的用法及优劣，旨在探究curator对于延迟队列的使用原理怎么使用 <!

2020-03-31

Java并发队列与容器

本文主要阐述Java并发包下的阻塞队列和并发容器，其实研读过大数据相关技术如Spark、Storm等源码的，会发现它们底层大多用到了Java并发队列、同步类容器、ReentrantLock等。

2019-12-18

最近线上的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

构建高并发AI数据流水线：基于腾讯云CKafka+DataPipeline+TI-ONE的实战

很多团队把“数据工程”等同于“写几个Spark SQL定时跑批”，但在实时推荐、风控、自动驾驶等场景下，数据延迟超过100ms就会导致模型AUC下降0.03，收入损失可达千万级。真正的瓶颈往往不在模型，而在：

2026-08-22

EventBridge消息路由｜高效构建消息路由能力

消息队列 RabbitMQ 版阿里云消息队列 RabbitMQ 版支持 AMQP 协议，完全兼容 RabbitMQ 开源生态以及多语言客户端，打造分布式、高吞吐、低延迟、高可扩展的云消息服务。

2022-02-27

腾讯云国际版注册：IM消息回调验签失败怎么办？

消息收不到、未读数卡死、线上用户投诉接踵而至，根因往往指向签名校验环节的一处微小偏差。本教程从最常见故障现象切入，拆解一套可复用的排查与配置流程，帮助开发者绕过那些让回调通道瘫痪的隐性坑位。

2026-07-28

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

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

2022-05-21

JAVA并发之阻塞队列浅析

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

2019-08-03

分布式队列Celery入门

Celery 是一个简单、灵活且可靠的，处理大量消息的分布式系统，并且提供维护这样一个系统的必需工具。它是一个专注于实时处理的任务队列，同时也支持任务调度。

2019-03-19

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

因此，我们开发了一个名为RocketMQ的消息中间件，来解决更广泛的使用场景，从传统的发布/订阅情景到超大容量的不容忍消息丢失的事物系统。

2018-10-29

Android 多线程之阻塞队列

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

2018-10-03

干货 | 解读 Java 并发队列 BlockingQueue

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

2018-08-21

Java中的阻塞队列（2）

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

2018-05-28

Java中的阻塞队列（1）

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

2018-05-27

yarn划分队列示例

修改Yarn服务的配置，修改Capacity Scheduler配置项如下：修改部分： yarn.scheduler.capacity.root.default.capacity=60 yarn.scheduler.capacity.root.default.maximum-capacity=60 yarn.scheduler.capacity.root.queues=default,dev 新增部分： yarn.scheduler.capacity.root.dev.capacity=40 yarn.scheduler.capacity.root.dev.maximum-capacity=40 yarn.scheduler.capacity.root.dev.state=RUNNING yarn.scheduler.capacity.queue-mappings=u:etl:dev,u:ETL:dev,u:gotop:dev,u:hive:default,g:hadoop:dev,g:hdfs:dev yarn.scheduler.capacity.queue-mappings-override.enable=true yarn.scheduler.capacity.root.dev.acl_administer_jobs= yarn.scheduler.capacity.root.dev.acl_submit_applications= 本文转自 yntmdr 51CTO博客，原文链接：http://blog.51cto.com/yntmdr/2049794，如需转载请自行联系原作者

2017-11-06

Java中ArrayDeque，栈与队列

System.out.println(stack.pop()); // 疯狂Android讲义 System.out.println(stack);//[轻量级Java EE企业应用实战, 疯狂Java讲义] // 当做队列来使用

2016-12-31

TypeScript 队列实战：从零实现简单、循环、双端、优先队列，附完整测试代码

以下是我们将要覆盖的内容：前置条件入门指南什么是队列？什么是链表？什么是简单队列？什么是循环队列？什么是双端队列？什么是优先队列？

2025-09-08

资源下载

更多资源

Spring

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

Rocky Linux

Rocky Linux（中文名：洛基）是由Gregory Kurtzer于2020年12月发起的企业级Linux发行版，作为CentOS稳定版停止维护后与RHEL（Red Hat Enterprise Linux）完全兼容的开源替代方案，由社区拥有并管理，支持x86_64、aarch64等架构。其通过重新编译RHEL源代码提供长期稳定性，采用模块化包装和SELinux安全架构，默认包含GNOME桌面环境及XFS文件系统，支持十年生命周期更新。

Sublime Text

Sublime Text具有漂亮的用户界面和强大的功能，例如代码缩略图，Python的插件，代码段等。还可自定义键绑定，菜单和工具栏。Sublime Text 的主要功能包括：拼写检查，书签，完整的 Python API ， Goto 功能，即时项目切换，多选择，多窗口等等。Sublime Text 是一个跨平台的编辑器，同时支持Windows、Linux、Mac OS X等操作系统。

WebStorm

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