在Spring Boot中，可以使用spring-boot-starter-data-redis库来实现Redis消息的订阅与分布。以下是一个简单的例子，展示如何使用Spring Data Redis实现发布/订阅模式。
首先，在pom.xml中添加依赖：
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-redis</artifactId>
</dependency>
然后，配置Redis消息监听器容器：
@Configuration
public class RedisConfig {
@Autowired
private RedisConnectionFactory redisConnectionFactory;
@Bean
RedisMessageListenerContainer redisMessageListenerContainer() {
RedisMessageListenerContainer container = new RedisMessageListenerContainer();
container.setConnectionFactory(redisConnectionFactory);
return container;
}
}
创建一个消息监听器来处理接收到的消息：
@Component
public class RedisMessageSubscriber 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);
// 根据接收到的消息进行业务逻辑处理
}
}
最后，发布消息：
@Service
public class RedisMessagePublisher {
@Autowired
private StringRedisTemplate stringRedisTemplate;
public void publish(String channel, String message) {
stringRedisTemplate.convertAndSend(channel, message);
}
}
在上述代码中，我们定义了一个配置类RedisConfig来创建RedisMessageListenerContainer，并设置了连接工厂。我们还实现了一个RedisMessageSubscriber类来监听消息，并在其中处理接收到的消息。RedisMessagePublisher服务用于发布消息到指定的频道。
要订阅一个频道，你需要在RedisMessageSubscriber中设置你感兴趣的频道，并将其注册到RedisMessageListenerContainer。
@Component
public class RedisMessageSubscriber implements MessageListener {
@Autowired
private RedisMessageListenerContainer redisMessageListenerContainer;
@PostConstruct
public void subscribe()