SpringBoot redisTemplate 实现基础订阅与发布

...
 <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.0.3.RELEASE</version>
 </parent>
...
<dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-data-redis</artifactId>
</dependency>
...

• 配置订阅频道

/**
订阅配置 channel1是频道，可以多个
也可以patternToppic
*/
@Configuration
public class MyRedisMessageListenerContainer {
    @Bean
    MessageListenerAdapter messageListener() {
        return new MessageListenerAdapter(new MySubcribe());
    }

    @Bean
    RedisMessageListenerContainer redisContainer(RedisConnectionFactory factory) {
        final RedisMessageListenerContainer container = new RedisMessageListenerContainer();
        container.setConnectionFactory(factory);
        container.addMessageListener(messageListener(), new ChannelTopic("channel1"));
        return container;
    }
}

• 订阅者

package com;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.connection.Message;
import org.springframework.data.redis.connection.MessageListener;
import org.springframework.data.redis.core.StringRedisTemplate;
import org.springframework.stereotype.Service;

@Service
public class MySubcribe implements MessageListener {
    @Autowired
    private StringRedisTemplate redisTemplate;

    @Override
    public void onMessage(Message message, byte[] pattern) {
        System.out.println("接收数据:"+message.toString());
        System.out.println("订阅频道:"+new String(message.getChannel()));
    }
}

• 发布者

@GetMapping("/anon/publish")
@ResponseStatus(HttpStatus.OK)
public void publish() {
    System.out.println("执行发布");
    redisTemplate.convertAndSend("channel1", "Hello, I'm Tom!");
}