kubectlproxy加token验证-创新互联
kubectl proxy 加token 验证
proxy 不支持token加验证,只能再封装了一层代理,进行加验证。
为柳林等地区用户提供了全套网页设计制作服务,及柳林网站建设行业解决方案。主营业务为网站建设、成都网站设计、柳林网站设计,以传统方式定制建设网站,并提供域名空间备案等一条龙服务,秉承以专业、用心的态度为用户提供真诚的服务。我们深信只要达到每一位用户的要求,就会得到认可,从而选择与我们长期合作。这样,我们也可以走得更远!
开启代理
kubectl proxy --port=8089 --address=127.0.0.1 --accept-hosts='^*$' # 后面这个可以去掉,不用允许所有
代码
mkdir go-proxy
cd go-proxy
go mod init go-proxy
vim main.go
package main
import (
"bytes"
"fmt"
"github.com/ouqiang/goproxy"
"io/ioutil"
"log"
"net"
"net/http"
"net/url"
"strings"
"time"
)
type EventHandler struct{}
func (e *EventHandler) Connect(ctx *goproxy.Context, rw http.ResponseWriter) {
}
func (e *EventHandler) Auth(ctx *goproxy.Context, rw http.ResponseWriter) {
}
func (e *EventHandler) BeforeRequest(ctx *goproxy.Context) {
if clientIP, _, err := net.SplitHostPort(ctx.Req.RemoteAddr); err == nil {
if prior, ok := ctx.Req.Header["X-Forwarded-For"]; ok {
clientIP = strings.Join(prior, ", ") + ", " + clientIP
}
ctx.Req.Header.Set("X-Forwarded-For", clientIP)
}
// 读取Body
body, err := ioutil.ReadAll(ctx.Req.Body)
if err != nil {
// 错误处理
return
}
if ctx.Req.Header.Get("token") != "1234" {
fmt.Println("没有权限,禁止登录")
ctx.Abort()
return
}
// Request.Body只能读取一次, 读取后必须再放回去
// Response.Body同理
ctx.Req.Body = ioutil.NopCloser(bytes.NewReader(body))
}
func (e *EventHandler) BeforeResponse(ctx *goproxy.Context, resp *http.Response, err error) {
if err != nil {
return
}
// 修改response
}
// 设置上级代理
func (e *EventHandler) ParentProxy(req *http.Request) (*url.URL, error) {
return url.Parse("http://127.0.0.1:8089")
}
func (e *EventHandler) Finish(ctx *goproxy.Context) {
log.Printf("请求结束 URL:%s\n", ctx.Req.URL)
}
// 记录错误日志
func (e *EventHandler) ErrorLog(err error) {
log.Println(err)
}
func main() {
proxy := goproxy.New(goproxy.WithDelegate(&EventHandler{}))
server := &http.Server{
Addr: ":8000",
Handler: proxy,
ReadTimeout: 1 * time.Minute,
WriteTimeout: 1 * time.Minute,
}
err := server.ListenAndServe()
if err != nil {
panic(err)
}
}
go run main.go
注意
主要修改的地方有2个
if ctx.Req.Header.Get("token") != "1234" { 这里是输入你的token密码
return url.Parse("http://127.0.0.1:8089") 这里是你本地的 proxy 接口
请求
请求头 添加 token : 1234
另外有需要云服务器可以了解下创新互联cdcxhl.cn,海内外云服务器15元起步,三天无理由+7*72小时售后在线,公司持有idc许可证,提供“云服务器、裸金属服务器、高防服务器、香港服务器、美国服务器、虚拟主机、免备案服务器”等云主机租用服务以及企业上云的综合解决方案,具有“安全稳定、简单易用、服务可用性高、性价比高”等特点与优势,专为企业上云打造定制,能够满足用户丰富、多元化的应用场景需求。
网站名称:kubectlproxy加token验证-创新互联
链接地址:http://scyanting.com/article/pjppe.html