spring注解的一些使用

逃离我推掉我的手 2022-09-11 10:18 112阅读 0赞

**1 条件注入**  
一个接口有多种实现，但有的时候只需要使用其中一个实现，这种方式就用到了`@ConditionalOnProperty`,例如下面的例子，就通过了`ws.tio.config.mqType`这个注解值来生成,注释使用的时候使用`@Resource`

public interface MqMsgService { 
        /** * 生产消息 * @param topic 主题 * @param msg 消息 * @return */
        boolean produce(String topic, String msg);
    }

这是一个rabbitmq的生产者实现

import lombok.extern.slf4j.Slf4j;
    import org.springframework.amqp.rabbit.core.RabbitTemplate;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
    import org.springframework.stereotype.Service;
    
    @Slf4j
    @Service
    @ConditionalOnProperty(name = "ws.tio.config.mqType", havingValue = "rabbitmq")
    public class RabbitMqMsgService implements MqMsgService { 
    
        @Autowired
        private RabbitTemplate rabbitTemplate;
    
        @Override
        public boolean produce(String topic, String msg) { 
            try{ 
                rabbitTemplate.convertAndSend(topic, msg);
            } catch(Exception e){ 
                log.error(e.getMessage(),e, msg);
                throw new RuntimeException("发行消息失败",e);
            }
            return true;
        }
    }

这是redis的生产者实现

import lombok.extern.slf4j.Slf4j;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
    import org.springframework.data.redis.core.StringRedisTemplate;
    import org.springframework.stereotype.Service;
    
    @Slf4j
    @Service
    @ConditionalOnProperty(name = "ws.tio.config.mqType", havingValue = "redis")
    public class RedisMqMsgService implements MqMsgService { 
    
        @Autowired
        private StringRedisTemplate stringRedisTemplate;
    
        @Override
        public boolean produce(String topic, String msg) { 
            try{ 
                stringRedisTemplate.convertAndSend(topic, msg);
            } catch(Exception e){ 
                log.error(e.getMessage(),e, msg);
                throw new RuntimeException("发行消息失败",e);
            }
            return true;
        }
    }

**2 策略工厂**  
还是一个接口多个实现，使用spring的上下文可以做，还有一种办法就是使用策略工厂,下面的`@Autowired`会将对象的实现类装载进去

import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.stereotype.Service;
    import java.util.Map;
    import java.util.concurrent.ConcurrentHashMap;
    
    /** * @Description * @Author dzm * @Date 2021-09-10 11:14 */
    @Service
    public class MqMsgFactory { 
    
        /** * 自动注解 */
        @Autowired
        Map<String, MqMsgService> mqMap = new ConcurrentHashMap<>(2);
    
        /** * 获取消息处理的生产者 * @param componet * @return */
        public MqMsgService getMqMsgService(String componet){ 
            MqMsgService mqMsgService = mqMap.get(componet);
            if (mqMsgService == null){ 
                throw new RuntimeException("策略没有定义");
            }
            return mqMsgService;
        }
    }