下面将详细介绍如何使用Spring Boot中的Redis实现这一目标。

首先，我们需要在项目中引入Redis相关的依赖。

在pom.xml文件中添加以下依赖：

    org.springframework.boot
    spring-boot-starter-data-redis

在application.properties文件中添加以下配置：

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

首先，我们需要创建一个消息监听器类，该类需要实现MessageListener接口，并重写onMessage方法。

在这个方法中，我们可以处理接收到的消息。

import org.springframework.data.redis.connection.Message;
import org.springframework.data.redis.connection.MessageListener;
import org.springframework.stereotype.Component;

@Component
public class RedisMessageListener implements MessageListener {

    @Override
    public void onMessage(Message message, byte[] pattern) {
        // 处理接收到的消息，例如打印到控制台
        System.out.println("Received message: " + new String(message.getBody()));
    }
}

在这个类中，我们可以使用RedisTemplate来发送消息。

为了确保消息能够被正确地发送，我们需要配置一个RedisMessagePublisher bean。

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.stereotype.Component;

@Component
public class RedisMessagePublisher {

    @Autowired
    private RedisTemplate redisTemplate;

    public void publish(String channel, Object message) {
        redisTemplate.convertAndSend(channel, message);
    }
}

例如，在一个控制器类中，我们可以创建一个方法来发布消息：

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RestController;

@RestController
public class RedisController {

    @Autowired
    private RedisMessagePublisher publisher;

    @GetMapping("/publish/{channel}/{message}")
    public String publish(@PathVariable("channel") String channel, @PathVariable("message") String message) {
        publisher.publish(channel, message);
        return "Message published: " + message;
    }
}

在这个类中，我们同样需要实现MessageListener接口，并重写onMessage方法。

在这个方法中，我们可以处理接收到的消息。

为了确保能够接收到所有的消息，我们需要订阅所有可用的频道。

为此，我们可以在构造函数中调用subscribe方法。

同时，为了避免阻塞主线程，我们可以使用setReceiveTimeout方法设置超时时间。

如果在指定的时间内没有接收到消息，那么订阅将会自动取消。

Springboot中Redis的订阅与发布机制详解 - 集智数据集