2021-11-26 17:56:25

本文是SpringBoot+Kafka的实战讲解，如果对kafka的架构原理还不了解的读者，建议先看一下《大白话kafka架构原理》、《秒懂kafka HA（高可用）》两篇文章。一、生产者实践    普通生

2021-11-25 13:57:08

一、什么是消息中间件消息中间件顾名思义实现的就是在两个系统或两个客户端之间进行消息传送二、什么是ActiveMQActiveMQ是一种开源的基于JMS（Java Message Servie）规范的一种

2021-11-25 13:48:22

目录前言ActiveMQ 介绍队列（Queue）广播（Topic）同时支持队列（Queue）和广播（Topic）总结前言消息队列中间件是分布式系统中重要的组件，主要解决应用耦合、异步消息、流量削锋等问题，实现

2021-11-16 10:49:08

1.RabbitMQ是什么？RabbitMQ是一款开源的，Erlang编写的，基于AMQP（高级消息队列协议）协议的消息中间件。2.为什么要使用消息队列？从本质上来说是因为互联网的快速发展，业务不断扩张，促

2021-11-04 16:50:19

目录使用工厂方法 supplyAsync创建 CompletableFuture对比对CompletableFuture async的理解目前为止我们已经了解了如何通过编程创建 CompletableFuture 对象以及如何获取返

2021-10-27 18:49:18

目录一、进程（Process）二、线程（Thread）三、并发编程解决方案：四、多线程实现 （两种）1、第一种 函数方法2、第二种 类方法包装五、守护线程与子线程1、线程在分法有：2、守护线程六、

2021-09-28 18:49:50

目录spring boot自动配置方式整合spring boot自动配置的不足spring boot下手动配置kafka批量消费消息spring boot整合kafka报错spring boot自动配置方式整合spring boot具有

2021-09-14 12:58:40

目录什么是消息队列为什么需要消息队列常见的消息队列ActiveMQRabbitMQZeroMQKafkaRocketMQRabbitMQ 的部署和使用Python 编写生产者Python 编写消费者最后的话什么是消息队

2021-09-14 12:53:33

相关方法：wait():一旦执行此方法，当前线程就进入阻塞状态，并释放同步监视器。notify():一旦执行此方法，就会唤醒被wait的一个线程，如果有多个线程被wait,就唤醒优先级高的那个。n

2021-09-13 12:53:32

为什么使用生产者消费者模式在线程世界里，生产者就是生产数据的线程，消费者就是消费数据的线程。在多线程开发中，如果生产者处理速度很快，而消费者处理速度很慢，那么生产者就必须

2021-09-06 12:51:43

目录python 的生产者和消费者模式一、生产者消费者模式概述二、为什么使用生产者消费者模式三、什么是生产者消费者模式四、代码案例1、定义一个生产者2、定义一个消费者3、

2021-09-04 18:50:22

目录celery1.celery介绍1.1 celery应用举例1.2 Celery有以下优点1.3 Celery 特性2.工作原理2.1 Celery 扮演生产者和消费者的角色3.异步发短信1.settings同级目录下创建 cel

2021-09-03 18:54:35

目录【1】阻塞队列一、什么是阻塞队列？二、阻塞队列有什么用？三、阻塞队列的简单实用【2】Java 线程池一、我们为什么需要Java 线程池？使用它的好处是什么？二、Java中主要提供了

2021-09-03 16:50:28

目录1.celery介绍1.1 celery应用举例1.2 Celery有以下优点1.3 Celery 特性2.工作原理2.1 Celery 扮演生产者和消费者的角色3.异步发短信总结1.celery介绍1.1 celery应用举例

2021-09-02 10:50:51

目录1.celery异步消息队列介绍celery应用举例Celery有以下优点Celery 特性2.工作原理 *****Celery 扮演生产者和消费者的角色思维导图3.异步发短信3.1.settings同级目录下创

2021-08-16 11:52:18

目录一、单例模式饿汉模式懒汉模式懒汉模式二、堵塞队列实现BlockingQueue三、定时器总结一、单例模式单例模式是一种设计模式，针对一些特定的场景，研究出对应的解决方案，。有

2021-08-12 16:51:48

目录什么是延时任务延时任务的特点实现思路：代码实现1.消息模型2.RedisMq 消息队列实现类3.消息生产者4.消息消费者5. 消息执接口6. 任务类型的实现类：可以根据自己的情况去实

2021-08-06 18:54:39

目录面试题1：说说你对消息队列的理解，消息队列为了解决什么问题？解耦异步削峰追问1：消息队列有什么优缺点面试题2：对于消息中间机，你们是怎么做技术选型的？面试题3：如何确保消息正确

2021-07-31 14:51:36

java wait()/notify() 实现生产者消费者模式java中的多线程会涉及到线程间通信，常见的线程通信方式，例如共享变量、管道流等，这里我们要实现生产者消费者模式，也需要涉及到线程

2021-07-23 17:54:33

目录简单使用Spring Cloud Stream 构建基于RocketMQ的生产者和消费者生产者消费者Stream其他特性消息发送失败的处理消费者错误处理Spring Cloud Stream对Spring Cloud体系

2021-06-22 14:52:33

目录高并发模式初探C语言的高并发案例Java的高并发实现Go的高并发实现Rust的高并发实现总结高并发模式初探在这个高并发时代最重要的设计模式无疑是生产者、消费者模式，比如

2021-06-16 18:04:26

什么是阻塞队列在数据结构中，队列遵循FIFO（先进先出）原则。在java中，Queue接口定义了定义了基本行为，由子类完成实现，常见的队列有ArrayDeque、LinkedList等，这些都是非线程安全的，

2021-05-31 19:55:52

Java BlockingQueue接口java.util.concurrent.BlockingQueue表示一个可以存取元素，并且线程安全的队列。换句话说，当多线程同时从 JavaBlockingQueue中插入元素、获取元素的时

2021-05-21 10:58:14

互斥锁（mutex）为了更好地理解，互斥锁，我们可以首先来看这么一个应用场景：模拟车站卖票。模拟车站卖票场景说明：Yang车站售卖从亚特兰蒂斯到古巴比伦的时光飞船票；因为机会难得，所以

2021-03-18 20:55:10

概述在本文中，我们将介绍JCTools（Java并发工具）库。简单地说，这提供了许多适用于多线程环境的实用数据结构。非阻塞算法传统上，在可变共享状态下工作的多线程代码使用锁来确保数