栏目分类:
子分类:
返回
名师互学网用户登录
快速导航关闭
当前搜索
当前分类
子分类
实用工具
热门搜索
名师互学网 > IT > 前沿技术 > 大数据 > 大数据系统

@ConditionalOnProperty 选择性加载配置(仅用于记录使用方法)

@ConditionalOnProperty 选择性加载配置(仅用于记录使用方法)

项目场景: @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 的值 则加载配置,否则不加载

转载请注明:文章转载自 www.mshxw.com
本文地址:https://www.mshxw.com/it/679988.html
我们一直用心在做
关于我们 文章归档 网站地图 联系我们

版权所有 (c)2021-2022 MSHXW.COM

ICP备案号:晋ICP备2021003244-6号