spring boot redis 发布订阅

Spring Boot整合Redis实现发布订阅模式，通过配置和使用RedisTemplate或StringRedisTemplate进行消息的发布和订阅。

在现代Web应用开发中，消息发布与订阅模式是一种常见的通信机制，Spring Boot框架结合Redis可以非常方便地实现这一模式，下面将介绍如何使用Spring Boot和Redis来实现消息的发布与订阅。

技术介绍

Spring Boot：Spring Boot是一个开源的Java基础项目，它旨在简化创建可立即运行的Spring应用程序，Spring Boot提供了一系列默认配置，使得开发者可以快速启动和部署Spring应用。

Redis：Redis是一个开源的内存数据结构存储系统，它可以用作数据库、缓存或消息中间件，由于其高性能和丰富的数据类型支持，Redis非常适合用于实现消息发布与订阅功能。

Spring Data Redis：Spring Data Redis是Spring提供的一个用于操作Redis的库，它提供了高层抽象，使得在Spring应用中使用Redis变得更加简单。

实现步骤

1. 引入依赖

需要在项目的pom.xml文件中添加Spring Boot和Spring Data Redis的依赖：

<dependencies>
    <!-Spring Boot Starter -->
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter</artifactId>
    </dependency>
    <!-Spring Data Redis -->
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-data-redis</artifactId>
    </dependency>
</dependencies>

2. 配置Redis

在application.properties（或application.yml）文件中配置Redis连接信息：

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

3. 创建消息发布者服务

创建一个服务类，用于发布消息到Redis：

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.stereotype.Service;
@Service
public class MessagePublisher {
    @Autowired
    private RedisTemplate<String, String> redisTemplate;
    public void publishMessage(String channel, String message) {
        redisTemplate.convertAndSend(channel, message);
    }
}

4. 创建消息订阅者服务

创建另一个服务类，用于订阅Redis中的消息：

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.connection.Message;
import org.springframework.data.redis.connection.MessageListener;
import org.springframework.data.redis.connection.RedisConnectionFactory;
import org.springframework.stereotype.Service;
@Service
public class MessageSubscriber {
    @Autowired
    private RedisConnectionFactory connectionFactory;
    public void subscribe(String channel) {
        connectionFactory.getConnection().subscribe((messageListener, pattern) -> {
            if (pattern.equals(channel)) {
                messageListener.onMessage((Message<?> message, byte[] pattern) -> {
                    System.out.println("Received message: " + message.toString());
                });
            }
        }, channel);
    }
}

5. 使用消息发布者和订阅者

在Spring Boot应用中，可以通过注入MessagePublisher和MessageSubscriber服务来使用消息发布和订阅功能：

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.CommandLineRunner;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
@SpringBootApplication
public class Application implements CommandLineRunner {
    @Autowired
    private MessagePublisher publisher;
    @Autowired
    private MessageSubscriber subscriber;
    public static void main(String[] args) {
        SpringApplication.run(Application.class, args);
    }
    @Override
    public void run(String... args) throws Exception {
        // 订阅消息
        subscriber.subscribe("myChannel");
        // 发布消息
        publisher.publishMessage("myChannel", "Hello, World!");
    }
}