专栏首页k8s_istioK8S实战:部署一个获取 HTTP Header 程序到 K8S
原创

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

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

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

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

前置条件

先看一下效果

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

GET 请求示例

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

POST 请求示例

$ curl -XPOST -H 'X-Forwarded-For: 192.168.1.1' -H "content-Type: application/JSON"  header.dhcp.cn/mall -d '{"age": 22}'
UserAgent: curl/7.64.1
Protocol: HTTP/1.1
Method: POST
Host: header.dhcp.cn
RemoteAddr: 192.168.31.125:56028
RequestURI: /mall
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。

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: %s\n", r.UserAgent())                         // 示例:curl/7.64.1,r.UserAgent() 是字符串,直接打印即可
		fmt.Fprintf(w, "Protocol: %s\n", r.Proto)                                // 示例:HTTP/1.1
		fmt.Fprintf(w, "Method: %s\n", r.Method)                                 // 示例:GET
		fmt.Fprintf(w, "Host: %s\n", r.Host)                                     // 示例:192.168.31.125,请求主机
		fmt.Fprintf(w, "RemoteAddr: %s\n", r.RemoteAddr)                         // 示例:192.168.31.125:54642,客户端地址(如果用了负载均衡器,请通过 X-Forwarded-For 来获取客户端真实IP)
		fmt.Fprintf(w, "RequestURI: %s\n", r.RequestURI)                         // 示例:/mall,请求URI
		fmt.Fprintf(w, "Header: %s\n", 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: %s\n", body)                                       // 示例:{"age": 22},例如POST 请求的 Body
		fmt.Fprintf(w, "X-Forwarded-For: %s\n", r.Header.Get("X-Forwarded-For")) // 示例:192.168.1.1,自定义Header,一般有负载均衡器的场景会把客户端的真实IP存储在这里
		fmt.Fprintf(w, "Accept: %s\n", r.Header.Get("Accept"))                   // 示例:*/*

	})

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

1.2 编译测试

$ 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下编译时需要指定运行环境的架构和操作系统。

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

2. 构建 Docker 镜像

2.1 编写 dockerfile

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 构建镜像

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

2.3 推送镜像

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

$ 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

3. 创建 Deployment 和 Service

注意几个重点参数即可,选择镜像地址

创建 Deployment
创建 Service

服务访问方式:VPC内网访问,因为 HTTP 服务一般不直接以 Service 直接对外提供访问入口,而是通过 Ingress 或 Istio(服务网格)。

4. 创建 Gateway

如果没有开通服务网格功能,可以把接下来的两个步骤替换为 Ingress

将域名解析到 istio-ingressgateway 所绑定的 负载均衡器 IP。

创建流量入口,放行指定HTTP 请求为指定 HOSTs、指定端口 (即 80)的流量。

创建 Gateway

5. 创建 Virtual Service

创建流量规则,这里先使用默认的。

如果想将 curl 等后台程序 和 浏览器的流量分开,可以参考这篇文章 istio virtualservice:使用正则过滤流量

注意 关联Hosts挂载Gateway 设置一定要正确。

创建 Virtual Service

6. 使用效果

在电脑上请求服务,可以看到服务网格的数据。

服务网格基本信息
监控
调用追踪

是不是很有意思,留言区说下你成功了吗~

reference

原创声明,本文系作者授权云+社区发表,未经许可,不得转载。

如有侵权,请联系 yunjia_community@tencent.com 删除。

我来说两句

0 条评论
登录 后参与评论

相关文章

  • ASP.NET Core on K8S深入学习(14)Ingress灰度发布

    本篇已加入《.NET Core on K8S学习实践系列文章索引》,可以点击查看更多容器化技术相关系列文章。

    Edison Zhou
  • EggJS 云原生应用硬核实战(Kubernetes+Traefik+Helm+Prometheus+Grafana)

    这是一个关于 Egg.js 应用上云☁️的示例,笔者所在的大前端团队的已应用于生产。

    为少
  • K8S Ingress环境下,Http Redirect端口丢失问题

    近日发现一个问题:应用程序在返回Http Redirect的时候丢失了原先访问的端口。比如,我们这样访问http://IP-A:Port-A/app/delet...

    颇忒脱
  • Sentry(v20.12.1) K8S 云原生架构探索,JavaScript 性能监控之管理 Transactions

    @sentry/tracing 包提供了一个 BrowserTracing 集成,以添加 automatic instrumentation 来监视浏览器应用程...

    为少
  • Kubernetes官方java客户端之四:内部应用

    至此,SpringBoot应用通过K8S官方java客户端,成功获取了自身所在K8S环境的信息,通过前文和本章,咱们对K8S官方java客户端已经有了基本的认识...

    程序员欣宸
  • 从0到1搭建k8s(四)——深入探索Pod

    如果读者已经按照前文的内容走下来,那么应该能够对k8s有一个非常基础的了解,即如何搭建环境,如何拉起一个容器,如何访问一个容器,这些操作都是我们想要往k8s部署...

    点点寒彬
  • Kubernetes容器集群管理环境 - Prometheus监控篇

    一、Prometheus介绍 之前已经详细介绍了Kubernetes集群部署篇,今天这里重点说下Kubernetes监控方案-Prometheus+Grafan...

    洗尽了浮华
  • 解决 Kubernetes 部署 Metrics Server 无法访问 Apiserver 问题

    通过二进制方式部署完成 kubernetes 后,部署 Metrics Server 后,查看日志出现下面错误信息:

    米开朗基杨
  • kubernetes系列教程(二十)prometheus提供完备监控系统

    上一个章节中kubernetes系列教程(十九)使用metric-server让HPA弹性伸缩愉快运行介绍了在kubernetes中的监控架构,通过安装和使用m...

    HappyLau谈云计算

扫码关注云+社区

领取腾讯云代金券