本文介绍如何安装Alibaba Cloud ACK SDK for Java和如何快速使用Alibaba Cloud ACK SDK for Java完成常见操作，如创建集群、集群扩容以及添加已有ECS实例至Kubernetes集群。

前提条件

在安装和使用Alibaba Cloud ACK SDK for Java前，请确保您已经完成以下操作。

  • 安装Java环境。

    Alibaba Cloud ACK SDK for Java要求使用JDK1.6或更高版本。

  • 注册阿里云账号并生成访问密钥（AccessKey）。

    详情参见创建AccessKey。

源码地址

请参见以下信息获取源码。

编程语言 Github地址 Github文档
Java aliyun-openapi-java-sdk README.md

安装Alibaba Cloud ACK SDK for Java

  • 方法一：添加Maven依赖 （推荐）

    如果您使用Maven管理Java项目，可以通过在pom.xml文件中添加Maven依赖安装Alibaba Cloud ACK SDK for Java。查看各云产品的Maven依赖信息，请参见Alibaba Cloud SDK for Java。

    以使用Alibaba Cloud ACK SDK for Java为例，您只需添加以下两个依赖来安装ACK SDK核心库和Alibaba Cloud ACK SDK for Java。 

    <dependency>
    <groupId>com.aliyun</groupId>
    <artifactId>aliyun-java-sdk-core</artifactId>
    <version>4.5.0</version>
</dependency>
<dependency>
    <groupId>com.aliyun</groupId>
    <artifactId>aliyun-java-sdk-cs</artifactId>
    <version>4.7.15</version>
</dependency>

    如果Maven没有从中央存储库下载.jar包，则需要将此依赖项添加到pom.xml文件中，否则将报告NoClassDefFoundError 异常。 

    <dependency>
    <groupId>com.google.code.gson</groupId>
    <artifactId>gson</artifactId>
    <version>2.8.5</version>
</dependency>
  • 方法二：在集成开发环境中导入JAR文件

    无论您使用Eclipse还是IntelliJ作为集成开发环境，都可以通过导入JAR文件的方式安装Alibaba Cloud ACK SDK for Java。下载各云产品的JAR文件，请参见Alibaba Cloud SDK for Java。

    • 使用Eclipse

      在Eclipse的项目中安装Alibaba Cloud ACK SDK for Java，操作如下：

      1. 将下载的aliyun-java-sdk-xxx.jar文件复制到您的项目文件夹中。
      2. 在Eclipse中打开您的项目，右键单击该项目，单击Properties。
      3. 在弹出的对话框中，单击Java Build Path > Libraries > Add JARs添加下载的JAR文件。
      4. 单击Apply and Close。
    • 使用IntelliJ
      在IntelliJ的项目中安装Alibaba Cloud SDK for Java，操作如下：
      1. 将下载的aliyun-java-sdk-xxx.jar文件复制到您的项目文件夹中。
      2. 在IntelliJ中打开您的项目，在菜单栏中单击File > Project Structure。
      3. 单击Apply，然后单击OK。

示例

  • 创建集群

    以下示例指定master节点数为3、worker节点数为3，用于创建一个的新的Kubernetes集群实例。有关更多参数详情，请参见创建Kubernetes专有版集群。 

    package com.aliyun.demo.cs;

import com.aliyuncs.profile.DefaultProfile;
import com.aliyuncs.DefaultAcsClient;
import com.aliyuncs.IAcsClient;
import com.aliyuncs.exceptions.ClientException;
import com.aliyuncs.exceptions.ServerException;
import com.aliyuncs.http.FormatType;
import com.aliyuncs.cs.model.v20151215.*;

import java.util.Arrays;
import java.util.HashMap;
import java.util.Map;

public class Main {
    public static void main(String[] args) {
        // 创建DefaultAcsClient实例并初始化。
        DefaultProfile profile = DefaultProfile.getProfile(
                "<your-region-id>",          // 地域ID
                "<your-access-key-id>",      // RAM账号的AccessKey ID
                "<your-access-key-secret>"); // RAM账号AccessKey Secret
        IAcsClient client = new DefaultAcsClient(profile);
        // 创建API请求并设置参数。
        CreateClusterRequest request = new CreateClusterRequest();
        final Map<String, Object> diskParams = new HashMap<String, Object>() {{
            put("category", "cloud_ssd");
            put("size", 500);
        }};
        Map<String, String> createParams = new HashMap<String, String>() {{
            put("cluster_type", "Kubernetes");
            put("name", "my-test-Kubernetes-cluster");
            put("region_id", "cn-beijing");
            put("kubernetes_version", "1.12.6-aliyun.1");
            put("master_count", "3");
            put("master_vswitch_ids", Arrays.asList("vsw-2ze48rkq464rsdts****", "vsw-2ze48rkq464rsdts1****", "vsw-2ze48rkq464rsdts1****").toString());
            put("master_instance_types", Arrays.asList("ecs.sn1.medium", "ecs.sn1.medium", "ecs.sn1.medium").toString());
            put("master_system_disk_category", "cloud_efficiency");
            put("master_system_disk_size", "40");
            put("worker_instance_types", Arrays.asList("ecs.sn2.3xlarge").toString());
            put("worker_system_disk_category", "cloud_efficiency");
            put("worker_system_disk_size", "120");
            put("worker_vswitch_ids", Arrays.asList("vsw-2ze48rkq464rsdts****").toString());
            put("worker_data_disks", Arrays.asList(diskParams).toString());
            put("master_data_disks", Arrays.asList(diskParams).toString());
            put("num_of_nodes", "3");
            put("container_cidr", "172.20.XX.XX/16");
            put("service_cidr", "172.21.XX.XX/20");
        }};

        if (createParams != null && !createParams.isEmpty()) {
            byte[] data;
            data = ParameterHelper.getJsonData(createParams);
            request.setHttpContent(data, "UTF-8", FormatType.JSON);
        }

        // 发起请求并处理应答或异常。
        CreateClusterResponse response;
        try {
            response = client.getAcsResponse(request);
        } catch (ServerException e) {
            e.printStackTrace();
        } catch (ClientException e) {
            e.printStackTrace();
        }
    }
}
  • 集群扩容

    以下示例将在集群<your-cluster-id>中扩容一台类型为ecs.c5.xlarge的节点。有关更多参数详情，请参见扩容Kubernetes集群。 

    package com.aliyun.demo.cs;

import com.aliyuncs.profile.DefaultProfile;
import com.aliyuncs.DefaultAcsClient;
import com.aliyuncs.IAcsClient;
import com.aliyuncs.exceptions.ClientException;
import com.aliyuncs.exceptions.ServerException;
import com.aliyuncs.http.FormatType;
import com.aliyuncs.cs.model.v20151215.*;

import java.util.Arrays;
import java.util.HashMap;
import java.util.Map;

public class Main {
    public static void main(String[] args) {
        // 创建DefaultAcsClient实例并初始化。
        DefaultProfile profile = DefaultProfile.getProfile(
                "<your-region-id>",          // 地域ID
                "<your-access-key-id>",      // RAM账号的AccessKey ID
                "<your-access-key-secret>"); // RAM账号AccessKey Secret
        IAcsClient client = new DefaultAcsClient(profile);
        // 创建API请求并设置参数。
        ScaleClusterRequest request = new ScaleClusterRequest();
        request.setClusterId("<your-cluster-id>");
        Map<String, String> scaleParams = new HashMap<String, String>(){{
            put("key_pair","common");
            put("count","1");
            put("worker_instance_types",Arrays.asList("ecs.c5.xlarge").toString());
            put("worker_system_disk_category","cloud_efficiency");
            put("worker_data_disk","120");
        }};
        if (scaleParams != null && !scaleParams.isEmpty()) {
            byte[] data;
            data = ParameterHelper.getJsonData(scaleParams);
            request.setHttpContent(data, "UTF-8", FormatType.JSON);
        }

        // 发起请求并处理应答或异常。
        ScaleClusterResponse response;
        try {
            response = client.getAcsResponse(request);
        } catch (ServerException e) {
            e.printStackTrace();
        } catch (ClientException e) {
            e.printStackTrace();
        }
    }
}
  • 添加已有ECS实例至Kubernetes集群

    以下示例将实例ID为i-xxxx和i-yyyy的ECS添加到集群<your-cluster-id>中。有关更多参数详情，请参见添加已有ECS节点到Kubernetes集群。 

    package com.aliyun.demo.cs;

import com.aliyuncs.profile.DefaultProfile;
import com.aliyuncs.DefaultAcsClient;
import com.aliyuncs.IAcsClient;
import com.aliyuncs.exceptions.ClientException;
import com.aliyuncs.exceptions.ServerException;
import com.aliyuncs.http.FormatType;
import com.aliyuncs.cs.model.v20151215.*;


import java.util.Arrays;
import java.util.HashMap;
import java.util.Map;

public class Main {
    public static void main(String[] args) {
        // 创建DefaultAcsClient实例并初始化。
        DefaultProfile profile = DefaultProfile.getProfile(
                "<your-region-id>",          // 地域ID
                "<your-access-key-id>",      // RAM账号的AccessKey ID
                "<your-access-key-secret>"); // RAM账号AccessKey Secret
        IAcsClient client = new DefaultAcsClient(profile);
        // 创建API请求并设置参数。
        AttachInstancesRequest request = new AttachInstancesRequest();
        request.setClusterId("<your-cluster-id>");
        Map<String, String> attachBody = new HashMap<String, String>(){{
            put("password","Hello1234");
            put("instances",Arrays.asList("i-xxxx","i-yyyy").toString());
        }};
        if (attachBody != null && !attachBody.isEmpty()) {
            byte[] data;
            data = ParameterHelper.getJsonData(attachBody);
            request.setHttpContent(data, "UTF-8", FormatType.JSON);
        }
        request.setHttpContentType(FormatType.JSON);
        // 发起请求并处理应答或异常。
        AttachInstancesResponse response;
        try {
            response = client.getAcsResponse(request);
        } catch (ServerException e) {
            e.printStackTrace();
        } catch (ClientException e) {
            e.printStackTrace();
        }
    }
}