MQ系列1：消息中间件执行原理 MQ系列2：消息中间件的技术选型 MQ系列3：RocketMQ 架构分析 MQ系列4：NameServer 原理解析 MQ系列5：RocketMQ消息的发送模式 MQ系列6：消息的消费 MQ系列7：消息通信，追求极致性能 MQ系列8：数据存储，消息队列的高可用保障 M
# 什么是 long-running thread long-running task 是指那些长时间运行的任务，比如在一个 while True 中执行耗时较长的同步处理。 下面的例子中，我们不断从队列中尝试取出数据，并对这些数据进行处理，这样的任务就适合交给一个 long-running tas
一，引言 Azure 存储账户功能经过官方改进迭代后，在创建的时候，存储账户的类型被分为两大类： 1）general-purpose v2 account（标准常规用途v2） Blob 存储，队列存储，表存储，Azure File存储 2）Premium 1，Blob 存储：包含 块存储 & 追加存
客户端是通过Rebalance服务做到高可靠的。当发生Broker掉线、消费者实例掉线、Topic 扩容等各种突发情况时，消费者组中的消费者实例是怎么重平衡，以支持全部队列的正常消费的呢？ RebalancePullImpl 和 RebalancePushImpl 两个重平衡实现类，分别被 Defa
1 引言 之前介绍了Redis的数据存储及String类型的实现，接下来再来看下List、Hash、Set及Sorted Set的数据结构的实现。 2 List List类型通常被用作异步消息队列、文章列表查询等；存储有序可重复数据或做为简单的消息推送机制时，可以使用Redis的List类型。对于这
本文首先介绍了进程的控制结构，即进程控制块（PCB），它是表示进程的数据结构，包含了进程的相关信息和资源。PCB之间通过链表连接，形成就绪队列和阻塞队列，用于进程调度和资源管理。接着，文章详细探讨了进程的切换过程。进程切换是为了保证公平分配CPU时间片，涉及保存和恢复进程的执行上下文、更新进程状态和调度算法选择等步骤。文中还提到了进程上下文切换的场景，如时间片用完、内存不足、高优先级进程需求等。最
Pop模式消费和消息粒度负载均衡 在RocketMQ 5.0之前，消费有两种方式可以从Broker获取消息，分别为Pull模式和Push模式。 Pull模式：消费需要不断的从阻塞队列中获取数据，如果没有数据就等待，这个阻塞队列中的数据由消息拉取线程从Broker拉取消息之后加入的，所以Pull模式下
算法学习笔记，记录容易忘记的知识点和难题。详解时空复杂度、50道常见面试笔试题，包括数组、单链表、栈、队列、字符串、哈希表、二叉树、递归、迭代、分治类型题目，均带思路与C++题解
除了可以通过ThreadPoolExecutor自定义线程池外，同Stream API中的Collectors一样，多线程里的Executors类也提供了一组相关的线程池工具，可以直接拿来用，不用考虑用什么队列合适的问题。 Javac除了传统的四大线程池工具： 1、newFixedThreadPoo
本文针对数据存储相关名词概念进行了解释，重点介绍了数据库技术的发展史。为了丰富文章的可读性以及实用性，又从数据结构设计层面进行了部分技术实战能力的外延扩展，阐述了拉链表，位运算，环形队列等相关数据结构在软件开发领域的应用，希望本文给你带来收获。
本文旨在探讨进程间通信的重要性，并介绍了不同的通信机制，如管道、消息队列、共享内存、信号量、信号和套接字。通过理解这些通信机制的特点和应用场景，可以更好地实现进程间的高效数据共享。同时，本文还强调了同步和互斥机制的重要性，以确保数据的一致性和正确性。最后，还介绍了套接字作为一种跨网络和同一主机上进程间通信的通信机制，为读者提供了更全面的了解。通过阅读本文，读者将能够深入理解进程间通信的概念和不同机制，为实现有效的数据共享提供指导。
在上一讲中，介绍了消息的存储，生产者向Broker发送消息之后，数据会写入到CommitLog中，这一讲，就来看一下消费者是如何从Broker拉取消息的。 RocketMQ消息的消费以组为单位，有两种消费模式： 广播模式：同一个消息队列可以分配给组内的每个消费者，每条消息可以被组内的消费者进行消费。
RocketMQ设定了延迟级别可以让消息延迟消费，延迟消息会使用SCHEDULE_TOPIC_XXXX这个主题，每个延迟等级对应一个消息队列，并且与普通消息一样，会保存每个消息队列的消费进度（delayOffset.json中的offsetTable）： public class MessageSt
1、什么是微服务 Java微服务是一种架构风格，通过将单个Spring Boot应用程序拆分为一组小型、独立的Spring Boot服务来构建分布式系统。每个微服务都运行在自己的进程中，并使用轻量级通信机制（如HTTP或消息队列）来进行相互之间的通信。微服务的设计目标是提高系统的灵活性、可伸缩性和可
tc（Traffic Control）是 Linux 中用于流量控制和网络模拟的强大工具。你可以使用它来模拟网络延迟、带宽限制、数据包丢失等。 以下是一个使用 tc 模拟网络延迟的基本步骤： 1.查看当前的 qdisc（队列规则）和 filter（过滤器） 首先，确保你的网络接口没有设置任何 qdi
http://blog.51niux.com/?id=99 sar也是sysstat中的一员。 一、介绍 1.1 简介 sar是一个优秀的一般性能监视工具，它可以输出Linux所完成的几乎所有工作的数据。sar命令在sysetat rpm中提供。 sar可以显示CPU、运行队列、磁盘I/O、分页（交
测试环境 3台服务器：ceph配置内外网分离，外网使用万兆线，内网使用千兆线，osd共21个。 1台客户端：安装fio工具、内核客户端，使用万兆线。 测试目的 针对fio工具中的iodepth（队列深度）和numjobs（线程数）参数，分析使用fio工具时，哪个参数对带宽值测试结果影响比较大。 测试
