Spring Boot Redis 实现消息队列：完整代码示例

以下是使用 Spring Boot 和 Redis 实现一个简单的消息队列的示例代码：

首先，我们需要引入 Redis 的依赖：

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-data-redis</artifactId>
</dependency>

然后，创建一个消息队列的接口：

public interface MessageQueue {
    void enqueue(String message);
    String dequeue();
}

接下来，实现该接口：

@Component
public class RedisMessageQueue implements MessageQueue {

    private final RedisTemplate<String, String> redisTemplate;
    private final String queueKey = 'messageQueue';

    public RedisMessageQueue(RedisTemplate<String, String> redisTemplate) {
        this.redisTemplate = redisTemplate;
    }

    @Override
    public void enqueue(String message) {
        redisTemplate.opsForList().rightPush(queueKey, message);
    }

    @Override
    public String dequeue() {
        return redisTemplate.opsForList().leftPop(queueKey);
    }
}

在上面的代码中，我们使用 Redis 的 List 数据结构实现了一个简单的消息队列。enqueue 方法用于将消息写入队列的末尾，dequeue 方法用于从队列的头部取出消息。

然后，我们可以在其他地方使用该消息队列：

@RestController
public class MessageController {

    private final MessageQueue messageQueue;

    public MessageController(MessageQueue messageQueue) {
        this.messageQueue = messageQueue;
    }

    @PostMapping('/enqueue')
    public void enqueueMessage(@RequestBody String message) {
        messageQueue.enqueue(message);
    }

    @GetMapping('/dequeue')
    public String dequeueMessage() {
        return messageQueue.dequeue();
    }
}

在上面的代码中，我们使用 Spring MVC 创建了一个简单的 REST 控制器。通过调用 /enqueue 接口可以将消息写入队列，通过调用 /dequeue 接口可以从队列中取出消息。

最后，我们需要配置 Redis 连接信息：

spring.redis.host=127.0.0.1
spring.redis.port=6379

以上就是使用 Spring Boot 和 Redis 实现一个简单的消息队列的详细代码。请注意，这只是一个基础示例，实际应用中需要根据具体需求进行适当的优化和改进。