<parent>        
        <groupId>com.das</groupId>
        <artifactId>dependency</artifactId>
        <version>3.0.0</version>
     </parent>

    <dependency>  
        <groupId>com.das.libcore</groupId>
        <artifactId>commons-base</artifactId>
        <version>3.0.0</version>
    </dependency>

    <dependency>  
        <groupId>com.das.libcore</groupId>
        <artifactId>web-spring-boot-starter</artifactId>
        <version>3.0.0</version>
    </dependency>

    <dependency>  
        <groupId>com.das.libcore</groupId>
        <artifactId>das-generator</artifactId>
        <version>3.0.0</version>
    </dependency>

    <dependency>  
        <groupId>com.das.libcore</groupId>
        <artifactId>drools-spring-boot-starter</artifactId>
        <version>3.0.0</version>
    </dependency>

    <dependency>  
        <groupId>com.das.libcore</groupId>
        <artifactId>globalization-spring-boot-starter</artifactId>
        <version>3.0.0</version>
    </dependency>

    <dependency>  
        <groupId>com.das.libcore</groupId>
        <artifactId>kafka-spring-boot-starter</artifactId>
        <version>3.0.0</version>
    </dependency>

    <dependency>  
        <groupId>com.das.libcore</groupId>
        <artifactId>mqtt-spring-boot-starter</artifactId>
        <version>3.0.0</version>
    </dependency>

    <dependency>  
        <groupId>com.das.libcore</groupId>
        <artifactId>pulsar-spring-boot-starter</artifactId>
        <version>3.0.0</version>
    </dependency>

    @PulsarConsumer 注解说明
    - topic：消费者订阅业务主题（无需租户和命名空间）, 通配符匹配订阅需使用${xxx}格式（但不能以正则开头）
    - subscriptionName: 消费订阅的名称， 类似于kafka 消费者组group，不指定客户端会自动生成。
    - subscriptionType： 消费订阅类型， Exclusive一个订阅名只能有一个消费者订阅、 Shared可供多个消费者消费，多topic 默认按轮流方式分配，
    不能保证消息顺序、Key_Shared 按消息键分配，保证同一键的消息按顺序分配到同一消费者、Failover可允许备用消费者订阅，只能主消费者消费. 默认Shared.
    - initCount： 创建消费者数量，默认1 (Exclusive模式下不要配置)
    - tenant：指定某个租户订阅, 不配置或配置*则订阅所有租户（包括public）。
    - initialPosition：指定消息从什么位置消费(默认最早未消费SubscriptionInitialPosition.Earliest)
    - namespace: 指定某个命名空间订阅，不配置或配置*则订阅所有命名空间, 支持${xxx}变量配置（变量配置需放入pular.namespace-var下，变量名建议用消费者类）
    - nameSpacePrefix: 订阅指定命名空间前缀，不指定默认为公共业务没有前缀(前缀枚举: NameSpacePrefix), 指定前缀则不能配置nameSpacePrefix 
      - 实例相关：IOT("iot_")
      - 项目相关：PROJ("proj_")
      - 公共:NONE("")

示例： 配置消费者确认超时与重试机制
配置官方文档：https://pulsar.apache.org/docs/3.0.x/concepts-messaging/
 /**
   * 当脚手架消费者配置无法满足时，允许自定义配置消费者
   * 脚手架创建pulsar消费者拓展点
   *
   * @param consumerBuilder  脚手架根据注解配置生成的ConsumerBuilder
   * @return
   */
    default ConsumerBuilder consumerBuilder(ConsumerBuilder consumerBuilder){
        
        consumerBuilder.ackTimeout(10, TimeUnit.SECONDS)
        .ackTimeoutRedeliveryBackoff(MultiplierRedeliveryBackoff.builder()
                .minDelayMs(1000)
                .maxDelayMs(60 * 1000)
                .multiplier(2)
                .build());
                
        return consumerBuilder;
    }

    authenticationEnabled=true
    authenticationProviders=org.apache.pulsar.broker.authentication.AuthenticationProviderBasic
    basicAuthConf=file:///path/to/.htpasswd
    brokerClientAuthenticationPlugin=org.apache.pulsar.client.impl.auth.AuthenticationBasic
    brokerClientAuthenticationParameters={"userId":"superuser","password":"admin"}
    authenticateOriginalAuthData=true

    authenticationEnabled=true
    authenticationProviders=org.apache.pulsar.broker.authentication.AuthenticationProviderBasic
    basicAuthConf=file:///path/to/.htpasswd
    brokerClientAuthenticationPlugin=org.apache.pulsar.client.impl.auth.AuthenticationBasic
    brokerClientAuthenticationParameters={"userId":"superuser","password":"admin"}
    forwardAuthorizationCredentials=true

    authPlugin=org.apache.pulsar.client.impl.auth.AuthenticationBasic
    authParams={"userId":"superuser","password":"admin"}

    AuthenticationBasic auth = new AuthenticationBasic();
    auth.configure("{\"userId\":\"superuser\",\"password\":\"admin\"}");
    PulsarClient client = PulsarClient.builder()
    .serviceUrl("pulsar://broker.example.com:6650")
    .authentication(auth)
    .build();

  配置文件：conf/standalone.conf:
  authenticationProviders=org.apache.pulsar.broker.authentication.AuthenticationProviderToken
  tokenSecretKey=file:///path/to/my-secret.key

    <dependency>  
        <groupId>com.das.libcore</groupId>
        <artifactId>rabbitmq</artifactId>
        <version>3.0.0</version>
    </dependency>

    <dependency>  
        <groupId>com.das.libcore</groupId>
        <artifactId>redis-spring-boot-starter</artifactId>
        <version>3.0.0</version>
    </dependency>

    <dependency>  
        <groupId>com.das.libcore</groupId>
        <artifactId>sign-spring-boot-starter</artifactId>
        <version>3.0.0</version>
    </dependency>

@Sign
@Validated
@Controller
@RequestMapping("/sign")
public class SignDemoController {
    @GetMapping(value = "/test/get/1")
    @ResponseBody
    public String testGetSignWithoutParam() {
        return ActionResult.ok("OK");
    }

    @PostMapping(value = "/test/post/2")
    @ResponseBody
    public UserVO testPostSignWithBody(@RequestBody @Validated UserVO userVO, @RequestParam String name) {
        return ActionResult.ok(userVO);
    }

    @IgnoreSign
    @PostMapping(value = "/test/ignore")
    @ResponseBody
    public String testIgnoreSign() {
        return ActionResult.ok("OK");
    }
}

http://localhost:8080/sign/test/get/1?timestamp=1666668081091&appid=tang&sign=4462488eabe48476213f5f2d04b46564&sign_method=md5&name=tang&age=26
age=26&appid=tang&name=tang&sign_method=md5&timestamp=1666668081091

http://localhost:8080/sign/test/post/2?timestamp=1666668081091&appid=tang&sign=07c6eb5e4dc2540cb9bf54e860f88626&sign_method=md5&name=tang
body={"userId":1,"username":"zhangsan"}&appid=tang&name=tang&sign_method=md5&timestamp=1666668081091

然后根据传过来的appId查询secret,同时根据sign_method方法类型选用不同算法进行加密,规则如下

当sign_method = hmac_sha256
HMACSHA256( "body={"police":"noPo"}&appid=knasdfnas&age=17&name=yuhun&timestamp=111111" , secret )

当sign_method = md5
md5( "body={"police":"noPo"}&appid=knasdfnas&age=17&name=yuhun&timestamp=111111" + secret )

    <dependency>  
        <groupId>com.das.libcore</groupId>
        <artifactId>file-spring-boot-starter</artifactId>
        <version>3.0.0</version>
    </dependency>

    <dependency>  
        <groupId>com.das.libcore</groupId>
        <artifactId>schema-spring-boot-starter</artifactId>
        <version>3.0.0</version>
    </dependency>

     <dependency>  
        <groupId>com.das.libcore</groupId>
        <artifactId>svclog-spring-boot-starter</artifactId>
        <version>3.0.0</version>
    </dependency>

     <dependency>  
        <groupId>com.das.libcore</groupId>
        <artifactId>xxljob-spring-boot-starter</artifactId>
        <version>3.0.0</version>
    </dependency>

     <dependency>  
        <groupId>com.das.libcore</groupId>
        <artifactId>apollo-client</artifactId>
        <version>3.0.0</version>
    </dependency>

    <dependency>  
        <groupId>com.das.libcore</groupId>
        <artifactId>apollo-spring-boot-starter</artifactId>
        <version>3.0.0</version>
    </dependency>

     <dependency>  
        <groupId>com.das.libcore</groupId>
        <artifactId>feign-spring-boot-starter</artifactId>
        <version>3.0.0</version>
    </dependency>

    <dependency>
        <groupId>com.das.libcore</groupId>
        <artifactId>justauth-spring-boot-starter</artifactId>
        <version>3.0.0</version>
    </dependency>

    <dependency>
        <groupId>com.das.libcore</groupId>
        <artifactId>minio-spring-boot-starter</artifactId>
        <version>3.0.0</version>
    </dependency>

划分依据：以租户或者项目维度进行管理资源，精确控制每个项目或者每个租户消耗的空间大小
服务名：由后端明确告诉前端，上传到所在服务下，方便管理
注意： 业务产生的文件，文件名不允许有规律，如按数字有规律递增或者时间戳等，防止拖库
建议：在现有文件层级后以 yyyy/MM/dd 创建 年月日或者年月层级的文件夹，方便业务统一处理和管理，如按时间清除文件

pipeline {
    agent{ label 'node22||node24||node25' }
    options {
        buildDiscarder logRotator(artifactDaysToKeepStr: '', artifactNumToKeepStr: '', daysToKeepStr: '300', numToKeepStr: '36500')
    }
    environment {
        Hub_Docker_Server='192.168.100.28:8088'
    }
    parameters {
        string(name: 'ImageTag', defaultValue: 'default',description: '默认情况下不用改动，定版时填写版本号。镜像标签,不能填写中文、空格和特殊字符')
        string(name: 'GitAddr',defaultValue: 'http://das-git.chn-das.com', description: '代码git地址')
        string(name: 'GitBranch',defaultValue: 'dev', description: '代码分支')
        string(name: 'AppPath',defaultValue: 'xxx', description: '程序入口文件夹。')
        booleanParam defaultValue: true, description: '是否发布,不发布的话就只打包镜像不更新环境', name: 'Release'
        string(name: 'DockerfilePath',defaultValue: '', description: '默认情况为空，有特殊服务需要自定义Dockerfile的服务填写Dockerfile文件路径。（不用填写Dockerfile文件名）')
        choice choices: ['192.168.100.26','192.168.100.21','192.168.100.22','192.168.100.23','192.168.100.27','192.168.100.29','192.168.100.30','192.168.100.32','192.168.100.33','192.168.100.191','192.168.100.193','192.168.100.194','192.168.100.195','192.168.100.196','192.168.100.197','192.168.100.198','192.168.100.199','192.168.100.204','192.168.100.210','192.168.100.211','192.168.100.212','192.168.100.213','192.168.100.214','192.168.100.215','192.168.100.216','192.168.100.217','192.168.100.218','192.168.100.219','192.168.100.220','192.168.100.221','192.168.100.222'], description: '选择发布的服务器', name: 'RemoteIP'
        booleanParam defaultValue: false, description: '清除缓存das/libcore', name: 'ClearCache'
        choice choices: ['amd64','arm64'], description: '选择处理器架构', name: 'Architecture'
    }

    stages {
      stage("start"){
        steps{
          script{
            deleteDir()
            if("${params.ClearCache}" == "true" )
            {
              sh 'rm -rf /root/.m2/repository/com/das/libcore/'
            }
            ## 拉取代码
            checkout([$class: 'GitSCM', branches: [[name: "${GitBranch}"]], doGenerateSubmoduleConfigurations: false, extensions: [], submoduleCfg: [], userRemoteConfigs: [[credentialsId: 'b94e7780-10e7-4dde-9c66-60b2615902f4', url: "${GitAddr}"]]])
              AppName=sh(returnStdout: true, script: 'echo ${AppPath}|tr "/" " "|awk \'{print $NF}\'|tr "." "-"|tr [A-Z] [a-z]').trim()
              Group_Name=sh(returnStdout: true, script: 'echo ${GitAddr}|sed "s#http://das-git.chn-das.com/##g"|awk -F"/" \'{print $2}\'|tr [A-Z] [a-z]').trim()
              ServerName="${Group_Name}-${AppName}"
              if (fileExists('./.k8s-servername')) {
                  ServerName=sh(returnStdout: true, script: 'cat ./.k8s-servername').trim()
              }
              imageTag="${params.ImageTag}"
              if(imageTag=="default")
              {
                imageTag = sh(returnStdout: true, script: 'git rev-parse --short HEAD').trim()
                CreateTime = sh(returnStdout: true, script: 'date +%s').trim()
                imageTag = "${GitBranch}-${imageTag}-${CreateTime}"
              }

              ImageName = "${Hub_Docker_Server}/dasaiot/${ServerName}:${imageTag}"
              LatestImageName = "${Hub_Docker_Server}/dasaiot/${ServerName}:latest"

              sh """
                echo ${params.AppPath}
                echo ${ServerName}
                echo ${imageTag}
                ## 打包操作
                mvn clean package -U
                ls ${params.AppPath}/target/
                cp ${params.AppPath}/target/${params.AppPath}.jar ./
                """
                ## amd64 - 标准, arm64 - 国产化环境
              if("${params.Architecture}" == "amd64" )
              {
              sh """
                if [ -z "${params.DockerfilePath}" ];
                then
                    export ServerName=${ServerName}
                    export AppPath=${params.AppPath}
                    jar ufe ${params.AppPath}.jar org.springframework.boot.loader.PropertiesLauncher
                    wget -O Dockerfile_java http://minio.rd.chn-das.com/cicd/dockerfile_template/Dockerfile_java
                    envsubst < Dockerfile_java > ./Dockerfile
                else
                    cp ${params.DockerfilePath}/Dockerfile ./
                    if cat Dockerfile | grep -q "PropertiesLauncher"; then
                        sed  -i /PropertiesLauncher/d Dockerfile
                        jar ufe ${params.AppPath}.jar org.springframework.boot.loader.PropertiesLauncher
                    fi
                fi
                docker build --no-cache -t ${ImageName} .
                docker tag ${ImageName} ${LatestImageName}
                ## 发布镜像
                docker push ${ImageName}
                docker push ${LatestImageName}
              """
             } else if("${params.Architecture}" == "arm64" )
             {
               sh """
                if [ -z "${params.DockerfilePath}" ];
                then
                    export ServerName=${ServerName}
                    export AppPath=${params.AppPath}
                    jar ufe ${params.AppPath}.jar org.springframework.boot.loader.PropertiesLauncher
                    wget -O Dockerfile_javaarm64 http://minio.rd.chn-das.com/cicd/dockerfile_template/Dockerfile_javaarm64
                    envsubst < Dockerfile_javaarm64 > ./Dockerfile
                else
                    cp ${params.DockerfilePath}/Dockerfilearm64 ./Dockerfile
                    if cat Dockerfile | grep -q "PropertiesLauncher"; then
                        sed  -i /PropertiesLauncher/d Dockerfile
                        jar ufe ${params.AppPath}.jar org.springframework.boot.loader.PropertiesLauncher
                    fi
                fi
                 docker build --no-cache -t ${ImageName} .
                 ## 发布镜像
                 docker push ${ImageName}
               """
             }


              echo "是否发布"
              if ( Release == "true" )
              {sh """
                  if [ -z "`ssh -i /root/.ssh/jenkins -o StrictHostKeyChecking=no -tt root@${RemoteIP} "kubectl get deploy| grep ${ServerName}"`" ];
                  then
                        wget -O Javatemplate.yaml http://minio.rd.chn-das.com/cicd/k8s_template/Javatemplate.yaml
                        export ServerName=${ServerName}
                        export ImageName=${ImageName}
                        envsubst < Javatemplate.yaml > ./${ServerName}.yaml

                        scp -i /root/.ssh/jenkins -o StrictHostKeyChecking=no ${ServerName}.yaml root@${RemoteIP}:/opt/data/appdata/yaml/${ServerName}.yaml
                        ssh -i /root/.ssh/jenkins -o StrictHostKeyChecking=no -tt root@${RemoteIP} "kubectl apply -f /opt/data/appdata/yaml/${ServerName}.yaml"
                        curl -X 'POST' 'http://webhook-api.rd.chn-das.com/api/webhook/v1/wechat/notice?token={token}&users=all'   -H 'accept: */*'   -H 'Content-Type: application/json' -d '"'${RemoteIP}环境新增java服务${ServerName}'"'
                  else
                        ssh -i /root/.ssh/jenkins -o StrictHostKeyChecking=no -tt root@${RemoteIP} "kubectl  set image deployment/${ServerName} ${ServerName}=${ImageName}"
                  fi
              """
              echo "ServerName=${ServerName}"
              echo "ImageName=${ImageName}"
            }
          }
        }
      }
    }
}

  mvn clean package -U

    ## 创建镜像
    docker build --no-cache -t ${ImageName} .
    ## 标记本地镜像。归档至某个仓库
    docker tag ${ImageName} ${LatestImageName}
    ## 发布镜像至镜像仓库
    docker push ${ImageName}
    docker push ${LatestImageName}

## 找到已部署的服务(判断服务是否存在)
kubectl get deploy| grep ${ServerName}
## 更新deploy配置(服务不存在时)
kubectl apply -f /opt/data/appdata/yaml/${ServerName}.yaml
## 更新当前服务的镜像(服务存在时)
kubectl  set image deployment/${ServerName} ${ServerName}=${ImageName}