K8S实战：部署一个获取 HTTP Header 程序到 K8S

通过实战能更好的理解 K8S、istio，这里将开发一个 golang 程序，将其部署到 K8S中，并通过 istio 做流量调度。

操作路径：使用 Golang 开发 -> 编译为 Golang -> 构建 Docker 镜像 -> 创建 Deployment 和 Service -> 创建 Gateway -> 创建 Virtual Service

本次实战会使用服务网格作为流量管理。（如果你没有开通服务网格，可以替换为 Ingress）

前置条件

腾讯云容器服务
镜像仓库
腾讯云容器服务服务网格
包含 Docker 环境的电脑，小编的是一台Mac，安装了 Mac 版 Docker
本地 golang 环境

先看一下效果

访问 dhcp.cn/header/ 查看当前 HTTP Header

GET 请求示例

代码语言：txt复制

$ curl   https://dhcp.cn/header/
UserAgent: curl/7.64.1 
Protocol: HTTP/1.1
Method: GET
Host: dhcp.cn
RemoteAddr: 192.168.31.125:56672
RequestURI: /header/
Header: map[Accept:[*/*] User-Agent:[curl/7.64.1]]
Body:
X-Forwarded-For:
Accept: */*

POST 请求示例

代码语言：txt复制

$ curl -XPOST -H 'X-Forwarded-For: 192.168.1.1' -H "content-Type: application/JSON"  https://dhcp.cn/header/ -d '{"age": 22}'
UserAgent: curl/7.64.1
Protocol: HTTP/1.1
Method: POST
Host: dhcp.cn
RemoteAddr: 192.168.31.125:56028
RequestURI: /header/
Header: map[Accept:[*/*] Content-Length:[11] Content-Type:[application/JSON] User-Agent:[curl/7.64.1] X-Forwarded-For:[192.168.1.1]]
Body: {"age": 22}
X-Forwarded-For: 192.168.1.1
Accept: */*

话不多说，实战干起来。

1. 使用 Golang 编写一个获取 HTTP Header 的服务。

1.1 代码

以下是一个完整的基于 Golang 实现的 HTTP Server，打印 HTTP Header。

代码语言：txt复制

package main

import (
	"fmt"
	"io/ioutil"
	"log"
	"net/http"
)

func main() {

	http.HandleFunc("/", func(w http.ResponseWriter, r *http.Request) {

		body, _ := ioutil.ReadAll(r.Body) // 获取 Body，因为 r.Body 的类型是 io.ReadCloser，而不是 string

		fmt.Fprintf(w, "UserAgent: %sn", r.UserAgent())                         // 示例：curl/7.64.1，r.UserAgent() 是字符串，直接打印即可
		fmt.Fprintf(w, "Protocol: %sn", r.Proto)                                // 示例：HTTP/1.1
		fmt.Fprintf(w, "Method: %sn", r.Method)                                 // 示例：GET
		fmt.Fprintf(w, "Host: %sn", r.Host)                                     // 示例：192.168.31.125，请求主机
		fmt.Fprintf(w, "RemoteAddr: %sn", r.RemoteAddr)                         // 示例：192.168.31.125:54642，客户端地址（如果用了负载均衡器，请通过 X-Forwarded-For 来获取客户端真实IP）
		fmt.Fprintf(w, "RequestURI: %sn", r.RequestURI)                         // 示例：/mall，请求URI
		fmt.Fprintf(w, "Header: %sn", r.Header)                                 // 示例：map[Accept:[*/*] Content-Length:[11] Content-Type:[application/JSON] User-Agent:[curl/7.64.1] X-Forwarded-For:[192.168.1.1]]
		fmt.Fprintf(w, "Body: %sn", body)                                       // 示例：{"age": 22}，例如POST 请求的 Body
		fmt.Fprintf(w, "X-Forwarded-For: %sn", r.Header.Get("X-Forwarded-For")) // 示例：192.168.1.1，自定义Header，一般有负载均衡器的场景会把客户端的真实IP存储在这里
		fmt.Fprintf(w, "Accept: %sn", r.Header.Get("Accept"))                   // 示例：*/*

	})

	log.Println("Starting server ...")
	log.Fatal(http.ListenAndServe(":80", nil))
}

1.2 编译测试

代码语言：txt复制

$ go build  print-header.go
$ ./print-header
2021/03/20 08:52:55 Starting server ...
$ curl localhost
UserAgent: curl/7.64.1
Protocol: HTTP/1.1
Method: GET
Host: localhost:80
RemoteAddr: [::1]:64838
RequestURI: /
Header: map[Accept:[*/*] User-Agent:[curl/7.64.1]]
Body:
X-Forwarded-For:
Accept: */*

1.3 编译在 Linux 下运行的程序

由于程序将运行在 Linux 镜像内，在Mac下编译时需要指定运行环境的架构和操作系统。

代码语言：txt复制

$ CGO_ENABLED=0 GOOS=linux GOARCH=amd64 go build  print-header.go

2. 构建 Docker 镜像

2.1 编写 dockerfile

代码语言：txt复制

FROM alpine:3.13.2  ## 很小的一个镜像，只有几MB。
WORKDIR /print-header/ ## 镜像中程序的工作路径
ADD print-header . ## 将当前目录的 print-header 程序添加到上面的工作路径中
EXPOSE 80  ## 对外暴露 80 端口
CMD ["/print-header/print-header", "-g", "daemon off;"]  ## 镜像启动时加载程序运行

2.2 构建镜像

代码语言：txt复制

$ docker build -t print-header:0.01 .

代码语言：txt复制

$ docker images 
REPOSITORY                                          TAG                                                     IMAGE ID       CREATED         SIZE
print-header                                        0.01                                                    7e67ffe991dd   3 weeks ago     15.8MB

2.3 推送镜像

这里是使用腾讯云的镜像仓库

代码语言：txt复制

$ docker tag print-header:0.01 ccr.ccs.tencentyun.com/<YOUR_DOCKER_NAESPACE>/print-header:0.01
$ docker push ccr.ccs.tencentyun.com/<YOUR_DOCKER_NAESPACE>/print-header:0.01