Movatterモバイル変換

[0]ホーム
URL:

Skip to content

Navigation Menu

Sign in
Appearance settings

Search code, repositories, users, issues, pull requests...

Provide feedback

We read every piece of feedback, and take your input very seriously.

Saved searches

Use saved searches to filter your results more quickly

 Sign up
Appearance settings

Simplifying mq usage

License

NotificationsYou must be signed in to change notification settings

guoshiqiufeng/loki

Repository files navigation

Maven centralLicenseCodeQLCommit-Activity

Read in other languages:简体中文

Introduction

Unified message sending and consumption framework that simplifies the use of message queues. Provides unified messagesending and consumption interfaces, supports multiple message queue implementations, and currently supports RocketMQ4.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 - 🚧
FeaturesRocketmq-gRPCRocketmq-RemotingKafkaRedis
【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-RemotingSend timed/delay messages is only supported inrocketmq 5.0 and above
  • RedisSend timed/delay messages requires Redis to enablenotify-keyspace-events Ex notification.

Use

Can be referred toloki-test

[8]ページ先頭
©2009-2025 Movatter.jp