在 springboot 项目中不同局域网下限制由 @Configuration 或者 @Component 注解装配的类内的定时任务的是否可执行方法

[yoloMiss]

由题所示：
现在碰到个这么个问题，有三个不同段的局域网，并且项目中有多个定时任务和 kafka 的消费端，三个网段中部署的是同一套代码，但是又不希望某几个定时任务（ kafka 消费端）在其中一个或者两个网段中执行。有没有比较简洁或者其他的方式限制一下定时任务（ kafka 消费）的执行。
目前使用的是 ConditionalOnProperty 注解通过配置文件配置环境名区分做限制，但是这样每次部署新包后（ k8s ）都要手动改一下项目的 yaml 文件，这样不太优雅，希望大佬能给个更优雅省力的方案。

补充一下：
1.是三个不同 ip 段下的三个不同的集群，互不相通
2.是集群中的一个 springboot 服务中的由 @Scheduled 注解管理的定时任务（ kafka 消费端），当然定时任务和 kafka 消费端都是由 @Configuration 或者 @Component 注入的。

[Dlin]

没用过 kafka 。。你说的定时任务是指由 kafka 队列中在某个时间推入一条消息来触发的执行吗？

[guodongbin]

可以试试环境变量，不过判断逻辑需要改下

[litchinn]

没有特别看懂你的环境

你这三个局域网是同一个集群呢还是有三个集群呢
我理解中你是一个集群，三个服务节点使用同一个 yaml 配置文件，你是如何通过修改 yaml 来指定某个节点读取到对应配置的呢？ k8s 可以指定节点部署（虽然我觉得服务设计上不应该关心具体节点），但是读取的不都是同一个 yaml 吗

我觉得可以 ConditionalOnProperty 中使用 hostname 来判断，havingValue 设置 hostname 的值

[dej2vu]

@Profile ?

[sl450282169]

可以实现 Import 接口,根据获取到的不同 ip 段(前提是你的三个局域网 ip 段不一样),来分别注入不同的 bean.或者简单点,直接手写一个 @bean,手动根据 ip 来返回不同的 bean

[newaccount]

建议不要用，定时任务交给 cron 去调，不然以后负载均衡麻烦的很

[nothingistrue]

大前提，如果你要区分同一个服务的不同节点实例，那么实例部署的时候当然要用不同的 bootstrap.yaml 。大前提，Spring Boot 和 Cloud 都不管部署（作为云服务的 Spring Cloud Foundry 另说）。

Spring Cloud 是允许你定义 instanceId 的，代码里面根据 instanceId 做区分即可。但是如何在 bootstrap.yaml 中定义 instanceId ，这个是部署的事，要 k8s 或者脚本去负责。

[yoloMiss]

@sl450282169 这个方案我想过，就是想在简单点那种，哈哈哈。最好通过简单配置就可以的。

[yoloMiss]

@litchinn 三个不同的集群你说的这个 hostname 是怎么获取的呢，k8s 的知识我了解的很浅薄。

[yoloMiss]

@newaccount 这个量级很小，完全为了业务做的妥协，暂时不需要考虑到负载均衡的问题。

[yoloMiss]

@nothingistrue 是三个不同的集群，虽然是一套代码但是 yaml 文件也是分别独立的，最外层的 k8s 的 yaml 不允许我动，只能通过服务里的 yaml 做配置

[litchinn]

spec.nodeName

https://kubernetes.io/docs/tasks/inject-data-application/environment-variable-expose-pod-information/#use-pod-fields-as-values-for-environment-variables

然后在 yaml 里就可以直接使用环境变量了，你可以试下，一个集群才适合这种，你是三个集群那这 3 个 node 的名称可能是一样的。

3 个集群的话直接 configmap 配置个环境变量不就好了吗，不让改 k8s 里配置的 yaml ，添加一个总没问题吧