Galosoft.IaaS.XxlJob 25.9.29.8-rc3

XxlJob

默认获取当前服务服务端口和地址作为xxljob的执行器地址，自动注册

部署 k8s

apiVersion: apps/v1
kind: Deployment
metadata:
 name: xxl-job-admin
 namespace: iaas-samples
 labels:
 app: xxl-job-admin
spec:
 replicas: 1
 selector:
 matchLabels:
 app: xxl-job-admin
 template:
 metadata:
 labels:
 app: xxl-job-admin
 spec:
 containers:
 - name: xxl-job-admin
 image: docker.1ms.run/xuxueli/xxl-job-admin:2.4.2
 env: 
 - name: PARAMS
 value: '
 --spring.datasource.url=jdbc:mysql://192.168.11.89:3306/xxl_job?useUnicode=true&characterEncoding=utf-8&zeroDateTimeBehavior=convertToNull&useSSL=true&serverTimezone=GMT%2B8&allowMultiQueries=true
 --spring.datasource.username=root
 --spring.datasource.password=jY0#R599#%17#&5g^^B!zT$#9g0A0Z
 --xxl.job.accessToken=xxl-job'
 ports:
 - containerPort: 80
 imagePullPolicy: Always
 imagePullSecrets:
 - name: zhangjiakou
---
apiVersion: v1
kind: Service
metadata:
 labels:
 expose: "true"
 app: xxl-job-admin
 name: xxl-job-admin
 namespace: iaas-samples
spec:
 ports:
 - name: transport
 port: 8080
 protocol: TCP
 targetPort: 8080 
 selector:
 app: xxl-job-admin

配置

 "XxlJob": {
 "AdminAddresses": "http://192.168.11.89:8040/xxl-job-admin",
 //"specialBindAddress": "127.0.0.1",
 "AccessToken": "xxl-job",
 "LogRetentionDays": 30
 }

中间件注册

 app.UseXxlJobExecutor();

业务代码

[JobHandler("demoJobHandler")]
internal class DemoXxlJobHandler : AbstractJobHandler
{
 public override async Task<ReturnT> Execute(JobExecuteContext context)
 {
 await Console.Out.WriteLineAsync(DateTime.Now.ToShortTimeString());
 return ReturnT.SUCCESS;
 }
}