# quick-queue-redis

**Repository Path**: yangyale/quick-queue-redis

## Basic Information

- **Project Name**: quick-queue-redis
- **Description**: 通过redis队列实现的消息队列
- **Primary Language**: Java
- **License**: GPL-3.0
- **Default Branch**: master
- **Homepage**: None
- **GVP Project**: No

## Statistics

- **Stars**: 115
- **Forks**: 30
- **Created**: 2018-03-19
- **Last Updated**: 2025-04-30

## Categories & Tags

**Categories**: message-server

**Tags**: None

## README

消息队列
=============================
### 基于redis实现的消息队列

#### 依赖
```xml
<dependency>
    <groupId>com.ipet</groupId>
    <artifactId>quick-queue-redis</artifactId>
    <version>1.0-SNAPSHOT</version>
</dependency>
```
#### 环境
```properties
使用spring redis配置
spring.redis.password=wIvJt@_redis
spring.redis.database=1
spring.redis.sentinel.master=sharddev6389
spring.redis.sentinel.nodes=192.168.11.29:26002,192.168.11.32:26002,192.168.11.20:26002
#redis IO 10 ms 超时
spring.redis.timeout=1000
spring.redis.pool.max-active=-1
```
#### 调用
##### 生产者
```java
    //通过RedisQueueScanner注入消息队列接口
    @RedisQueueScanner("com.ipet.test.queue")
    @Configuration
    @SpringBootApplication
    public class ServiceExecutor {
    
        public static void main(String[] args) throws InterruptedException {
            new SpringApplication(ServiceExecutor.class).run(args);
            new CountDownLatch(1).await();
        }
    }
    
    //通过RedisQueue接口定义消息队列生产者interface
    //通过RedisQueueProvider接口定义生产者队列名称
    @RedisQueue
    public interface TestQueue {
    
        @RedisQueueProvider("queue1")
        void sendMessage1(String msg);
    
        @RedisQueueProvider("queue2")
        void sendMessage2(List<String> msgList);
    }
    
    //消息发送
    @Component
    @EnableScheduling
    public class QueueTask {
        @Autowired
        private TestQueue testQueue;
    
        @Autowired
        private TestQueue1 testQueue1;
    
        @Scheduled(cron = "0/5 * * * * ?")
        public void queue1Task(){
            //定义好消息队列的接口可直接调用，不需要管实现，实现由代理完成
            testQueue.sendMessage1("Msg:[" + (int)(Math.random() * Integer.MAX_VALUE) + "]");
        }
    
        @Scheduled(cron = "0/10 * * * * ?")
        public void queue2Task(){
            testQueue.sendMessage2(Arrays.asList("Hello ","World."));
        }
    
        @Scheduled(cron = "0/5 * * * * ?")
        public void queue3Task(){
            testQueue1.sendMessage1("Msg:[" + (int)(Math.random() * Integer.MAX_VALUE) + "]");
        }
    
        @Scheduled(cron = "0/10 * * * * ?")
        public void queue4Task(){
            testQueue1.sendMessage2(Arrays.asList("Hello ","World."));
        }
    }
```
##### 消费者
```java
    //继承AbstractRedisQueueConsumer并通过RedisQueueConsumer注解标明队列名称即可
    @RedisQueueConsumer("queue1")
    public class Message1Consumer extends AbstractRedisQueueConsumer<String> {
        private Logger logger = LoggerFactory.getLogger(getClass());
        @Override
        public void doConsume(String message) {
            logger.info("Message1 : [{}]",message);
        }
    }
```