k8s 上 go 微服务实战: go 实现 istio bookinfo 微服务

简介: 在完成 `k8s 上快速部署 go 服务` 和 `k8s: istio 入门` 后, 继续 **膨胀**, 使用 go 来实现 istio 提供的 bookinfo 微服务 demo

在完成 `k8s 上快速部署 go 服务` 和 `k8s: istio 入门` 后, 继续 **膨胀**, 使用 go 来实现 istio 提供的 bookinfo 微服务 demo


快速回顾之前的 blog:


- [k8s 上 go 服务实战: 扩容 发版更新 回滚 平滑重启](https://zhuanlan.zhihu.com/p/248866126 "k8s 上 go 服务实战: 扩容 发版更新 回滚 平滑重启")

- [k8s 上 go 服务实战: 使用 helm 快速构建云原生应用](https://zhuanlan.zhihu.com/p/251261134 "k8s 上 go 服务实战: 使用 helm 快速构建云原生应用")

- [k8s: istio 入门实践](https://zhuanlan.zhihu.com/p/258104456 "k8s: istio 入门实践")


涉及到的问题:


- [istio bookinfo demo](https://istio.io/latest/zh/docs/examples/bookinfo/#start-the-application-services "istio bookinfo demo")

- [istio task](https://istio.io/latest/zh/docs/tasks/traffic-management/request-routing/ "istio task")


简单实践步骤:


- 使用 go 重写 bookinfo 微服务并部署到 k8s 中

- 基于 go 版 bookinfo 微服务, 验证 istio task


## 使用 go 重写 bookinfo 微服务并部署到 k8s 中


先回顾一下 bookinfo 微服务应用的端到端架构:


![image](https://upload-images.jianshu.io/upload_images/567399-f369d202d827fff3.jpg?imageMogr2/auto-orient/strip%7CimageView2/2/w/1240)


包含 4 个微服务:


- rating: 书籍评分

- review: 书籍评价, 有 v1/v2/v3 三个版本, 其中 v2/v3 需要调用 `rating` 服务

- detail: 书籍详情

- productpage: 书籍产品页面, 需要调用 `review + detail` 服务


### 实现 rating 服务


可以参考 [k8s 上 go 服务实战: 使用 helm 快速构建云原生应用](https://zhuanlan.zhihu.com/p/251261134 "k8s 上 go 服务实战: 使用 helm 快速构建云原生应用") 快速部署 rating 服务


- go


```go

// rating/main.go

package main


import (

   "fmt"

   "net/http"

)


func main() {

   http.HandleFunc("/", func(writer http.ResponseWriter, request *http.Request) {

       fmt.Fprintf(writer, "rating")

   })

   http.ListenAndServe(":80", nil)

}

```


- dockerfile


```dockerfile

FROM golang:alpine as builder

WORKDIR /

COPY main.go .

RUN go build -o app main.go


FROM alpine

WORKDIR /

COPY --from=builder /app /app

ENTRYPOINT /app

EXPOSE 80

```


- 使用 alibaba cloudtookit 快速打包上传镜像


![image](https://upload-images.jianshu.io/upload_images/567399-ecc17cf26aebfda7.png?imageMogr2/auto-orient/strip%7CimageView2/2/w/1240)


- helm 快速部署


```sh

helm create rating


# 修改 values.yaml

repository: registry.cn-shanghai.aliyuncs.com/daydaygo/istio_bookinfo_rating

# 修改 chart.yml

appVersion: 0.1.1


helm lint --strict rating

helm install rating rating # 部署到 k8s 中

kubectl get pod # 查看 pod

kubectl port-forward $POD_NAME 8081:80 # 开启 port-forward 测试, 本地端口:pod端口

➜ curl localhost:8081

rating⏎

```


同理, 实现 `productpage` `detail` 服务


### 实现 review 服务并包含 3 个版本


- 实现三个版本的 review 应用


| 应用名称  | 镜像版本 |

| --------- | -------- |

| review-v1 | 0.1.0    |

| review-v2 | 0.2.0    |

| Review-v3 | 0.3.0    |


- 直接使用 yaml 文件部署( helm 单应用多版本下次继续折腾)


```yaml

##################################################################################################

# Reviews service

##################################################################################################

apiVersion: v1

kind: Service

metadata:

 name: review

 labels:

   app: review

   service: review

spec:

 ports:

   - port: 80

     name: http

 selector:

   app: review

---

apiVersion: v1

kind: ServiceAccount

metadata:

 name: bookinfo-review

 labels:

   account: review

---

apiVersion: apps/v1

kind: Deployment

metadata:

 name: review-v1

 labels:

   app: review

   version: v1

spec:

 replicas: 1

 selector:

   matchLabels:

     app: review

     version: v1

 template:

   metadata:

     labels:

       app: review

       version: v1

   spec:

     serviceAccountName: bookinfo-review

     containers:

       - name: review

         image: registry.cn-shanghai.aliyuncs.com/daydaygo/istio_bookinfo_review:0.1.0

         imagePullPolicy: IfNotPresent

         env:

           - name: LOG_DIR

             value: "/tmp/logs"

         ports:

           - containerPort: 80

         volumeMounts:

           - name: tmp

             mountPath: /tmp

           - name: wlp-output

             mountPath: /opt/ibm/wlp/output

     volumes:

       - name: wlp-output

         emptyDir: {}

       - name: tmp

         emptyDir: {}

---

apiVersion: apps/v1

kind: Deployment

metadata:

 name: review-v2

 labels:

   app: review

   version: v2

spec:

 replicas: 1

 selector:

   matchLabels:

     app: review

     version: v2

 template:

   metadata:

     labels:

       app: review

       version: v2

   spec:

     serviceAccountName: bookinfo-review

     containers:

       - name: review

         image: registry.cn-shanghai.aliyuncs.com/daydaygo/istio_bookinfo_review:0.2.0

         imagePullPolicy: IfNotPresent

         env:

           - name: LOG_DIR

             value: "/tmp/logs"

         ports:

           - containerPort: 80

         volumeMounts:

           - name: tmp

             mountPath: /tmp

           - name: wlp-output

             mountPath: /opt/ibm/wlp/output

     volumes:

       - name: wlp-output

         emptyDir: {}

       - name: tmp

         emptyDir: {}

---

apiVersion: apps/v1

kind: Deployment

metadata:

 name: review-v3

 labels:

   app: review

   version: v3

spec:

 replicas: 1

 selector:

   matchLabels:

     app: review

     version: v3

 template:

   metadata:

     labels:

       app: review

       version: v3

   spec:

     serviceAccountName: bookinfo-review

     containers:

       - name: review

         image: registry.cn-shanghai.aliyuncs.com/daydaygo/istio_bookinfo_review:0.3.0

         imagePullPolicy: IfNotPresent

         env:

           - name: LOG_DIR

             value: "/tmp/logs"

         ports:

           - containerPort: 80

         volumeMounts:

           - name: tmp

             mountPath: /tmp

           - name: wlp-output

             mountPath: /opt/ibm/wlp/output

     volumes:

       - name: wlp-output

         emptyDir: {}

       - name: tmp

         emptyDir: {}

---

```


- 部署到 k8s 中


```sh

kubectl apply -f review.yaml

kubectl get pod

# 重复验证各个 pod

kubectl port-forward $POD_NAME 8081:80 # 开启 port-forward 测试, 本地端口:pod端口

➜ curl localhost:8081

review-v1⏎

```


## 基于 go 版 bookinfo 微服务, 验证 istio task


- istio task 文档: https://github.com/istio/istio.io/content/en/docs/tasks

- task 都可以在 istio sample 找到例子: https://github.com/istio/istio/samples


```sh

# istio.io/content/en/docs/tasks

➜  tasks git:(master) tree -d

.

├── observability

│   ├── distributed-tracing

│   │   ├── configurability

│   │   ├── jaeger

│   │   ├── lightstep

│   │   ├── overview

│   │   └── zipkin

│   ├── gateways

│   ├── kiali

│   ├── logs

│   │   └── access-log

│   └── metrics

│       ├── classify-metrics

│       ├── customize-metrics

│       ├── querying-metrics

│       ├── tcp-metrics

│       └── using-istio-dashboard

├── security

│   ├── authentication

│   │   ├── authn-policy

│   │   └── mtls-migration

│   ├── authorization

│   │   ├── authz-deny

│   │   ├── authz-http

│   │   ├── authz-ingress

│   │   ├── authz-jwt

│   │   ├── authz-tcp

│   │   └── authz-td-migration

│   └── cert-management

│       ├── dns-cert

│       └── plugin-ca-cert

└── traffic-management

   ├── circuit-breaking

   ├── egress

   │   ├── egress-control

   │   ├── egress-gateway

   │   ├── egress-gateway-tls-origination

   │   ├── egress-gateway-tls-origination-sds

   │   ├── egress-kubernetes-services

   │   ├── egress-tls-origination

   │   ├── http-proxy

   │   └── wildcard-egress-hosts

   ├── fault-injection

   ├── ingress

   │   ├── ingress-control

   │   ├── ingress-sni-passthrough

   │   ├── kubernetes-ingress

   │   └── secure-ingress

   ├── mirroring

   ├── request-routing

   ├── request-timeouts

   ├── tcp-traffic-shifting

   └── traffic-shifting


53 directories

```


## 写在最后


istio 几乎涵盖了 服务治理/流量控制 的方方面面, 作为服务治理层的基础设施 **完全够用**, 问题开始从 **行不行**, 转向 **用哪些**, 让 业务层/devops工作流/k8s基础设施 用起来更爽


还需要解决的问题:

- helm 对单应用多版本的支持, 比如 review 应用是通一个 srv, 多个 deploy

- k8s/helm 发布对服务间依赖的支持, 比如 A 服务必须依赖 B 服务更新后才能更新

相关实践学习
深入解析Docker容器化技术
Docker是一个开源的应用容器引擎,让开发者可以打包他们的应用以及依赖包到一个可移植的容器中,然后发布到任何流行的Linux机器上,也可以实现虚拟化,容器是完全使用沙箱机制,相互之间不会有任何接口。Docker是世界领先的软件容器平台。开发人员利用Docker可以消除协作编码时“在我的机器上可正常工作”的问题。运维人员利用Docker可以在隔离容器中并行运行和管理应用,获得更好的计算密度。企业利用Docker可以构建敏捷的软件交付管道,以更快的速度、更高的安全性和可靠的信誉为Linux和Windows Server应用发布新功能。 在本套课程中,我们将全面的讲解Docker技术栈,从环境安装到容器、镜像操作以及生产环境如何部署开发的微服务应用。本课程由黑马程序员提供。     相关的阿里云产品:容器服务 ACK 容器服务 Kubernetes 版(简称 ACK)提供高性能可伸缩的容器应用管理能力,支持企业级容器化应用的全生命周期管理。整合阿里云虚拟化、存储、网络和安全能力,打造云端最佳容器化应用运行环境。 了解产品详情: https://www.aliyun.com/product/kubernetes
目录
相关文章
|
10月前
|
Linux Go iOS开发
Go语言100个实战案例-进阶与部署篇:使用Go打包生成可执行文件
本文详解Go语言打包与跨平台编译技巧,涵盖`go build`命令、多平台构建、二进制优化及资源嵌入(embed),助你将项目编译为无依赖的独立可执行文件,轻松实现高效分发与部署。
1527 162
|
10月前
|
存储 前端开发 JavaScript
Go语言实战案例-项目实战篇:编写一个轻量级在线聊天室
本文介绍如何用Go语言从零实现一个轻量级在线聊天室,基于WebSocket实现实时通信,支持多人消息广播。涵盖前后端开发、技术选型与功能扩展,助你掌握Go高并发与实时通信核心技术。
993 158
|
11月前
|
数据采集 数据挖掘 测试技术
Go与Python爬虫实战对比:从开发效率到性能瓶颈的深度解析
本文对比了Python与Go在爬虫开发中的特点。Python凭借Scrapy等框架在开发效率和易用性上占优,适合快速开发与中小型项目;而Go凭借高并发和高性能优势,适用于大规模、长期运行的爬虫服务。文章通过代码示例和性能测试,分析了两者在并发能力、错误处理、部署维护等方面的差异,并探讨了未来融合发展的趋势。
1156 0
|
11月前
|
存储 人工智能 Go
Go-Zero全流程实战即时通讯
Go-Zero 是一个功能丰富的微服务框架,适用于开发高性能的即时通讯应用。它具备中间件、工具库和代码生成器,简化开发流程。本文介绍其环境搭建、项目初始化及即时通讯功能实现,涵盖用户认证、消息收发和实时推送,帮助开发者快速上手。
565 0
|
11月前
|
数据采集 Go API
Go语言实战案例:使用context控制协程取消
本文详解 Go 语言中 `context` 包的使用,通过实际案例演示如何利用 `context` 控制协程的生命周期,实现任务取消、超时控制及优雅退出,提升并发程序的稳定性与资源管理能力。
570 152
|
11月前
|
负载均衡 监控 Java
微服务稳定性三板斧:熔断、限流与负载均衡全面解析(附 Hystrix-Go 实战代码)
在微服务架构中,高可用与稳定性至关重要。本文详解熔断、限流与负载均衡三大关键技术,结合API网关与Hystrix-Go实战,帮助构建健壮、弹性的微服务系统。
997 1
微服务稳定性三板斧:熔断、限流与负载均衡全面解析(附 Hystrix-Go 实战代码)
|
11月前
|
安全 Go 开发者
Go语言实战案例:使用sync.Mutex实现资源加锁
在Go语言并发编程中,数据共享可能导致竞态条件,使用 `sync.Mutex` 可以有效避免这一问题。本文详细介绍了互斥锁的基本概念、加锁原理及实战应用,通过构建并发安全的计数器演示了加锁与未加锁的区别,并封装了一个线程安全的计数器结构。同时对比了Go中常见的同步机制,帮助开发者理解何时应使用 `Mutex` 及其注意事项。掌握 `Mutex` 是实现高效、安全并发编程的重要基础。
|
11月前
|
数据采集 Go API
Go语言实战案例:多协程并发下载网页内容
本文是《Go语言100个实战案例 · 网络与并发篇》第6篇,讲解如何使用 Goroutine 和 Channel 实现多协程并发抓取网页内容,提升网络请求效率。通过实战掌握高并发编程技巧,构建爬虫、内容聚合器等工具,涵盖 WaitGroup、超时控制、错误处理等核心知识点。
|
11月前
|
Go 开发者
Go语言实战案例:使用select监听多个channel
本文为《Go语言100个实战案例 · 网络与并发篇》第5篇,详解Go并发核心工具`select`的使用。通过实际案例讲解如何监听多个Channel、实现多任务处理、超时控制和非阻塞通信,帮助开发者掌握Go并发编程中的多路异步事件处理技巧。
|
11月前
|
数据采集 编解码 监控
Go语言实战案例:使用channel实现生产者消费者模型
本文是「Go语言100个实战案例 · 网络与并发篇」第4篇,通过实战案例详解使用 Channel 实现生产者-消费者模型,涵盖并发控制、任务调度及Go语言并发哲学,助你掌握优雅的并发编程技巧。