经验首页 前端设计 程序设计 Java相关 移动开发 数据库/运维 软件/图像 大数据/云计算 其他经验
当前位置：技术经验 » Java相关 » Java » 查看文章
springboot集成调用Azkaban
来源：cnblogs　　作者：不再_单纯　　时间：2018/11/16 10:30:45　　对本文有异议

springboot集成调用Azkaban

 

一、 说明

　　1.Azkaban是由Linkedin公司推出的一个批量工作流任务调度器，主要用于在一个工作流内以一个特定的顺序运行一组工作和流程，它的配置是通过简单的key:value对的方式，通过配置中的dependencies 来设置依赖关系，这个依赖关系必须是无环的，否则会被视为无效的工作流。Azkaban使用job配置文件建立任务之间的依赖关系，并提供一个易于使用的web用户界面维护和跟踪你的工作流。

        2.springboot版本：2.0.5  azkaban版本：3.59.0

 

二、maven依赖

  1.         <dependency>
  2.             <groupId>com.google.code.gson</groupId>
  3.             <artifactId>gson</artifactId>
  4.             <version>2.8.5</version>
  5.         </dependency>
  6.         <dependency>
  7.             <groupId>org.apache.commons</groupId>
  8.             <artifactId>commons-pool2</artifactId>
  9.             <version>2.5.0</version>
  10.         </dependency>
  11.         <dependency>
  12.             <groupId>org.apache.httpcomponents</groupId>
  13.             <artifactId>httpcore</artifactId>
  14.             <version>4.4.9</version>
  15.         </dependency>
  16.         <dependency>
  17.             <groupId>joda-time</groupId>
  18.             <artifactId>joda-time</artifactId>
  19.             <version>2.9.7</version>
  20.         </dependency>
View Code

 

三、代码

　　1.azkaban配置文件（注意需要在启动类@PropertySource标签中引入读取该配置文件）

  1. monitor.azkaban.username=azkaban
  2. monitor.azkaban.password=azkaban
  3. monitor.azkaban.url=http://192.168.11.12:8081
  4. monitor.azkaban.connectTimeout=60000
  5. monitor.azkaban.readTimeout=120000
azkaban.properties

　　2.azkaban配置实体类

  1. import org.springframework.beans.factory.annotation.Value;
  2. import org.springframework.context.annotation.Bean;
  3. import org.springframework.context.annotation.Configuration;
  4. import org.springframework.http.client.SimpleClientHttpRequestFactory;
  5. import org.springframework.web.client.RestTemplate;
  7. @Configuration
  8. public class AzkabanConfig {
  9.     @Value("${monitor.azkaban.username}")
  10.     private String azkUsername;
  11.     @Value("${monitor.azkaban.password}")
  12.     private String azkPassword;
  13.     @Value("${monitor.azkaban.url}")
  14.     private String azkUrl;
  15.     @Value("${monitor.azkaban.connectTimeout}")
  16.     private int connectTimeout;
  17.     @Value("${monitor.azkaban.readTimeout}")
  18.     private int readTimeout;
  20.     @Bean
  21.     public RestTemplate getRestTemplate() {
  22.         SimpleClientHttpRequestFactory requestFactory = new SimpleClientHttpRequestFactory();
  23.         requestFactory.setConnectTimeout(connectTimeout);
  24.         requestFactory.setReadTimeout(readTimeout);
  25.         RestTemplate restTemplate = new RestTemplate(requestFactory);
  26.         return restTemplate;
  27.     }
  29.     public String getAzkUsername() {
  30.         return azkUsername;
  31.     }
  33.     public void setAzkUsername(String azkUsername) {
  34.         this.azkUsername = azkUsername;
  35.     }
  37.     public String getAzkPassword() {
  38.         return azkPassword;
  39.     }
  41.     public void setAzkPassword(String azkPassword) {
  42.         this.azkPassword = azkPassword;
  43.     }
  45.     public String getAzkUrl() {
  46.         return azkUrl;
  47.     }
  49.     public void setAzkUrl(String azkUrl) {
  50.         this.azkUrl = azkUrl;
  51.     }
  53. }
AzkabanConfig

　　3.HttpClient配置SSL绕过https证书 

  1. import java.security.KeyManagementException;
  2. import java.security.NoSuchAlgorithmException;
  3. import java.security.cert.X509Certificate;
  5. import javax.net.ssl.HttpsURLConnection;
  6. import javax.net.ssl.SSLContext;
  7. import javax.net.ssl.TrustManager;
  8. import javax.net.ssl.X509TrustManager;
  10. public class SSLUtil {
  12.     private static final String PROTOCOL = "SSL";
  13.     private static final TrustManager[] UNQUESTIONING_TRUST_MANAGER = new TrustManager[] { new X509TrustManager() {
  15.         public java.security.cert.X509Certificate[] getAcceptedIssuers() {
  16.             return null;
  17.         }
  19.         public void checkClientTrusted(X509Certificate[] certs, String authType) {
  20.         }
  22.         public void checkServerTrusted(X509Certificate[] certs, String authType) {
  23.         }
  24.     } };
  26.     private SSLUtil() {
  27.     }
  29.     public static void turnOffSslChecking() throws NoSuchAlgorithmException, KeyManagementException {
  30.         final SSLContext sc = SSLContext.getInstance(PROTOCOL);
  31.         sc.init(null, UNQUESTIONING_TRUST_MANAGER, null);
  32.         HttpsURLConnection.setDefaultSSLSocketFactory(sc.getSocketFactory());
  33.     }
  35.     public static void turnOnSslChecking() throws KeyManagementException, NoSuchAlgorithmException {
  36.         SSLContext.getInstance(PROTOCOL).init(null, null, null);
  37.     }
  38. }
SSLUtil

　　4.常量类

  1. public interface SysContants {
  2.     
  3.         /**azkaban成功状态**/
  4.     String AZK_SUCCESS = "success";
  5.     
  6. }
SysContants

　　5.根据azkaban返回数据定制实体类(注释少抱歉)

  1. import java.util.List;
  3. public class ExecNode {
  4.     private String nestedId;
  5.     private List<String> in;
  6.     private String status;
  7.     private String id;
  8.     private String type;
  9.     private Long updateTime;
  10.     private Long startTime;
  11.     private Long endTime;
  12.     private Long attempt;
  14.     public String getNestedId() {
  15.         return nestedId;
  16.     }
  18.     public void setNestedId(String nestedId) {
  19.         this.nestedId = nestedId;
  20.     }
  22.     public List<String> getIn() {
  23.         return in;
  24.     }
  26.     public void setIn(List<String> in) {
  27.         this.in = in;
  28.     }
  30.     public String getStatus() {
  31.         return status;
  32.     }
  34.     public void setStatus(String status) {
  35.         this.status = status;
  36.     }
  38.     public String getId() {
  39.         return id;
  40.     }
  42.     public void setId(String id) {
  43.         this.id = id;
  44.     }
  46.     public String getType() {
  47.         return type;
  48.     }
  50.     public void setType(String type) {
  51.         this.type = type;
  52.     }
  54.     public Long getUpdateTime() {
  55.         return updateTime;
  56.     }
  58.     public void setUpdateTime(Long updateTime) {
  59.         this.updateTime = updateTime;
  60.     }
  62.     public Long getStartTime() {
  63.         return startTime;
  64.     }
  66.     public void setStartTime(Long startTime) {
  67.         this.startTime = startTime;
  68.     }
  70.     public Long getEndTime() {
  71.         return endTime;
  72.     }
  74.     public void setEndTime(Long endTime) {
  75.         this.endTime = endTime;
  76.     }
  78.     public Long getAttempt() {
  79.         return attempt;
  80.     }
  82.     public void setAttempt(Long attempt) {
  83.         this.attempt = attempt;
  84.     }
  85. }
ExecNode
  1. import java.util.List;
  3. public class ExecNodeBean {
  4.     private String nestedId;
  5.     private List<String> dependencies;
  6.     private String status;
  7.     private String jobId;
  8.     private String type;
  9.     private String updateTime;
  10.     private String startTime;
  11.     private String endTime;
  12.     private Long attempt;
  13.     private String logs;
  14.     private Long elapsed;
  16.     public String getNestedId() {
  17.         return nestedId;
  18.     }
  20.     public void setNestedId(String nestedId) {
  21.         this.nestedId = nestedId;
  22.     }
  24.     public List<String> getDependencies() {
  25.         return dependencies;
  26.     }
  28.     public void setDependencies(List<String> dependencies) {
  29.         this.dependencies = dependencies;
  30.     }
  32.     public String getStatus() {
  33.         return status;
  34.     }
  36.     public void setStatus(String status) {
  37.         this.status = status;
  38.     }
  40.     public String getJobId() {
  41.         return jobId;
  42.     }
  44.     public void setJobId(String jobId) {
  45.         this.jobId = jobId;
  46.     }
  48.     public String getType() {
  49.         return type;
  50.     }
  52.     public void setType(String type) {
  53.         this.type = type;
  54.     }
  56.     public String getUpdateTime() {
  57.         return updateTime;
  58.     }
  60.     public void setUpdateTime(String updateTime) {
  61.         this.updateTime = updateTime;
  62.     }
  64.     public String getStartTime() {
  65.         return startTime;
  66.     }
  68.     public void setStartTime(String startTime) {
  69.         this.startTime = startTime;
  70.     }
  72.     public String getEndTime() {
  73.         return endTime;
  74.     }
  76.     public void setEndTime(String endTime) {
  77.         this.endTime = endTime;
  78.     }
  80.     public Long getAttempt() {
  81.         return attempt;
  82.     }
  84.     public void setAttempt(Long attempt) {
  85.         this.attempt = attempt;
  86.     }
  88.     public String getLogs() {
  89.         return logs;
  90.     }
  92.     public void setLogs(String logs) {
  93.         this.logs = logs;
  94.     }
  96.     public Long getElapsed() {
  97.         return elapsed;
  98.     }
  100.     public void setElapsed(Long elapsed) {
  101.         this.elapsed = elapsed;
  102.     }
  103.     
  104. }
ExecNodeBean
  1. public class Execution {
  2.     private String submitUser;
  3.     private String flowId;
  4.     private String status;
  5.     private Long submitTime;
  6.     private Long startTime;
  7.     private Long endTime;
  8.     private Long projectId;
  9.     private Long execId;
  11.     public String getSubmitUser() {
  12.         return submitUser;
  13.     }
  15.     public void setSubmitUser(String submitUser) {
  16.         this.submitUser = submitUser;
  17.     }
  19.     public String getFlowId() {
  20.         return flowId;
  21.     }
  23.     public void setFlowId(String flowId) {
  24.         this.flowId = flowId;
  25.     }
  27.     public String getStatus() {
  28.         return status;
  29.     }
  31.     public void setStatus(String status) {
  32.         this.status = status;
  33.     }
  35.     public Long getSubmitTime() {
  36.         return submitTime;
  37.     }
  39.     public void setSubmitTime(Long submitTime) {
  40.         this.submitTime = submitTime;
  41.     }
  43.     public Long getStartTime() {
  44.         return startTime;
  45.     }
  47.     public void setStartTime(Long startTime) {
  48.         this.startTime = startTime;
  49.     }
  51.     public Long getEndTime() {
  52.         return endTime;
  53.     }
  55.     public void setEndTime(Long endTime) {
  56.         this.endTime = endTime;
  57.     }
  59.     public Long getProjectId() {
  60.         return projectId;
  61.     }
  63.     public void setProjectId(Long projectId) {
  64.         this.projectId = projectId;
  65.     }
  67.     public Long getExecId() {
  68.         return execId;
  69.     }
  71.     public void setExecId(Long execId) {
  72.         this.execId = execId;
  73.     }
Execution
  1. import java.util.List;
  3. public class ExecutionInfo {
  4.     private String project;
  5.     private String type;
  6.     private Long updateTime;
  7.     private Long attempt;
  8.     private Long execid;
  9.     private Long submitTime;
  10.     private Long startTime;
  11.     private Long endTime;
  12.     private Long projectId;
  13.     private String nestedId;
  14.     private String submitUser;
  15.     private String id;
  16.     private String flowId;
  17.     private String flow;
  18.     private String status;
  19.     private List<ExecNode> nodes;
  21.     public String getProject() {
  22.         return project;
  23.     }
  25.     public void setProject(String project) {
  26.         this.project = project;
  27.     }
  29.     public String getType() {
  30.         return type;
  31.     }
  33.     public void setType(String type) {
  34.         this.type = type;
  35.     }
  37.     public Long getUpdateTime() {
  38.         return updateTime;
  39.     }
  41.     public void setUpdateTime(Long updateTime) {
  42.         this.updateTime = updateTime;
  43.     }
  45.     public Long getAttempt() {
  46.         return attempt;
  47.     }
  49.     public void setAttempt(Long attempt) {
  50.         this.attempt = attempt;
  51.     }
  53.     public Long getExecid() {
  54.         return execid;
  55.     }
  57.     public void setExecid(Long execid) {
  58.         this.execid = execid;
  59.     }
  61.     public Long getSubmitTime() {
  62.         return submitTime;
  63.     }
  65.     public void setSubmitTime(Long submitTime) {
  66.         this.submitTime = submitTime;
  67.     }
  69.     public Long getStartTime() {
  70.         return startTime;
  71.     }
  73.     public void setStartTime(Long startTime) {
  74.         this.startTime = startTime;
  75.     }
  77.     public Long getEndTime() {
  78.         return endTime;
  79.     }
  81.     public void setEndTime(Long endTime) {
  82.         this.endTime = endTime;
  83.     }
  85.     public Long getProjectId() {
  86.         return projectId;
  87.     }
  89.     public void setProjectId(Long projectId) {
  90.         this.projectId = projectId;
  91.     }
  93.     public String getNestedId() {
  94.         return nestedId;
  95.     }
  97.     public void setNestedId(String nestedId) {
  98.         this.nestedId = nestedId;
  99.     }
  101.     public String getSubmitUser() {
  102.         return submitUser;
  103.     }
  105.     public void setSubmitUser(String submitUser) {
  106.         this.submitUser = submitUser;
  107.     }
  109.     public String getId() {
  110.         return id;
  111.     }
  113.     public void setId(String id) {
  114.         this.id = id;
  115.     }
  117.     public String getFlowId() {
  118.         return flowId;
  119.     }
  121.     public void setFlowId(String flowId) {
  122.         this.flowId = flowId;
  123.     }
  125.     public String getFlow() {
  126.         return flow;
  127.     }
  129.     public void setFlow(String flow) {
  130.         this.flow = flow;
  131.     }
  133.     public String getStatus() {
  134.         return status;
  135.     }
  137.     public void setStatus(String status) {
  138.         this.status = status;
  139.     }
  141.     public List<ExecNode> getNodes() {
  142.         return nodes;
  143.     }
  145.     public void setNodes(List<ExecNode> nodes) {
  146.         this.nodes = nodes;
  147.     }
  149. }
ExecutionInfo
  1. import java.util.List;
  3. public class ExecutionInfoBean{
  4.         
  5.     private String project;
  6.     private String type;
  7.     private String updateTime;
  8.     private Long attempt;
  9.     private Long execid;
  10.     private String submitTime;
  11.     private String startTime;
  12.     private String endTime;
  13.     private Long projectId;
  14.     private String nestedId;
  15.     private String submitUser;
  16.     private String jobId;
  17.     private String flowId;
  18.     private String flow;
  19.     private String status;
  20.     private String flowLog;
  21.     private Long elapsed;
  22.     private List<ExecNodeBean> nodes;
  24.     public String getProject() {
  25.         return project;
  26.     }
  28.     public void setProject(String project) {
  29.         this.project = project;
  30.     }
  32.     public String getType() {
  33.         return type;
  34.     }
  36.     public void setType(String type) {
  37.         this.type = type;
  38.     }
  40.     public String getUpdateTime() {
  41.         return updateTime;
  42.     }
  44.     public void setUpdateTime(String updateTime) {
  45.         this.updateTime = updateTime;
  46.     }
  48.     public Long getAttempt() {
  49.         return attempt;
  50.     }
  52.     public void setAttempt(Long attempt) {
  53.         this.attempt = attempt;
  54.     }
  56.     public Long getExecid() {
  57.         return execid;
  58.     }
  60.     public void setExecid(Long execid) {
  61.         this.execid = execid;
  62.     }
  64.     public String getSubmitTime() {
  65.         return submitTime;
  66.     }
  68.     public void setSubmitTime(String submitTime) {
  69.         this.submitTime = submitTime;
  70.     }
  72.     public String getStartTime() {
  73.         return startTime;
  74.     }
  76.     public void setStartTime(String startTime) {
  77.         this.startTime = startTime;
  78.     }
  80.     public String getEndTime() {
  81.         return endTime;
  82.     }
  84.     public void setEndTime(String endTime) {
  85.         this.endTime = endTime;
  86.     }
  88.     public Long getProjectId() {
  89.         return projectId;
  90.     }
  92.     public void setProjectId(Long projectId) {
  93.         this.projectId = projectId;
  94.     }
  96.     public String getNestedId() {
  97.         return nestedId;
  98.     }
  100.     public void setNestedId(String nestedId) {
  101.         this.nestedId = nestedId;
  102.     }
  104.     public String getSubmitUser() {
  105.         return submitUser;
  106.     }
  108.     public void setSubmitUser(String submitUser) {
  109.         this.submitUser = submitUser;
  110.     }
  112.     public String getJobId() {
  113.         return jobId;
  114.     }
  116.     public void setJobId(String jobId) {
  117.         this.jobId = jobId;
  118.     }
  120.     public String getFlowId() {
  121.         return flowId;
  122.     }
  124.     public void setFlowId(String flowId) {
  125.         this.flowId = flowId;
  126.     }
  128.     public String getFlow() {
  129.         return flow;
  130.     }
  132.     public void setFlow(String flow) {
  133.         this.flow = flow;
  134.     }
  136.     public String getStatus() {
  137.         return status;
  138.     }
  140.     public void setStatus(String status) {
  141.         this.status = status;
  142.     }
  144.     public String getFlowLog() {
  145.         return flowLog;
  146.     }
  148.     public void setFlowLog(String flowLog) {
  149.         this.flowLog = flowLog;
  150.     }
  152.     public Long getElapsed() {
  153.         return elapsed;
  154.     }
  156.     public void setElapsed(Long elapsed) {
  157.         this.elapsed = elapsed;
  158.     }
  160.     public List<ExecNodeBean> getNodes() {
  161.         return nodes;
  162.     }
  164.     public void setNodes(List<ExecNodeBean> nodes) {
  165.         this.nodes = nodes;
  166.     }
  168. }
ExecutionInfoBean
  1. import java.util.List;
  3. public class FlowExecution {
  4.     private String project;
  5.     private String flow;
  6.     private Long total;
  7.     private Long length;
  8.     private Long from;
  9.     private Long projectId;
  10.     private List<Execution> executions;
  12.     public String getProject() {
  13.         return project;
  14.     }
  16.     public void setProject(String project) {
  17.         this.project = project;
  18.     }
  20.     public String getFlow() {
  21.         return flow;
  22.     }
  24.     public void setFlow(String flow) {
  25.         this.flow = flow;
  26.     }
  28.     public Long getTotal() {
  29.         return total;
  30.     }
  32.     public void setTotal(Long total) {
  33.         this.total = total;
  34.     }
  36.     public Long getLength() {
  37.         return length;
  38.     }
  40.     public void setLength(Long length) {
  41.         this.length = length;
  42.     }
  44.     public Long getFrom() {
  45.         return from;
  46.     }
  48.     public void setFrom(Long from) {
  49.         this.from = from;
  50.     }
  52.     public Long getProjectId() {
  53.         return projectId;
  54.     }
  56.     public void setProjectId(Long projectId) {
  57.         this.projectId = projectId;
  58.     }
  60.     public List<Execution> getExecutions() {
  61.         return executions;
  62.     }
  64.     public void setExecutions(List<Execution> executions) {
  65.         this.executions = executions;
  66.     }
  68. }
FlowExecution
  1. public class GovernTaskRecordBean extends PageEntity {
  3.     private static final long serialVersionUID = 1L;
  4.     private String createTime;
  5.     private String status;
  6.     private String owner;
  7.     private String startTime;
  8.     private String endTime;
  9.     private String flowId;
  10.     private Long projectId;
  11.     private Long execId;
  12.     private String projectPath;
  13.     private Long elapsed;
  15.     public String getCreateTime() {
  16.         return createTime;
  17.     }
  19.     public void setCreateTime(String createTime) {
  20.         this.createTime = createTime;
  21.     }
  23.     public String getStatus() {
  24.         return status;
  25.     }
  27.     public void setStatus(String status) {
  28.         this.status = status;
  29.     }
  31.     public String getOwner() {
  32.         return owner;
  33.     }
  35.     public void setOwner(String owner) {
  36.         this.owner = owner;
  37.     }
  39.     public String getStartTime() {
  40.         return startTime;
  41.     }
  43.     public void setStartTime(String startTime) {
  44.         this.startTime = startTime;
  45.     }
  47.     public String getEndTime() {
  48.         return endTime;
  49.     }
  51.     public void setEndTime(String endTime) {
  52.         this.endTime = endTime;
  53.     }
  55.     public String getFlowId() {
  56.         return flowId;
  57.     }
  59.     public void setFlowId(String flowId) {
  60.         this.flowId = flowId;
  61.     }
  63.     public Long getProjectId() {
  64.         return projectId;
  65.     }
  67.     public void setProjectId(Long projectId) {
  68.         this.projectId = projectId;
  69.     }
  71.     public Long getExecId() {
  72.         return execId;
  73.     }
  75.     public void setExecId(Long execId) {
  76.         this.execId = execId;
  77.     }
  79.     public String getProjectPath() {
  80.         return projectPath;
  81.     }
  83.     public void setProjectPath(String projectPath) {
  84.         this.projectPath = projectPath;
  85.     }
  87.     public Long getElapsed() {
  88.         return elapsed;
  89.     }
  91.     public void setElapsed(Long elapsed) {
  92.         this.elapsed = elapsed;
  93.     }
  95. }
GovernTaskRecordBean

　　6.调度执行状态枚举类

  1. public enum ScheduleStatus {
  3.     READY("READY","就绪"),SUCCEEDED("SUCCEEDED","成功"),KILLING("KILLING","停止中"),KILLED("KILLED","已中断"),FAILED("FAILED","失败"),
  4.     SKIPPED("SKIPPED","跳过"),DISABLED("DISABLED","停用"),QUEUED("QUEUED","等待中"),CANCELLED("CANCELLED","取消执行"),
  5.     RUNNING("RUNNING","运行中"),PAUSED("PAUSED","暂停");
  6.     
  8.     /**
  9.      * 状态编码
  10.      */
  11.     private String code;
  13.     /**
  14.      * 状态描述
  15.      */
  16.     private String desc;
  18.     public String getCode() {
  19.         return code;
  20.     }
  22.     public void setCode(String code) {
  23.         this.code = code;
  24.     }
  26.     public String getDesc() {
  27.         return desc;
  28.     }
  30.     public void setDesc(String desc) {
  31.         this.desc = desc;
  32.     }
  34.     ScheduleStatus(String code, String desc) {
  35.         this.code = code;
  36.         this.desc = desc;
  37.     }
  39. }
ScheduleStatus

　　7.AzkabanService接口类

  1. import java.io.BufferedOutputStream;
  2. import java.io.File;
  3. import java.io.FileOutputStream;
  4. import java.io.IOException;
  5. import java.io.InputStream;
  6. import java.io.OutputStream;
  7. import java.net.HttpURLConnection;
  8. import java.net.URL;
  9. import java.util.ArrayList;
  10. import java.util.Calendar;
  11. import java.util.Date;
  12. import java.util.HashMap;
  13. import java.util.List;
  14. import java.util.Map;
  15. import org.apache.commons.collections4.CollectionUtils;
  16. import org.apache.commons.io.IOUtils;
  17. import org.apache.commons.lang3.StringUtils;
  18. import org.joda.time.DateTime;
  19. import org.joda.time.format.DateTimeFormat;
  20. import org.joda.time.format.DateTimeFormatter;
  21. import org.slf4j.Logger;
  22. import org.slf4j.LoggerFactory;
  23. import org.springframework.beans.factory.annotation.Autowired;
  24. import org.springframework.core.io.FileSystemResource;
  25. import org.springframework.http.HttpEntity;
  26. import org.springframework.http.HttpHeaders;
  27. import org.springframework.http.HttpMethod;
  28. import org.springframework.http.ResponseEntity;
  29. import org.springframework.stereotype.Service;
  30. import org.springframework.util.LinkedMultiValueMap;
  31. import org.springframework.util.MultiValueMap;
  32. import org.springframework.web.client.RestTemplate;
  34. import com.google.common.collect.Lists;
  35. import com.google.gson.Gson;
  36. import com.google.gson.JsonElement;
  37. import com.google.gson.JsonObject;
  39. import org.apache.http.HttpStatus;
  41. /**
  42.  * azkaban接口
  43.  * @author hao
  44.  *
  45.  */
  46. @Service
  47. public class AzkabanService {
  48.     
  49.     private static final Logger logger = LoggerFactory.getLogger(AzkabanService.class);
  50.     private static final String CONTENT_TYPE = "application/x-www-form-urlencoded; charset=utf-8";
  51.     private static final String X_REQUESTED_WITH = "XMLHttpRequest";
  52.     private static final DateTimeFormatter formatterTime = DateTimeFormat.forPattern("yyyy-MM-dd HH:mm:ss");
  53.     
  54.     @Autowired
  55.     private RestTemplate restTemplate;
  56.     
  57.     @Autowired
  58.     private AzkabanConfig azkabanConfig;
  59.     
  60.     /**
  61.      * Azkaban登录接口,返回sessionId
  62.      * @return
  63.      * @throws Exception
  64.      */
  65.     public String login() throws Exception {
  66.         SSLUtil.turnOffSslChecking();
  67.         HttpHeaders hs = new HttpHeaders();
  68.         hs.add("Content-Type", CONTENT_TYPE);
  69.         hs.add("X-Requested-With", X_REQUESTED_WITH);
  70.         LinkedMultiValueMap<String, String> linkedMultiValueMap = new LinkedMultiValueMap<String, String>();
  71.         linkedMultiValueMap.add("action", "login");
  72.         linkedMultiValueMap.add("username", azkabanConfig.getAzkUsername());
  73.         linkedMultiValueMap.add("password", azkabanConfig.getAzkPassword());
  75.         HttpEntity<MultiValueMap<String, String>> httpEntity = new HttpEntity<>(linkedMultiValueMap, hs);
  76.         String result = restTemplate.postForObject(azkabanConfig.getAzkUrl(), httpEntity, String.class);
  77.         if (!SysContants.AZK_SUCCESS.equals(new Gson().fromJson(result, JsonObject.class).get("status").getAsString())) {
  78.             logger.error("Azkaban登录失败!返回错误信息："+result);
  79.             throw new Exception("Azkaban登录失败!");
  80.         }
  81.         return new Gson().fromJson(result, JsonObject.class).get("session.id").getAsString();
  82.     }
  84.     /**
  85.      * Azkaban上传zip文件
  86.      * @param projectName 项目名称
  87.      * @param file 文件
  88.      * @return projectId编号
  89.      * @throws Exception
  90.      */
  91.     public String uploadZip(String projectName, File file) throws Exception {
  92.         SSLUtil.turnOffSslChecking();
  93.         FileSystemResource resource = new FileSystemResource(file);
  94.         LinkedMultiValueMap<String, Object> linkedMultiValueMap = new LinkedMultiValueMap<String, Object>();
  95.         linkedMultiValueMap.add("session.id", login());
  96.         linkedMultiValueMap.add("ajax", "upload");
  97.         linkedMultiValueMap.add("project", projectName);
  98.         linkedMultiValueMap.add("file", resource);
  99.         String result = restTemplate.postForObject(azkabanConfig.getAzkUrl() + "/manager", linkedMultiValueMap,
  100.                 String.class);
  101.         if (StringUtils.isEmpty(new Gson().fromJson(result, JsonObject.class).get("projectId").getAsString())) {
  102.             logger.error("上传文件至Azkaban失败:",projectName,file.getPath());
  103.             logger.error("Azkaban上传文件失败!返回错误信息："+result);
  104.             return null;
  105.         }
  107.         return new Gson().fromJson(result, JsonObject.class).get("projectId").getAsString();
  108.     }
  109.     
  110.     /**
  111.      * Azkaban创建project
  112.      * @param projectName,project名称
  113.      * @param description,project描述
  114.      * @return 是否成功
  115.      * @throws Exception
  116.      */
  117.     public boolean createProject(String projectName, String description) throws Exception {
  118.         SSLUtil.turnOffSslChecking();
  119.         HttpHeaders hs = new HttpHeaders();
  120.         hs.add("Content-Type", CONTENT_TYPE);
  121.         hs.add("X-Requested-With", X_REQUESTED_WITH);
  122.         LinkedMultiValueMap<String, String> linkedMultiValueMap = new LinkedMultiValueMap<String, String>();
  123.         linkedMultiValueMap.add("session.id", login());
  124.         linkedMultiValueMap.add("action", "create");
  125.         linkedMultiValueMap.add("name", projectName);
  126.         linkedMultiValueMap.add("description", description);
  128.         HttpEntity<MultiValueMap<String, String>> httpEntity = new HttpEntity<>(linkedMultiValueMap, hs);
  129.         logger.info("Azkaban请求信息：" + httpEntity.toString());
  130.         String result = restTemplate.postForObject(azkabanConfig.getAzkUrl() + "/manager", httpEntity, String.class);
  131.         logger.info("Azkaban返回创建Project信息：" + result);
  132.         // 创建成功和已存在，都表示创建成功
  133.         if (!SysContants.AZK_SUCCESS
  134.                 .equals(new Gson().fromJson(result, JsonObject.class).get("status").getAsString())) {
  135.             if (!"Project already exists."
  136.                     .equals(new Gson().fromJson(result, JsonObject.class).get("message").getAsString())) {
  137.                 logger.error("创建Azkaban Project失败:",projectName);
  138.                 logger.error("创建Azkaban Project失败!返回错误信息："+result);
  139.                 return false;
  140.             }
  141.         }
  142.         return true;
  143.     }
  144.     
  145.     /**
  146.      * Azkaban删除project
  147.      * @param projectName 项目名称
  148.      * @throws Exception 
  149.      */
  150.     public void deleteProject(String projectName) throws Exception {
  151.         SSLUtil.turnOffSslChecking();
  153.         HttpHeaders hs = new HttpHeaders();
  154.         hs.add("Content-Type", CONTENT_TYPE);
  155.         hs.add("X-Requested-With", X_REQUESTED_WITH);
  156.         hs.add("Accept", "text/plain;charset=utf-8");
  158.         Map<String, String> map = new HashMap<>();
  160.         map.put("id", login());
  161.         map.put("project", projectName);
  163.         ResponseEntity<String> exchange = restTemplate.exchange(
  164.                 azkabanConfig.getAzkUrl() + "/manager?session.id={id}&delete=true&project={project}", HttpMethod.GET,
  165.                 new HttpEntity<String>(hs), String.class, map);
  167.         if (HttpStatus.SC_OK != exchange.getStatusCodeValue()) {
  168.             logger.error("删除Azkaban Project失败!返回错误信息："+exchange);
  169.             throw new Exception("删除Azkaban Project失败");
  170.         }
  171.     }
  172.     
  173.         /**
  174.          * 获取一个项目的所有流flows
  175.          * @param projectName 项目名称
  176.          * @return List<String> 项目的所有流
  177.          * @throws Exception
  178.          */
  179.         public List<String> fetchFlowsProject(String projectName) throws Exception {
  180.         SSLUtil.turnOffSslChecking();
  181.         HttpHeaders hs = new HttpHeaders();
  182.         hs.add("Content-Type", CONTENT_TYPE);
  183.         hs.add("X-Requested-With", X_REQUESTED_WITH);
  184.         hs.add("Accept", "text/plain;charset=utf-8");
  186.         Map<String, String> map = new HashMap<>();
  188.         map.put("id", login());
  189.         map.put("project", projectName);
  191.         ResponseEntity<String> exchange = restTemplate.exchange(
  192.                 azkabanConfig.getAzkUrl() + "/manager?&session.id={id}&project={project}&ajax=fetchprojectflows", HttpMethod.GET,
  193.                 new HttpEntity<String>(hs), String.class, map);
  194.         if (exchange == null||HttpStatus.SC_OK != exchange.getStatusCodeValue()) {
  195.             logger.error("Azkaban获取一个项目的所有流信息失败：" + projectName);
  196.             logger.error("Azkaban获取一个项目的所有流信息失败：!返回错误信息："+exchange);
  197.             return null;
  198.         }
  199.         JsonElement obj = new Gson().fromJson(exchange.getBody(), JsonObject.class).get("flows");
  200.         if (obj == null) {
  201.             logger.error("Azkaban获取一个项目的所有流信息失败:{}:{}", projectName);
  202.             return null;
  203.         }
  204.         List<String> flows = new ArrayList<String>();
  205.         for(JsonElement jobj:obj.getAsJsonArray()) {
  206.             flows.add(jobj.getAsJsonObject().get("flowId").getAsString());
  207.         }
  208.         return flows;
  209.     }
  210.     
  211.         /**
  212.          * 获取一个流的所有作业
  213.          * @param projectName 项目名
  214.          * @param flowId 流id
  215.          * @return 
  216.          * @throws Exception
  217.          */
  218.         public String fetchJobsFlow(String projectName, String flowId) throws Exception {
  219.         SSLUtil.turnOffSslChecking();
  221.         HttpHeaders hs = new HttpHeaders();
  222.         hs.add("Content-Type", CONTENT_TYPE);
  223.         hs.add("X-Requested-With", X_REQUESTED_WITH);
  224.         hs.add("Accept", "text/plain;charset=utf-8");
  226.         Map<String, String> map = new HashMap<>();
  228.         map.put("id", login());
  229.         map.put("project", projectName);
  230.         map.put("flow", flowId);
  232.         ResponseEntity<String> exchange = restTemplate.exchange(
  233.                 azkabanConfig.getAzkUrl() + "/manager?&session.id={id}&project={project}&flow={flow}&ajax=fetchflowgraph", HttpMethod.GET,
  234.                 new HttpEntity<String>(hs), String.class, map);
  235.         if (exchange == null) {
  236.             logger.error("Azkaban获取一个项目的所有流信息失败：" + projectName);
  237.             return null;
  238.         }
  239.         logger.debug("Azkaban获取一个项目的所有流信息：" + exchange);
  240.         if (HttpStatus.SC_OK != exchange.getStatusCodeValue()) {
  241.             throw new Exception("Azkaban获取一个项目的所有流信息失败");
  242.         }
  243.         return exchange.toString();
  244.     }
  245.     
  246.         /**
  247.          * Flow 获取执行的project 列表
  248.          * azkaban api 获取流的执行
  249.          * @param projectName 项目名
  250.          * @param flowId 流id
  251.          * @param start
  252.          * @param length
  253.          * @return
  254.          * @throws Exception
  255.          */
  256.          public FlowExecution fetchFlowExecutions(String projectName, String flowId, String start,String length) throws Exception {
  257.             SSLUtil.turnOffSslChecking();
  258.             HttpHeaders hs = new HttpHeaders();
  259.             hs.add("Content-Type", "application/x-www-form-urlencoded; charset=utf-8");
  260.             hs.add("X-Requested-With", "XMLHttpRequest");
  261.             hs.add("Accept", "text/plain;charset=utf-8");
  263.             Map<String, String> map = new HashMap<>();
  265.             map.put("id", login());
  266.             map.put("project", projectName);
  267.             map.put("flow", flowId);
  268.             map.put("start", String.valueOf(start));
  269.             map.put("length", String.valueOf(length));
  271.             ResponseEntity<String> exchange = restTemplate.exchange(
  272.                     azkabanConfig.getAzkUrl() + "/manager?session.id={id}&ajax=fetchFlowExecutions&project={project}&flow={flow}&start={start}&length={length}",
  273.                     HttpMethod.GET, new HttpEntity<String>(hs), String.class, map);
  274.             if (exchange == null || HttpStatus.SC_OK != exchange.getStatusCodeValue()) {
  275.                 logger.error("Azkaban获取一个项目运行记录信息失败：{}:{}", projectName, flowId);
  276.                 return null;
  277.             }
  278.             return new Gson().fromJson(exchange.getBody(), FlowExecution.class);
  279.         }
  280.      
  281.      /**
  282.       * Flow 获取正在执行的流id
  283.       * @param projectName
  284.       * @param flowId
  285.       * @return
  286.       * @throws Exception
  287.       */
  288.          public String getRunning(String projectName, String flowId) throws Exception {
  289.             SSLUtil.turnOffSslChecking();
  290.             HttpHeaders hs = new HttpHeaders();
  291.             hs.add("Content-Type", "application/x-www-form-urlencoded; charset=utf-8");
  292.             hs.add("X-Requested-With", "XMLHttpRequest");
  293.             hs.add("Accept", "text/plain;charset=utf-8");
  295.             Map<String, String> map = new HashMap<>();
  296.             map.put("id", login());
  297.             map.put("project", projectName);
  298.             map.put("flow", flowId);
  299.             ResponseEntity<String> exchange = restTemplate.exchange(
  300.                     azkabanConfig.getAzkUrl() + "/executor?session.id={id}&ajax=getRunning&project={project}&flow={flow}", HttpMethod.GET,
  301.                     new HttpEntity<String>(hs), String.class, map);
  302.            return exchange.getBody();
  303.         }
  304.          
  305.          /**
  306.          * Execute a Flow 执行一个流 还有很多其他参数 具体参考azkabanConfig.getAzkUrl()
  307.          * 
  308.          * @throws KeyManagementException
  309.          * @throws NoSuchAlgorithmException
  310.          */
  311.         public String executeFlow(String projectName, String flowId) throws Exception {
  312.             SSLUtil.turnOffSslChecking();
  313.             HttpHeaders hs = new HttpHeaders();
  314.             hs.add("Content-Type", "application/x-www-form-urlencoded; charset=utf-8");
  315.             hs.add("X-Requested-With", "XMLHttpRequest");
  316.             hs.add("Accept", "text/plain;charset=utf-8");
  318.             Map<String, String> map = new HashMap<>();
  319.             map.put("id", login());
  320.             map.put("project", projectName);
  321.             map.put("flow", flowId);
  322.             ResponseEntity<String> exchange = restTemplate.exchange(
  323.                     azkabanConfig.getAzkUrl() + "/executor?session.id={id}&ajax=executeFlow&project={project}&flow={flow}", HttpMethod.GET,
  324.                     new HttpEntity<String>(hs), String.class, map);
  325.             if (exchange == null||HttpStatus.SC_OK != exchange.getStatusCodeValue()) {
  326.                 logger.error("执行一个流请求失败:{}:{}", projectName, flowId);
  327.                 return null;
  328.             }
  329.             JsonElement obj = new Gson().fromJson(exchange.getBody(), JsonObject.class).get("execid");
  330.             if (obj == null) {
  331.                 logger.error("执行一个流失败:{}:{}", projectName, flowId);
  332.                 return null;
  333.             }
  334.             return obj.getAsString();
  335.         }
  336.         
  337.         /**
  338.          * Cancel a Flow Execution 取消流程执行
  339.          * azkaban api 取消流程执行
  340.          * @throws KeyManagementException
  341.          * @throws NoSuchAlgorithmException
  342.          */
  343.         public void cancelEXEaFlow(String projectName,String start,String size) throws Exception {
  344.             int flag=0;
  345.             List<String> flows = fetchFlowsProject(projectName);//获取所有流
  346.             for (String flow : flows) {
  347.                 FlowExecution fe = fetchFlowExecutions(projectName, flow, start, size);
  348.                 if (fe == null) {
  349.                     continue;
  350.                 }
  351.                 List<Execution> executions = fe.getExecutions();//获取执行id
  352.                 for (Execution execution : executions) {
  353.                     if(null!=execution&&null!=execution.getExecId()&&"RUNNING".equals(execution.getStatus())){//运行中的
  354.                         SSLUtil.turnOffSslChecking();
  355.                         HttpHeaders hs = new HttpHeaders();
  356.                         hs.add("Content-Type", "application/x-www-form-urlencoded; charset=utf-8");
  357.                         hs.add("X-Requested-With", "XMLHttpRequest");
  358.                         hs.add("Accept", "text/plain;charset=utf-8");
  360.                         Map<String, String> map = new HashMap<>();
  361.                         map.put("id", login());
  362.                         map.put("execid", String.valueOf(execution.getExecId()));
  363.                         ResponseEntity<String> exchange = restTemplate.exchange(
  364.                                 azkabanConfig.getAzkUrl() + "/executor?session.id={id}&ajax=cancelFlow&execid={execid}", HttpMethod.GET,
  365.                                 new HttpEntity<String>(hs), String.class, map);
  366.                         System.out.println(exchange.getBody());
  367.                         if (exchange == null||HttpStatus.SC_OK != exchange.getStatusCodeValue()) {
  368.                             logger.error("取消执行调度失败，请求azkaban接口异常："+exchange);
  369.                             throw new Exception("取消执行调度失败，请求azkaban接口异常："+exchange);
  370.                         }
  371.                         JsonElement obj = new Gson().fromJson(exchange.getBody(), JsonObject.class).get("error");
  372.                         if (obj != null) {
  373.                             throw new Exception("取消执行调度失败，请刷新列表获取最新调度状态！");
  374.                         }
  375.                         flag++;
  376.                     }
  377.                 }
  378.             }
  379.             if(0==flag){
  380.                 throw new Exception("该调度不是运行中状态，请刷新列表获取最新状态！");
  381.             }
  382.         }
  383.         
  384.         /**
  385.          * 根据时间 创建调度任务
  386.          * 
  387.          * @param projectId
  388.          * @param projectName
  389.          * @param flow
  390.          * @param flowName
  391.          * @param recurring,是否循环,on循环
  392.          * @param period,循环频率:M:Months,w:Weeks,d:Days,h:Hours,m:Minutes,s:Seconds;如60s,支持分钟的倍数
  393.          * @param date,开始时间
  394.          * @return 返回scheduleId
  395.          * @throws Exception
  396.          */
  397.         public String scheduleEXEaFlow(String projectId, String projectName, String flow, String flowName, String recurring,
  398.                 String period, Date date) throws Exception {
  400.             SSLUtil.turnOffSslChecking();
  401.             HttpHeaders hs = new HttpHeaders();
  402.             hs.add("Content-Type", CONTENT_TYPE);
  403.             hs.add("X-Requested-With", X_REQUESTED_WITH);
  404.             LinkedMultiValueMap<String, String> linkedMultiValueMap = new LinkedMultiValueMap<String, String>();
  405.             linkedMultiValueMap.add("session.id", login());
  406.             linkedMultiValueMap.add("ajax", "scheduleFlow");
  407.             linkedMultiValueMap.add("projectName", projectName);
  408.             linkedMultiValueMap.add("projectId", projectId);
  409.             linkedMultiValueMap.add("flow", flow);
  410.             linkedMultiValueMap.add("flowName", flowName);
  411.             linkedMultiValueMap.add("is_recurring", recurring);
  412.             linkedMultiValueMap.add("period", period);
  413.             scheduleTimeInit(linkedMultiValueMap, date);
  415.             HttpEntity<MultiValueMap<String, String>> httpEntity = new HttpEntity<>(linkedMultiValueMap, hs);
  416.             String result = restTemplate.postForObject(azkabanConfig.getAzkUrl() + "/schedule", httpEntity, String.class);
  418.             logger.info("Azkaban返回根据时间创建定时任务信息：" + result);
  420.             if (!SysContants.AZK_SUCCESS.equals(new Gson().fromJson(result, JsonObject.class).get("status").getAsString())
  421.                     || new Gson().fromJson(result, JsonObject.class).get("scheduleId").getAsInt() < 0) {
  422.                 logger.error("Azkaban返回根据时间创建定时任务信息失败：!返回错误信息："+result);
  423.                 throw new Exception("根据时间创建定时任务失败");
  424.             }
  426.             return new Gson().fromJson(result, JsonObject.class).get("scheduleId").getAsString();
  427.         }
  429.         /**
  430.          * 根据cron表达式 创建调度任务
  431.          * @param projectName 项目名称
  432.          * @param cron cron表达式
  433.          * @param flow 流
  434.          * @param flowName 流名称
  435.          * @return 返回scheduleId
  436.          * @throws Exception
  437.          */
  438.         public String scheduleByCronEXEaFlow(String projectName, String cron, String flowName)
  439.                 throws Exception {
  441.             SSLUtil.turnOffSslChecking();
  442.             HttpHeaders hs = new HttpHeaders();
  443.             hs.add("Content-Type", CONTENT_TYPE);
  444.             hs.add("X-Requested-With", X_REQUESTED_WITH);
  445.             LinkedMultiValueMap<String, String> linkedMultiValueMap = new LinkedMultiValueMap<String, String>();
  446.             linkedMultiValueMap.add("session.id", login());
  447.             linkedMultiValueMap.add("ajax", "scheduleCronFlow");
  448.             linkedMultiValueMap.add("projectName", projectName);
  449.             linkedMultiValueMap.add("cronExpression", cron);
  450.             linkedMultiValueMap.add("flow", flowName);
  452.             HttpEntity<MultiValueMap<String, String>> httpEntity = new HttpEntity<>(linkedMultiValueMap, hs);
  453.             String result = restTemplate.postForObject(azkabanConfig.getAzkUrl() + "/schedule", httpEntity, String.class);
  455.             if (!SysContants.AZK_SUCCESS
  456.                     .equals(new Gson().fromJson(result, JsonObject.class).get("status").getAsString())) {
  457.                 logger.error("Azkaban返回根据时间创建定时任务信息失败：!返回错误信息："+result);
  458.                 return null;
  459.             }
  461.             return new Gson().fromJson(result, JsonObject.class).get("scheduleId").getAsString();
  462.         }
  464.         /**
  465.          * 根据scheduleId取消一个流的调度
  466.          * 暂停一次执行，输入为exec id。如果这个执行不是处于running状态，会返回错误信息。
  467.          * @param scheduleId
  468.          * @throws Exception
  469.          */
  470.         public boolean unscheduleFlow(String scheduleId) {
  471.             try {
  472.                 SSLUtil.turnOffSslChecking();
  473.                 HttpHeaders hs = new HttpHeaders();
  474.                 hs.add("Content-Type", CONTENT_TYPE);
  475.                 hs.add("X-Requested-With", X_REQUESTED_WITH);
  476.                 LinkedMultiValueMap<String, String> linkedMultiValueMap = new LinkedMultiValueMap<String, String>();
  477.                 linkedMultiValueMap.add("session.id", login());
  478.                 linkedMultiValueMap.add("action", "removeSched");
  479.                 linkedMultiValueMap.add("scheduleId", scheduleId);
  481.                 HttpEntity<MultiValueMap<String, String>> httpEntity = new HttpEntity<>(linkedMultiValueMap, hs);
  482.                 String result = restTemplate.postForObject(azkabanConfig.getAzkUrl() + "/schedule", httpEntity,
  483.                         String.class);
  484.                 if (StringUtils.isBlank(result)) {
  485.                     return false;
  486.                 }
  487.                 if (!SysContants.AZK_SUCCESS
  488.                         .equals(String.valueOf(new Gson().fromJson(result, JsonObject.class).get("status")))) {
  489.                     logger.error("取消流调度信息失败:{}", scheduleId);
  490.                     logger.error("Azkaban取消流调度信息失败失败：!返回错误信息："+result);
  491.                     return false;
  492.                 }
  493.             } catch (Exception e) {
  494.                 logger.error("取消流调度信息失败:{}", scheduleId);
  495.                 return false;
  496.             }
  497.             return true;
  498.         }
  500.         /**
  501.          * 下载Azkaban压缩文件
  502.          * @param projectName 项目名称
  503.          * @param zipPath 文件路径
  504.          * @throws Exception 文件异常
  505.          */
  506.         public void downLoadZip(String projectName, String zipPath) throws Exception {
  507.             OutputStream output = null;
  508.             BufferedOutputStream bufferedOutput = null;
  510.             try {
  511.                 URL url = new URL(azkabanConfig.getAzkUrl() + "/manager?session.id=" + login() + "&download=true&project="
  512.                         + projectName);
  513.                 HttpURLConnection conn = (HttpURLConnection) url.openConnection();
  514.                 conn.setConnectTimeout(3 * 1000);
  515.                 InputStream inputStream = conn.getInputStream();
  516.                 File file = new File(zipPath);
  517.                 output = new FileOutputStream(file);
  518.                 bufferedOutput = new BufferedOutputStream(output);
  519.                 bufferedOutput.write(IOUtils.toByteArray(inputStream));
  520.             } catch (Exception e) {
  521.                 logger.info("下载Azkaban压缩文件异常：" + e.getMessage(), e);
  522.             } finally {
  523.                 if (bufferedOutput != null) {
  524.                     try {
  525.                         bufferedOutput.flush();
  526.                         bufferedOutput.close();
  527.                     } catch (IOException e) {
  528.                         logger.info("关闭流异常：" + e.getMessage(), e);
  529.                     }
  530.                 }
  532.                 if (output != null) {
  533.                     try {
  534.                         output.close();
  535.                     } catch (IOException e) {
  536.                         logger.info("关闭流异常：" + e.getMessage(), e);
  537.                     }
  538.                 }
  539.             }
  540.         }
  543.         /**
  544.          * 获取一个调度器job的信息 根据project的id 和 flowId
  545.          * @param projectId 项目名称
  546.          * @param flowId 流编号
  547.          * @return job的信息
  548.          */
  549.         public String fetchSchedule(String projectId, String flowId) {
  550.             try {
  551.                 SSLUtil.turnOffSslChecking();
  552.                 HttpHeaders hs = new HttpHeaders();
  553.                 hs.add("Content-Type", "application/x-www-form-urlencoded; charset=utf-8");
  554.                 hs.add("X-Requested-With", "XMLHttpRequest");
  555.                 hs.add("Accept", "text/plain;charset=utf-8");
  557.                 Map<String, String> map = new HashMap<>();
  558.                 map.put("id", login());
  559.                 map.put("projectId", projectId);
  560.                 map.put("flowId", flowId);
  561.                 ResponseEntity<String> exchange = restTemplate.exchange(
  562.                         azkabanConfig.getAzkUrl()
  563.                                 + "/schedule?session.id={id}&ajax=fetchSchedule&projectId={projectId}&flowId={flowId}",
  564.                         HttpMethod.GET, new HttpEntity<String>(hs), String.class, map);
  565.                 if (HttpStatus.SC_OK != exchange.getStatusCodeValue()) {
  566.                     logger.error("获取一个调度器job的信息失败:{}:{}", projectId, flowId);
  567.                     return null;
  568.                 }
  569.                 JsonElement obj = new Gson().fromJson(exchange.getBody(), JsonObject.class).get("schedule");
  570.                 if (obj == null) {
  571.                     logger.error("获取一个调度器job的信息失败:{}:{}", projectId, flowId);
  572.                     return null;
  573.                 }
  574.                 return obj.getAsJsonObject().get("scheduleId").getAsString();
  575.             } catch (Exception e) {
  576.                 logger.error("获取一个调度器job的信息失败:{}:{}", projectId, flowId);
  577.             }
  578.             return null;
  579.         }
  581.         /**
  582.          * SLA 设置调度任务 执行的时候 或者执行成功失败等等的规则匹配 发邮件或者...
  583.          * @return
  584.          * @throws Exception
  585.          */
  586.         public String setSla() throws Exception {
  587.             SSLUtil.turnOffSslChecking();
  588.             HttpHeaders hs = new HttpHeaders();
  589.             hs.add("Content-Type", "application/x-www-form-urlencoded; charset=utf-8");
  590.             hs.add("X-Requested-With", "XMLHttpRequest");
  591.             LinkedMultiValueMap<String, String> linkedMultiValueMap = new LinkedMultiValueMap<String, String>();
  592.             linkedMultiValueMap.add("session.id", "ffad7355-4427-4770-9c14-3d19736fa73a");
  593.             linkedMultiValueMap.add("ajax", "setSla");
  594.             linkedMultiValueMap.add("scheduleId", "6");
  595.             linkedMultiValueMap.add("slaEmails", "771177@qq.com");
  596.             linkedMultiValueMap.add("settings[0]", "begin,SUCCESS,5:00,true,false");
  597.             linkedMultiValueMap.add("settings[1]", "exe,SUCCESS,5:00,true,false");
  598.             linkedMultiValueMap.add("settings[2]", "end,SUCCESS,5:00,true,false");
  599.             // linkedMultiValueMap.add("settings[3]",
  600.             // "xxx,SUCCESS,5:00,true,false");
  602.             HttpEntity<MultiValueMap<String, String>> httpEntity = new HttpEntity<>(linkedMultiValueMap, hs);
  603.             String postForObject = restTemplate.postForObject(azkabanConfig.getAzkUrl() + "/schedule", httpEntity, String.class);
  604.            return postForObject;
  605.         }
  607.         /**
  608.          * SLA 获取调度的规则配置
  609.          * @throws Exception
  610.          */
  611.         public void slaInfo() throws Exception {
  613.             SSLUtil.turnOffSslChecking();
  614.             HttpHeaders hs = new HttpHeaders();
  615.             hs.add("Content-Type", "application/x-www-form-urlencoded; charset=utf-8");
  616.             hs.add("X-Requested-With", "XMLHttpRequest");
  617.             hs.add("Accept", "text/plain;charset=utf-8");
  619.             Map<String, String> map = new HashMap<>();
  620.             map.put("id", "c4adf192-dcf4-4e05-bd08-f6989dc544a7");
  621.             map.put("scheduleId", "6");
  622.             ResponseEntity<String> exchange = restTemplate.exchange(
  623.                     azkabanConfig.getAzkUrl() + "/schedule?session.id={id}&ajax=slaInfo&scheduleId={scheduleId}", HttpMethod.GET,
  624.                     new HttpEntity<String>(hs), String.class, map);
  625.             System.out.println(exchange.getBody());
  626.         }
  628.         /**
  629.          * Execution 暂停一个执行流
  630.          * @throws Exception
  631.          */
  632.         public void pauseFlow() throws Exception {
  634.             SSLUtil.turnOffSslChecking();
  635.             HttpHeaders hs = new HttpHeaders();
  636.             hs.add("Content-Type", "application/x-www-form-urlencoded; charset=utf-8");
  637.             hs.add("X-Requested-With", "XMLHttpRequest");
  638.             hs.add("Accept", "text/plain;charset=utf-8");
  640.             Map<String, String> map = new HashMap<>();
  641.             map.put("id", "c4adf192-dcf4-4e05-bd08-f6989dc544a7");
  642.             map.put("execid", "12");
  643.             ResponseEntity<String> exchange = restTemplate.exchange(
  644.                     azkabanConfig.getAzkUrl() + "/executor?session.id={id}&ajax=pauseFlow&execid={execid}", HttpMethod.GET,
  645.                     new HttpEntity<String>(hs), String.class, map);
  646.             System.out.println(exchange.getBody());
  647.         }
  649.         /**
  650.          * Flow Execution 重新执行一个执行流
  651.          * @throws Exception
  652.          */
  653.         public void resumeFlow() throws Exception {
  655.             SSLUtil.turnOffSslChecking();
  656.             HttpHeaders hs = new HttpHeaders();
  657.             hs.add("Content-Type", "application/x-www-form-urlencoded; charset=utf-8");
  658.             hs.add("X-Requested-With", "XMLHttpRequest");
  659.             hs.add("Accept", "text/plain;charset=utf-8");
  661.             Map<String, String> map = new HashMap<>();
  662.             map.put("id", "c4adf192-dcf4-4e05-bd08-f6989dc544a7");
  663.             map.put("execid", "11");
  664.             ResponseEntity<String> exchange = restTemplate.exchange(
  665.                     azkabanConfig.getAzkUrl() + "/executor?session.id={id}&ajax=resumeFlow&execid={execid}", HttpMethod.GET,
  666.                     new HttpEntity<String>(hs), String.class, map);
  667.             System.out.println(exchange.getBody());
  668.         }
  670.         /**
  671.          *  获取一个执行流的详细信息 这个流的每个节点的信息 成功或者失败等等
  672.          * @param execid 执行id
  673.          * @return
  674.          * @throws Exception
  675.          */
  676.         public String fetchexecflow(String execid) throws Exception {
  678.             SSLUtil.turnOffSslChecking();
  679.             HttpHeaders hs = new HttpHeaders();
  680.             hs.add("Content-Type", "application/x-www-form-urlencoded; charset=utf-8");
  681.             hs.add("X-Requested-With", "XMLHttpRequest");
  682.             hs.add("Accept", "text/plain;charset=utf-8");
  684.             Map<String, String> map = new HashMap<>();
  685.             map.put("id", login());
  686.             map.put("execid", execid);
  687.             ResponseEntity<String> exchange = restTemplate.exchange(
  688.                     azkabanConfig.getAzkUrl() + "/executor?session.id={id}&ajax=fetchexecflow&execid={execid}", HttpMethod.GET,
  689.                     new HttpEntity<String>(hs), String.class, map);
  690.             if (exchange == null || HttpStatus.SC_OK != exchange.getStatusCodeValue()) {
  691.                 logger.error("获取一个执行流的详细信息失败：" + execid);
  692.                 return null;
  693.             }
  694.             return exchange.getBody();
  695.         }
  697.         /**
  698.          * 获取一个执行流的日志
  699.          * @param execid 执行编号
  700.          * @param jobId job编号
  701.          * @param offset
  702.          * @param length
  703.          * @return
  704.          * @throws Exception
  705.          */
  706.         public String fetchExecJobLogs(String execid,String jobId,String offset,String length) throws Exception {
  708.             SSLUtil.turnOffSslChecking();
  709.             HttpHeaders hs = new HttpHeaders();
  710.             hs.add("Content-Type", "application/x-www-form-urlencoded; charset=utf-8");
  711.             hs.add("X-Requested-With", "XMLHttpRequest");
  712.             hs.add("Accept", "text/plain;charset=utf-8");
  714.             Map<String, String> map = new HashMap<>();
  715.             map.put("id", login());
  716.             map.put("execid", execid);
  717.             map.put("jobId", jobId);
  718.             map.put("offset", offset);
  719.             map.put("length", length);
  720.             ResponseEntity<String> exchange = restTemplate.exchange(
  721.                     azkabanConfig.getAzkUrl() + "/executor?session.id={id}&ajax=fetchExecJobLogs&execid={execid}&jobId={jobId}&offset={offset}&length={length}",
  722.                     HttpMethod.GET, new HttpEntity<String>(hs), String.class, map);
  723.             if (exchange == null || HttpStatus.SC_OK != exchange.getStatusCodeValue()) {
  724.                 logger.error("获取一个执行流的详细信息失败：{}:{}", execid,jobId);
  725.                 return null;
  726.             }
  727.             
  728.             JsonElement obj = new Gson().fromJson(exchange.getBody(), JsonObject.class).get("data");
  729.             if (obj == null) {
  730.                 logger.error("获取一个执行流的详细信息为空：{}:{}", execid,jobId);
  731.                 return null;
  732.             }
  733.             return obj.getAsString();
  734.         }
  735.         
  736.         /**
  737.          * 获取一个执行流的日志概要
  738.          * @param execid
  739.          * @param offset
  740.          * @param length
  741.          * @return
  742.          * @throws Exception
  743.          */
  744.         public String fetchExecFlowLogs(String execid,String offset,String length) throws Exception {
  746.             SSLUtil.turnOffSslChecking();
  747.             HttpHeaders hs = new HttpHeaders();
  748.             hs.add("Content-Type", "application/x-www-form-urlencoded; charset=utf-8");
  749.             hs.add("X-Requested-With", "XMLHttpRequest");
  750.             hs.add("Accept", "text/plain;charset=utf-8");
  752.             Map<String, String> map = new HashMap<>();
  753.             map.put("id", login());
  754.             map.put("execid", execid);
  755.             map.put("offset", offset);
  756.             map.put("length", length);
  757.             ResponseEntity<String> exchange = restTemplate.exchange(
  758.                     azkabanConfig.getAzkUrl() + "/executor?session.id={id}&ajax=fetchExecFlowLogs&execid={execid}&offset={offset}&length={length}",
  759.                     HttpMethod.GET, new HttpEntity<String>(hs), String.class, map);
  760.             if (exchange == null || HttpStatus.SC_OK != exchange.getStatusCodeValue()) {
  761.                 logger.error("获取一个执行流的日志概要信息失败：{}", execid);
  762.                 return null;
  763.             }
  764.             
  765.             JsonElement obj = new Gson().fromJson(exchange.getBody(), JsonObject.class).get("data");
  766.             if (obj == null) {
  767.                 logger.error("获取一个执行流的日志概要信息为空：{}:{}", execid);
  768.                 return null;
  769.             }
  770.             return obj.getAsString();
  771.         }
  772.         
  773.         /**
  774.          * 获取执行流的信息状态
  775.          * @throws Exception
  776.          */
  777.         public void fetchexecflowupdate() throws Exception {
  779.             SSLUtil.turnOffSslChecking();
  780.             HttpHeaders hs = new HttpHeaders();
  781.             hs.add("Content-Type", "application/x-www-form-urlencoded; charset=utf-8");
  782.             hs.add("X-Requested-With", "XMLHttpRequest");
  783.             hs.add("Accept", "text/plain;charset=utf-8");
  785.             Map<String, String> map = new HashMap<>();
  786.             map.put("id", "c4adf192-dcf4-4e05-bd08-f6989dc544a7");
  787.             map.put("execid", "11");
  788.             map.put("lastUpdateTime", "-1");
  789.             ResponseEntity<String> exchange = restTemplate.exchange(
  790.                     azkabanConfig.getAzkUrl() + "/executor?session.id={id}&ajax=fetchexecflowupdate&execid={execid}&lastUpdateTime={lastUpdateTime}",
  791.                     HttpMethod.GET, new HttpEntity<String>(hs), String.class, map);
  792.             System.out.println(exchange.getBody());
  793.         }
  794.         
  795.         private void scheduleTimeInit(LinkedMultiValueMap<String, String> linkedMultiValueMap, Date date) {
  796.             Calendar calendar = Calendar.getInstance();
  797.             calendar.setTime(date);
  798.             Integer year = calendar.get(Calendar.YEAR);
  799.             Integer month = calendar.get(Calendar.MONTH) + 1;
  800.             Integer day = calendar.get(Calendar.DATE);
  801.             Integer hour = calendar.get(Calendar.HOUR_OF_DAY);
  802.             Integer minute = calendar.get(Calendar.MINUTE);
  804.             linkedMultiValueMap.add("scheduleTime", hour + "," + minute + (hour > 11 ? ",pm,PDT" : ",am,EDT"));
  805.             linkedMultiValueMap.add("scheduleDate", month + "/" + day + "/" + year);
  806.         }
  808.         /**
  809.          * 获取azkaban调度  调度概况  (分页查询)
  810.          * @param projectName  工程名称
  811.          * @param start  分页参数
  812.          * @param size   分页参数
  813.          * @return
  814.          * @throws Exception
  815.          * @throws Exception
  816.          */
  817.         public List<GovernTaskRecordBean> getAzkabanExcutions(String projectName,String start,String size) throws Exception {
  819.             List<GovernTaskRecordBean> excInfoList = Lists.newArrayList();
  820.             List<String> flows = fetchFlowsProject(projectName);
  821.             for (String flow : flows) {
  822.                 FlowExecution fe = fetchFlowExecutions(projectName, flow, start, size);
  823.                 if (fe == null) {
  824.                     continue;
  825.                 }
  826.                 List<Execution> executions = fe.getExecutions();
  827.                 for (Execution execution : executions) {
  828.                     GovernTaskRecordBean eInfo = new GovernTaskRecordBean();
  829.                     eInfo.setCreateTime(new DateTime(execution.getSubmitTime()).toString(formatterTime));
  830.                     if (execution.getEndTime() > 0) {
  831.                         eInfo.setEndTime(new DateTime(execution.getEndTime()).toString(formatterTime));
  832.                         eInfo.setElapsed((execution.getEndTime() - execution.getStartTime()) / 1000);
  833.                     } else {
  834.                         eInfo.setElapsed((DateTime.now().getMillis() - execution.getStartTime()) / 1000);
  835.                     }
  836.                     eInfo.setExecId(execution.getExecId());
  837.                     eInfo.setFlowId(execution.getFlowId());
  838.                     eInfo.setOwner(execution.getSubmitUser());
  839.                     eInfo.setProjectId(execution.getProjectId());
  840.                     eInfo.setProjectPath(projectName);
  841.                     eInfo.setStartTime(new DateTime(execution.getStartTime()).toString(formatterTime));
  842.                     if (execution.getStatus().equalsIgnoreCase(ScheduleStatus.FAILED.getDesc())) {
  843.                         eInfo.setStatus(ScheduleStatus.FAILED.getCode());
  844.                     } else if (execution.getStatus().equalsIgnoreCase(ScheduleStatus.CANCELLED.getDesc())) {
  845.                         eInfo.setStatus(ScheduleStatus.CANCELLED.getCode());
  846.                     } else if (execution.getStatus().equalsIgnoreCase(ScheduleStatus.KILLED.getDesc())) {
  847.                         eInfo.setStatus(ScheduleStatus.KILLED.getCode());
  848.                     } else if (execution.getStatus().equalsIgnoreCase(ScheduleStatus.SUCCEEDED.getDesc())) {
  849.                         eInfo.setStatus(ScheduleStatus.SUCCEEDED.getCode());
  850.                     } 
  851.                     excInfoList.add(eInfo);
  852.                 }
  853.             }
  854.             return excInfoList;
  855.         }
  857.         /**
  858.          * 获取azkaban调度 流的执行情况 （分页）
  859.          * @param excuteId  调度执行id
  860.          * @param start
  861.          * @param size
  862.          * @return
  863.          * @throws Exception
  864.          */
  865.         public ExecutionInfoBean getAzkabanExcutionDetails(String excuteId, String start, String size) throws Exception {
  866.             String result = fetchexecflow(excuteId);
  867.             if (StringUtils.isBlank(result)) {
  868.                 throw new CommonException("查询任务流的执行详情失败!");
  869.             }
  870.             ExecutionInfo ei = new Gson().fromJson(result, ExecutionInfo.class);
  871.             if(ei==null) {
  872.                 throw new CommonException("查询任务流的执行详情失败!");
  873.             }
  874.             List<ExecNode> nodes = ei.getNodes();
  875.             if (nodes == null || nodes.size() == 0) {
  876.                 return null;
  877.             }
  878.             ExecutionInfoBean eib = new ExecutionInfoBean();
  879.             eib.setAttempt(ei.getAttempt());
  880.             eib.setStartTime(new DateTime(ei.getStartTime()).toString(formatterTime));
  881.             if (ei.getEndTime() > 0) {
  882.                 eib.setEndTime(new DateTime(ei.getEndTime()).toString(formatterTime));
  883.                 eib.setElapsed((ei.getEndTime() - ei.getStartTime()) / 1000);
  884.             } else {
  885.                 eib.setElapsed((DateTime.now().getMillis() - ei.getStartTime()) / 1000);
  886.             }
  887.             eib.setExecid(ei.getExecid());
  888.             eib.setFlow(ei.getFlow());
  889.             eib.setFlowId(ei.getFlowId());
  890.             eib.setJobId(ei.getId());
  891.             eib.setNestedId(ei.getNestedId());
  892.             eib.setProject(ei.getProject());
  893.             eib.setProjectId(ei.getProjectId());
  894.             String stats = ScheduleStatus.getDescByCode(ei.getStatus());
  895.             if(StringUtils.isNotBlank(stats)){
  896.                 eib.setStatus(stats);
  897.             }
  898.             eib.setSubmitTime(new DateTime(ei.getSubmitTime()).toString(formatterTime));
  899.             eib.setSubmitUser(ei.getSubmitUser());
  900.             eib.setType(ei.getType());
  901.             eib.setUpdateTime(new DateTime(ei.getUpdateTime()).toString(formatterTime));
  903.             String flowLog= fetchExecFlowLogs(excuteId, start, size);
  904.             eib.setFlowLog(flowLog);
  905.             List<ExecNodeBean> nodeBeanList = Lists.newArrayList();
  906.             for(ExecNode node:nodes) {
  907.                 ExecNodeBean ebn = new ExecNodeBean();
  908.                 ebn.setAttempt(node.getAttempt());
  909.                 ebn.setJobId(node.getId());
  910.                 ebn.setDependencies(node.getIn());
  911.                 ebn.setNestedId(node.getNestedId());
  912.                 ebn.setStartTime(new DateTime(ei.getStartTime()).toString(formatterTime));
  913.                 if (node.getEndTime() > 0) {
  914.                     ebn.setEndTime(new DateTime(node.getEndTime()).toString(formatterTime));
  915.                     ebn.setElapsed((node.getEndTime() - node.getStartTime()) / 1000);
  916.                 } else {
  917.                     ebn.setElapsed((DateTime.now().getMillis() - node.getStartTime()) / 1000);
  918.                 }
  919.                 String stats2 = ScheduleStatus.getDescByCode(node.getStatus());
  920.                 if(StringUtils.isNotBlank(stats2)){
  921.                     ebn.setStatus(stats2);
  922.                 }
  923.                 ebn.setType(node.getType());
  924.                 ebn.setUpdateTime(new DateTime(ei.getUpdateTime()).toString(formatterTime));
  925.                 String logs = fetchExecJobLogs(excuteId,ebn.getJobId(),start, size);
  926.                 ebn.setLogs(logs);
  927.                 nodeBeanList.add(ebn);
  928.             }
  929.             eib.setNodes(nodeBeanList);
  930.             return eib;
  931.         }
  933.         /**
  934.          * 获取一个项目的projectId
  935.          * @param projectName
  936.          * @return
  937.          * @throws Exception
  938.          */
  939.         public String fetchProjectId(String projectName) throws Exception {
  940.             SSLUtil.turnOffSslChecking();
  941.             HttpHeaders hs = new HttpHeaders();
  942.             hs.add("Content-Type", CONTENT_TYPE);
  943.             hs.add("X-Requested-With", X_REQUESTED_WITH);
  944.             hs.add("Accept", "text/plain;charset=utf-8");
  946.             Map<String, String> map = new HashMap<>();
  948.             map.put("id", login());
  949.             map.put("project", projectName);
  951.             ResponseEntity<String> exchange = restTemplate.exchange(
  952.                     azkabanConfig.getAzkUrl() + "/manager?&session.id={id}&project={project}&ajax=fetchprojectflows", HttpMethod.GET,
  953.                     new HttpEntity<String>(hs), String.class, map);
  954.             if (exchange == null||HttpStatus.SC_OK != exchange.getStatusCodeValue()) {
  955.                 logger.error("Azkaban获取一个项目的所有流信息失败：" + projectName);
  956.                 return null;
  957.             }
  958.             JsonElement obj = new Gson().fromJson(exchange.getBody(), JsonObject.class).get("projectId");
  959.             if (obj == null) {
  960.                 logger.error("Azkaban获取一个项目的所有流信息失败:{}:{}", projectName);
  961.                 return null;
  962.             }
  963.             String projectId = obj.getAsString();
  964.             if(StringUtils.isBlank(projectId)){
  965.                 logger.error("获取Azkaban  projectId 异常");
  966.             }
  967.             return projectId;
  968.         }
  970.         /**
  971.          * 获取
  972.          * @param projectName
  973.          * @return
  974.          * @throws Exception
  975.          */
  976.         public String getLastScheduleStatus(String projectName) throws Exception {
  977.             List<String> flows = fetchFlowsProject(projectName);
  978.             if(CollectionUtils.isNotEmpty(flows)) {
  979.                 for (String flow : flows) {
  980.                     FlowExecution fe = fetchFlowExecutions(projectName, flow, "0", "1000");
  981.                     if (fe == null) {
  982.                         continue;
  983.                     }
  984.                     List<Execution> executions = fe.getExecutions();
  985.                     if (executions == null || executions.size() == 0) {
  986.                         continue;
  987.                     }
  988.                     String status = executions.get(0).getStatus();
  989.                     return status;
  990.                 }
  991.             }
  992.             return null;
  993.         }
  994.     
  995.     
  997. }
AzkabanService

　　8.调用demo

  1.     /**
  2.      * 根据flowId 立即执行任务
  3.      * @param projectName 项目名称
  4.      * @param flow 流id
  5.      * @throws CommonException 阿兹卡班异常
  6.      */
  7.     private  void excuteFlowImmediately(String projectName, String flow) throws CommonException {
  8.         try {
  9.             azkabanService.executeFlow(projectName,flow);
  10.         } catch (Exception e) {
  11.             throw new CommonException("调度初始化完毕，立即执行任务异常",e);
  12.         }
  13.     }
demo

 

四、注意

　　1.如遇报错情况，请关注azkaban相关log日志。

　　2.如果pom文件jar包不全 请评论。

 

 

 友情链接：直通硅谷 　点职佳 　北美留学生论坛

Java热门文章

  • 【IDEA】Application context not configured for this file
  • [IDEA] chapter_reader - idea看小说插件 idea阅读插件 idea摸鱼插件
  • thrift常见异常及原因分析
  • Java 调用 PaddleDetection 模型
  • JVM 详解，大白话带你认识 JVM
  • spring-boot-2.0.3不一样系列之番外篇 - @Configuration、Condition与@Conditional
  • Java Comparator.comparing比较导致空指针异常的解决
  • Java使用EasyExcel进行单元格合并的问题详解
  • 死磕 java集合之ArrayBlockingQueue源码分析
  • Java基础之集合Set详解

    • Java推荐文章

  • 面试场景题：一次关于线程池使用场景的讨论。
  • 前端黑科技：使用 JavaScript 实现网页扫码功能
  • 聊一聊 Netty 数据搬运工 ByteBuf 体系的设计与实现
  • 简单设计一个JAVA并行处理工具类
  • 【杂谈】JPA乐观锁改悲观锁遇到的一些问题与思考
  • 认识netty的基本组件
  • Jenkins如何使用CrumbIssuer防御CSRF攻击
  • 如何平稳地从nacos迁移到r-nacos？
  • 线程池遇到父子任务，有大坑，要注意！
  • Java JVM——12. 垃圾回收理论概述

    • 本站QQ群：前端 618073944 | Java 606181507 | Python 626812652 | C/C++ 612253063 | 微信 634508462 | 苹果 692586424 | C#/.net 182808419 | PHP 305140648 | 运维 608723728

    W3xue 的所有内容仅供测试，对任何法律问题及风险不承担任何责任。通过使用本站内容随之而来的风险与本站无关。
    关于我们  |  意见建议  |  捐助我们  |  报错有奖  |  广告合作、友情链接（目前9元/月）请联系QQ：27243702 沸活量
    皖ICP备17017327号-2　皖公网安备34020702000426号