From a45f7b9f3af78f31e7e3eff7baccde98f433ec1a Mon Sep 17 00:00:00 2001 From: kedong Date: Mon, 15 Nov 2021 09:27:41 +0800 Subject: [PATCH] Create WebSocketExamples --- .../client/examples/WebSocketExamples | 23 +++++++++++++++++++ 1 file changed, 23 insertions(+) create mode 100644 examples/examples-release-13/src/main/java/io/kubernetes/client/examples/WebSocketExamples diff --git a/examples/examples-release-13/src/main/java/io/kubernetes/client/examples/WebSocketExamples b/examples/examples-release-13/src/main/java/io/kubernetes/client/examples/WebSocketExamples new file mode 100644 index 0000000000..1985e94218 --- /dev/null +++ b/examples/examples-release-13/src/main/java/io/kubernetes/client/examples/WebSocketExamples @@ -0,0 +1,23 @@ +final ApiClient client = Config.fromConfig("/root/.kube/config"); +Exec exec = new Exec(client); +Process proc = exec.exec(namespace,podname,execCommand,"",true,true) + +InputStream inputStream = proc.getInputStream(); +try { + byte[] buffer = new byte[1024]; + int i = 0; + while ((i=inputStream.read(buffer)) != -1) { + sendMessage(webSocket, Arrays.copyOfRange(buffer, 0, i));// websocket.send(new String(buffer)); + } +} catch (Exception e) { + +} + +//将消息转发到终端 +private void transToPod(Process process, String command) { + if (process != null) { + OutputStream outputStream = process.getOutputStream(); + outputStream.write(command.getBytes()); + outputStream.flush(); + } +}