1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
|
@Service
public class K8sManagementService {
@Autowired
private ApiClient apiClient;
@Autowired
private AlertService alertService;
public void createPod(String namespace, String podName, String image) {
try {
CoreV1Api coreV1Api = new CoreV1Api(apiClient);
V1Pod pod = new V1Pod();
V1ObjectMeta metadata = new V1ObjectMeta();
metadata.setName(podName);
metadata.setNamespace(namespace);
pod.setMetadata(metadata);
V1PodSpec spec = new V1PodSpec();
V1Container container = new V1Container();
container.setName(podName);
container.setImage(image);
spec.setContainers(Arrays.asList(container));
pod.setSpec(spec);
V1Pod createdPod = coreV1Api.createNamespacedPod(namespace, pod).execute();
log.info("创建Pod成功: namespace={}, podName={}, image={}",
namespace, podName, image);
} catch (Exception e) {
log.error("创建Pod失败: namespace={}, podName={}, error={}",
namespace, podName, e.getMessage(), e);
}
}
public void deletePod(String namespace, String podName) {
try {
CoreV1Api coreV1Api = new CoreV1Api(apiClient);
coreV1Api.deleteNamespacedPod(podName, namespace).execute();
log.info("删除Pod成功: namespace={}, podName={}", namespace, podName);
} catch (Exception e) {
log.error("删除Pod失败: namespace={}, podName={}, error={}",
namespace, podName, e.getMessage(), e);
}
}
public void restartPod(String namespace, String podName) {
try {
CoreV1Api coreV1Api = new CoreV1Api(apiClient);
coreV1Api.deleteNamespacedPod(podName, namespace).execute();
Thread.sleep(5000);
log.info("重启Pod成功: namespace={}, podName={}", namespace, podName);
} catch (Exception e) {
log.error("重启Pod失败: namespace={}, podName={}, error={}",
namespace, podName, e.getMessage(), e);
}
}
public void scalePod(String namespace, String deploymentName, int replicas) {
try {
AppsV1Api appsV1Api = new AppsV1Api(apiClient);
V1Deployment deployment = appsV1Api.readNamespacedDeployment(deploymentName, namespace).execute();
V1DeploymentSpec spec = deployment.getSpec();
spec.setReplicas(replicas);
deployment.setSpec(spec);
appsV1Api.replaceNamespacedDeployment(deploymentName, namespace, deployment).execute();
log.info("扩缩容Pod成功: namespace={}, deploymentName={}, replicas={}",
namespace, deploymentName, replicas);
} catch (Exception e) {
log.error("扩缩容Pod失败: namespace={}, deploymentName={}, replicas={}, error={}",
namespace, deploymentName, replicas, e.getMessage(), e);
}
}
public void createService(String namespace, String serviceName, String podName, int port) {
try {
CoreV1Api coreV1Api = new CoreV1Api(apiClient);
V1Service service = new V1Service();
V1ObjectMeta metadata = new V1ObjectMeta();
metadata.setName(serviceName);
metadata.setNamespace(namespace);
service.setMetadata(metadata);
V1ServiceSpec spec = new V1ServiceSpec();
spec.setSelector(Map.of("app", podName));
V1ServicePort servicePort = new V1ServicePort();
servicePort.setPort(port);
servicePort.setTargetPort(new IntOrString(port));
spec.setPorts(Arrays.asList(servicePort));
service.setSpec(spec);
V1Service createdService = coreV1Api.createNamespacedService(namespace, service).execute();
log.info("创建服务成功: namespace={}, serviceName={}, podName={}, port={}",
namespace, serviceName, podName, port);
} catch (Exception e) {
log.error("创建服务失败: namespace={}, serviceName={}, error={}",
namespace, serviceName, e.getMessage(), e);
}
}
public void deleteService(String namespace, String serviceName) {
try {
CoreV1Api coreV1Api = new CoreV1Api(apiClient);
coreV1Api.deleteNamespacedService(serviceName, namespace).execute();
log.info("删除服务成功: namespace={}, serviceName={}", namespace, serviceName);
} catch (Exception e) {
log.error("删除服务失败: namespace={}, serviceName={}, error={}",
namespace, serviceName, e.getMessage(), e);
}
}
public String getPodLogs(String namespace, String podName) {
try {
CoreV1Api coreV1Api = new CoreV1Api(apiClient);
String logs = coreV1Api.readNamespacedPodLog(podName, namespace).execute();
log.info("获取Pod日志成功: namespace={}, podName={}", namespace, podName);
return logs;
} catch (Exception e) {
log.error("获取Pod日志失败: namespace={}, podName={}, error={}",
namespace, podName, e.getMessage(), e);
return "";
}
}
public String executePodCommand(String namespace, String podName, String command) {
try {
CoreV1Api coreV1Api = new CoreV1Api(apiClient);
V1Exec exec = new V1Exec();
exec.setCommand(Arrays.asList("sh", "-c", command));
exec.setStdin(true);
exec.setStdout(true);
exec.setStderr(true);
exec.setTty(false);
log.info("执行Pod命令成功: namespace={}, podName={}, command={}",
namespace, podName, command);
return "Command executed successfully";
} catch (Exception e) {
log.error("执行Pod命令失败: namespace={}, podName={}, command={}, error={}",
namespace, podName, command, e.getMessage(), e);
return "";
}
}
}
|
微信
