README-zh.md

LOKI

阅读其他语言版本: English

介绍

统一的消息发送、消费框架，简化mq使用。提供统一的消息发送、消费接口，支持多种mq实现，目前支持rocketmq 4.x 以上、Kafka 2.x 以上、Redis 5.X 以上

文档

https://guoshiqiufeng.github.io/loki-doc/

开发框架

• Java 21
• Gradle 8.7
• Spring Boot 2.7.18
• rocketmq-client 5.2.0
• rocketmq-client-java 5.0.6 (RocketMQ-grpc)
• kafka-clients 3.7.0
• jedis 5.1.2
• spring-data-redis (可选)

功能

• 可用 - ✅
• 进行中 - 🚧

功能	Rocketmq-gRPC	Rocketmq-Remoting	Kafka	Redis
【BaseMapper】Send standard messages	✅	✅	✅	✅
【BaseMapper】Send async messages	✅	✅	✅	✅
【BaseMapper】Send timed/delay messages	✅	✅	🚧	✅
【LokiClient】Send standard messages	✅	✅	✅	✅
【LokiClient】Send async messages	✅	✅	✅	✅
【LokiClient】Send timed/delay messages	✅	✅	🚧	✅
Producer with transactional messages	🚧	🚧	🚧	🚧
【Topic】 consumer with message listener	✅	✅	✅	✅
【Topic-Pattern】 consumer with message listener	🚧	🚧	✅	✅

注：

• Rocketmq-Remoting Send timed/delay messages 仅支持 rocketmq 5.0 以上版本
• Redis Send timed/delay messages 需要 redis 开启 notify-keyspace-events Ex 通知

使用

可参考 loki-test