美文网首页Java高开发Java 杂谈Java
quick-queue-redis redis队列实现的消息队列

quick-queue-redis redis队列实现的消息队列

作者: java高并发 | 来源:发表于2019-06-03 16:45 被阅读9次

    消息队列

    基于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等多个知识点的架构资料)合理利用自己每一分每一秒的时间来学习提升自己,不要再用"没有时间“来掩饰自己思想上的懒惰!趁年轻,使劲拼,给未来的自己一个交代!

    相关文章

      网友评论

        本文标题:quick-queue-redis redis队列实现的消息队列

        本文链接:https://www.haomeiwen.com/subject/gizcxctx.html