Spring Boot Redis 任务队列实现：详细代码示例

以下是一个使用 Spring Boot 编写的 Redis 任务队列的示例代码：

首先，需要在 pom.xml 文件中添加 Redis 和 Spring Data Redis 的依赖：

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

接下来，创建一个名为 RedisTaskQueue 的类，用于处理 Redis 任务队列的数据写入和数据出队操作：

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.stereotype.Component;

@Component
public class RedisTaskQueue {

    private static final String QUEUE_KEY = 'task_queue';

    @Autowired
    private RedisTemplate<String, String> redisTemplate;

    public void enqueue(String data) {
        redisTemplate.opsForList().rightPush(QUEUE_KEY, data);
    }

    public String dequeue() {
        return redisTemplate.opsForList().leftPop(QUEUE_KEY);
    }
}

在上述代码中，我们使用了 RedisTemplate 来操作 Redis 队列。enqueue 方法将任务数据写入 Redis 队列的右侧，而 dequeue 方法则从 Redis 队列的左侧取出任务数据。

接下来，你可以在其他地方使用 RedisTaskQueue 来进行数据的写入和读取操作，例如在一个控制器中：

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RestController;

@RestController
public class TaskController {

    @Autowired
    private RedisTaskQueue taskQueue;

    @PostMapping("/task")
    public void addTask(@RequestBody String data) {
        taskQueue.enqueue(data);
    }

    @PostMapping("/task/dequeue")
    public String dequeueTask() {
        return taskQueue.dequeue();
    }
}

在上述代码中，我们使用了 @RestController 注解来指示该类是一个控制器。addTask 方法用于将任务数据写入 Redis 队列，而 dequeueTask 方法则从 Redis 队列中取出任务数据。

请注意，这只是一个简单的示例，你可以根据自己的需求对代码进行修改和扩展。