代码整洁之道-小优化（三）

实际需求是这样的，结束订单还车的时候，要同时关锁。原始代码是结束订单+关锁都是同步的形式。我不由自主的提出了，这关锁应该改成异步的形式。所以领导就安排给我了，哈哈哈哈。

搜了一把，redis的发布/订阅模式，拿来用，也初步测试了一下，没问题。

@Component
@Slf4j
public class RedisReceiver {

    @Autowired
    private BikeOrderBiz bikeOrderBiz;
    @Autowired
    private CmdDataCache cmdDataCache;

    /**接收消息的方法*/
    public void receiveMessage(String message){
        log.info("这里面就是具体的业务操作了");
    }

}


@Configuration
public class RedisSubConfig {

    public static final String SUB_KEY = "rent-bike-control-chat-01";//频道channel

    /**
     * redis消息监听器容器
     * 可以添加多个监听不同话题的redis监听器，只需要把消息监听器和相应的消息订阅处理器绑定，该消息监听器
     * 通过反射技术调用消息订阅处理器的相关方法进行一些业务处理
     * @param connectionFactory
     * @param listenerAdapter
     * @return
     */
    @Bean
    RedisMessageListenerContainer container(RedisConnectionFactory connectionFactory, MessageListenerAdapter listenerAdapter) {

        RedisMessageListenerContainer container = new RedisMessageListenerContainer();
        container.setConnectionFactory(connectionFactory);

        //订阅了一个频道
        container.addMessageListener(listenerAdapter, new PatternTopic(RedisSubConfig.SUB_KEY));
        return container;
    }

    /**
     * 消息监听器适配器，绑定消息处理器，利用反射技术调用消息处理器的业务方法
     * @param receiver
     * @return
     */
    @Bean
    MessageListenerAdapter listenerAdapter(RedisReceiver receiver) {
        return new MessageListenerAdapter(receiver, "receiveMessage");
    }

    /**
     * redis 读取内容的template
     * @param connectionFactory
     * @return
     */
    @Bean
    StringRedisTemplate template(RedisConnectionFactory connectionFactory) {
        return new StringRedisTemplate(connectionFactory);
    }
}

 消息发送放代码：

stringRedisTemplate.convertAndSend(RedisSubConfig.SUB_KEY, JSONObject.toJSONString(message));