java 实时推送 redis_java spring redis 消息发布与监听

在Java中实现Redis的实时推送可以使用Redis的发布/订阅功能。Redis的发布/订阅功能是一种消息传递模式，它允许发送者（发布者）向一个或多个接收者（订阅者）发送消息。下面是使用Spring Boot和Redis实现Redis消息发布与监听的示例代码：

1. 添加Redis依赖

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

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-data-redis</artifactId>
</dependency>

2. 配置Redis连接

在application.properties文件中添加Redis连接配置：

spring.redis.host=127.0.0.1
spring.redis.port=6379

3. 定义消息监听器

定义一个Redis消息监听器，用于接收订阅的消息。示例代码如下：

@Component
public class RedisMessageListener implements MessageListener {

    @Override
    public void onMessage(Message message, byte[] pattern) {
        System.out.println("Received message: " + message.toString());
    }
}

4. 发布消息

在需要发布消息的地方，注入RedisTemplate对象，调用convertAndSend方法即可发送消息。示例代码如下：

@Autowired
private RedisTemplate<String, Object> redisTemplate;

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

5. 订阅消息

在启动类中定义Redis消息监听器容器，并将Redis消息监听器注册到容器中。示例代码如下：

@SpringBootApplication
public class Application implements CommandLineRunner {

    @Autowired
    private RedisMessageListener redisMessageListener;

    public static void main(String[] args) {
        SpringApplication.run(Application.class, args);
    }

    @Override
    public void run(String... args) throws Exception {
        RedisMessageListenerContainer container = new RedisMessageListenerContainer();
        container.setConnectionFactory(redisConnectionFactory());
        container.addMessageListener(redisMessageListener, new PatternTopic("test"));
        container.start();
    }

    @Bean
    public JedisConnectionFactory redisConnectionFactory() {
        RedisStandaloneConfiguration config = new RedisStandaloneConfiguration();
        config.setHostName("127.0.0.1");
        config.setPort(6379);
        return new JedisConnectionFactory(config);
    }
}

以上代码中，容器使用Redis连接工厂创建，监听器注册到容器中，并使用PatternTopic定义订阅的消息通道。

这样，当有消息发布到指定通道时，RedisMessageListener的onMessage方法会被触发，从而实现了Redis的实时推送功能。