springboot集成redission实现发布订阅

本文主要是介绍springboot集成redission实现发布订阅，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

创建发布者和订阅者

MessageSubscriber

import org.redisson.api.RTopic;  
import org.redisson.api.RedissonClient;  
import org.springframework.beans.factory.annotation.Autowired;  
import org.springframework.stereotype.Component;  @Component  
public class MessageSubscriber {  @Autowired  private RedissonClient redissonClient;  @PostConstructpublic void subscribe() {  RTopic<String> topic = redissonClient.getTopic("myTopic");  topic.addListener(message -> System.out.println("Received message: " + message));  }  
}

注：@PostConstruct 注解
@PostConstruct 注解用于标记在依赖注入完成后需要执行的方法，以进行初始化工作。这个方法会在类的构造函数调用之后，依赖注入完成之后被自动调用。

MessagePublisher

import org.redisson.api.RTopic;  
import org.redisson.api.RedissonClient;  
import org.springframework.beans.factory.annotation.Autowired;  
import org.springframework.stereotype.Service;  @Service  
public class MessagePublisher {  @Autowired  private RedissonClient redissonClient;  public void publish(String message) {  RTopic<String> topic = redissonClient.getTopic("myTopic");  topic.publish(message);  }  
}