springboot入门--springboot集成redis实现消息发布订阅模式

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

1，application.properties配置redis以及连接池

#redis
spring.redis.host=localhost
spring.redis.port=6379
#spring.redis.password=
spring.redis.database=1
spring.redis.pool.max-active=8
spring.redis.pool.max-wait=-1
spring.redis.pool.max-idle=500
spring.redis.pool.min-idle=0
spring.redis.timeout=0

2，消息发布者、消息处理者POJO、redis消息监听器容器以及redis监听器注入IOC容器

• redis configuration

@Configuration //相当于xml中的beans
public class RedisConfig {/*** redis消息监听器容器* 可以添加多个监听不同话题的redis监听器，只需要把消息监听器和相应的消息订阅处理器绑定，该消息监听器* 通过反射技术调用消息订阅处理器的相关方法进行一些业务处理* @param connectionFactory* @param listenerAdapter* @return*/@Bean //相当于xml中的beanRedisMessageListenerContainer container(RedisConnectionFactory connectionFactory,MessageListenerAdapter listenerAdapter) {RedisMessageListenerContainer container = new RedisMessageListenerContainer();container.setConnectionFactory(connectionFactory);//订阅了一个叫chat 的通道container.addMessageListener(listenerAdapter, new PatternTopic("chat"));//这个container 可以添加多个 messageListenerreturn container;}/*** 消息监听器适配器，绑定消息处理器，利用反射技术调用消息处理器的业务方法* @param receiver* @return*/@BeanMessageListenerAdapter listenerAdapter(MessageReceiver receiver) {//这个地方 是给messageListenerAdapter 传入一个消息接受的处理器，利用反射的方法调用“receiveMessage”//也有好几个重载方法，这边默认调用处理器的方法 叫handleMessage 可以自己到源码里面看return new MessageListenerAdapter(receiver, "receiveMessage");}/**redis 读取内容的template */@BeanStringRedisTemplate template(RedisConnectionFactory connectionFactory) {return new StringRedisTemplate(connectionFactory);}}

MessageListenerAdapter通过反射使普通的POJO就可以处理消息。具体情况见MessageListenerAdapter的onMessage方法。

3，消息发布者

@EnableScheduling //开启定时器功能
@Component
public class MessageSender {@Autowiredprivate StringRedisTemplate stringRedisTemplate;@Scheduled(fixedRate = 2000) //间隔2s 通过StringRedisTemplate对象向redis消息队列chat频道发布消息public void sendMessage(){stringRedisTemplate.convertAndSend("chat",String.valueOf(Math.random()));}
}

4，普通的消息处理器POJO

@Component
public class MessageReceiver {/**接收消息的方法*/public void receiveMessage(String message){System.out.println("收到一条消息："+message);}}

MessageListenerAdapter通过反射调用receiveMessage方法处理消息

5，pom.xml

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"><modelVersion>4.0.0</modelVersion><groupId>com.learn</groupId><artifactId>springboot-redis-message-pubsub-demo</artifactId><version>0.0.1-SNAPSHOT</version><packaging>jar</packaging><name>springboot-redis-message-pubsub-demo</name><description>Demo project for Spring Boot</description><parent><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-parent</artifactId><version>1.5.10.RELEASE</version><relativePath/> <!-- lookup parent from repository --></parent><properties><project.build.sourceEncoding>UTF-8</project.build.sourceEncoding><project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding><java.version>1.8</java.version></properties><dependencies><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter</artifactId></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-data-redis</artifactId></dependency></dependencies><build><plugins><plugin><groupId>org.springframework.boot</groupId><artifactId>spring-boot-maven-plugin</artifactId></plugin></plugins></build></project>

github代码

---

参考资料：

1，《Spring AMQP 源码分析 07 - MessageListenerAdapter》

2，《Spring整合JMS(二)——三种消息监听器》

3，《redis 消息队列发布订阅模式spring boot实现》

这篇关于springboot入门--springboot集成redis实现消息发布订阅模式的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！

---