redis的发布订阅功能

@Bean
 MyPublisher redisPublisher(RedisConnectionFactory factory) {
 return new MyPublisher( redisTemplate(factory), topic() );
 }
 @Bean
 ChannelTopic topic() {
 return new ChannelTopic( "pubsub:queue" );
 }

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() );
 }
}

//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;
 }

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.codecraft.RedisdemoApplication : Starting RedisdemoApplication on Jupiter.local with PID 1481 (/Users/codecraft/workspace/redisdemo/target/classes started by codecraft in /Users/codecraft/workspace/redisdemo)
2016-02-16 00:14:08.193 INFO 1481 --- [ main] com.codecraft.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.codecraft.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"