redis的發布訂閱功能

來自： https://segmentfault.com/a/1190000004438233

序

redis提供了簡單的發布訂閱功能，對于一些合適的場景(比如不要求消費者不在線時也能收到離線消息)，比起專業的MQ來說，用起來更簡單些。本文主要是記錄下怎么在SpringBoot里頭使用redis的發布訂閱功能。

定義生產者

配置

    @Bean
    MyPublisher redisPublisher(RedisConnectionFactory factory) {
        return new MyPublisher( redisTemplate(factory), topic() );
    }


@Bean
ChannelTopic topic() {
    return new ChannelTopic( "pubsub:queue" );
}</pre> <h3>生產者實例</h3>

public class MyPublisher {


private final RedisTemplate< String, Object > template;
private final ChannelTopic topic;
private final AtomicLong counter = new AtomicLong( 0 );

public MyPublisher( final RedisTemplate< String, Object > template,
                           final ChannelTopic topic ) {
    this.template = template;
    this.topic = topic;
}

@Scheduled( fixedDelay = 100 )
public void publish() {
    template.convertAndSend( topic.getTopic(), "Message " + counter.incrementAndGet() +
            ", " + Thread.currentThread().getName() );
}

}</pre> 
定義消費者

配置

//subscribe
    @Bean
    MessageListenerAdapter messageListener() {
        return new MessageListenerAdapter( new MyMessageListener() );
    }


@Bean
RedisMessageListenerContainer redisContainer(RedisConnectionFactory factory) {
    final RedisMessageListenerContainer container = new RedisMessageListenerContainer();
    container.setConnectionFactory(factory);
    container.addMessageListener(messageListener(), topic());
    return container;
}</pre> <h3>消費者實例</h3>

public class MyMessageListener implements MessageListener {
    @Override
    public void onMessage( final Message message, final byte[] pattern ) {
        System.out.println( "Message received: " + message.toString() );
    }
}
 
運行

  .   _                        
 /\ / '   ()     \ \ \ \
( ( )__ | ' | '| | ' \/ ` | \ \ \ \
 \/  )| |)| | | | | || (_| |  ) ) ) )
  '  |__| .|| ||| |\, | / / / /
 =========||==============|__/=///_/
 :: Spring Boot ::        (v1.3.2.RELEASE)

2016-02-16 00:14:08.190  INFO 1481 --- [           main] com.patterncat.RedisdemoApplication      : Starting RedisdemoApplication on Jupiter.local with PID 1481 (/Users/patterncat/workspace/redisdemo/target/classes started by patterncat in /Users/patterncat/workspace/redisdemo)
2016-02-16 00:14:08.193  INFO 1481 --- [           main] com.patterncat.RedisdemoApplication      : No active profile set, falling back to default profiles: default
2016-02-16 00:14:08.242  INFO 1481 --- [           main] s.c.a.AnnotationConfigApplicationContext : Refreshing org.springframework.context.annotation.AnnotationConfigApplicationContext@140e5a13: startup date [Tue Feb 16 00:14:08 CST 2016]; root of context hierarchy
2016-02-16 00:14:09.756  INFO 1481 --- [           main] o.s.j.e.a.AnnotationMBeanExporter        : Registering beans for JMX exposure on startup
2016-02-16 00:14:09.763  INFO 1481 --- [           main] o.s.c.support.DefaultLifecycleProcessor  : Starting beans in phase 0
2016-02-16 00:14:09.807  INFO 1481 --- [           main] o.s.c.support.DefaultLifecycleProcessor  : Starting beans in phase 2147483647
2016-02-16 00:14:09.897  INFO 1481 --- [           main] com.patterncat.RedisdemoApplication      : Started RedisdemoApplication in 2.215 seconds (JVM running for 2.589)
Message received: "Message 1, pool-1-thread-1"
Message received: "Message 2, pool-1-thread-1"
Message received: "Message 3, pool-1-thread-1"
Message received: "Message 4, pool-1-thread-1"
Message received: "Message 5, pool-1-thread-1"
Message received: "Message 6, pool-1-thread-1"
Message received: "Message 7, pool-1-thread-1"
Message received: "Message 8, pool-1-thread-1"
Message received: "Message 9, pool-1-thread-1"
Message received: "Message 10, pool-1-thread-1"</pre> 
參考



Redis 發布訂閱


使用Redis構建消息隊列和發布訂閱系統


Redis編程實踐【pub/sub】


Redis pub/sub Using Spring