http.handlefunc不起作用

Question

我正在处理一个在Google Cloud上托管在Kubernetes上的应用程序，它使用Ingress来管理每个服务的路由，然后在每个服务中使用Golang。P>

我的问题是：当我尝试将API请求发送到/api/auth/healthz时，我希望我能达到statusHandler()函数，而是我总是点击requestHandler()函数，即使我有一个http.handlefunc： http.HandleFunc("/healthz", statusHandler)

这是我的代码

func main() {
    flag.Parse()
    // initialize the "database"
    err := store.Initialise()
    if err != nil {
        glog.Error(err)
        glog.Error("Store failed to initialise")
    }
    defer store.Uninitialise()
    // Initialize the default TTL for JWT access tokens to 1 day
    tokenTTL = 24 * time.Hour
    glog.Infof("JWT access tokens time-to-live set to: %s", tokenTTL.String())
    http.HandleFunc("/healthz", statusHandler)
    http.HandleFunc("/", requestHandler)
    glog.Infof("Authentication service started on port 8080...n")
    http.ListenAndServe(":8080", nil)
}
func statusHandler(w http.ResponseWriter, r *http.Request) {
    glog.Infof("Reached the status handler")
    statusObj := serviceStatus{
        GitSHA:         os.Getenv("GIT_SHA"),
        BuildTimestamp: os.Getenv("BUILD_TIMESTAMP"),
        DeployEnv:      os.Getenv("DEPLOY_ENV"),
    }
    statusJSON, _ := json.Marshal(statusObj)
    w.Header().Set("Content-Type", "application/json")
    fmt.Fprintf(w, "%s", statusJSON)
}
func requestHandler(w http.ResponseWriter, r *http.Request) {
    glog.Infof("Reached the request handler")
    ...
}

这是我的入口代码：

apiVersion: extensions/v1beta1
kind: Ingress
metadata:
  # https://github.com/kubernetes/ingress-nginx/blob/master/docs/user-guide/annotations.md
  annotations:
    kubernetes.io/ingress.class: nginx
    certmanager.k8s.io/cluster-issuer: letsencrypt-staging
    nginx.ingress.kubernetes.io/enable-cors: "false"
    nginx.ingress.kubernetes.io/cors-enable-origin: "*"
    nginx.ingress.kubernetes.io/auth-type: "basic"
    nginx.ingress.kubernetes.io/auth-secret: "ci-ingress-auth"
    nginx.ingress.kubernetes.io/proxy-body-size: "4g"
  name: ci-api-ingress
  namespace: ci
spec:
  rules:
  - host: ci.omitted.io
    http:
      paths:
      - backend:
          serviceName: auth-service << This is the service I am working on
          servicePort: 8080
        path: /api/auth
      - backend:
          serviceName: data-import-service
          servicePort: 8080
        path: /api/data-import
      - backend:
          serviceName: log-service
          servicePort: 8080
        path: /api/log
      - backend:
          serviceName: project-service
          servicePort: 8080
        path: /api/project
      - backend:
          serviceName: orchestration-service
          servicePort: 8080
        path: /api/orchestration
      - backend:
          serviceName: public
          servicePort: 80
        path: /

---

基于Kubernetes的文档，该文档应像我的实现相似：

http.HandleFunc("/healthz", func(w http.ResponseWriter, r *http.Request) {
    duration := time.Now().Sub(started)
    if duration.Seconds() > 10 {
        w.WriteHeader(500)
        w.Write([]byte(fmt.Sprintf("error: %v", duration.Seconds())))
    } else {
        w.WriteHeader(200)
        w.Write([]byte("ok"))
    }
})

Answer 1

基于您的入口规则，请求的路径应为： /api/auth/healthz 不是/api/auth-service/healthz

入口路径/api/auth/保存在请求URI中的请求URI中。

将rewrite-target添加到入学注释中，将确保路径被传递给您的基础服务器，如您所期望的，例如作为/<path>而不是/api/auth/<path>。检查应用程序服务器日志应该显示这种情况。

ingress.kubernetes.io/rewrite-target: /