简述

在本博客中，我们将会创建一个reids的消息队列，Redis可以被当成消息队列使用。消息会被存放在一个key-value集合中。

redis消息生产者使用RPUSH命令将消息添加到队列的尾部，而消息消费者可以使用BLPOP命令获取列表开头的消息，使用FIFO(先进先出)规则。

注意：本博客前置条件，熟悉redis并且知道如何启动redis服务器

Redis 队列实现需要的maven依赖

xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"

xsi:schemaLocation="http://maven.apache.org/POM/4.0.0

http://maven.apache.org/xsd/maven-4.0.0.xsd">

4.0.0

com.leftso.redis

message-queue

1.0.0-SNAPSHOT

REDDIS - ${project.artifactId}

http://leftso.com

redis.clients

jedis

2.7.2

Redis消息队列生产者

我们先使用rpush()方法将消息发布到mq-key队列中。这条消息将会添加到列表的最末端。

import redis.clients.jedis.Jedis;

public class MessageProducer {

public static void main(String... args) {

Jedis jedis = new Jedis("localhost");

jedis.rpush("mq-key", "first message");

jedis.rpush("mq-key", "second message");

jedis.rpush("mq-key", "third message");

}

}

Redis消息队列消费者

我们可以使用lpop()或者blpop()方法来消费消息。下面我们将会使用阻塞的lpop 方法，就如方法名称一样，使用该方法线程会进入阻塞状态直到下一个消息过来。我们可以设置一个等待消息的超时时间。下面设置的超时时间为0，表示永久等待没有超时时间。

import redis.clients.jedis.Jedis;

import java.util.List;

public class MessageConsumer {

private static final int TIMEOUT = 0;

public static void main(String... args ) {

Jedis jedis = new Jedis("localhost");

while(true){

System.out.println("Waiting for a message in the queue");

List messages = jedis.blpop(TIMEOUT, "mq-key");

System.out.println("received message with key:" + messages.get(0) + " with value:" + messages.get(1));

}

}

}

启动消息队列消费者

$title(console)

Waiting for a message in the queue

启动消息队列生产者

$title(console)

Waiting for a message in the queue

received message with key:mq-key with value:first message

Waiting for a message in the queue

received message with key:mq-key with value:second message

Waiting for a message in the queue

received message with key:mq-key with value:third message

Waiting for a message in the queue

参考文档：