当前位置：首页 > 文章列表 > Golang > Go教程 > Golang Kubernetes Ingress路由管理示例

Golang Kubernetes Ingress路由管理示例

2025-12-21 14:03:13 0浏览收藏

推广推荐

支持 PC / 移动端，安全直达

golang学习网今天将给大家带来《Golang Kubernetes Ingress路由管理示例》，感兴趣的朋友请继续看下去吧！以下内容将会涉及到等等知识点，如果你是正在学习Golang或者已经是大佬级别了，都非常欢迎也希望大家都能给我建议评论哈~希望能帮助到大家！

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

Golang Kubernetes 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 和本地开发模式：

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 端口：

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 动态更新路由、实现多租户子域名分配等场景。

今天关于《Golang Kubernetes Ingress路由管理示例》的内容就介绍到这里了，是不是学起来一目了然！想要了解更多关于的内容请关注golang学习网公众号！