快捷導(dǎo)航

k8s+springboot+CronJob定時(shí)任務(wù)部署實(shí)現(xiàn)

更新時(shí)間：2023年07月11日 15:17:21 作者：xiaogg3678

本文主要介紹了k8s+springboot+CronJob定時(shí)任務(wù)部署實(shí)現(xiàn)，文中通過示例代碼介紹的非常詳細(xì)，對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧

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

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ù)類的名稱
              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
          #從私有倉庫拉取鏡像憑證
          imagePullSecrets:
            - name: rz-dt-miyue-vpc
          volumes:
            - name: time-config
              hostPath:
                path: /usr/share/zoneinfo/Asia/Shanghai

Dockerfile 文件

#基礎(chǔ)鏡像，如果本地倉庫沒有，會(huì)從遠(yuǎn)程倉庫拉取 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
#指定容器啟動(dòng)時(shí)要執(zhí)行的命令
ENTRYPOINT ["java","-jar","/usr/local/cenobitor/k8s-springboot-demo.jar"]

test.sh 文件

echo "開始制作鏡像..."
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)類：

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 客戶端執(zhí)行，sh test.sh :

到此這篇關(guān)于k8s+springboot+CronJob定時(shí)任務(wù)部署實(shí)現(xiàn)的文章就介紹到這了,更多相關(guān)springboot CronJob定時(shí)任務(wù)內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

您可能感興趣的文章: