logo
publist
写文章

简介

该用户还未填写简介

擅长的技术栈

可提供的服务

暂无可提供的服务

Kafka消费者多线程实现

Kafka的生产者KafkaProducer是线程安全的,然而消费者KafkaConsumer却是非线程安全的。KafkaConsumer定义了一个acquire()方法,用来检测当前是否只有一个线程在操作,若有其它线程正在操作会抛出ConcurrentModifycationException异常:java.util.ConcurrentModifycationException: K...

Java死锁及如何解决死锁

死锁:是指两个或两个以上的进程在执行过程中,由于竞争资源或者由于彼此通信而造成的一种阻塞的现象,若无外力作用,它们都将无法推进下去。此时称系统处于死锁状态或系统产生了死锁。1、普通死锁1.1 死锁代码下面通过代码演示:public class NormalDeadLock {//定义两个对象锁private static Object valueFirst...

#java
Kafka高性能之页缓存(page cache)使用

页缓存是操作系统实现的一种主要的磁盘缓存,以此用来减少对磁盘I/O的操作。具体来说,就是把磁盘中的数据缓存到内存中,把对磁盘的访问变为对内存的访问。为了弥补性能上的差异 ,现代操作系统越来越多地将内存作为磁盘缓存,甚至会将所有可用的内存用途磁盘缓存,这样当内存回收时也几乎没有性能损失,所有对于磁盘的读写也将经由统一的缓存。当一个进程准备读取磁盘上的文件内容时,操作系统会先查看待读取的数据所在的页(

#大数据#kafka
到底了