消息队列

基于redis实现的消息队列

依赖

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

环境

使用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

调用

生产者

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

git地址：https://gitee.com/yangyale/quick-queue-redis

欢迎工作一到五年的Java工程师朋友们加入JavaQQ群：219571750，群内提供免费的Java架构学习资料（里面有高可用、高并发、高性能及分布式、Jvm性能调优、Spring源码，MyBatis，Netty,Redis,Kafka,Mysql,Zookeeper,Tomcat,Docker,Dubbo,Nginx等多个知识点的架构资料）合理利用自己每一分每一秒的时间来学习提升自己，不要再用"没有时间“来掩饰自己思想上的懒惰！趁年轻，使劲拼，给未来的自己一个交代！