用 java fabric客户连接 k8s(GKE) 并创建一个deployment
1. 引入依赖<dependency><groupId>io.fabric8</groupId><artifactId>openshift-client</artifactId><version>5.9.0</version></dependency>2. 获取config文件从$HOME/.kube/
·
1. 引入依赖
<dependency>
<groupId>io.fabric8</groupId>
<artifactId>openshift-client</artifactId>
<version>5.9.0</version>
</dependency>
2. 获取config文件
从$HOME/.kube/目录下获取config文件,放在项目的指定目录下,代码中会用到。
3. 获取accessToken(需要认证的情况下,需要获取accessToken)
public static String getAccessToken() throws IOException {
GoogleCredential credential = GoogleCredential
.fromStream(new FileInputStream(
"src/main/java/xxxxxx.json"))// 加载服务帐户认证文件
.createScoped(SCOPES);
// 刷新token
credential.refreshToken();
// 获取token
String preAccessToken1 = credential.getAccessToken();
System.out.println(preAccessToken1);
String accessToken = preAccessToken1.substring(0, preAccessToken1.indexOf(".."));
System.out.println(accessToken);
return accessToken;
}
该 xxxxxx.json 需要从GKE平台下载,即创建GKE集群时候,用的账号,对应的json文件。
4. 创建KubernetesClient
public static KubernetesClient getFabricClient(String accessToken) throws IOException {
File configFile = new File("src/main/java/config");
final String configYAML = String.join("\n", Files.readAllLines(configFile.toPath()));
Config config = Config.fromKubeconfig(configYAML);
config.setTrustCerts(true);
config.setMasterUrl("https://apiserver-ip");
config.setOauthToken(accessToken);
KubernetesClient kubernetesClient = new DefaultKubernetesClient(config);
return kubernetesClient;
}
5. 在k8s集群中创建一个deployment
private static final String NAMESPACE = "HelloKitty";
public static void createDeployment(KubernetesClient client ) {
Namespace ns = new NamespaceBuilder().withNewMetadata().withName(NAMESPACE).addToLabels("this", "rocks").endMetadata().build();
logger.info("Created namespace: {}", client.namespaces().createOrReplace(ns));
ServiceAccount fabric8 = new ServiceAccountBuilder().withNewMetadata().withName("fabric8").endMetadata().build();
client.serviceAccounts().inNamespace(NAMESPACE).createOrReplace(fabric8);
try {
Deployment deployment = new DeploymentBuilder()
.withNewMetadata()
.withName("nginx")
.endMetadata()
.withNewSpec()
.withReplicas(1)
.withNewTemplate()
.withNewMetadata()
.addToLabels("app", "nginx")
.endMetadata()
.withNewSpec()
.addNewContainer()
.withName("nginx")
.withImage("nginx")
.addNewPort()
.withContainerPort(80)
.endPort()
.endContainer()
.endSpec()
.endTemplate()
.withNewSelector()
.addToMatchLabels("app", "nginx")
.endSelector()
.endSpec()
.build();
deployment = client.apps().deployments().inNamespace(NAMESPACE).create(deployment);
logger.info("Created deployment: {}", deployment);
logger.info("Scaling up: {}", deployment.getMetadata().getName());
client.apps().deployments().inNamespace(NAMESPACE).withName("nginx").scale(2, true);
logger.info("Created replica sets: {}", client.apps().replicaSets().inNamespace(NAMESPACE).list().getItems());
// logger.info("Deleting: {}", deployment.getMetadata().getName());
// client.resource(deployment).delete();
} finally {
// client.namespaces().withName(NAMESPACE).delete();
}
logger.info("Done.");
}
更多推荐
已为社区贡献8条内容
所有评论(0)