从一个简单 API 的发布到组件化的架构思考

在 SaaS 版本的零代码平台中，高级用户希望能上传自己编写的 WebAPI ，来实现一些复杂场景下的业务。就需要添加可以通过上传程序包进行发布部署的功能。

假设云服务器采用华为云，将一个自定义程序发布到华为云可以总结为三个步骤：

1、将自定义程序包构建成镜像推送到华为云的镜像仓库；

2、通过 API 的方式创建 Deploment （无状态负载）；

2、通过 API 的方式创建 Service ，并和 Deploment 关联；

下面看下简单实现这三个步骤需要怎么做。

在服务器上创建目录 pub ，目录中创建 Dockerfile 文件，内容如下：

FROM swr.cn-north-4.myhuaweicloud.com/xxx/openjdk:latest
ENV PARAMS=""
ENV TZ=PRC
ADD auto-deploy-demo-0.0.1-SNAPSHOT.jar /auto-deploy-demo-0.0.1-SNAPSHOT.jar
ENTRYPOINT ["sh","-c","java -jar /auto-deploy-demo-0.0.1-SNAPSHOT.jar  $PARAMS"]

From 后面的是在华为云上构建的基础 openjdk 镜像
auto-deploy-demo-0.0.1-SNAPSHOT.jar 为上传的 jar 包名称

在 pub 目录中再创建一个 pub.sh 文件，用来构建镜像并将镜像推送到华为云镜像仓库，pub.sh 内容如下：

docker build -t deploy-test .

docker login -u cn-xxxxxx-4@QYL2XOIAQQLUNJQXU6C7 -p 6ba6cbe87d61045efc9505fcd463cfc1aeceb6 swr.cn-xxxxxx.myhuaweicloud.com

docker tag deploy-test:latest swr.cn-xxxxxx.myhuaweicloud.com/xxxxxx/deploy-test:v1.0

docker push swr.cn-xxxxxx.myhuaweicloud.com/xxxxxx/deploy-test:v1.0

首先构建本地镜像
登录华为云的镜像仓库
设置 tag 并推送镜像

上传 jar 包的代码这里就不放了，下面是连接服务器并执行 pub.sh 文件的代码：

@GetMapping("/pushImage")
public String pushImage() throws IOException {
    SshClient sshClient = SshClientFactory.createSsh("root","xxxxxx","10.211.55.3",22);
    sshClient.exec("sh /root/pub/pub.sh", log -> {
    });

    return "ok";
}

可以看到，上面 jar 包的名称和镜像的名称都是写死的，真实场景中，会根据上传的包名和配置的镜像名来进行替换。

镜像有了，下一步就是创建 Deploment ，也就是华为云的无状态负载，使用接口的方式来进行创建。

调用华为云的接口，需要先获取 token ：

private String getToken(){
    String url="https://iam.xxxxxx.myhuaweicloud.com/v3/auth/tokens";
    Map<String, String> headerMap = new HashMap<>(8);
    headerMap.put("Content-Type","application/json");
    String tokenBody="{\n" +
    "    \"auth\": {\n" +
    "        \"identity\": {\n" +
    "            \"methods\": [\n" +
    "                \"password\"\n" +
    "            ],\n" +
    "            \"password\": {\n" +
    "                \"user\": {\n" +
    "                    \"name\": \"tokenuser\",\n" +
    "                    \"password\": \"password\",\n" +
    "                    \"domain\": {\n" +
    "                        \"name\": \"domain\"\n" +
    "                    }\n" +
    "                }\n" +
    "            }\n" +
    "        },\n" +
    "        \"scope\": {\n" +
    "            \"project\": {\n" +
    "                \"name\": \"xxxxxx\"\n" +
    "            }\n" +
    "        }\n" +
    "    }\n" +
    "}";
    HttpResponse httpResponse= HttpUtil.doPost(url,tokenBody,headerMap);
    //String result = httpResponse.body();

    String token=httpResponse.header("X-Subject-Token");
    return token;
}

需要注意的是，获取 token 时入参中的用户名和密码，需要在「统一身份认证」模块中创建一个单独的用户。

创建的 Deploment 的代码如下：

@GetMapping("/createDeploment")
public String createDeploment(){
    String token=getToken();
    String url="https://96284164-xxxx-11ec-a34d-0255ac1015f0.cce.cn-north-4.myhuaweicloud.com/apis/apps/v1/namespaces/default/deployments";
    Map<String, String> headerMap = new HashMap<>(8);
    headerMap.put("Content-Type","application/json");
    headerMap.put("X-Auth-Token",token);
    headerMap.put("X-Cluster-ID","96284164-xxxx-11ec-a34d-0255ac1015f0");
    String deploymentBody="{ \n" +
    "     \"apiVersion\": \"apps/v1\", \n" +
    "     \"kind\": \"Deployment\", \n" +
    "     \"metadata\": { \n" +
    "         \"labels\": { \n" +
    "             \"app\": \"deploy-test\" \n" +
    "         }, \n" +
    "         \"name\": \"deploy-test\" \n" +
    "     }, \n" +
    "     \"spec\": { \n" +
    "         \"replicas\": 1, \n" +
    "         \"selector\": { \n" +
    "             \"matchLabels\": { \n" +
    "                 \"app\": \"deploy-test\" \n" +
    "             } \n" +
    "         }, \n" +
    "         \"template\": { \n" +
    "             \"metadata\": { \n" +
    "                 \"labels\": { \n" +
    "                     \"app\": \"deploy-test\" \n" +
    "                 } \n" +
    "             }, \n" +
    "             \"spec\": { \n" +
    "                 \"containers\": [ \n" +
    "                     { \n" +
    "                         \"image\": \"swr.cn-xxxxxx.myhuaweicloud.com/xxxxxx/deploy-test:v1.0\", \n" +
    "                         \"imagePullPolicy\": \"IfNotPresent\", \n" +
    "                         \"name\": \"deploy-test\" \n" +
    "                     } \n" +
    "                 ], \n" +
    "                 \"imagePullSecrets\": [{ \n" +
    "                     \"name\": \"default-secret\" \n" +
    "                 }] \n" +
    "             } \n" +
    "         } \n" +
    "     } \n" +
    " }";

    HttpResponse httpResponse= HttpUtil.doPost(url,deploymentBody,headerMap);
    String result=httpResponse.body();

    return result;
}

image：使用上面推送到华为云镜像仓库中的镜像名称
接口的入参是 json 格式，json 中的内容，可以参考已创建的无状态负载中 Yaml 配置的内容，当然建议还是深入学习 k8s 的知识，这些参数什么意思自然就清楚了

创建完 Deploment 后，还需要创建 Service 才能进行访问，下面是创建 Service 的代码：

@GetMapping("/createService")
public String createService() {
    String token=getToken();
    String url="https://96284164-xxxx-11ec-a34d-0255ac1015f0.cce.xxxxxx-4.myhuaweicloud.com/api/v1/namespaces/default/services";
    Map<String, String> headerMap = new HashMap<>(8);
    headerMap.put("Content-Type","application/json");
    headerMap.put("X-Auth-Token",token);
    headerMap.put("X-Cluster-ID","96284164-xxxx-11ec-a34d-0255ac1015f0");

    String serviceBody="{ \n" +
    "     \"kind\":\"Service\", \n" +
    "     \"apiVersion\":\"v1\", \n" +
    "     \"metadata\":{ \n" +
    "        \"name\":\"service-deploy-test\", \n" +
    "        \"creationTimestamp\":null, \n" +
    "        \"labels\":{ \n" +
    "           \"app\":\"deploy-test\" \n" +
    "        } \n" +
    "     }, \n" +
    "     \"spec\":{ \n" +
    "        \"ports\":[{ \n" +
    "           \"name\":\"http\", \n" +
    "           \"port\":8082,\n" +
    "         \"protocol\":\"TCP\",  \n" +
    "           \"targetPort\":8080 \n" +
    "        }], \n" +
    "        \"selector\":{ \n" +
    "        \"app\":\"deploy-test\" \n" +
    "        }, \n" +
    "               \"type\":\"ClusterIP\"\n" +
    "    }\n" +
    " }";

    HttpResponse httpResponse= HttpUtil.doPost(url,serviceBody,headerMap);
    String result=httpResponse.body();

    return result;
}

name：service-deploy-test ，服务的名称，名称可以在界面中输入指定，最终会拼成访问的地址；
app：设置为 deploy-test ，这个名称和 Deploment 的名称要对应上，否则就挂接不上
type：设置为 ClusterIP ，表示集群内访问，集群内的容器之间可以访问，如果想要外网访问，需要设置为 NodePort ，如果使用了华为云的网关服务，则需要设置为 DNAT
port：8082 是访问时的端口
targetPort：8080 是 jar 包程序中监听的端口

依次进行镜像构建、创建 Deploment 和 Service 后，在华为云的 cce 无状态负载中就可以看到 deploy-test 了：