我正在使用 fabric8.io 在 Kubernetes 中编排应用程序容器。我正在寻找一个服务来管理在某个端口上具有某个标签的 pod。是否有执行此操作的 API 的特定示例。我在示例中找不到它
似乎没有可用的 javadocs???
【问题讨论】：
标签： java service kubernetes fabric8
Fabric8 的 Kubernetes 客户端使用生成的模型和 DSL，其结构与 JSON 和 YAML 配置完全相同。
所以为了创建一个看起来像这样的服务实例：
{
"kind": "Service",
"apiVersion": "v1",
"metadata": {
"name": "myservice"
},
"spec": {
"ports": [
{
"protocol": "TCP",
"port": 80,
"targetPort": 8080,
}
],
"selector": {
"key": "value1",
},¬
"portalIP": "172.30.234.134",
"type": "ClusterIP",
}
}
您可以使用以下代码：
Service service = new ServiceBuilder()
.withNewMetadata()
.withName("myservice")
.endMetadata()
.withNewSpec()
.addNewPort()
.withProtocol("TCP")
.withPort(80)
.withNewTargetPort(8080)
.endPort()
.addToSelector("key1", "value1")
.withPortalIP("172.30.234.134")
.withType("ClusterIP")
.endSpec()
.build();
如果不需要保存服务对象的引用而只想创建它，则可以像这样内联它：
client.services().createNew()
.withNewMetadata()
.withName("myservice")
.endMetadata()
.withNewSpec()
.addNewPort()
.withProtocol("TCP")
.withPort(80)
.withNewTargetPort(8080)
.endPort()
.addToSelector("key1", "value1")
.withPortalIP("172.30.234.134")
.withType("ClusterIP")
.endSpec()
.done();
它比 JSON 等价物更加紧凑，因为可以提交默认值，并且选择器之类的一些东西可以选择性地内联在一行中。
这不仅适用于服务，也适用于每一个 Kubernetes/Openshift 资源。
如果您有 JSON 或 YAML，您可以通过向客户端提供输入流来轻松加载它们：
Service service = client.services().load(inputStream).get();
这里有更多选项，比如直接创建服务：
Service newService = client.services().load(inputStream).create();
无论语言、格式如何，记住结构总是相同的总是有帮助的。几乎所有内容都可以内联，因此 IDE 中的选项卡补全功能非常有用。
【讨论】：
我使用的是同一个库，你是对的，创建部门的文档有点缺乏。我不得不使用 Eclipse 手动探索 API，因为我也找不到任何解释。以下是它的工作原理。
KubernetesClient client = new KubernetesClient(masterURL);
Service serv = (Service) KubernetesHelper.loadJson(serviceJson);
Service result = client.services().create(serv);
所以基本上，您使用 KubernetesClient 来创建所有对象。它将具有每个对象的方法（服务、复制控制器等），以及与它们相关的任何操作。第二行将您的服务定义文件或字符串加载到服务对象中。然后使用客户端在 Kubernetes 中创建对象。
KubernetesHelper 对象可以加载 yaml 或 json。您还可以使用 ServiceBuilder 对象以编程方式构建它。
编辑：在回顾标记为 kubernetes 的答案后，我在一个问题中发现了这一点，问的问题基本相同：example to deploy docker image on kubernetes from java
【讨论】：
如果你不知道你正在创建的资源类型（pod、服务、部署等），那么你可以使用
client.load(inputStream).createOrReplaceAnd();
它将创建或更新已创建的资源。
注意： 如果您在单个 yaml 文件中定义要创建的多个资源并使用最新的 kubernetes 客户端，您将只能创建第一个资源。
使用 kubernetes 仪表板或 kubectl，您应该能够创建在同一个 yaml 文件中列出的多个资源。
【讨论】：