spring:

  redis:

    jedis:

      pool:

        max-active: 10

        min-idle: 5

        max-idle: 10

        max-wait: 2000

    port: 6379

    host: 192.168.1.88

    timeout: 1000

package com.example.demo.common;

import org.springframework.data.redis.connection.Message;

import org.springframework.data.redis.connection.MessageListener;

import org.springframework.stereotype.Component;

/**

 * @author Tyler

 * @date 2019/7/11

 */

@Component

public class RedisMessageListener implements MessageListener {

    @Override

    public void onMessage(Message message, byte[] bytes) {

        String body=new String(message.getBody());

        String topic=new String(bytes);

        System.out.println(body);

        System.out.println(topic);

    }

}

package com.example.demo;

import org.mybatis.spring.annotation.MapperScan;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.boot.SpringApplication;

import org.springframework.boot.autoconfigure.SpringBootApplication;

import org.springframework.context.annotation.Bean;

import org.springframework.data.redis.connection.MessageListener;

import org.springframework.data.redis.connection.RedisConnectionFactory;

import org.springframework.data.redis.listener.ChannelTopic;

import org.springframework.data.redis.listener.RedisMessageListenerContainer;

import org.springframework.data.redis.listener.Topic;

import org.springframework.scheduling.concurrent.ThreadPoolTaskScheduler;

import org.springframework.stereotype.Repository;

@SpringBootApplication

@MapperScan(basePackages ="com.example.demo.common", annotationClass = Repository.class)

public class DemoApplication {

    public static void main(String[] args) {

        SpringApplication.run(DemoApplication.class, args);

    }

    @Autowired

    private RedisConnectionFactory connectionFactory;

    @Autowired

    private MessageListener redisMsgListener;

    private ThreadPoolTaskScheduler taskScheduler;

    @Bean

    public ThreadPoolTaskScheduler initTaskScheduler()

    {

        if(taskScheduler!=null)

        {

            return taskScheduler;

        }

        taskScheduler=new ThreadPoolTaskScheduler();

        taskScheduler.setPoolSize(20);

        return taskScheduler;

    }

    @Bean

    public RedisMessageListenerContainer initRedisContainer()

    {

        RedisMessageListenerContainer container=new RedisMessageListenerContainer();

        container.setConnectionFactory(connectionFactory);

        container.setTaskExecutor(initTaskScheduler());

        Topic topic=new ChannelTopic("topic1");

        container.addMessageListener(redisMsgListener,topic);

        return container;

    }

}

@Controller

@RequestMapping("/redis")

public class RedisController {

    @Autowired

    private StringRedisTemplate stringRedisTemplate;

    @RequestMapping("/stringAndHash")

    @ResponseBody

    public Map<String,Object> testStringAndHash()

    {

        stringRedisTemplate.convertAndSend("topic1","hello");

        Map<String,Object> map=new HashMap<>();

        map.put("success",true);

        return map;

    }

}