springboot redis 队列

### 使用 Spring Boot 实现 Redis 消息队列 在构建基于 Spring Boot 的应用程序时，可以通过集成 Redis 来创建高效的消息队列系统。此过程涉及几个关键组件的配置和编码工作。 #### 添加 Maven 依赖项 要在项目中启用对 Redis 数据库的支持，需向 `pom.xml` 中加入特定的依赖项： ```xml <dependencies> <!-- 引入 spring-boot-starter-data-redis --> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-data-redis</artifactId> </dependency> <!-- 基础启动器 --> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter</artifactId> </dependency> </dependencies> ``` 这些依赖允许应用连接到 Redis 并执行基本的数据操作[^3]。 #### 配置 Redis 连接属性 接下来，在项目的 `application.properties` 或者 `application.yml` 文件里定义必要的 Redis 设置参数，比如主机地址、端口号以及密码等信息: ```properties # application.properties 示例 spring.redis.host=localhost spring.redis.port=6379 ``` 对于更复杂的场景，还可以进一步调整其他选项以优化性能或满足安全需求。 #### 创建消息生产者服务类 为了发送消息至指定频道，开发者应编写一个名为 `MessageProducerService` 的 Java 类，其中包含了用于发布消息的方法： ```java import org.springframework.beans.factory.annotation.Autowired; import org.springframework.data.redis.core.StringRedisTemplate; import org.springframework.stereotype.Service; @Service public class MessageProducerService { private final StringRedisTemplate stringRedisTemplate; @Autowired public MessageProducerService(StringRedisTemplate stringRedisTemplate) { this.stringRedisTemplate = stringRedisTemplate; } /** * 发布一条新消息给定的主题(channel). */ public void sendMessageToChannel(String channel, String message){ stringRedisTemplate.convertAndSend(channel,message); } } ``` 上述代码片段展示了如何利用 `StringRedisTemplate` 对象来广播自定义字符串形式的信息给目标通道[^1]。 #### 构建消费者监听逻辑 为了让某些部分能够接收来自某个主题的通知，还需要建立相应的侦听机制。这通常涉及到声明带有 `@RedisListener` 注解的方法，并指明其关注的具体频道名称： ```java import lombok.extern.slf4j.Slf4j; import org.springframework.data.redis.connection.Message; import org.springframework.data.redis.listener.KeyExpirationEventMessageListener; import org.springframework.data.redis.listener.RedisMessageListenerContainer; import org.springframework.messaging.handler.annotation.Payload; import org.springframework.stereotype.Component; @Component @Slf4j public class ChannelMessageListener extends KeyExpirationEventMessageListener { protected ChannelMessageListener(RedisMessageListenerContainer listenerContainer) { super(listenerContainer); } @Override public void onMessage(Message message, byte[] pattern) { log.info("Received Message: " + new String(message.getBody())); } // 如果需要针对具体channel，则可以使用如下方式注册listener // @RedisListener(topics = {"${topic.name}"}) // public void handleTopic(@Payload String payload){ // System.out.println("received topic:"+payload); // } } ``` 这段程序会自动捕获所有匹配模式下的事件通知，并打印出收到的内容日志记录[^2]。 通过以上步骤，就可以成功建立起一套完整的 Spring Boot 应用内嵌式的 Redis 消息队列解决方案了。