在Spring Boot中整合Redis监听数据变化，可以使用spring-boot-starter-data-redis依赖，并利用RedisMessageListenerContainer来实现。以下是一个基本的实现示例：
- 添加依赖到
pom.xml：
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-redis</artifactId>
</dependency>- 配置
RedisMessageListenerContainer：
@Configuration
public class RedisConfig {
@Autowired
private RedisConnectionFactory redisConnectionFactory;
@Bean
RedisMessageListenerContainer redisContainer() {
final RedisMessageListenerContainer container = new RedisMessageListenerContainer();
container.setConnectionFactory(redisConnectionFactory);
return container;
}
}- 实现
MessageListener接口来监听消息：
@Component
public class RedisMessageListener implements MessageListener {
@Override
public void onMessage(Message message, byte[] pattern) {
// 对接收到的消息进行处理
String receivedMessage = new String(message.getBody(), StandardCharsets.UTF_8);
System.out.println("Received Message: " + receivedMessage);
// 如果有必要，可以对pattern进行处理
String receivedPattern = new String(pattern, StandardCharsets.UTF_8);
System.out.println("Received Pattern: " + receivedPattern);
}
}- 在Spring Boot应用程序中启动RedisMessageListenerContainer：
@SpringBootApplication
public class RedisListeningApplication {
public static void main(String[] args) {
SpringApplication.run(RedisListeningApplication.class, args);
}
@Autowired
private RedisMessageListenerContainer redisContainer;
@Autowired
private RedisMessageListener redisMessageListener;
@PostConstruct
public void startRedisListening() {
Topic topic = new ChannelTopic("yourTopic"); // 你的监听主题
redisContainer.addMessageListener(redisMessageListener, topic);
}
}确保Redis服务器运行并且你的应用程序配置了正确的Redis连接信息。当在指定主题上发布消息时，RedisMessageListener会接收到消息并处理。