https://www.jianshu.com/p/e55e971aebd8 AMQP简介 AMQP，即 Advanced Message Queuing Protocol，高级消息队列协议，是应用层协议的一个开放标准，为面向消息的中间件设计。消息中间件主要用于组件之间的解耦和通讯。 AMQP的主要
我们知道，生产者会先将消息发送给交换机，但是如果交换机此时没有匹配到相关的队列时，交换机中的消息就会出现丢失的问题。 那么，如何保证交换机中的消息不丢失呢？ mandatory 参数 当 basicPublish 方法的 mandatory 参数设为 true 时，如果交换器无法匹配到绑定的队列，那
参考资料：RabbitMQ tutorial - Publish/Subscribe — RabbitMQ 前言 在 RabbitMQ学习笔记03：Work Queues 中，每个进入队列中的消息只会被投递给一个消费者进程。而在这篇文章中，我们将会把一条消息同时投递给多个消费者进程。这种模式也叫做p
https://www.cnblogs.com/zengkefu/p/5634345.html http://elf8848.iteye.com/blog/1731274 AHCI： NCQ技术,600MB/S，一个队列，每个队列32个指令 NVME：65000个队列，每个队列65000指令，3.2
在早期NVMe的讨论话题中，常常将之AHCI协议进行对比，在支持的最大队列深度、并发进程数以及消耗时钟周期数等方面，NVMe吊打了AHCI。最直观也最权威的就是下面这张对比图片。 NVMe与AHCI协议对比（来源：sata-io.org） SATA的发展最早可以追溯到上世纪80年代的IDE/ATA，
前言 这段时间在做 MQ（Pulsar）相关的治理工作，其中一个部分内容关于消息队列的升级，比如： 一键创建一个测试集群。 运行一批测试用例，覆盖我们线上使用到的功能，并输出测试报告。 模拟压测，输出测试结果。 本质目的就是想直到新版本升级过程中和升级后对现有业务是否存在影响。 一键创建集群和执行测
三、用go语言，用一个单链表L实现一个队列。要求操作 ENQUEUE 和 DEQUEUE 的运行时间仍为O(1)。 文心一言： 在 Go 语言中，使用单链表实现队列的操作，包括入队（ENQUEUE）和出队（DEQUEUE），并保持操作的时间复杂度为 O(1)，需要利用两个指针，一个指向队头，另一个指
五、用go语言，栈插入和删除元素只能在同一端进行，队列的插入操作和删除操作分别在两端进行，与它们不同的，有一种双端队列(deque)，其插入和删除操作都可以在两端进行。写出4个时间均为 O(1)的过程，分别实现在双端队列的两端插入和删除元素的操作，该队列是用一个数组实现的。 文心一言： 在 Go 语
四、用go语言，重写 ENQUEUE 和 DEQUEUE 的代码，使之能处理队列的下溢和上溢。 文心一言： 在 Go 语言中，我们可以使用切片来实现队列。下面是如何实现 ENQUEUE 和 DEQUEUE 操作，同时处理队列的下溢和上溢的情况： package main import "fmt" t
消费者负载均衡，是指为消费组下的每个消费者分配订阅主题下的消费队列，分配了消费队列消费者就可以知道去消费哪个消费队列上面的消息，这里针对集群模式，因为广播模式，所有的消息队列可以被消费组下的每个消费者消费不涉及负载均衡，而集群模式一个消息队列同一时间只能分配给组内的一个消费者进行消费。 Rocket
RocketMQ是一个纯Java、分布式、队列模型的开源消息中间件，具有高性能、高可靠、高实时、分布式特点。本篇文章通关源码分析深入地介绍了RocketMQ主从复制原理。
**全局有序** 在RocketMQ中，如果使消息全局有序，可以为Topic设置一个消息队列，使用一个生产者单线程发送数据，消费者端也使用单线程进行消费，从而保证消息的全局有序，但是这种方式效率低，一般不使用。  。这个库提供了一些支持并发的数据结构，计数器Counter，哈希 Map，队列Queue。我着重看了下
Linux多线程，线程的基本概念，线程库的基本原理，线程私有栈的由来，互斥与同步，互斥锁，信号量，条件变量，线程池，生产者消费者模式，基于阻塞队列/阻塞环形队列的生产者消费者模模型，单例模式，饿汉懒汉方式
IP重组 ip重组这部分 4.19内核与3.10内核有些差别，4.9.134以后内核中不使用低水位和工作队列了，同时使用了rhashtable 替代了 hash bucket的概念，在3.10内核中使用1024个hash bucket, 每个bucket中最多存放128个分片队列，在4.19内核中所
Netty 框架是以性能著称的框架，因此在它的框架中使用了大量提升性能的机制，例如 Netty 用于实现延迟队列的时间轮调度算法就是一个典型的例子。使用时间轮调度算法可以实现海量任务新增和取消任务的时间度为 O(1)，那么什么是时间轮调度算法呢？接下来我们一起来看。 1.延迟任务实现 在 Netty
线程池的拒绝策略有哪些？ 如果当前同时运行的线程数量达到最大线程数量并且队列也已经被放满了任务时，ThreadPoolExecutor 定义一些策略: ThreadPoolExecutor.AbortPolicy：抛出 RejectedExecutionException来拒绝新任务的处理。 Thr
在软件开发过程中，集成测试是至关重要的一环。它确保不同组件之间的协作正常，并验证系统在整体上的功能和性能。然而，传统的集成测试往往需要依赖于外部资源，如数据库、消息队列等，这给测试环境的搭建和维护带来了一定的挑战。 为了解决这个问题，我们可以使用 TestContainers 这个强大的开源工具。T
