Spring Boot学习：Redis发布订阅

Redis发布订阅

Redis 2.8 及以上版本实现了发布订阅的功能，发送者可以通过 PUBLISH发布消息，订阅者通过 SUBSCRIBE 订阅接收消息或通过UNSUBSCRIBE 取消订阅。当发布者发布消息到指定频道时，所有订阅该频道的订阅者都能够接收到消息。这对于实时通信、聊天应用、实时数据更新等场景非常有用。

Redis发布订阅实现

下面我就在Spring Boot项目中使用Redisson 来实现发布订阅
1、添加redisson依赖，依赖如下

		<dependency><groupId>org.redisson</groupId><artifactId>redisson</artifactId><version>3.16.8</version></dependency>

2、创建Redisson客户端

我们需要创建一个Redisson客户端实例来使用Redisson，一般通过在Spring Boot配置文件中添加Redisson客户端的配置来创建它

下面是一个简单的配置示例

@Configuration  
public class RedissonConfig {  @Value("${redisson.address}")  private String address;  @Bean(destroyMethod="shutdown")  RedissonClient redisson() throws IOException {  Config config = new Config();  config.useSingleServer().setAddress(address);  return Redisson.create(config);  }  
}

3、创建发布者

接下来，您需要创建一个发布者类，用于向指定的频道发布消息。您可以使用Redisson客户端的getTopic方法获取指定的频道，并使用publish方法发布消息。例如：

@Service  
public class Publisher {  @Autowired  private RedissonClient redissonClient;  /*** 发布消息到 Topic* @param topicName Topic名称* @param message 消息体*/public void publish(String topicName, String message) {RTopic topic = redissonClient.getTopic(topicName);topic.publish(message);}}

4、创建消息监听器类

为了定义接收到消息后的处理逻辑，还需要创建一个消息监听器接口（MessageListener）的实现类，实现onMessage方法来定义我们的消息处理逻辑

@Slf4j
@Component
public class MyMessageListener implements org.redisson.api.listener.MessageListener<String> {/*** 消息处理* @param channel* @param msg*/@Overridepublic void onMessage(CharSequence channel, String msg) {log.info("监听到消息："+msg);}
}

5、创建订阅者

最后，您需要创建一个订阅者类，用于订阅指定的频道并处理接收到的消息。您可以使用Redisson客户端的getTopic方法获取指定的频道，并使用addListener方法添加消息监听器。例如：

@Slf4j
@Component
public class Subscriber{/*** 主题名称*/public static final String TOPIC_NAME = "test_topic";@Autowiredprivate RedissonClient redissonClient;@Autowiredprivate MyMessageListener myMessageListener;/*** 订阅主题*/@PostConstructpublic void init() {redissonClient.getTopic(TOPIC_NAME).addListener(String.class, myMessageListener);}/*** 订阅主题* @param topicName 主题名* @param type      消息类型* @param listener  监听器*/public void subscribeTopic(String topicName, Class type, MessageListener listener) {RTopic topic = redissonClient.getTopic(topicName);topic.addListener(type,listener);}
}