WeJob - Java 本地轻量级消息队列框架
项目简介
WeJob 是一款基于 Java 开发的本地化消息队列框架，专注于简化分布式系统中的异步通信与任务调度。其核心设计参考 Kafka 的分区存储与高吞吐特性，结合本地文件系统的持久化能力，适用于轻量级场景下的消息持久化、削峰填谷及系统解耦需求34。
核心特性
轻量级本地存储
基于文件系统的消息持久化机制，支持消息顺序写入与分区管理，确保数据不丢失12
文件滚动策略自动清理已消费数据，避免存储空间无限增长1
高吞吐设计
采用批量消息提交机制，优化磁盘 I/O 性能，单机支持每秒万级消息处理34
零拷贝技术减少内存拷贝开销，提升数据传输效率4
多线程支持
提供生产者-消费者线程模型，支持并发消息提交与顺序消费（当前线程模型存在锁竞争优化空间）15
内置 MessageProducerTest 测试用例验证多线程场景下的消息完整性1
点击空白处退出提示
评论