SpringBoot整合Redis发布订阅

### Spring Boot 整合 Redis 实现发布订阅 #### 添加依赖 为了使Spring Boot项目能够与Redis交互，需在`pom.xml`文件中加入必要的依赖项。这一步骤确保了应用程序具备访问Redis所需的功能库。 ```xml <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-data-redis</artifactId> </dependency> ``` 该操作使得应用可以通过Spring Data Redis来简化对Redis的操作[^4]。 #### 配置Redis连接参数 接着，在项目的配置文件（通常是`application.properties`或`application.yml`）里指定Redis服务器的相关设置，如主机地址、端口号以及认证密码等信息： ```properties spring.redis.host=localhost spring.redis.port=6379 ``` 这些属性定义了客户端如何定位并连接到远程的Redis实例上。 #### 创建消息监听器 构建一个实现了`MessageListener`接口的消息处理器类，用于处理接收到的信息。此类中的方法会在每次有新消息到达时被调用执行逻辑业务流程。 ```java @Component public class MessageReceiver implements MessageListener { @Override public void onMessage(Message message, byte[] pattern) { String channel = new String(message.getChannel()); String body = new String(message.getBody()); System.out.printf("Received '%s' from channel '%s'\n", body, channel); } } ``` 这段代码展示了怎样创建一个简单的接收者组件，它会打印出所有通过特定频道传入的内容[^1]。 #### 注册通道订阅者 为了让程序知道应该关注哪些通信渠道，还需要注册对应的ChannelTopic对象至容器内，并关联之前定义好的监听函数。 ```java @Configuration public class RedisConfig { @Bean public RedisMessageListenerContainer container(RedisConnectionFactory connectionFactory, MessageListenerAdapter listenerAdapter) { RedisMessageListenerContainer container = new RedisMessageListenerContainer(); container.setConnectionFactory(connectionFactory); Topics topic = new Topics(); // 自定义主题枚举或其他形式的主题集合 for(String key : topic.getKeys()){ Topic t = new ChannelTopic(key); container.addMessageListener(listenerAdapter, t); } return container; } @Bean MessageListenerAdapter listenerAdapter(MessageReceiver receiver) { return new MessageListenerAdapter(receiver, "onMessage"); } static enum Topics{ INSTANCE; List<String> getKeys(){ ArrayList<String> keys=new ArrayList<>(); keys.add("test-channel"); // 可以扩展成更多不同的topic名称列表 return keys; } } } ``` 此处介绍了如何利用`RedisMessageListenerContainer`将自定义的话题映射给相应的事件响应机制。 #### 构建信息发布方 最后，设计一个负责向目标频道广播通知的服务层实体——即所谓的“生产者”。这个角色的任务就是把待传递的数据打包好之后推送给其他成员节点。 ```java @Service public class PublisherService { private final RedisTemplate<String, Object> redisTemplate; public PublisherService(RedisTemplate<String, Object> redisTemplate){ this.redisTemplate = redisTemplate; } public void publish(String channelName,Object payload){ redisTemplate.convertAndSend(channelName,payload.toString()); } } ``` 以上片段解释了怎样封装一条命令以便于后续触发实际的通知动作。 ---