调用marathon rest API

步骤：

1、访问marathon下载源码地址为 https://github.com/mesosphere/marathon-client

2、修改Marathon类此处多添加一个GET ping 的方法

===============================================================================================

package mesosphere.marathon.client;

import java.util.List;

import javax.inject.Named;

import mesosphere.marathon.client.model.v2.App;
import mesosphere.marathon.client.model.v2.DeleteAppTaskResponse;
import mesosphere.marathon.client.model.v2.DeleteAppTasksResponse;
import mesosphere.marathon.client.model.v2.Deployment;
import mesosphere.marathon.client.model.v2.GetAppResponse;
import mesosphere.marathon.client.model.v2.GetAppTasksResponse;
import mesosphere.marathon.client.model.v2.GetAppsResponse;
import mesosphere.marathon.client.model.v2.GetQueuesResponse;
import mesosphere.marathon.client.model.v2.GetServerInfoResponse;
import mesosphere.marathon.client.model.v2.GetTasksResponse;
import mesosphere.marathon.client.model.v2.Group;
import mesosphere.marathon.client.model.v2.Result;
import mesosphere.marathon.client.utils.MarathonException;
import feign.RequestLine;

public interface Marathon {
//ping IP
@RequestLine("GET /ping")
void ping();
// Apps
@RequestLine("GET /v2/apps")
GetAppsResponse getApps();

@RequestLine("GET /v2/apps/{id}")
GetAppResponse getApp(@Named("id") String id) throws MarathonException;

@RequestLine("GET /v2/apps/{id}/tasks")
GetAppTasksResponse getAppTasks(@Named("id") String id);

@RequestLine("POST /v2/apps/{app_id}/restart")
Result reStartApp(@Named("app_id") String app_id) throws MarathonException;

@RequestLine("GET /v2/tasks")
GetTasksResponse getTasks();

@RequestLine("POST /v2/apps")
App createApp(App app) throws MarathonException;

@RequestLine("PUT /v2/apps/{app_id}")
void updateApp(@Named("app_id") String appId, App app) throws MarathonException;

@RequestLine("PUT /v2/apps/{app_id}?force=true")
void forceUpdateApp(@Named("app_id") String appId, App app) throws MarathonException;

@RequestLine("DELETE /v2/apps/{id}")
Result deleteApp(@Named("id") String id) throws MarathonException;

@RequestLine("DELETE /v2/apps/{id}?force=true")
Result forceDeleteApp(@Named("id") String id) throws MarathonException;

@RequestLine("DELETE /v2/apps/{app_id}/tasks?host={host}&scale={scale}")
DeleteAppTasksResponse deleteAppTasks(@Named("app_id") String appId,
@Named("host") String host, @Named("scale") String scale);

@RequestLine("DELETE /v2/apps/{app_id}/tasks/{task_id}?scale={scale}")
DeleteAppTaskResponse deleteAppTask(@Named("app_id") String appId,
@Named("task_id") String taskId, @Named("scale") String scale);

// Groups
@RequestLine("POST /v2/groups")
Result createGroup(Group group) throws MarathonException;

@RequestLine("PUT /v2/groups/{id}")
Result updateGroup(@Named("id") String id, Group group) throws MarathonException;

@RequestLine("PUT /v2/groups/{id}?force=true")
Result forceUpdateGroup(@Named("id") String id, Group group) throws MarathonException;

@RequestLine("DELETE /v2/groups/{id}")
Result deleteGroup(@Named("id") String id) throws MarathonException;

@RequestLine("DELETE /v2/groups/{id}?force=true")
Result forceDeleteGroup(@Named("id") String id) throws MarathonException;

@RequestLine("GET /v2/groups/{id}")
Group getGroup(@Named("id") String id) throws MarathonException;

// Tasks

// Deployments
@RequestLine("GET /v2/deployments")
List<Deployment> getDeployments();

@RequestLine("DELETE /v2/deployments/{deploymentId}")
void cancelDeploymentAndRollback(@Named("deploymentId") String id);

@RequestLine("DELETE /v2/deployments/{deploymentId}?force=true")
void cancelDeployment(@Named("deploymentId") String id);

// Event Subscriptions

// Queue
@RequestLine("GET /v2/queue")
GetQueuesResponse getQueues() throws MarathonException;
// Server Info
@RequestLine("GET /v2/info")
GetServerInfoResponse getServerInfo();

// Miscellaneous
}

=============================================================================================

3、修改MarathonClient类重载方法getInstance（）；

package mesosphere.marathon.client;

import mesosphere.marathon.client.utils.MarathonException;
import mesosphere.marathon.client.utils.ModelUtils;
import feign.Feign;
import feign.RequestInterceptor;
import feign.RequestTemplate;
import feign.Response;
import feign.codec.ErrorDecoder;
import feign.gson.GsonDecoder;
import feign.gson.GsonEncoder;
import java.util.List;
import java.util.Map;

public class MarathonClient {
static class MarathonHeadersInterceptor implements RequestInterceptor {
@Override
public void apply(RequestTemplate template) {
template.header("Accept", "application/json");
template.header("Content-Type", "application/json");
}
}

static class MarathonErrorDecoder implements ErrorDecoder {
@Override
public Exception decode(String methodKey, Response response) {
return new MarathonException(response.status(), response.reason());
}
}
public static Marathon getInstance(String endpoint) {
GsonDecoder decoder = new GsonDecoder(ModelUtils.GSON);
GsonEncoder encoder = new GsonEncoder(ModelUtils.GSON);
return Feign.builder().encoder(encoder).decoder(decoder)
.errorDecoder(new MarathonErrorDecoder())
.requestInterceptor(new MarathonHeadersInterceptor())
.target(Marathon.class, endpoint);
/*marathon.ping();
return marathon;*/
}
public static Marathon getInstance(String area,Map<String,List<String>> urlConfs) {
Marathon marathon = null;
GsonDecoder decoder = new GsonDecoder(ModelUtils.GSON);
GsonEncoder encoder = new GsonEncoder(ModelUtils.GSON);
//String []marathonUrl=endpoint.split(",");

List<String> urls=urlConfs.get(area);
for(int i=0;i<urls.size();i++){
//初始化实例
marathon= Feign.builder().encoder(encoder).decoder(decoder)
.errorDecoder(new MarathonErrorDecoder())
.requestInterceptor(new MarathonHeadersInterceptor())
.target(Marathon.class, urls.get(i));
try{
//测试所选择的url是否可以ping通
marathon.ping();
return marathon;
}catch(Exception e){
System.out.println("连接url="+urls.get(i)+"异常！");
System.out.println("错误信息："+e.getMessage());
continue;
}
}

System.out.println("连接marathon集群异常！");
return null;
}

public static String getEnableUrl(String area,Map<String,List<String>> urlConfs){
String url="";
Marathon marathon = null;
GsonDecoder decoder = new GsonDecoder(ModelUtils.GSON);
GsonEncoder encoder = new GsonEncoder(ModelUtils.GSON);
//String []marathonUrl=endpoint.split(",");
List<String> urls=urlConfs.get(area);

for(int i=0;i<urls.size();i++){
url=urls.get(i);
//初始化实例
marathon= Feign.builder().encoder(encoder).decoder(decoder)
.errorDecoder(new MarathonErrorDecoder())
.requestInterceptor(new MarathonHeadersInterceptor())
.target(Marathon.class, url);
try{
//测试所选择的url是否可以ping通
marathon.ping();
return url;
}catch(Exception e){
System.out.println("连接url="+url+"异常！");
System.out.println("错误信息："+e.getMessage());
continue;
}
}
return null;
}

}

4、test

public class Test {
public static void main(String[] args){

String url = "http://ip:端口号";
Map<String,List<String>> urlConfs = new HashMap<String, List<String>>();
List<String> list = new ArrayList<String>();
list.add(url);
urlConfs.put("1", list);
Marathon marathon = MarathonClient.getInstance("1", urlConfs);
List<Deployment> list3 = marathon.getDeployments();
System.out.println(ModelUtils.toString(list3));
for(Deployment dep : list3){
System.out.println(dep.toString());
marathon.cancelDeployment(dep.getId());
}

}

5、所需jar包

feign.jar和inject.jar

文档中有可下载

调用marathon rest API相关推荐

api.php t.cn,PHP通过调用新浪API生成t.cn格式短网址链接的方法详解
本文实例讲述了PHP通过调用新浪API生成t.cn格式短网址链接的方法.分享给大家供大家参考,具体如下: 新浪提供了长链接转为短链接的API,可以把长链接转为 t.cn/xxx 这种格式的短链接. A ...
C#调用Win32 的API函数--User32.dll
Win32的API函数是微软自己的东西,可以直接在C#中直接调用,在做WinForm时还是很有帮助的.有时候我们之直接调用Win32 的API,可以很高效的实现想要的效果. using System; ...
python有道api-python 调用有道api接口的方法
初学python ,研究了几天,写了一个python 调用有道api接口程序效果看下图: 申明:代码仅供和我一样的初学者学习交流申请很简单的 ps:审核不用花时间的,请勿滥用!! #-*- co ...
python实现简单的api接口-简单实现Python调用有道API接口(最新的)
# ''' # Created on 2018-5-26 # # @author: yaoshuangqi # ''' import urllib.request import urllib.pars ...
python如何实现别人调用自己的API
5_python如何实现别人调用自己的API(5-20181224) 参考别人的API接口的形式参考别人的API接口的形式 https://docs.open.alipay.com/api_1/al ...
C#调用百度地图 api
转 http://blog.csdn.net/kkkkkxiaofei/article/details/8663377 这一篇,记录一下我调用的地图API实现的功能.下面介绍的都是一些片段的节选,不 ...
【c#】Form调用百度地图api攻略及常见问题
首先,在Form中调用百度地图api,我们需要使用webbrowser控件,这个在前面的文章中已经讲过了,可以参照(http://blog.csdn.net/buptgshengod/article/ ...
python调用系统api_Python调用系统底层API播放wav文件的方法
本文实例讲述了Python调用系统底层API播放wav文件的方法.分享给大家供大家参考,具体如下: 这里未使用其他库,只是使用 pywin32 调用系统底层 API 播放 wav 文件. 具体代码如下 ...
C#调用百度地图API入门解决BMap未定义问题
本文主要是最近帮助好友研究JavaScript的百度地图API,同时显示到C# Winform界面.同时遇到了BMap未定义的错误(BMap is not defined)及解决方法.以前写过基于An ...

调用marathon rest API

调用marathon rest API相关推荐

最新文章

热门文章