kubernetes+springboot+CronJob 定時(shí)任務(wù)配置如下代碼：

1. cronjob.yaml k8s 文件??

   apiVersion: batch/v1
   kind: CronJob
   metadata:
     name: k8s-springboot-demo
     namespace: rz-dt
   spec:
     failedJobsHistoryLimit: 3 #執(zhí)行失敗job任務(wù)保留數(shù)量
     successfulJobsHistoryLimit: 5 #執(zhí)行成功job任務(wù)保留數(shù)量
     startingDeadlineSeconds: 180
     concurrencyPolicy: Forbid
     schedule: "*/1 * * * *" #每分鐘執(zhí)行一次
     jobTemplate:
       spec:
         template:
           spec:
             containers:
               - name: k8s-springboot-demo
                 image: rz-dt-image-server-registry-vpc.cn-shanghai.cr.aliyuncs.com/rz-dt/k8s-springboot-demo:$IMG_TAG
                 imagePullPolicy: Always
                 #command: ["java","-jar","/usr/local/cenobitor/k8s-springboot-demo.jar"]#dockerfile已有此處不需要配置
                 args: ["sendEmail","sendEmail2"] # 配置任務(wù)類(lèi)的名稱(chēng)
                 volumeMounts:
                   - name: time-config
                     mountPath: /etc/localtime
                     readOnly: true
                 #envFrom:
                 # - configMapRef:
                 #      name: smcp-config
                 # - secretRef:
                 #     name: smcp-service-secret
                 resources:
                   requests:
                     cpu: "250m"
                     memory: 216Mi
                   limits:
                     cpu: "500m"
                     memory: 512Mi
             restartPolicy: Never
             #從私有倉(cāng)庫(kù)拉取鏡像憑證
             imagePullSecrets:
               - name: rz-dt-miyue-vpc
             volumes:
               - name: time-config
                 hostPath:
                   path: /usr/share/zoneinfo/Asia/Shanghai
   

2. Dockerfile 文件

   #基礎(chǔ)鏡像，如果本地倉(cāng)庫(kù)沒(méi)有，會(huì)從遠(yuǎn)程倉(cāng)庫(kù)拉取 openjdk:8
   FROM openjdk:8
   #暴露端口
   EXPOSE 8089
   #容器中創(chuàng)建目錄
   RUN mkdir -p /usr/local/cenobitor
   #編譯后的jar包c(diǎn)opy到容器中創(chuàng)建到目錄內(nèi)
   COPY target/k8s-springboot-demo.jar /usr/local/cenobitor/k8s-springboot-demo.jar
   #指定容器時(shí)區(qū)
   RUN rm -f /etc/localtime \
   && ln -sv /usr/share/zoneinfo/Asia/Shanghai /etc/localtime \
   && echo "Asia/Shanghai" > /etc/timezone
   #指定容器啟動(dòng)時(shí)要執(zhí)行的命令
   ENTRYPOINT ["java","-jar","/usr/local/cenobitor/k8s-springboot-demo.jar"]
   

3. test.sh 文件

   echo "開(kāi)始制作鏡像..."
   image_tag=`date +%Y-%m-%d-%H-%M-%S` #_%H%M
   echo "當(dāng)前時(shí)間：$image_tag"
   docker build -t k8s-springboot-demo:${image_tag} .
   echo "制作鏡像成功!"
   
   echo "登錄"
   sudo docker login --username=aliyun0398513152 rz-dt-image-server-registry-vpc.cn-shanghai.cr.aliyuncs.com --password=1234
   
   echo "鏡像最新版本提交"
   docker tag k8s-springboot-demo:${image_tag} rz-dt-image-server-registry-vpc.cn-shanghai.cr.aliyuncs.com/rz-dt/k8s-springboot-demo:${image_tag}
   docker push rz-dt-image-server-registry-vpc.cn-shanghai.cr.aliyuncs.com/rz-dt/k8s-springboot-demo:${image_tag}
   
   echo "k8s一鍵部署"
   export IMG_TAG=${image_tag}
   envsubst < cronjob.yaml | kubectl --kubeconfig ~/.kube-rz/config apply -f -
   
   
   

   4個(gè)代碼實(shí)現(xiàn)類(lèi)：

4. package com.example.demo.job;
   
   public interface Command {
       /**
        * 遵循Unix約定，如果命令執(zhí)行正常，則返回0；否則為非0。
        */
       int execute(String... args);
   }
   
   
   
   package com.example.demo.job;
   
   import lombok.extern.slf4j.Slf4j;
   import org.springframework.stereotype.Component;
   
   @Component
   @Slf4j
   public class SendEmailCommand implements Command {
   
       @Override
       public int execute(String... args) {
   
           try {
               // 省略業(yè)務(wù)邏輯代碼
               for (String arg:args) {
                   log.info("send email  success args：" +arg);
               }
   
   
               log.info("send email success");
   
               return 0;
   
           } catch (Exception e) {
               log.error("send email error", e);
               return -1;
           }
       }
   }
   
   
   
   package com.example.demo.job;
   
   import lombok.extern.slf4j.Slf4j;
   import org.springframework.stereotype.Component;
   
   @Component
   @Slf4j
   public class SendEmail2Command implements Command {
   
       @Override
       public int execute(String... args) {
   
           try {
               // 省略業(yè)務(wù)邏輯代碼
   
               for (String arg:args) {
                   log.info("send email 2  success args：" +arg);
               }
   
               log.info("send email 2 success");
   
               return 0;
   
           } catch (Exception e) {
               log.error("send email error", e);
               return -1;
           }
       }
   }
   
   
   
   package com.example.demo.job;
   
   import lombok.extern.slf4j.Slf4j;
   import org.springframework.beans.factory.annotation.Autowired;
   import org.springframework.boot.CommandLineRunner;
   import org.springframework.stereotype.Component;
   
   import javax.annotation.PostConstruct;
   import java.util.Arrays;
   import java.util.HashMap;
   import java.util.Map;
   
   @Component
   @Slf4j
   public class ProjectCommandLineRunner implements CommandLineRunner {
   
       Map<String, Command> commandMap = new HashMap<>();
   
       @Autowired
       private SendEmailCommand sendEmailCommand;
   
       @Autowired
       private SendEmail2Command sendEmail2Command;
   
       @PostConstruct
       private void init() {
           commandMap.put("sendEmail", sendEmailCommand);
           commandMap.put("sendEmail2", sendEmail2Command);
       }
   
       @Override
       public void run(String... args) throws Exception {
   
           if (args.length == 0) {
               return;
           }
   
           if (!commandMap.containsKey(args[0])) {
               log.error("'{}' command not found", args[0]);
               System.exit(-1);
           }
   
           for (String arg:args) {
               log.info("command args：" +arg);
           }
   
          for (int i = 0; i < args.length; i++) {
               Command command =  commandMap.get(args[i]);
               String[] arguments = Arrays.copyOfRange(args, 0, args.length);
               command.execute(arguments);
           }
   
           
           //執(zhí)行成功則，正常退出0, 異常退出非0
           System.exit(0);
       }
   }
   
   
   

kubectl 客戶(hù)端執(zhí)行，sh test.sh :

文章來(lái)源地址http://www.zghlxwxcb.cn/news/detail-555201.html

到了這里，關(guān)于k8s+springboot+CronJob 定時(shí)任務(wù)部署的文章就介紹完了。如果您還想了解更多內(nèi)容，請(qǐng)?jiān)谟疑辖撬阉鱐OY模板網(wǎng)以前的文章或繼續(xù)瀏覽下面的相關(guān)文章，希望大家以后多多支持TOY模板網(wǎng)！