项目场景:

@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 的值 则加载配置,否则不加载

Logo

Kafka开源项目指南提供详尽教程,助开发者掌握其架构、配置和使用,实现高效数据流管理和实时处理。它高性能、可扩展,适合日志收集和实时数据处理,通过持久化保障数据安全,是企业大数据生态系统的核心。

更多推荐