redis作为消息队列使用1 了解背景2 redis-消息队列使用

122 阅读 0 评论 81 点赞

我是靠谱客的博主会撒娇心情，这篇文章主要介绍redis作为消息队列使用1 了解背景2 redis-消息队列使用，现在分享给大家，希望可以做个参考。

1 了解背景

redis在我们的项目中一般作为缓存使用，在我们团队中偶然听到有在讨论要实现一个消息队列的功能。
领导在向一个负责实现此功能的同事下达要使用redis实现这项功能的时候，好像在沟通中出现了很多问题（注：我们的领导是一个从业Java开发十余年的骨灰级工程师，从我进入到这个项目组后学到了还是很多的东西，所以我对他还是比较崇拜的。至于要实现这个功能的同事，是刚刚入职的，了解不是很多，年龄也是不小了，据说也是工作过好多年的）。当领导初步向同事描述完需求的时候好像处于一种蒙蔽的状态，然后领导只能再进一步的和他说实现方法，至于最后沟通了多少遍我也是记不清了，就差直接给这个同事手把手的敲代码了。
我是因为不停的听他们再讨论这个话题，突然想到要是把这个任务给我，我是否能实现的了。redis做缓存使用我是用过很多了，消息队列我只了解过mq和kafka，redis作为消息队列使用我还真不了解。抱着侥幸的心理，趁着工作间隙赶紧自己去网上搜了一下，初步对这个知识点有了些了解，赶紧记录下来，以防过几天脑子再清零了。

2 redis-消息队列使用

为了简单实现，我直接在之前一个搭好的低配版springBoot项目中直接引入redis做了。
通过在网上的了解，redis能作为消息队列使用的有三种数据格式：

复制代码

1
2
3
4
List结构：基于List结构来模拟消息队列
PubSub：基本的点对点消息模型
Stream：较完善的消息队列模型

这边文章先记录一下对List结构的使用吧。。。。。
redis的List结构是一种双向链表的结构，他在头尾添加或者删除节点的时候是非常容易的。
二话不说直接上代码，所有的实现都在这里

复制代码

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
@RestController
@RequestMapping("/test")
public class TestController {

    @Autowired
    private RedisTemplate redisTemplate;

    @GetMapping("/list/{aa}")
    public void jinSave(@PathVariable("aa") String aa){
        redisTemplate.opsForList().leftPush("myQ",aa);
    }

    @GetMapping("/bb")//开启监听
    public void jinSave(){
        for(;;){
            System.out.println("开始获取数据");
            Object data = redisTemplate.opsForList().rightPop("myQ", 0l, TimeUnit.MINUTES);
            if(null == data){
                System.out.println("监听到的数据为空");
            }else {
                System.out.println("监听到的数据为:"+data);
            }

        }
    }
}

说一下消息队列，肯定要有生产者和消费者，我就写了两个接口分别代表。
“/list/{aa}”接口作为生产者使用，每调用一次就会向队列中插入一个节点，用到的就是push方法，但是push方法有两个，leftPush和rightPush，顾名思义就是在链表的左边插入或者右边插入。使用哪个都可以，注意在出队列的时候在另一边即可。
“/bb”接口作为消费者使用，这里注意在redis命令中有两种出队列命令，分别是（RPOP，LPOP）和（BRPOP，BLPOP），他们的区别是（BRPOP，BLPOP）是线程阻塞的，如果队列中没有消息，他就会一直等待，不会像（RPOP，LPOP）一样如果队列中没有消息直接报空，在java里面不是很友好，如果在redisTemplate.opsForList().rightPop(“myQ”, 0l, TimeUnit.MINUTES)中加入了时间就会自动变为（BRPOP，BLPOP），通过源码即可知道，下面是源码：

复制代码

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
/**
	 * Removes and returns last element in list stored at {@code key}.
	 *
	 * @param key must not be {@literal null}.
	 * @return can be {@literal null}.
	 * @see <a href="https://redis.io/commands/rpop">Redis Documentation: RPOP</a>
	 */
	@Nullable
	V rightPop(K key);

/**
	 * Removes and returns last element from lists stored at {@code key}. <br>
	 * <b>Blocks connection</b> until element available or {@code timeout} reached.
	 *
	 * @param key must not be {@literal null}.
	 * @param timeout
	 * @param unit must not be {@literal null}.
	 * @return can be {@literal null}.
	 * @see <a href="https://redis.io/commands/brpop">Redis Documentation: BRPOP</a>
	 */
	@Nullable
	V rightPop(K key, long timeout, TimeUnit unit);