java - 如何将输入传递到 Kubernetes 容器内的 Java 应用程序？

Question

我已配置在 AWS EKS 上托管的 Kubernetes 服务(LoadBalancer 类型)。该服务的 Pod 以交互模式运行(这是在 Pod 中运行容器所必需的)。其中的容器正在运行一个简单的 Java .jar 应用程序，该应用程序接收输入并根据输入生成输出。

问题:如何将输入传递到 Kubernetes 容器内的 Java 应用程序？

以下是 Pod 的 yaml 配置部分，可确保其以交互模式运行:

spec:
  containers:
  - image: ardulat/mckinsey
    imagePullPolicy: Always
    name: anuar-mckinsey
    ports:
    - containerPort: 8080
      name: http
      protocol: TCP
    stdin: true
    tty: true

Pod 已启动并正在运行。正如您从配置中看到的，它接收 TCP 连接。

这是 Pod 的服务:

NAME             TYPE           CLUSTER-IP       EXTERNAL-IP                                                               PORT(S)          AGE
anuar-mckinsey   LoadBalancer   10.100.239.207   a8154210d09da11ea9c3806983848f2f-1085657314.us-east-2.elb.amazonaws.com   8080:32516/TCP

通过查看从容器中的 Java 应用程序输出打印消息的 pod 日志，我可以确保 pod 和服务配置正确。

已经尝试过:

• 以详细模式 curl 应用程序，生成:

*   Trying 18.190.142.22...
* TCP_NODELAY set
* Connected to a8154210d09da11ea9c3806983848f2f-1085657314.us-east-2.elb.amazonaws.com (18.190.142.22) port 8080 (#0)
> GET / HTTP/1.1
> Host: a8154210d09da11ea9c3806983848f2f-1085657314.us-east-2.elb.amazonaws.com:8080
> User-Agent: curl/7.63.0
> Accept: */*
>
* Empty reply from server
* Connection #0 to host a8154210d09da11ea9c3806983848f2f-1085657314.us-east-2.elb.amazonaws.com left intact
curl: (52) Empty reply from server

• 通过 netcat 以详细模式进行连接，生成输出:

found 1 connections:
     1: flags=82<CONNECTED,PREFERRED>
    outif en0
    src 172.20.22.204 port 51144
    dst 18.190.142.22 port 8080
    rank info not available
    TCP aux info available

Connection to a8154210d09da11ea9c3806983848f2f-1085657314.us-east-2.elb.amazonaws.com port 8080 [tcp/http-alt] succeeded!

最终想法:看来配置是正确的，并且服务在 AWS EKS 托管的集群上运行。日志产生正确的输出。但是，我无法将消息(通过 TCP 连接？)发送到容器内的 Java 应用程序。关于如何将输入传递给它有什么想法吗？

Answer 1

根据评论中的讨论，信息是Java应用程序使用System.in接收输入。这通常相当于 stdin .

将输入发送到容器中的应用程序并获取输出的方法是 attaching以原始终端模式连接到容器中的进程，该进程连接本地 stdin和stdout与容器的:

kubectl -n <namespace> attach <pod-name> -c <container-name> -i -t

关于如何从外部访问应用程序而不直接访问 pod 以及使用服务的附加问题，我建议:

• 更改应用程序，使其创建 ServerSocket监听并接受特定端口号的连接。
• 从套接字的输入流中读取各个行并对其进行处理，就像输入来自 System.in 一样.
• 将结果写入套接字的输出流。
• 像您已经拥有的那样，通过 LoadBalancer Kubernetes 服务公开端口。

This here可能是新代码的一个很好的起点。您可以使用telnet 127.0.0.1 <port>或curl telnet://127.0.0.1:<port>/在本地测试应用程序以及不在容器中运行应用程序时。

在我看来，公开基于 HTTP 的服务对于这个应用程序来说似乎有点过分了。