异步消息的方式有很多，这篇博客详情如何用redis进行发布订阅，

完成这个示例只要要三个文件

1.redis消息监听配置

@Configurationpublicclass RedisListenerConfig {

? ? /**? ? * redis消息监听器容器

? ? * 能增加多个监听不同话题的redis监听器，只要要把消息监听器和相应的消息订阅解决器绑定，该消息监听器

? ? * 通过反射技术调使用消息订阅解决器的相关方法进行少量业务解决

? ? * @param connectionFactory

? ? * @param listenerAdapter

? ? * @return*/? ? @Bean

? ? RedisMessageListenerContainer container(RedisConnectionFactory connectionFactory,

? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? MessageListenerAdapter listenerAdapter

? ? ) {

? ? ? ? RedisMessageListenerContainer container =new RedisMessageListenerContainer();

? ? ? ? container.setConnectionFactory(connectionFactory);

? ? ? ? //能增加多个 messageListenercontainer.addMessageListener(listenerAdapter,newPatternTopic("index"));

? ? ? ? return container;

? ? }

? ? /**? ? * 消息监听器适配器，绑定消息解决器，利使用反射技术调使用消息解决器的业务方法

? ? * @param redisReceiver

? ? * @return*/? ? @Bean

? ? MessageListenerAdapter listenerAdapter(RedisReceiver redisReceiver) {

? ? ? ? System.out.println("消息适配器进来了");

? ? ? ? returnnewMessageListenerAdapter(redisReceiver, "receiveMessage");

? ? }

? ? //用默认的工厂初始化redis操作模板? ? @Bean

? ? StringRedisTemplate template(RedisConnectionFactory connectionFactory) {

? ? ? ? returnnew StringRedisTemplate(connectionFactory);

? ? }

}

2.消息解决

@Servicepublicclass RedisReceiver {

? ? publicvoid receiveMessage(String message) {

? ? ? ? System.out.println("消息来了："+message);

? ? ? ? //这里是收到通道的消息之后执行的方法? ? }

}

3.一个发送消息的定时器

//定时器@EnableScheduling

@Componentpublicclass TestSenderController {

? ? @Autowired

? ? private StringRedisTemplate stringRedisTemplate;

? ? //向redis消息队列index通道发布消息@Scheduled(fixedRate = 3000)

? ? publicvoid sendMessage(){

? ? ? ? stringRedisTemplate.convertAndSend("index",String.valueOf(Math.random()));

? ? }

}

运行结果如图

{附}：大家能点击加入群：【java高级架构进阶】：https://jq.qq.com/?_wv=1027&k=575y0Kj里面有Java高级大牛直播讲解知识点 走的就是高端路线（假如你想跳槽换工作 但是技术又不够 或者者工作上遇到了瓶颈 我这里有一个JAVA的免费直播课程 讲的是高端的知识点基础不好的误入哟 只需你有1-5年的开发经验能加群找我要课堂链接 注意：是免费的 没有开发经验误入哦）