redis如何实现消息队列?

发布日期:2020年9月4日 21:06 星期五

  • 正文内容
  • 相关推荐

把瞬间服务器的请求处理换成异步处理,缓解服务器的压力,实现数据顺序排列获取。本文主要和大家分享redis如何实现消息队列,希望能帮助到大家。

 

redis怎么实现消息队列?

消息队列,通俗点说就是消息传输过程中暂时保存消息的容器,可以在不同平台、不同语言的应用之间传输数据,并且可以异步地实现数据写入,在处理大并发问题时能起到很好的效果。

说一下我现在使用消息队列的场景:我的系统需要实时接收来自客户端的请求(周期性请求),并且将请求的数据保存在数据库,每次请求的数据量很小,但是由于需要频繁操作数据库,所以系统遭遇到性能瓶颈。原先的想法是直接将这些数据保存在redis中,但仔细想想,虽然每次的数据量不大,但是由于数据是周期性的并且会不断增长,虽然redis也有持久化功能,但如果依靠持久化到硬盘来保存,就失去了redis作为内存数据库的优势,所以最终决定使用消息队列。

方式如下:

每次请求的数据直接写入消息队列,然后给予客户端响应,后台开启一个线程监听消息队列,一旦有数据写入,取得消息队列中的数据写入mysql数据库,这样就可以实现异步地将实时数据写入数据库,避免系统因直接操作数据库造成的瓶颈。

那么问题来了,使用哪种消息队列,现在比较主流的消息队列如:RabbitMQ,ActiveMQ等,其技术比较成熟效率也很高。但是考虑到项目本身已经使用了redis(做缓存),并且每次的数据量比较小,而redis不仅仅是一个key-value数据库,它支持丰富的数据类型,如HashMap、Set、List等,其中的List完全可以作为消息队列使用,并且redis的List支持blpop,brpop等阻塞式的命令,完全可以满足我的需求。简单的测试代码如下:

//产生数据

import redis.clients.jedis.Jedis;

public class RedisProducer {

    /** 

     * jedis操作List 

     */ 

    public static void main(String[] args){

        Jedis jedis = new Jedis("192.168.10.209", 6379); 

        for(int i = 0;i<10;i++) {

            jedis.lpush("informList","value_" + i);  

        }

        jedis.close();

    }

}

//消费数据

import java.util.List;

import redis.clients.jedis.Jedis;

public class RedisConsumer {

    /** 

     * jedis操作List 

     */ 

    public static void main(String[] args){

       ScheduleMQ mq = new ScheduleMQ();

       mq.start();

    }   

}

class ScheduleMQ extends Thread {

    @Override

    public void run() {

        while(true) {

            Jedis jedis = new Jedis("192.168.10.209", 6379);

            //阻塞式brpop,List中无数据时阻塞

            //参数0表示一直阻塞下去,直到List出现数据

            List<String> list = jedis.brpop(0, "informList");

            for(String s : list) {

                System.out.println(s);

            }

            jedis.close();

        }

    }

}
趣乐分享-趣乐资源网
如有密码均为:www.itql.cn
学到东西应该懂得感恩作者 无脑喷子永封IP段+删帐号所有评论
本站资源软件和源码 文章大部分为网上收集,如侵犯您的权利,请告知管理员,我们会及时删除,并向您赔礼道歉.

站长QQ:209993299  

作者资料
描述: 90后草根站长!不忘初心,方得始终!

本文标签:

文章标题:redis如何实现消息队列?

文章链接:https://www.itql.cn/post-3562.html

版权声明:若无特殊注明,本文皆为《钱哆哆》原创,转载请保留文章出处。