如何基于与K8s中的Pod的交互获得用户的IP

问题描述

我想基于用户(客户端)与Pod的交互来获取其IP,(我正在考虑获取用户IP并根据其IP定位他)

我制作了下图,以更好地解释我的问题, 我唯一能找到可能改善这种情况的方法就是修补服务,并将externalTrafficPolicy设置为“ Local”,以便该服务保留用户的IP。

但是仍然不确定应该如何检查用户的IP,或者甚至应该检查用户的IP。是否可以从Pod外部监视用户的活动?有什么主意吗?

(我正在使用golang)

k8s cluster with NodePort as a service

更新:更明确地说,我不是在创建Pod,在以下情况下,客户负责并且可以创建不同的Pod和容器,甚至是他们需要的服务,就像测试一样-床,所以我不能编辑他们的容器文件,但是我可以在他们的容器旁边调出另一个容器,然后使用此帖子的https://stackoverflow.com/a/27971761/9350055来查找客户端的IP。您认为这行得通吗?

tiny container- two container in a single pod

解决方法

当然可以,但是请记住,您只会在具有用于特定服务的Pod的节点上接收流量(在您的情况下为 Service NodePort )。

如果您正在使用Golang

Image1

现在,这应该适用于L4或L7流量。如果您使用的是Golang,请参见X-Forwarded-For HTTP标头:

package main

import (
    "encoding/json"
    "net/http"
)

func main() {
    http.HandleFunc("/",ExampleHandler)
    if err := http.ListenAndServe(":8080",nil); err != nil {
        panic(err)
    }
}

func ExampleHandler(w http.ResponseWriter,r *http.Request) {
    w.Header().Add("Content-Type","application/json")
    resp,_ := json.Marshal(map[string]string{
        "ip": GetIP(r),})
    w.Write(resp)
}

// GetIP gets a requests IP address by reading off the forwarded-for
// header (for proxies) and falls back to use the remote address.
func GetIP(r *http.Request) string {
    forwarded := r.Header.Get("X-FORWARDED-FOR")
    if forwarded != "" {
        return forwarded
    }
    return r.RemoteAddr
}

还有here's an example of how to get for L4 services (TCP)

✌️