分类：生产者消费者

2021
02-21

Java实现Kafka生产者和消费者的示例

Kafka简介Kafka是由Apache软件基金会开发的一个开源流处理平台，由Scala和Java编写。Kafka的目标是为处理实时数据提供一个统一、高吞吐、低延迟的平台。方式一：kafka-clients引入依赖在pom.xml文件中，引入kafka-clients依赖：<dependency><groupId>org.apache.kafka</groupId><artifactId>kafka-clients</artifactId><version>2.3.1</version></dependency>生产者创建一个KafkaProducer的生产者实例：@Configurationpublic... 继续阅读 >

2020
10-08

Java中生产者消费者问题总结

生产者-消费者算是并发编程中常见的问题。依靠缓冲区我们可以实现生产者与消费者之间的解耦。生产者只管往缓冲区里面放东西，消费者只管往缓冲区里面拿东西。这样我们避免生产者想要交付数据给消费者，但消费者此时还无法接受数据这样的情况发生。waitnotify这个问题其实就是线程间的通讯，所以要注意的是不能同时读写。生产者在缓冲区满的时候不生产，等待；消费者在缓冲区为空的时候不消费，等待。比较经典的做法是wait和notify... 继续阅读 >