zoukankan      html  css  js  c++  java
  • 使用redis实现消息队列

    消息队列

    每当想到消息队列:我们都会想到RabbitMQ,ActiveMQ,RocketMQ,等等一些专业的消息中间件。但是如果我们做的事情比较简单,只有一个消息队列,要使用专业的消息中间件是非常麻烦的,因此我们可以使用Redis做消息队列。

    如果对消息的可靠性没有较高的要求的话,那么就可以使用Redis去实现。

    Redis做消息队列,可以使用List这个数据类型。List里面有两个命令,lpush/rpush操作来实现入队,然后使用lpop/rpop实现出队。

    在客户端中,我们会维护一个死循环来不停的从队列中pop读取数据,如果队列中有消息,则直接读取,如果没有,就会陷入死循环,直到下一次有消息进入。这种死循环会造成大量的资源浪费,这个时候我们可以使用,blpop/brpop去处理,相当于lpop的阻塞,当没有消息到来的时候就会休眠,直到消息来临,才唤醒,pop去读取数据。在java中可以使用while循环去实现。

    延迟消息队列

    延迟消息队列,可以用zset实现,里面有score分数浮动数值,数据 可以根据core排序,zset可用于高效的检索,我们可以将时间作为score,将value存到redis中,然后通过轮询的方式去读取消息出来,在当前时间的基础上在加5s,就可以实现延迟消息队列。

    首先,如果消息是字符串,直接发送就可以,如果是对象,则需要序列化,实现序列化接口或者使用JSON进行序列化和反序列化。

    步骤一:构造一个消息对象。

    步骤二:封装消息队列,包括消息入队,和消息出队

    步骤三:测试,构造消息队列,构造一个消息生产者,构造一个消息消费者。

  • 相关阅读:
    Spring基于纯注解的声明式事务控制
    Spring基于XML的声明式事务控制
    2.Jersey
    1.解读REST和JAX-RS
    getHibernateTemplate和getSession 区别, this.getHibernateTemplate().getSessionFactory().getCurrentSession()和OpenSession区别
    eclipse安装maven报错
    MyEclipse10 + tomcat8 64位
    理解MVC
    java编程规范
    c3p0详细配置
  • 原文地址:https://www.cnblogs.com/javazl/p/12729462.html
Copyright © 2011-2022 走看看