Apache Kafka 是一个分布式流处理平台，广泛用于构建实时数据管道、日志聚合系统和事件溯源架构。Spring Boot 提供了对 Kafka 的良好集成支持，使得开发者可...
什么是Spring Cloud Stream Spring Cloud Stream 是 Spring 生态系统中的一个框架，用于简化构建消息驱动微服务的开发和集成。它通过抽象化的方式将消息中间...
架构哲学系列旨在用最精简的话讲解高性能框架最高级的玩法，让你可以将这些设计思想为己所用。 图是坐早班车画的，字是坐晚班车写的。 介绍 Disruptor是LM...
文章目录 1. 生产者消费者模型 1.1 深入生产消费模型 1.2 条件变量误唤醒 2. POSIX信号量 2.1 信号量的概念 2.2 信号量的接口 3. 环形队列生产...
（一）Kafka介绍 Kafka 也是是我们在开发过程中经常会使用的一种消息队列 Kafka的核心概念包括Producer、Consumer、Broker、Topic、Partition和Offset。 Pr...
文章目录 1. 同步 1.1 同步与互斥的关系 1.2 条件变量 1.3 条件变量的接口 1.4 代码中易出问题的地方 1.5 条件变量的使用 2. 生产者消费者模型 2...
文章目录 一、发送者的可靠性 1.1 生产者重试机制： 1.2 生产者确认机制： 1.2.1 开启生产者确认： 1.2.2 定义 ReturnCallback： 1.2.3 定义 ConfirmCa...
一、客户端使用MQ基本代码示例 1、添加maven依赖 org.apache.rocketmq rocketmq-client 5.3.0 2、生产者代码示例 public class Producer { public static v...
一、实现流程 1. 定义线程安全的队列结构 需要封装std::queue，用std::mutex保证互斥访问，用std::condition_variable触发唤醒： #include #include #includ...
