Golang Kubernetes Ingress路由管理示例

答案：使用Golang通过client-go库操作Kubernetes Ingress资源，可实现创建、查询和删除Ingress规则，适用于自动化路由管理。

在 Kubernetes 中，Ingress 是管理外部访问集群内服务的重要方式，通常用于 HTTP/HTTPS 路由。使用 Golang 可以编写自定义控制器或工具来动态管理 Ingress 资源。下面是一个简单的示例，展示如何使用 Golang 操作 Kubernetes Ingress 资源。

环境准备与依赖引入

要操作 Kubernetes API，我们需要使用官方的 client-go 库。先初始化项目并添加依赖：

go mod init ingress-manager
go get k8s.io/client-go/kubernetes
go get k8s.io/client-go/rest
go get k8s.io/client-go/tools/clientcmd

确保你的 kubeconfig 文件位于 ~/.kube/config，或通过环境变量指定路径。

连接 Kubernetes 集群

使用以下代码连接到集群，支持 in-cluster 和本地开发模式：

立即学习“go语言免费学习笔记（深入）”；

package main
import (
“context”
“fmt”
“path/filepath”
“k8s.io/client-go/kubernetes”
“k8s.io/client-go/rest”
“k8s.io/client-go/tools/clientcmd”
“k8s.io/client-go/util/homedir”
)
func getKubernetesClient() (*kubernetes.Clientset, error) {
var config *rest.Config
var err error
// 尝试使用 in-cluster 配置（Pod 内运行）
config, err = rest.InClusterConfig()
if err != nil {
// 回退到本地 kubeconfig
home := homedir.HomeDir()
kubeconfig := filepath.Join(home, “.kube”, “config”)
config, err = clientcmd.BuildConfigFromFlags(“”, kubeconfig)
if err != nil {
return nil, err
}
}
return kubernetes.NewForConfig(config)
}

创建和管理 Ingress 资源

下面是一个创建简单 Ingress 的示例，将域名 example.com 映射到服务 my-service 的 80 端口：

乾坤圈新媒体矩阵管家

新媒体账号、门店矩阵智能管理系统

17

查看详情

import (
“context”
“time”
networkingv1 “k8s.io/api/networking/v1”
metav1 “k8s.io/apimachinery/pkg/apis/meta/v1”
)
func createIngress(client *kubernetes.Clientset) error {
ingress := &networkingv1.Ingress{
ObjectMeta: metav1.ObjectMeta{
Name: “example-ingress”,
Namespace: “default”,
Annotations: map[string]string{
“nginx.ingress.kubernetes.io/rewrite-target”: “/”,
},
},
Spec: networkingv1.IngressSpec{
IngressClassName: &[]string{“nginx”}[0],
Rules: []networkingv1.IngressRule{
{
Host: “example.com”,
IngressRuleValue: networkingv1.IngressRuleValue{
HTTP: &networkingv1.HTTPIngressRuleValue{
Paths: []networkingv1.HTTPIngressPath{
{
Path: “/”,
PathType: (*networkingv1.PathType)(pointer.StringPtr(“Prefix”)),
Backend: networkingv1.IngressBackend{
Service: &networkingv1.IngressServiceBackend{
Name: “my-service”,
Port: networkingv1.ServiceBackendPort{Number: 80},
},
},
},
},
},
},
},
},
},
}
_, err := client.NetworkingV1().Ingresses(“default”).Create(
context.TODO(),
ingress,
metav1.CreateOptions{},
)
return err
}
// 辅助函数：生成指针
func pointer(s string) *string { return &s }

调用方式：

func main() {
client, err := getKubernetesClient()
if err != nil {
panic(err)
}
if err := createIngress(client); err != nil {
panic(err)
}
fmt.Println(“Ingress 创建成功”)
}

查询和删除 Ingress

你可以通过 List 获取所有 Ingress，或 Get 获取特定资源：

// 列出 default 命名空间下的 Ingress
ingresses, err := client.NetworkingV1().Ingresses(“default”).List(
context.TODO(),
metav1.ListOptions{},
)
if err != nil {
panic(err)
}
for _, ing := range ingresses.Items {
fmt.Printf(“Host: %s, Name: %s\n”, ing.Spec.Rules[0].Host, ing.Name)
}
// 删除 Ingress
err = client.NetworkingV1().Ingresses(“default”).Delete(
context.TODO(),
“example-ingress”,
metav1.DeleteOptions{},
)
if err != nil {
panic(err)
}
fmt.Println(“Ingress 删除成功”)

基本上就这些。通过 Golang 结合 client-go，你可以实现自动化的 Ingress 管理，比如配合 CI/CD 动态更新路由、实现多租户子域名分配等场景。