zoukankan      html  css  js  c++  java
  • Java 调用 Rest api 设置经典 Linux 虚拟机的实例启停

    现象描述

    用户可以通过 Rest API 设置经典 Linux 虚拟机实例的启停。在调用该 API 时需要通过 Azure Active Directory(下文简称 AAD) 获取 Token,但是因为中国 Azure 中通过 AAD 的 Application 获取到的 Token 无法操作经典 API,所以需要通过 Client ID 和管理员的用户名密码来获取 Token。

    前提条件

    创建一台 Linux 经典虚拟机。

    示例代码

    Java
    import java.io.DataOutputStream;
    import java.io.File;
    import java.io.FileInputStream;
    import java.io.IOException;
    import java.io.InputStream;
    import java.net.URI;
    import java.net.URISyntaxException;
    import java.net.URL;
    import java.security.KeyManagementException;
    import java.security.*;
    import java.security.KeyStoreException;
    import java.security.NoSuchAlgorithmException;
    import java.security.UnrecoverableKeyException;
    import java.security.cert.X509Certificate;
    import java.util.HashMap;
    import java.util.Map;
    import java.util.Scanner;
    import java.util.concurrent.ExecutionException;
    import java.util.concurrent.ExecutorService;
    import java.util.concurrent.Executors;
    import java.util.concurrent.Future;
    import javax.net.ssl.*;
    import javax.net.ssl.KeyManagerFactory;
    import javax.net.ssl.SSLSocketFactory;
    import javax.net.ssl.TrustManager;
    import org.codehaus.jackson.map.ObjectMapper;
    
    //get Access token for Rest API
    public void GetToken() { 
        ExecutorService service = Executors.newFixedThreadPool(1);
        AuthenticationContext ac = new AuthenticationContext("https://login.chinacloudapi.cn/tenantID", true, service); 
        Future<AuthenticationResult> future = ac.acquireToken("https://management.core.chinacloudapi.cn/",  "1950a258-227b-4e31-a9cf-717495945fc2", "username", "password", null);
        AuthenticationResult result = future.get();
        String token = result.getAccessToken();
        rest(token);
    }
    
    public static void rest(String accessToken) throws IOException{
        URL url = new URL(String.format("https://management.core.chinacloudapi.cn/subID/services/hostedservices/{hostedservices}/deployments/{deployments}/roleinstances/{roleinstancesName}/Operations"));
        HttpsURLConnection conn = (HttpsURLConnection)url.openConnection();
        conn.setRequestProperty("x-ms-version", "2013-06-01");
        conn.setRequestProperty("Authorization", "Bearer " + accessToken);
        conn.setRequestProperty("Content-Type", "application/xml");
    
        //StartRole
        String roleInstance = new String("<StartRoleOperation xmlns="http://schemas.microsoft.com/windowsazure" xmlns:i="http://www.w3.org/2001/XMLSchema-instance">
    " + "<OperationType>StartRoleOperation</OperationType>
    " +                               "</StartRoleOperation>");
        //ShutdownRole             
        String roleins = new String( "<ShutdownRoleOperation xmlns="http://schemas.microsoft.com/windowsazure" xmlns:i="http://www.w3.org/2001/XMLSchema-instance">" +"<OperationType>ShutdownRoleOperation</OperationType>" +                                           "<PostShutdownAction>StoppedDeallocated</PostShutdownAction>" +                                               "</ShutdownRoleOperation>");
        byte[] data = roleInstance.getBytes();
        conn.setDoOutput(true);
        conn.setRequestMethod("POST");
        if (data != null)
        {
            DataOutputStream requestStream = new DataOutputStream(conn.getOutputStream());
            requestStream.write(data);
            requestStream.flush();
            requestStream.close();
        }
        String mess =  conn.getResponseMessage();
        int code = conn.getResponseCode(); 
        InputStream input = conn.getErrorStream();
        if (input == null)
        input = conn.getInputStream();
        String response = null;
        try (Scanner scanner = new Scanner(input)) {
            scanner.useDelimiter("\Z");
            response = scanner.next();
            scanner.close();
            input.close();
        }
    }
    

    参考链接

    Virtual Machines (classic) REST API - Start Role

  • 相关阅读:
    Java多线程之线程安全队列Queue与同步容器
    Java的四种引用方式
    java编程使用freemarker导出word问题
    Hive 报错:java.lang.RuntimeException: Unable to instantiate org.apache.hadoop.hive.metastore.HiveMetaStoreClient
    windows10上Eclipse运行MapReduce wordcount程序遇到的坑
    HDFS中namenode启动失败
    【将文件中字符串赋值到 ArrayList 中】
    【把 ArrayList 集合中的字符串内容写到文本文件中】
    【复制文本:按行复制文件】
    【复制文本:字符缓冲流】
  • 原文地址:https://www.cnblogs.com/zangdalei/p/7692990.html
Copyright © 2011-2022 走看看