Galosoft.IaaS.XxlJob 24.12.26.5-nj

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;
    }
}