新建兩個訂閱監聽

@Component public class MessageSubListener implements MessageListener {@Overridepublic void onMessage(Message message, byte[] pattern) {System.out.println("consume1: " + new String(message.getBody()) + ", pattern: "+new String(pattern));} } @Component public class MessageSubListener2 implements MessageListener {@Overridepublic void onMessage(Message message, byte[] pattern) {System.out.println("consume2: " + new String(message.getBody()));} }

訂閱配置

@Configuration public class RedisSubConfig {public static final String SUB_KEY = "message:pool";@BeanRedisMessageListenerContainer container(RedisConnectionFactory connectionFactory, MessageListenerAdapter listenerAdapter,MessageListenerAdapter listenerAdapter2){RedisMessageListenerContainer container = new RedisMessageListenerContainer();container.setConnectionFactory(connectionFactory);container.addMessageListener(listenerAdapter, new PatternTopic(SUB_KEY));container.addMessageListener(listenerAdapter2, new PatternTopic(SUB_KEY));return container;}@BeanMessageListenerAdapter listenerAdapter(MessageSubListener redisPubSubListener){System.out.println("listenerAdapter register");return new MessageListenerAdapter(redisPubSubListener, "onMessage");}@BeanMessageListenerAdapter listenerAdapter2(MessageSubListener2 redisPubSubListener){System.out.println("listenerAdapter2 register");return new MessageListenerAdapter(redisPubSubListener, "onMessage");} }

訂閱模塊已經寫好，然后就是廣播消息

@Component public class PubMessageTask implements ApplicationRunner {@AutowiredRedisTemplate redisTemplate;@Overridepublic void run(ApplicationArguments args) throws Exception {for (int i = 0;i< 10; i++){redisTemplate.convertAndSend(RedisSubConfig.SUB_KEY, "message:" + i);Thread.sleep(1000);}} }

測試結果

consume1: message:0, pattern: message:pool consume2: message:0 consume1: message:1, pattern: message:pool consume2: message:1 consume1: message:2, pattern: message:pool consume2: message:2 consume1: message:3, pattern: message:pool consume2: message:3 consume1: message:4, pattern: message:pool consume2: message:4 consume1: message:5, pattern: message:pool consume2: message:5 consume1: message:6, pattern: message:pool consume2: message:6 consume1: message:7, pattern: message:pool consume2: message:7 consume1: message:8, pattern: message:pool consume2: message:8 consume1: message:9, pattern: message:pool consume2: message:9

兩個監聽都收到了廣播消息

pom中引入redis maven 包

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

總結

以上是生活随笔為你收集整理的spring boot redis 广播消息的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。