# redis-mq

**Repository Path**: mqredis/redis-mq

## Basic Information

- **Project Name**: redis-mq
- **Description**: No description available
- **Primary Language**: Java
- **License**: MIT
- **Default Branch**: master
- **Homepage**: None
- **GVP Project**: No

## Statistics

- **Stars**: 5
- **Forks**: 0
- **Created**: 2025-08-03
- **Last Updated**: 2025-09-25

## Categories & Tags

**Categories**: Uncategorized

**Tags**: None

## README

基于 Redis 的轻量级消息队列中间件，适用于简单异步和延时任务场景。

## 项目简介

RedisMQ 是一个使用 Redis 作为底层存储实现的简单、高效、可靠的消息队列服务。它适用于需要轻量级消息队列的场景，例如任务调度、事件通知、异步处理等。项目设计目标是易于部署、使用和扩展。

## 功能特性

*   支持生产者-消费者模型
*   支持消息持久化（依赖 Redis 持久化机制）
*   支持多主题（Topic）和消费组（Consumer Group）
*   提供简单易用的 API 接口

## 安装与使用

### 安装依赖

*   JDK8

### 快速开始

1. 添加依赖：

   ```bash
   <dependency>
       <groupId>io.gitee.mqredis</groupId>
       <artifactId>redis-mq</artifactId>
       <version>1.0.2</version>
   </dependency>
   ```

2. 修改配置文件中的 Redis 连接信息（如地址、端口、密码等）。

   ```yaml
   spring:
       redis:
       # 地址
       host: 127.0.0.1
       # 端口，默认为6379
       port: 6379
       # 数据库索引
       database: 0
       # 密码
       password: 123456
   	
   ```

3.  使用客户端发送和消费消息：

    ```java
    redisMQTemplate.addQueue("test_queue",1);
    
    # 消费
    @RedisMQListener(queue = "test_queue")
     public class TestMessageQueue extends AbstractMessageQueue<Integer> {
         @Override
         public void onMessage(Integer message) {
             log.info("TestMessageTask onMessage: {}", message);
         }
     
     }
    ```

## 项目结构

## 贡献指南

欢迎贡献代码和改进文档！请遵循以下步骤：

1.  Fork 本项目
2.  创建新分支 (`git checkout -b feature/new-feature`)
3.  提交代码 (`git commit -am 'Add new feature'`)
4.  Push 到分支 (`git push origin feature/new-feature`)
5.  提交 Pull Request

## 开源协议

本项目遵循 MIT License，请查看 [LICENSE](LICENSE) 文件以获取更多信息。