Commit 2ef7abea authored by 黎博's avatar 黎博

BUG修复

parent 15e09f93
...@@ -223,18 +223,18 @@ public class K8sController { ...@@ -223,18 +223,18 @@ public class K8sController {
if (label.equals("java")) { if (label.equals("java")) {
// JAVA // JAVA
DockerProject dockerProject = dockerProjectService.getOne(queryWrapper); DockerProject dockerProject = dockerProjectService.getOne(queryWrapper);
// 创建Service
if (k8sService.queryIfServiceExistByName(namespace, serviceName)) {
k8sService.deleteService(namespace, serviceName);
}
k8sService.createJavaService(namespace, serviceName, serviceCreateVo.getDebug());
// 创建Deployment // 创建Deployment
if (k8sService.queryIfDeploymentExistByName(namespace, serviceName)) { if (k8sService.queryIfDeploymentExistByName(namespace, serviceName)) {
k8sService.deleteDeployment(namespace, serviceName); k8sService.deleteDeployment(namespace, serviceName);
} }
k8sService.createJavaDeployment(serviceCreateVo, dockerProject); k8sService.createJavaDeployment(serviceCreateVo, dockerProject);
// 创建Service
if (k8sService.queryIfServiceExistByName(namespace, serviceName)) {
k8sService.deleteService(namespace, serviceName);
}
k8sService.createJavaService(namespace, serviceName, serviceCreateVo.getDebug());
// 创建Ingress // 创建Ingress
if (k8sService.queryIfIngressExistByName(namespace, serviceName)) { if (k8sService.queryIfIngressExistByName(namespace, serviceName)) {
k8sService.deleteIngress(namespace, serviceName); k8sService.deleteIngress(namespace, serviceName);
...@@ -243,18 +243,18 @@ public class K8sController { ...@@ -243,18 +243,18 @@ public class K8sController {
} else if (label.equals("ui") || label.equals("node")) { } else if (label.equals("ui") || label.equals("node")) {
// UI // UI
DockerProject dockerProject = dockerProjectService.getOne(queryWrapper); DockerProject dockerProject = dockerProjectService.getOne(queryWrapper);
// 创建Service
if (k8sService.queryIfServiceExistByName(namespace, serviceName)) {
k8sService.deleteService(namespace, serviceName);
}
k8sService.createUIAndNodeService(namespace, serviceName, type, label);
// 创建Deployment // 创建Deployment
if (k8sService.queryIfDeploymentExistByName(namespace, serviceName)) { if (k8sService.queryIfDeploymentExistByName(namespace, serviceName)) {
k8sService.deleteDeployment(namespace, serviceName); k8sService.deleteDeployment(namespace, serviceName);
} }
k8sService.createUIAndNodeDeployment(serviceCreateVo, dockerProject); k8sService.createUIAndNodeDeployment(serviceCreateVo, dockerProject);
// 创建Service
if (k8sService.queryIfServiceExistByName(namespace, serviceName)) {
k8sService.deleteService(namespace, serviceName);
}
k8sService.createUIAndNodeService(namespace, serviceName, type, label);
// 创建Ingress // 创建Ingress
if (k8sService.queryIfIngressExistByName(namespace, serviceName)) { if (k8sService.queryIfIngressExistByName(namespace, serviceName)) {
k8sService.deleteIngress(namespace, serviceName); k8sService.deleteIngress(namespace, serviceName);
...@@ -298,7 +298,7 @@ public class K8sController { ...@@ -298,7 +298,7 @@ public class K8sController {
deployment = k8sService.createJavaDeployment(serviceCreateVo, dockerProject); deployment = k8sService.createJavaDeployment(serviceCreateVo, dockerProject);
k8sService.createJavaService(namespace, serviceName, serviceCreateVo.getDebug()); k8sService.createJavaService(namespace, serviceName, serviceCreateVo.getDebug());
} }
// 类型为UI // 类型为UI或Node
if (label.equals("ui") || label.equals("node")) { if (label.equals("ui") || label.equals("node")) {
deployment = k8sService.createUIAndNodeDeployment(serviceCreateVo, dockerProject); deployment = k8sService.createUIAndNodeDeployment(serviceCreateVo, dockerProject);
k8sService.createUIAndNodeService(namespace, serviceName, type, label); k8sService.createUIAndNodeService(namespace, serviceName, type, label);
......
...@@ -458,11 +458,11 @@ public class K8sService { ...@@ -458,11 +458,11 @@ public class K8sService {
*/ */
public boolean deleteDeployment(String namespace, String serviceName) { public boolean deleteDeployment(String namespace, String serviceName) {
// 删除Service // 删除Service
log.info("删除{}环境{}的Service.", namespace, serviceName); // log.info("删除{}环境{}的Service.", namespace, serviceName);
kubernetesClient.services().inNamespace(namespace).withName(serviceName).delete(); // kubernetesClient.services().inNamespace(namespace).withName(serviceName).delete();
// 删除Ingress // // 删除Ingress
log.info("删除{}环境{}的Ingress.", namespace, serviceName); // log.info("删除{}环境{}的Ingress.", namespace, serviceName);
kubernetesClient.extensions().ingresses().inNamespace(namespace).withName(serviceName).delete(); // kubernetesClient.extensions().ingresses().inNamespace(namespace).withName(serviceName).delete();
// 删除eployment // 删除eployment
log.info("删除{}环境{}的pod.", namespace, serviceName); log.info("删除{}环境{}的pod.", namespace, serviceName);
return kubernetesClient.apps().deployments().inNamespace(namespace).withName(serviceName).delete(); return kubernetesClient.apps().deployments().inNamespace(namespace).withName(serviceName).delete();
...@@ -2205,6 +2205,7 @@ public class K8sService { ...@@ -2205,6 +2205,7 @@ public class K8sService {
* @return * @return
*/ */
public boolean deleteIngress(String namespace, String serviceName) { public boolean deleteIngress(String namespace, String serviceName) {
log.info("删除{}环境的{} Ingress", namespace, serviceName);
return kubernetesClient.extensions().ingresses().inNamespace(namespace).withName(serviceName).delete(); return kubernetesClient.extensions().ingresses().inNamespace(namespace).withName(serviceName).delete();
} }
...@@ -2215,6 +2216,7 @@ public class K8sService { ...@@ -2215,6 +2216,7 @@ public class K8sService {
* @return * @return
*/ */
public boolean deleteService(String namespace, String serviceName) { public boolean deleteService(String namespace, String serviceName) {
log.info("删除{}环境的{} Service", namespace, serviceName);
return kubernetesClient.services().inNamespace(namespace).withName(serviceName).delete(); return kubernetesClient.services().inNamespace(namespace).withName(serviceName).delete();
} }
...@@ -2227,10 +2229,10 @@ public class K8sService { ...@@ -2227,10 +2229,10 @@ public class K8sService {
} }
public static void main(String[] args) { public static void main(String[] args) {
K8sService k8sService = new K8sService(); // K8sService k8sService = new K8sService();
// k8sService.createNewNamespace("test6", "dev", "黎博"); // k8sService.createNewNamespace("test6", "dev", "黎博");
// k8sService.podTest(); // k8sService.podTest();
// k8sService.getPodList("k8s"); // k8sService.getPodList("k8s");
System.out.println(JSON.toJSONString(k8sService.getPodListNew("fe"))); // System.out.println(JSON.toJSONString(k8sService.getPodListNew("fe")));
} }
} }
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment