Skip to content

Latest commit

 

History

History
55 lines (40 loc) · 2.87 KB

README.md

File metadata and controls

55 lines (40 loc) · 2.87 KB
Raw

LOKI

Maven central License CodeQL Commit-Activity

Read in other languages: 简体中文

Introduction

Unified message sending and consumption framework that simplifies the use of message queues. Provides unified message sending and consumption interfaces, supports multiple message queue implementations, and currently supports RocketMQ 4.x and above, Kafka 2.x and above, and Redis 5.X and above

Documentation

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

Development Framework

  • Java 21
  • Gradle 8.8
  • Spring Boot 2.7.18
  • rocketmq-client 5.2.0
  • rocketmq-client-java 5.0.7 (RocketMQ-grpc)
  • kafka-clients 3.7.0
  • jedis 5.1.3
  • spring-data-redis (Optional)

Features

  • Available - ✅
  • In progress - 🚧
Features 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 🚧 🚧 ✅ ✅

Note:

  • Rocketmq-Remoting Send timed/delay messages is only supported in rocketmq 5.0 and above
  • Redis Send timed/delay messages requires Redis to enable notify-keyspace-events Ex notification.

Use

Can be referred to loki-test