java redis 实现消息队列

Redis可以通过list数据结构来实现简单的消息队列。以下是一个简单的Java实现：

1. 安装Redis Java客户端

在pom.xml中添加以下依赖项：

<dependency>
    <groupId>redis.clients</groupId>
    <artifactId>jedis</artifactId>
    <version>3.5.3</version>
</dependency>

2. 连接Redis

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

3. 生产者将消息推送到队列中

jedis.lpush("queue", "message1", "message2", "message3");

4. 消费者从队列中获取消息

while (true) {
    List<String> messages = jedis.brpop(0, "queue");
    for (String message : messages) {
        System.out.println("Received message: " + message);
    }
}

brpop命令是一个阻塞命令，它将一直等待直到有消息可用。第一个参数指定等待时间，0表示无限等待。

完整的代码示例：

import redis.clients.jedis.Jedis;

import java.util.List;

public class RedisQueueExample {
    public static void main(String[] args) {
        Jedis jedis = new Jedis("localhost", 6379);

        // Producer
        jedis.lpush("queue", "message1", "message2", "message3");

        // Consumer
        while (true) {
            List<String> messages = jedis.brpop(0, "queue");
            for (String message : messages) {
                System.out.println("Received message: " + message);
            }
        }
    }
}