springboot2.5 集成redis消息队列 list 操作

### 集成 Redis 作为消息队列并执行 List 操作

为了在 Spring Boot 2.5 中集成 Redis 并将其用作消息队列，可以利用 `spring-data-redis` 库来实现这一目标。下面是一个简单的教程，展示了如何配置和使用 Redis 进行基本的消息队列操作。

#### 添加依赖项

首先，在项目的 `pom.xml` 文件中添加必要的 Maven 依赖：

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

<!-- 如果需要连接到远程Redis实例 -->
<dependency>
    <groupId>io.lettuce.core</groupId>
    <artifactId>lettuce-core</artifactId>
</dependency>

这会引入用于与 Redis 数据库交互所需的核心组件和支持异步处理的能力[^1]。

#### 配置 Redis 属性

接着，在应用程序属性文件 (`application.properties`) 或 YAML 文件 (`application.yml`) 中定义 Redis 的连接参数：

对于 `.properties` 文件:

spring.redis.host=localhost
spring.redis.port=6379

对于 `.yml` 文件:

spring:
  redis:
    host: localhost
    port: 6379

这些设置指定了本地运行的 Redis 实例的位置；如果是在云环境中部署，则应替换为实际的服务地址和端口信息。

#### 创建服务类来进行列表(List)操作

创建一个新的 Java 类用来封装对 Redis 列表的操作逻辑。这里提供了一个名为 `MessageQueueService` 的例子：

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.connection.RedisConnectionFactory;
import org.springframework.data.redis.core.ListOperations;
import org.springframework.stereotype.Service;

@Service
public class MessageQueueService {

    private final ListOperations<String, String> listOps;

    @Autowired
    public MessageQueueService(RedisConnectionFactory connectionFactory){
        var template = new org.springframework.data.redis.core.StringRedisTemplate(connectionFactory);
        this.listOps = template.opsForList();
    }

    /**
     * 向指定键对应的列表左侧插入一条或多条记录.
     */
    public void pushLeft(String key, String... values){
        listOps.leftPush(key,values);
    }

    /**
     * 获取并移除指定键对应列表最右侧的一条记录.
     */
    public String popRight(String key){
        return listOps.rightPop(key);
    }
}

上述代码片段实现了两个主要方法：一个是向给定名称的列表左端追加新元素(`pushLeft`)，另一个是从右端取出第一个可用项目(`popRight`)。通过这种方式模拟了先进先出(FIFO)的行为模式。

#### 测试功能

最后一步是编写单元测试或控制器接口去验证以上实现的功能是否正常工作。例如，可以通过 RESTful API 来触发消息入队/出队动作：

@RestController
@RequestMapping("/api/messagequeue")
public class MessageQueueController {
    
    private final MessageQueueService mqService;

    @Autowired
    public MessageQueueController(MessageQueueService mqService){
        this.mqService=mqService;
    }

    @PostMapping("/enqueue/{key}")
    ResponseEntity<Void> enqueue(@PathVariable String key,@RequestParam String value){
        mqService.pushLeft(key,value);
        return ResponseEntity.ok().build();
    }

    @GetMapping("/dequeue/{key}")
    ResponseEntity<String> dequeue(@PathVariable String key){
        Optional<String> resultOpt = Optional.ofNullable(mqService.popRight(key));
        return resultOpt.map(ResponseEntity::ok).orElseGet(() -> ResponseEntity.noContent().build());
    }
}

这段代码提供了两个 HTTP 终结点 `/api/messagequeue/enqueue/:key?value=` 和 `/api/messagequeue/dequeue/:key` ，分别允许客户端发送 POST 请求以将数据放入队列以及 GET 请求从中获取下一个待处理的数据项。