标签: java
所有带有标签 "java".
Kafka(七)集成Apache Avro+Apicurio Schema Registry以保障生产者与消费者的消息兼容性
针对Kafka消息格式变更引发的反序列化失败,介绍从JSON迁移到Avro并接入Apicurio Schema Registry的流程。涵盖Schema定义、Java类生成、生产与消费配置,以及版本兼容性检查,降低毒药消息带来的风险。
彻底理解Java NIO(三)Java实现 I/O多路复用+Reactor模式及开源框架代码解读
使用Java NIO实现Multi-Reactor服务器,介绍Channel、Buffer、Selector及wakeup的协作方式。说明跨线程注册通道和动态调整读写事件的处理,并结合Apache HttpClient与Kafka客户端源码分析NIO的应用。
彻底理解Java NIO(二)C语言实现 I/O多路复用+Reactor模式 服务器详解
从非阻塞I/O轮询的局限出发,通过C语言示例介绍select和epoll多路复用。解释文件描述符、水平触发与边缘触发,并逐步将连接管理、I/O事件处理和业务线程池组合为Multi-Reactor服务器。
彻底理解Java NIO(一)C语言实现 单进程+多进程+多线程 阻塞式I/O 服务器详解
通过C语言实现单进程、多进程、多线程及线程池形式的阻塞式Socket服务器,解释连接处理、文件描述符与资源释放。比较这些模型的并发特点和开销,为后续学习非阻塞I/O与I/O多路复用建立基础。