[新增] 部署脚本生成

loit-build-component/loit-build-deploy-env/pom.xml

@@ -10,6 +10,47 @@
     <modelVersion>4.0.0</modelVersion>
 
     <artifactId>loit-build-deploy-env</artifactId>
+    <properties>
+        <!-- Maven Plugin Versions -->
+        <loit-core-boot.version>1.0.32</loit-core-boot.version>
+    </properties>
 
+    <dependencies>
+        <dependency>
+            <groupId>com.loit</groupId>
+            <artifactId>loit-core-boot</artifactId>
+            <version>${loit-core-boot.version}</version>
+            <exclusions>
+                <exclusion>
+                    <groupId>org.springframework.boot</groupId>
+                    <artifactId>spring-boot-starter-security</artifactId>
+                </exclusion>
+                <exclusion>
+                    <groupId>org.springframework.boot</groupId>
+                    <artifactId>spring-boot-starter-activemq</artifactId>
+                </exclusion>
+                <exclusion>
+                    <groupId>com.loit</groupId>
+                    <artifactId>loit-common</artifactId>
+                </exclusion>
+            </exclusions>
+        </dependency>
 
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-freemarker</artifactId>
+        </dependency>
+
+        <dependency>
+            <groupId>org.apache.httpcomponents</groupId>
+            <artifactId>httpcore</artifactId>
+            <version>4.4.6</version>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework</groupId>
+            <artifactId>spring-test</artifactId>
+            <version>5.0.10.RELEASE</version>
+        </dependency>
+
+    </dependencies>
 </project>

loit-build-component/loit-build-deploy-env/src/main/java/com/loit/common/script/GeneratorScript.java

+package com.loit.common.script;
+
+import com.loit.common.script.dto.BackendFrontEnum;
+import com.loit.common.script.dto.DeployInfoDataDTO;
+import com.loit.common.utils.ListUtil;
+import com.loit.common.utils.StringUtils;
+import com.loit.common.utils.excel.ImportExcel;
+import com.loit.common.utils.file.FileUtils;
+import com.loit.common.utils.freemarker.FreeMarkerUtils;
+import lombok.extern.slf4j.Slf4j;
+import org.apache.http.entity.ContentType;
+import org.springframework.mock.web.MockMultipartFile;
+import org.springframework.web.multipart.MultipartFile;
+
+import java.io.File;
+import java.io.FileInputStream;
+import java.io.IOException;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+@Slf4j
+public class GeneratorScript {
+
+
+    protected static String root_path = "F:\\9Git140\\loit-build-common\\loit-build-component\\loit-build-deploy-env\\src\\main\\resources\\bin";
+
+
+    protected static String root_path_full = root_path + "\\serverTest";
+
+
+    public static void main(String[] args) {
+
+        try {
+
+            //String filePathStr = Thread.currentThread().getContextClassLoader().getResource("deployInfo.xlsx").getPath();
+            String filePathStr = "F:\\9Git140\\loit-build-common\\loit-build-component\\loit-build-deploy-env\\src\\main\\resources\\deployInfo.xlsx";
+
+            File pdfFile = new File(filePathStr);
+            FileInputStream fileInputStream = new FileInputStream(pdfFile);
+            MultipartFile multipartFile = new MockMultipartFile(pdfFile.getName(), pdfFile.getName(),
+
+                    ContentType.APPLICATION_OCTET_STREAM.toString(), fileInputStream);
+            ImportExcel ei = new ImportExcel(multipartFile, 1, 0);
+            List<DeployInfoDataDTO> grayVersionDataDTOList = ei.getDataList(DeployInfoDataDTO.class);
+
+            if (ListUtil.isEmpty(grayVersionDataDTOList)) {
+                return;
+            }
+
+            for (DeployInfoDataDTO grayVersionDataDTO : grayVersionDataDTOList) {
+                buildInitEnv(grayVersionDataDTO);
+                buildConfig(grayVersionDataDTO);
+            }
+
+        } catch (Exception e) {
+            log.error(e.getMessage(), e);
+        }
+
+    }
+
+    /**
+     * 生成InitEnv
+     *
+     * @throws IOException
+     */
+    private static void buildInitEnv(DeployInfoDataDTO grayVersionDataDTO) throws IOException {
+
+        String fileDir = root_path_full + "\\" + grayVersionDataDTO.getFixedIp();
+        File folder = new File(fileDir);
+        if (!folder.exists()) {
+            folder.mkdirs();
+        }
+
+        String filePath = fileDir + "\\initEnv.sh";
+        File file = new File(filePath);
+        if (!file.exists()) {
+            FileUtils.write(filePath, "#!/bin/bash ");
+        }
+
+        String deployPath = grayVersionDataDTO.getDeployPath();
+        if (StringUtils.isNoneBlank(deployPath)) {
+            FileUtils.appendNewLine(filePath, "mkdir -p " + deployPath);
+            BackendFrontEnum backendFrontType = BackendFrontEnum.getEnumByCode(grayVersionDataDTO.getBackendFrontType());
+            if (BackendFrontEnum.BACKEND.equals(backendFrontType)) {
+                FileUtils.appendNewLine(filePath, "mkdir -p " + deployPath + "/logs");
+            }
+        }
+    }
+
+
+    /**
+     * 生成bootstrap.properties 及其 sh
+     */
+    private static void buildConfig(DeployInfoDataDTO grayVersionDataDTO) throws IOException {
+
+        String serviceName = grayVersionDataDTO.getServiceName();
+        String fixedIp = grayVersionDataDTO.getFixedIp();
+        String port = grayVersionDataDTO.getPort();
+        String deployPath = grayVersionDataDTO.getDeployPath();
+        String deployJar = grayVersionDataDTO.getDeployJar();
+
+
+        if (StringUtils.isBlank(serviceName)) {
+            return;
+        }
+
+        BackendFrontEnum backendFrontType = BackendFrontEnum.getEnumByCode(grayVersionDataDTO.getBackendFrontType());
+        if (!BackendFrontEnum.BACKEND.equals(backendFrontType)) {
+            return;
+        }
+
+        String fileDir = root_path_full + "\\" + fixedIp + "\\" + serviceName + "-" + port;
+        File folder = new File(fileDir);
+        if (!folder.exists()) {
+            folder.mkdirs();
+        }
+
+        String bootstrapFileName = fileDir + "\\bootstrap.properties";
+
+        Map model = new HashMap();
+        model.put("port", port);
+        model.put("serviceName", serviceName);
+        model.put("deployPath", deployPath);
+        model.put("deployJar", deployJar);
+
+        String result = FreeMarkerUtils.process("bootstrap.ftl", model);
+        FileUtils.write(bootstrapFileName, result);
+
+
+        String replace = serviceName.replace("loit-", "deploy-");
+        String deployShFileName = fileDir + "\\" + replace + "-" + port + ".sh";
+        String deployShResult = FreeMarkerUtils.process("deploy-sh.ftl", model);
+        FileUtils.write(deployShFileName, deployShResult);
+    }
+
+}

loit-build-component/loit-build-deploy-env/src/main/java/com/loit/common/script/dto/BackendFrontEnum.java

+package com.loit.common.script.dto;
+
+/**
+ * 前后端类型
+ */
+public enum BackendFrontEnum {
+
+
+    /**
+     * 后端
+     */
+    BACKEND("backend", "后端"),
+
+    /**
+     * web 前端
+     */
+    web("web", "前端"),
+
+
+    /**
+     * h5
+     */
+    h5("h5", "h5");
+
+    private String code;
+    private String name;
+
+    private BackendFrontEnum(String code, String name) {
+        this.code = code;
+        this.name = name;
+    }
+
+    public String getName() {
+        return name;
+    }
+
+    public String getCode() {
+        return code;
+    }
+
+    /**
+     * 根据Code 获取枚举
+     */
+    public static BackendFrontEnum getEnumByCode(String code) {
+        for (BackendFrontEnum bfEnum : BackendFrontEnum.values()) {
+            if (bfEnum.getCode().equals(code)) {
+                return bfEnum;
+            }
+        }
+        return null;
+    }
+
+}

loit-build-component/loit-build-deploy-env/src/main/java/com/loit/common/script/dto/DeployInfoDataDTO.java

+package com.loit.common.script.dto;
+
+import com.loit.common.utils.excel.annotation.ExcelField;
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+
+import java.io.Serializable;
+
+
+@ApiModel(value = "DeployInfoDataDTO", description = "部署信息DTO")
+public class DeployInfoDataDTO implements Serializable {
+
+    private static final long serialVersionUID = -6587921299183759035L;
+
+    @ApiModelProperty(value = "固定IP")
+    @ExcelField(title = "固定IP", sort = 1)
+    private String fixedIp;
+
+    @ApiModelProperty(value = "浮动IP")
+    @ExcelField(title = "浮动IP", sort = 2)
+    private String floatingIp;
+
+    @ApiModelProperty(value = "部署路径")
+    @ExcelField(title = "deployPath", sort = 3)
+    private String deployPath;
+
+    @ApiModelProperty(value = "前后端类型")
+    @ExcelField(title = "前后端类型", sort = 4)
+    private String backendFrontType;
+
+    @ApiModelProperty(value = "模块服务名")
+    @ExcelField(title = "模块服务名", sort = 5)
+    private String serviceName;
+
+    @ApiModelProperty(value = "端口")
+    @ExcelField(title = "端口", sort = 6)
+    private String port;
+
+    @ApiModelProperty(value = "部署包名称")
+    @ExcelField(title = "部署包名称", sort = 6)
+    private String deployJar;
+
+    public String getFixedIp() {
+        return fixedIp;
+    }
+
+    public void setFixedIp(String fixedIp) {
+        this.fixedIp = fixedIp;
+    }
+
+    public String getFloatingIp() {
+        return floatingIp;
+    }
+
+    public void setFloatingIp(String floatingIp) {
+        this.floatingIp = floatingIp;
+    }
+
+    public String getDeployPath() {
+        return deployPath;
+    }
+
+    public void setDeployPath(String deployPath) {
+        this.deployPath = deployPath;
+    }
+
+    public String getBackendFrontType() {
+        return backendFrontType;
+    }
+
+    public void setBackendFrontType(String backendFrontType) {
+        this.backendFrontType = backendFrontType;
+    }
+
+    public String getServiceName() {
+        return serviceName;
+    }
+
+    public void setServiceName(String serviceName) {
+        this.serviceName = serviceName;
+    }
+
+    public String getPort() {
+        return port;
+    }
+
+    public void setPort(String port) {
+        this.port = port;
+    }
+
+    public String getDeployJar() {
+        return deployJar;
+    }
+
+    public void setDeployJar(String deployJar) {
+        this.deployJar = deployJar;
+    }
+}

loit-build-component/loit-build-deploy-env/src/main/java/com/loit/common/utils/file/FileUtils.java

+package com.loit.common.utils.file;
+
+import lombok.extern.slf4j.Slf4j;
+
+import java.io.*;
+
+/**
+ * 文件追加工具类
+ *
+ * @author
+ */
+
+@Slf4j
+public class FileUtils {
+
+
+    public static void write(String file, String conent) {
+
+        BufferedWriter out = null;
+        try {
+            out = new BufferedWriter(new OutputStreamWriter(new FileOutputStream(file)));
+            out.write(conent);
+            out.newLine();
+        } catch (Exception e) {
+            log.error(e.getMessage(), e);
+        } finally {
+            try {
+                if (out != null) {
+                    out.close();
+                }
+            } catch (IOException e) {
+                log.error(e.getMessage(), e);
+            }
+        }
+    }
+
+    /**
+     * 使用 FileOutputStream
+     */
+    public static void appendNewLine(String file, String conent) {
+        BufferedWriter out = null;
+        try {
+            out = new BufferedWriter(new OutputStreamWriter(new FileOutputStream(file, true)));
+            out.write(conent);
+            out.newLine();
+        } catch (Exception e) {
+            log.error(e.getMessage(), e);
+        } finally {
+            try {
+                if (out != null) {
+                    out.close();
+                }
+            } catch (IOException e) {
+                log.error(e.getMessage(), e);
+            }
+        }
+    }
+
+
+    public static void append(String file, String conent) {
+        BufferedWriter out = null;
+        try {
+            out = new BufferedWriter(new OutputStreamWriter(new FileOutputStream(file, true)));
+            out.write(conent);
+        } catch (Exception e) {
+            log.error(e.getMessage(), e);
+        } finally {
+            try {
+                if (out != null) {
+                    out.close();
+                }
+            } catch (IOException e) {
+                log.error(e.getMessage(), e);
+            }
+        }
+    }
+
+}

loit-build-component/loit-build-deploy-env/src/main/java/com/loit/common/utils/freemarker/FreeMarkerUtils.java

+package com.loit.common.utils.freemarker;
+
+import freemarker.template.Configuration;
+import freemarker.template.DefaultObjectWrapper;
+import freemarker.template.Template;
+import lombok.extern.slf4j.Slf4j;
+
+import java.io.File;
+import java.io.StringWriter;
+import java.util.Map;
+
+@Slf4j
+public class FreeMarkerUtils {
+
+
+    public static String process(String templateFileName, Map<String, ?> model) {
+        try {
+
+            Configuration cfg = new Configuration(Configuration.VERSION_2_3_23);
+            cfg.setDirectoryForTemplateLoading(new File("F:\\9Git140\\loit-build-common\\loit-build-component\\loit-build-deploy-env\\src\\main\\resources\\template\\"));
+            cfg.setObjectWrapper(new DefaultObjectWrapper(Configuration.VERSION_2_3_23));
+            Template temp = cfg.getTemplate(templateFileName);
+
+            StringWriter out = new StringWriter();
+            temp.process(model, out);
+            String result = out.toString();
+            return result;
+
+        } catch (Exception e) {
+            log.error(e.getMessage(), e);
+        }
+
+        return "";
+    }
+
+}

loit-build-component/loit-build-deploy-env/src/main/resources/template/bootstrap.ftl

+spring.profiles.active=prod${port}
+spring.application.name=${serviceName}
+# Nacos \ufffd\ufffd\ufffd\ufffd\ufffd\ufffd\ufffd\u0135\ufffd\u05b7
+spring.cloud.nacos.config.server-addr=10.0.120.221:8848
+spring.cloud.nacos.config.namespace=05270cbf-5a81-4a23-a534-b59ba26f11d5
+spring.cloud.nacos.config.file-extension=yaml
+spring.main.allow-bean-definition-overriding=true

loit-build-component/loit-build-deploy-env/src/main/resources/template/deploy-sh.ftl

+#!/bin/sh
+echo "pramas:" $1
+command=$(cat updowncommand.txt)
+echo 'command:' $command
+
+if [ -z "$1" ]; then
+  command='up'
+  echo 'command reset value:' $command
+fi
+
+echo '---------------kill.jar----------------'
+
+KILL_PROCESS_NAME='${deployPath}/${deployJar}'
+
+PROCESS_ID=`ps -ef | grep $KILL_PROCESS_NAME | grep -v 'grep' | awk '{print $2}'`
+
+echo 'ProcessId: ' $PROCESS_ID
+
+for id in $PROCESS_ID
+
+do
+        echo 'KILL_ID: ' $id
+        kill -s 9 $id
+done
+
+echo '---------------killed.jar----------------'
+
+if [ "$command" != "down" ]; then
+echo '---------------start.jar----------------'
+
+nohup  /usr/local/java/jdk1.8/bin/java  -javaagent:/usr/local/skywalking/agent/skywalking-agent.jar -Dskywalking.trace.ignore_path=/api/v1/rest/event/longpolling  -Dskywalking.agent.service_name=${serviceName} -Dskywalking.collector.backend_service=10.0.120.212:11800,10.0.120.143:11800,10.0.120.44:11800   -Xms2g -Xmx2g -jar $KILL_PROCESS_NAME --spring.profiles.active=prod${port} >/dev/null 2>&1  &
+
+echo '---------------started.jar----------------'
+
+for i in {1..30};do
+  sleep 1
+  tail -n5 ${deployPath}/logs/${serviceName}.log
+done
+fi