<dependency>    <groupId>com.ipet</groupId>    <artifactId>quick-queue-redis</artifactId>    <version>1.0-SNAPSHOT</version></dependency>

使用spring redis配置spring.redis.password=wIvJt@_redisspring.redis.database=1spring.redis.sentinel.master=sharddev6389spring.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=1000spring.redis.pool.max-active=-1

    //通过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."));        }    }

    //继承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);        }    }