文章目录 一、AMQP 二、Spring AMQP 2.1 介绍 2.2 SpringAMQP发送消息 2.3 SpringAMQP接收消息 2.4 WorkQueue模型 2.4.1 概念 2.4.2 示例 2.5 发布...
什么是MQ MQ全称是Message Queue,即消息对列！消息队列是典型的：生产者、消费者模型。生产者不断向消息队列中生产消息，消费者不断的从...
前 言 🍉 作者简介：半旧518，长跑型选手，立志坚持写10年博客，专注于java后端 ☕专栏简介：纯手打总结面试题...
1.认识channel 管道本质是一个队列（先进先出） 管道是线程安全的（自带锁) 管道解决协程中资源同步问题 2.声明...
需求 构造RocketMQ生产者。 在服务启动时构造生产者，在服务关闭时销毁生产者。 代码模板 抽象类 @Slf4j public abstract class AbstractMqPro...
目录 一、线程同步的概念 1. 饥饿状态 2. 同步的概念 二、生产者消费者模型 1. 生产者消费者模型基本概念 2. 生产者、消费者之间的关系 2.1 消费者与消费者...
目录 一、Flink概述 二、单机版安装配置 1.开启hadoop 2.解压Flink压缩包 3.修改文件名 4.开启客户端 5.访问webUI 三、集群配置 1.jobmanager配置 2.master...
Kafka基础篇学习笔记整理 生产者 数据发送流程 批量与定时发送 缓冲区大小 send发送消息 消息可靠性 发布确认机制 重试机制 消息顺序性问题 如何避...
文章目录 阻塞队列概念与基本使用 生产者消费者模型 生产者消费者初心是什么？ 什么叫耦合？ 什么是高内聚低耦合？ 阻塞队列削峰填...
