@Configuration

public class RedisSubListenerConfig {

    //不同的频道名

    private static final  String channel = "testchannel";

    private static final  String channel2 = "chat";

     /**

     * redis消息监听器容器

     * 可以添加多个监听不同话题的redis监听器，只需要把消息监听器和相应的消息订阅处理器绑定，该消息监听器

     * 通过反射技术调用消息订阅处理器的相关方法进行一些业务处理

     * @param connectionFactory

     * @param listenerAdapter

     * @return

     */

    @Bean //相当于xml中的bean

    RedisMessageListenerContainer container(RedisConnectionFactory connectionFactory,

                                            MessageListenerAdapter listenerAdapter,MessageListenerAdapter listenerAdapter2) {

        RedisMessageListenerContainer container = new RedisMessageListenerContainer();

        container.setConnectionFactory(connectionFactory);

        //订阅了一个叫testchannel 的通道

        container.addMessageListener(listenerAdapter, new PatternTopic(RedisSubListenerConfig.channel));

        //订阅了一个叫chat的频道

        container.addMessageListener(listenerAdapter2, new PatternTopic(RedisSubListenerConfig.channel2));

        return container;

    }

    /**

     * 消息监听器适配器，绑定消息处理器，利用反射技术调用消息处理器的业务方法

     * @param receiver

     * @return

     */

    @Bean

    MessageListenerAdapter listenerAdapter(MessageReceiver receiver) {

        return new MessageListenerAdapter(receiver, "receiveMessage");

    }

    @Bean

    MessageListenerAdapter listenerAdapter2(MessageReceiver receiver) {

        return new MessageListenerAdapter(receiver, "receiveMessage2");

    }

    /**redis 读取内容的template */

    @Bean

    StringRedisTemplate template(RedisConnectionFactory connectionFactory) {

        return new StringRedisTemplate(connectionFactory);

    }

}

@Component

public class MessageReceiver {

     /**接收消息的方法*/

    public void receiveMessage(String message){

        System.out.println("收到一条消息："+message);

    }

    /**接收消息的方法*/

    public void receiveMessage2(String message){

        System.out.println("收到一条消息2："+message);

    }

}