Commit 8aa3c51c authored by 黎博's avatar 黎博

优化

parent 752951a6
...@@ -277,24 +277,26 @@ public class K8sController { ...@@ -277,24 +277,26 @@ public class K8sController {
} }
// 再创建新pod // 再创建新pod
Deployment deployment = null; Deployment deployment = null;
// 删除原来的Service
if (k8sService.queryIfServiceExistByName(namespace, serviceName)) {
k8sService.deleteService(namespace, serviceName);
}
// 类型为Java
if (label.equals("java")) { if (label.equals("java")) {
deployment = k8sService.createJavaDeployment(serviceCreateVo, dockerProject); deployment = k8sService.createJavaDeployment(serviceCreateVo, dockerProject);
if (!k8sService.queryIfServiceExistByName(namespace, serviceName)) {
k8sService.createJavaService(namespace, serviceName, serviceCreateVo.getDebug()); k8sService.createJavaService(namespace, serviceName, serviceCreateVo.getDebug());
} }
if (!k8sService.queryIfIngressExistByName(namespace, serviceName)) { // 类型为UI
k8sService.createIngress(namespace, serviceName, serviceCreateVo.getDomain());
}
}
if (label.equals("ui") || label.equals("node")) { if (label.equals("ui") || label.equals("node")) {
deployment = k8sService.createUIAndNodeDeployment(serviceCreateVo, dockerProject); deployment = k8sService.createUIAndNodeDeployment(serviceCreateVo, dockerProject);
if (!k8sService.queryIfServiceExistByName(namespace, serviceName)) {
k8sService.createUIAndNodeService(namespace, serviceName, type, label); k8sService.createUIAndNodeService(namespace, serviceName, type, label);
} }
if (!k8sService.queryIfIngressExistByName(namespace, serviceName)) { // 删除原有Ingress
k8sService.createIngress(namespace, serviceName, serviceCreateVo.getDomain()); if (k8sService.queryIfIngressExistByName(namespace, serviceName)) {
} k8sService.deleteIngress(namespace, serviceName);
} }
// 创建新的Ingress
k8sService.createIngress(namespace, serviceName, serviceCreateVo.getDomain());
if (deployment != null) { if (deployment != null) {
return JsonResult.buildSuccessResult("更新成功!", true); return JsonResult.buildSuccessResult("更新成功!", true);
} else { } else {
......
...@@ -457,14 +457,14 @@ public class K8sService { ...@@ -457,14 +457,14 @@ public class K8sService {
* @return * @return
*/ */
public boolean deleteDeployment(String namespace, String serviceName) { public boolean deleteDeployment(String namespace, String serviceName) {
// 删除service // 删除Service
log.info("删除{}环境{}的Service.", namespace, serviceName);
kubernetesClient.services().inNamespace(namespace).withName(serviceName).delete(); kubernetesClient.services().inNamespace(namespace).withName(serviceName).delete();
Map<String, String> map = new HashMap<>(); // 删除Ingress
map.put("qcloud-app", serviceName); log.info("删除{}环境{}的Ingress.", namespace, serviceName);
LabelSelector labelSelector = new LabelSelector(); kubernetesClient.extensions().ingresses().inNamespace(namespace).withName(serviceName).delete();
labelSelector.setMatchLabels(map); // 删除eployment
// 删除deployment 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();
} }
......
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