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

213 天前
 yoloMiss
由题所示:
现在碰到个这么个问题,有三个不同段的局域网,并且项目中有多个定时任务和 kafka 的消费端,三个网段中部署的是同一套代码,但是又不希望某几个定时任务( kafka 消费端)在其中一个或者两个网段中执行。有没有比较简洁或者其他的方式限制一下定时任务( kafka 消费)的执行。
目前使用的是 ConditionalOnProperty 注解通过配置文件配置环境名区分做限制,但是这样每次部署新包后( k8s )都要手动改一下项目的 yaml 文件,这样不太优雅,希望大佬能给个更优雅省力的方案。
1046 次点击
所在节点    Java
12 条回复
Dlin
213 天前
没用过 kafka 。。你说的定时任务是指由 kafka 队列中在某个时间推入一条消息来触发的执行吗?
guodongbin
212 天前
可以试试环境变量,不过判断逻辑需要改下
litchinn
212 天前
没有特别看懂你的环境

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

我觉得可以 ConditionalOnProperty 中使用 hostname 来判断,havingValue 设置 hostname 的值
dej2vu
212 天前
sl450282169
212 天前
可以实现 Import 接口,根据获取到的不同 ip 段(前提是你的三个局域网 ip 段不一样),来分别注入不同的 bean.或者简单点,直接手写一个 @bean,手动根据 ip 来返回不同的 bean
newaccount
212 天前
建议不要用,定时任务交给 cron 去调,不然以后负载均衡麻烦的很
nothingistrue
212 天前
大前提,如果你要区分同一个服务的不同节点实例,那么实例部署的时候当然要用不同的 bootstrap.yaml 。大前提,Spring Boot 和 Cloud 都不管部署(作为云服务的 Spring Cloud Foundry 另说)。

Spring Cloud 是允许你定义 instanceId 的,代码里面根据 instanceId 做区分即可。但是如何在 bootstrap.yaml 中定义 instanceId ,这个是部署的事,要 k8s 或者脚本去负责。
yoloMiss
212 天前
@sl450282169 这个方案我想过,就是想在简单点那种,哈哈哈。最好通过简单配置就可以的。
yoloMiss
212 天前
@litchinn 三个不同的集群你说的这个 hostname 是怎么获取的呢,k8s 的知识我了解的很浅薄。
yoloMiss
212 天前
@newaccount 这个量级很小,完全为了业务做的妥协,暂时不需要考虑到负载均衡的问题。
yoloMiss
212 天前
@nothingistrue 是三个不同的集群,虽然是一套代码但是 yaml 文件也是分别独立的,最外层的 k8s 的 yaml 不允许我动,只能通过服务里的 yaml 做配置
litchinn
211 天前
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 ,添加一个总没问题吧

这是一个专为移动设备优化的页面(即为了让你能够在 Google 搜索结果里秒开这个页面),如果你希望参与 V2EX 社区的讨论,你可以继续到 V2EX 上打开本讨论主题的完整版本。

https://www.v2ex.com/t/980008

V2EX 是创意工作者们的社区,是一个分享自己正在做的有趣事物、交流想法,可以遇见新朋友甚至新机会的地方。

V2EX is a community of developers, designers and creative people.

© 2021 V2EX