@ConditionalOnProperty 选择性加载配置(仅用于记录使用方法)
项目场景:@ConditionalOnProperty实际遇到的两个使用场景:1:监听redis失效key,根据失效key将设备更新为离线状态。2:判断是否有kafka中间件,有则推送数据到kafka,没有则继续下面的逻辑。问题描述:1:第一个问场景的问题:项目可能是redis集群,也可能是单节点redis。针对不同的redis部署方式,项目的配置类不同(两个配置类,一个用于集群,一个用于单节点)
·
项目场景:
@ConditionalOnProperty实际遇到的两个使用场景: 1:监听redis失效key,根据失效key将设备更新为离线状态。 2:判断是否有kafka中间件,有则推送数据到kafka,没有则继续下面的逻辑。问题描述:
1:第一个问场景的问题:
项目可能是redis集群,也可能是单节点redis。针对不同的redis部署方式,项目的配置类不同(两个配置类,一个用于集群,一个用于单节点)。
spring:
redis:
clusterFlag: true
@Component
@ConditionalOnProperty(prefix = "spring.redis", name = "clusterFlag", havingValue = "true")
public class ClusterSubscriber extends RedisPubSubAdapter implements ApplicationRunner {
//监听配置参数 && 逻辑
}
2:第二个问场景的问题:
这个系统定位是产品,私有化部署时,客户可以裁剪调部分功能,如:不使用kafka中间件。此时最省事的便是不加载kafka的配置&bean
spring:
kafka:
loadFlag: true
@Component
@ConditionalOnProperty(prefix = "spring.kafka", name = "loadFlag", havingValue = "true")
public class ProducerUtil {
//配置参数 && 推送逻辑
}
@Autowired
private ApplicationContext applicationContext;
@Override
public void pushToKafka(String topic,KafkaInfo model) throws Exception {
try {
ProducerUtil pBean = applicationContext.getBean(ProducerUtil.class);
log.debug("存在ProducerUtil bean,进行推送");
pBean.send(topic, JSONObject.toJSONString(model));
} catch (NoSuchBeanDefinitionException e) {
log.debug("不存在ProducerUtil bean,不推送kafka");
}
}
总结:
@ConditionalOnProperty(prefix = “spring.kafka”, name = “loadFlag”, havingValue = “true”)
在配置文件里:prefix+name 的值 == havingValue 的值 则加载配置,否则不加载
更多推荐
已为社区贡献1条内容
所有评论(0)