《Go 简易速速上手小册》第10章:微服务与云原生应用(2024 最新版)

在这里插入图片描述

文章目录

  • 10.1 构建微服务架构 - 探索 Go 语言的微观世界
    • 10.1.1 基础知识讲解
    • 10.1.2 重点案例:订单处理系统
      • 订单服务
      • 测试服务
    • 10.1.3 拓展案例 1:用户认证服务
      • 安装所需的包
      • 实现用户模型和存储
      • 实现 JWT 生成和验证
      • 实现认证服务
      • 测试服务
    • 10.1.4 拓展案例 2:商品推荐服务
      • 设计商品推荐服务
      • 实现简化的推荐服务
      • 集成推荐服务到订单系统
      • 测试服务
  • 10.2 容器化与 Go - 打包你的 Go 应用航向云端
    • 10.2.1 基础知识讲解
    • 10.2.2 重点案例:Go Web 服务的容器化
      • 步骤一:编写Go Web服务
      • 步骤二:编写 Dockerfile
      • 步骤三:构建和运行容器
      • 测试服务
    • 10.2.3 拓展案例 1:多阶段构建优化
      • 功能描述
      • 步骤一:优化 Dockerfile
      • 步骤二:构建和运行容器
      • 步骤三:验证镜像大小的优化
      • 测试服务
    • 10.2.3 拓展案例 2:为 Go 微服务创建 Docker Compose 环境
      • 功能描述
      • 步骤一:准备用户服务和产品服务
      • 步骤二:编写 Dockerfile
      • 步骤三:编写 Docker Compose 文件
      • 步骤四:启动服务
      • 测试服务
  • 10.3 云原生技术栈与 Go - Go 语言在云上的航行
    • 10.3.1 基础知识讲解
    • 10.3.2 重点案例:Go 微服务在 Kubernetes 上的部署
      • 步骤一:准备 Go 微服务
      • 步骤二:容器化 Go 微服务
      • 步骤三:编写 Kubernetes 部署配置
      • 步骤四:部署到 Kubernetes
      • 步骤五:访问微服务
    • 10.3.3 拓展案例 1:使用 Helm 管理 Go 应用的 Kubernetes 部署
      • 步骤一:创建 Helm Chart
      • 步骤二:定制化 Chart
      • 步骤三:打包和部署 Chart
      • 步骤四:验证部署
      • 步骤五:更新和升级
    • 10.3.4 拓展案例 2:实现 Go 微服务的自动扩展
      • 步骤一:准备 Go 微服务
      • 步骤二:为微服务启用资源请求和限制
      • 步骤三:创建 HPA
      • 步骤四:测试自动扩展
      • 步骤五:调整 HPA 策略(可选)

10.1 构建微服务架构 - 探索 Go 语言的微观世界

10.1.1 基础知识讲解

微服务架构是一种将单一应用程序划分成一组小服务的方法,每个服务运行在其独立的进程中,服务之间通过轻量级的通信机制(通常是HTTP资源API)相互协作、相互独立部署。这种架构允许快速、可靠和频繁地部署大型、复杂的应用程序。

微服务架构的核心特点包括:

  • 服务分离:每个微服务负责应用程序的一小部分功能,并可以独立更新和扩展。
  • 自治性:每个服务都是独立部署的,有自己的数据库和数据管理模型,减少了服务间的依赖。
  • 技术多样性:不同的服务可以使用不同的编程语言和数据存储技术开发,使得技术栈更加灵活。
  • 可扩展性:可以根据需要对特定功能进行扩展,而不必重新部署整个应用。

Go 在微服务中的应用

Go语言以其并发支持、高性能和简洁语法成为构建微服务的热门选择。Go的标准库提供了强大的网络和HTTP支持,使得开发RESTful API变得简单快捷。

10.1.2 重点案例:订单处理系统

在这个扩展案例中,我们将构建一个简单的订单处理系统,演示如何使用Go语言和gin框架开发微服务。这个系统将包含订单服务的基础实现,包括创建订单和查询订单详情的功能。

订单服务

安装gin框架

首先,确保安装了gin框架:

go get -u github.com/gin-gonic/gin

定义订单模型

在订单服务中,我们定义一个Order结构体来表示订单信息:

// models.gopackage maintype Order struct {ID    string  `json:"id"`Items []Item  `json:"items"`Total float64 `json:"total"`
}type Item struct {ProductID string `json:"product_id"`Quantity  int    `json:"quantity"`Price     float64 `json:"price"`
}

实现订单服务

我们使用gin来创建RESTful API,处理创建和查询订单的请求:

// order_service.gopackage mainimport ("github.com/gin-gonic/gin""net/http"
)var orders = []Order{{ID: "1", Items: []Item{{ProductID: "101", Quantity: 2, Price: 15.0}}, Total: 30.0},
}func main() {router := gin.Default()router.POST("/orders", createOrder)router.GET("/orders/:id", getOrder)router.Run(":8080")
}func createOrder(c *gin.Context) {var newOrder Orderif err := c.ShouldBindJSON(&newOrder); err != nil {c.JSON(http.StatusBadRequest, gin.H{"error": err.Error()})return}// 这里简化处理,直接添加到数组。在实际应用中,应保存到数据库。newOrder.ID = "2" // 假设生成的订单IDorders = append(orders, newOrder)c.JSON(http.StatusCreated, newOrder)
}func getOrder(c *gin.Context) {orderID := c.Param("id")for _, order := range orders {if order.ID == orderID {c.JSON(http.StatusOK, order)return}}c.JSON(http.StatusNotFound, gin.H{"error": "Order not found"})
}

在这个简单的示例中,我们实现了两个API端点:/orders用于创建新订单,/orders/:id用于查询指定ID的订单详情。为了简化,我们将创建的订单存储在内存中的一个切片中,并未使用数据库。

测试服务

  1. 创建订单:使用curl或Postman发送POST请求到http://localhost:8080/orders,请求体包含订单数据。
  2. 查询订单:发送GET请求到http://localhost:8080/orders/1,获取ID为1的订单详情。

通过这个案例,你已经学会了如何使用Go语言和gin框架开发简单的微服务。虽然这个订单处理系统非常基础,但它为你提供了微服务架构下开发复杂系统的起点。随着你进一步深入学习,你将能够添加更多服务,如支付服务和库存服务,使用消息队列处理服务间通信,甚至使用容器化和云原生技术来部署你的微服务。

10.1.3 拓展案例 1:用户认证服务

在这个扩展案例中,我们将为订单处理系统添加一个用户认证服务,使用JSON Web Tokens (JWT)进行安全认证。这个服务将负责用户的注册、登录,并在成功登录后发放JWT,以便用户在访问受保护的订单服务时进行身份验证。

安装所需的包

首先,安装gin框架和JWT相关的Go包:

go get -u github.com/gin-gonic/gin
go get -u github.com/golang-jwt/jwt/v4

实现用户模型和存储

为简化,我们使用内存存储来保存用户信息和模拟数据库操作:

// models.gopackage maintype User struct {Username stringPassword string // 注意:实际应用中应存储密码的哈希值
}var userStore = map[string]string{"user1": "password1", // 用户名:密码,实际应用中应存储密码的哈希值
}

实现 JWT 生成和验证

定义一个简单的JWT管理器,用于生成和验证JWT:

// jwt_manager.gopackage mainimport ("fmt""time""github.com/golang-jwt/jwt/v4"
)var jwtKey = []byte("my_secret_key") // 保持安全type Claims struct {Username string `json:"username"`jwt.RegisteredClaims
}func GenerateJWT(username string) (string, error) {expirationTime := time.Now().Add(1 * time.Hour)claims := &Claims{Username: username,RegisteredClaims: jwt.RegisteredClaims{ExpiresAt: jwt.NewNumericDate(expirationTime),},}token := jwt.NewWithClaims(jwt.SigningMethodHS256, claims)tokenString, err := token.SignedString(jwtKey)return tokenString, err
}func ValidateToken(tokenString string) (*Claims, bool) {claims := &Claims{}token, err := jwt.ParseWithClaims(tokenString, claims, func(token *jwt.Token) (interface{}, error) {return jwtKey, nil})if err != nil {return nil, false}return claims, token.Valid
}

实现认证服务

使用gin框架实现用户注册、登录以及JWT验证的中间件:

// auth_service.gopackage mainimport ("github.com/gin-gonic/gin""net/http"
)func main() {router := gin.Default()router.POST("/login", login)router.GET("/orders", authenticateJWT(), getOrder) // 使用JWT中间件保护订单服务router.Run(":8080")
}func login(c *gin.Context) {var user Userif err := c.ShouldBindJSON(&user); err != nil {c.JSON(http.StatusBadRequest, gin.H{"error": "Bad request"})return}// 模拟用户认证expectedPassword, ok := userStore[user.Username]if !ok || expectedPassword != user.Password {c.JSON(http.StatusUnauthorized, gin.H{"error": "Authentication failed"})return}// 生成JWTtoken, err := GenerateJWT(user.Username)if err != nil {c.JSON(http.StatusInternalServerError, gin.H{"error": "Failed to generate token"})return}c.JSON(http.StatusOK, gin.H{"token": token})
}func authenticateJWT() gin.HandlerFunc {return func(c *gin.Context) {const Bearer_schema = "Bearer "header := c.GetHeader("Authorization")if header == "" {c.AbortWithStatusJSON(http.StatusUnauthorized, gin.H{"error": "Authorization header missing"})return}tokenString := header[len(Bearer_schema):]claims, valid := ValidateToken(tokenString)if !valid {c.AbortWithStatusJSON(http.StatusUnauthorized, gin.H{"error": "Invalid token"})return}// Token is valid, add username to the contextc.Set("username", claims.Username)c.Next()}
}func getOrder(c *gin.Context) {// 获取订单逻辑c.JSON(http.StatusOK, gin.H{"message": "Order details"})
}

在这个示例中,login函数处理用户登录请求,成功认证后生成JWT。authenticateJWT是一个中间件,用于保护需要认证的路由,它验证请求中的JWT并提取用户名。

测试服务

  1. 登录:发送POST请求到http://localhost:8080/login,包含用户名和密码,以获取JWT。
  2. 访问受保护的路由:使用获取的JWT作为Authorization头发送GET请求到http://localhost:8080/orders

通过这个拓展案例,你已经学会了如何在Go语言中添加用户认证服务,并使用JWT进行安全认证。这是构建现代Web应用和微服务的关键组成部分,确保了数据的安全访问和服务的安全调用。随着你对Go和微服务架构的深入理解,你将能够构建更加安全、可靠的应用。

10.1.4 拓展案例 2:商品推荐服务

在这个拓展案例中,我们将为订单处理系统添加一个商品推荐服务,根据用户的购买历史和浏览行为来推荐商品。此服务将独立于订单处理系统,通过事件驱动方式接收用户行为数据,并使用简单的算法来生成推荐。

设计商品推荐服务

核心概念

  • 用户行为数据:包括用户的购买记录和浏览历史,用于分析用户偏好。
  • 推荐算法:基于用户行为数据,推算出可能感兴趣的商品。
  • 事件驱动:该服务通过监听用户行为事件(如购买或浏览商品)来触发推荐算法。

实现简化的推荐服务

为了保持示例的简洁性,我们将使用一个静态的商品列表来模拟商品数据库,并实现一个基于用户最近购买商品的简单推荐算法。

模拟商品数据库

// products.gopackage mainvar products = []string{"Go Programming Book","Rubber Duck","Pirate Hat","Gin Framework Guide","Kubernetes Deployment Handbook",
}

实现推荐逻辑

// recommendation_service.gopackage mainimport ("fmt""math/rand""time"
)func recommendProduct(boughtProduct string) string {rand.Seed(time.Now().UnixNano())recommendedIndex := rand.Intn(len(products))// 简单地从产品列表中随机选择一个产品作为推荐,确保推荐的产品不是刚买的产品for products[recommendedIndex] == boughtProduct {recommendedIndex = rand.Intn(len(products))}return products[recommendedIndex]
}

集成推荐服务到订单系统

我们将模拟用户购买商品后接收推荐的过程。在订单服务中,每当用户购买商品,我们将调用推荐服务来推荐另一个商品。

// order_service.gopackage mainimport ("github.com/gin-gonic/gin""net/http"
)func main() {router := gin.Default()router.POST("/purchase", purchaseProduct)router.Run(":8080")
}func purchaseProduct(c *gin.Context) {type Purchase struct {ProductName string `json:"product_name"`}var purchase Purchaseif err := c.ShouldBindJSON(&purchase); err != nil {c.JSON(http.StatusBadRequest, gin.H{"error": "Invalid request"})return}recommendedProduct := recommendProduct(purchase.ProductName)c.JSON(http.StatusOK, gin.H{"message": "Purchase successful", "recommended_product": recommendedProduct})
}

在这个简单的示例中,当用户通过POST请求到/purchase端点购买一个商品时,系统将返回一个推荐的商品。这个推荐是基于一个简单的随机选择算法,实际应用中,推荐算法会更加复杂,可能会考虑用户的购买历史、商品相似度、用户评分等因素。

测试服务

  • 购买商品:发送 POST 请求到http://localhost:8080/purchase,包含要购买的商品名称,查看返回的推荐商品。

通过这个拓展案例,你了解了如何为现有的订单处理系统添加一个简单的商品推荐服务。虽然这里使用的推荐算法非常基础,但它展示了如何基于用户行为数据来增加额外的服务和功能,为用户提供个性化体验。随着技术的深入,你可以探索更高级的算法和技术,如机器学习,来进一步提升推荐系统的准确性和效率。

10.2 容器化与 Go - 打包你的 Go 应用航向云端

10.2.1 基础知识讲解

容器化是一种轻量级、可移植的软件打包技术,它允许开发者将应用及其全部依赖一起打包成一个容器镜像。这种方法确保了应用在不同环境中的一致性和可靠性。Docker是目前最流行的容器化平台,提供了一个标准化的方法来打包、分发和运行容器化应用。

为什么 Go 适合容器化?

  • 高效的二进制文件:Go编译后的应用是单个二进制文件,包含了所有依赖,非常适合放入轻量级的容器中。
  • 跨平台编译:Go支持交叉编译,可以轻松为不同平台生成二进制文件,进一步增强了容器的可移植性。
  • 快速启动时间:Go应用启动速度快,非常适合在容器环境中快速扩展和部署。

容器化 Go 应用的基本步骤

  1. 编写Dockerfile:定义如何在容器中构建和运行Go应用。
  2. 构建容器镜像:使用Dockerfile和源代码构建可部署的容器镜像。
  3. 运行容器:从镜像启动容器,运行你的Go应用。

10.2.2 重点案例:Go Web 服务的容器化

让我们通过一个实际的示例来演示如何将一个简单的Go编写的Web服务容器化,从而可以在任何支持Docker的环境中运行。

步骤一:编写Go Web服务

首先,我们需要创建一个简单的HTTP服务。以下是服务的代码,它会在根路径/上响应带有欢迎信息的HTTP请求。

main.go:

package mainimport ("fmt""net/http"
)func main() {http.HandleFunc("/", func(w http.ResponseWriter, r *http.Request) {fmt.Fprintf(w, "Hello, Dockerized World!")})fmt.Println("Server is running on port 8080...")http.ListenAndServe(":8080", nil)
}

步骤二:编写 Dockerfile

接下来,我们需要为我们的Go应用编写一个Dockerfile。这个Dockerfile使用了多阶段构建,第一阶段用于构建应用,第二阶段运行应用。

Dockerfile:

# 第一阶段:构建环境
FROM golang:1.16-alpine AS buildWORKDIR /app# 复制模块文件并下载依赖
COPY go.mod go.sum ./
RUN go mod download# 复制源代码
COPY *.go ./# 编译应用
RUN CGO_ENABLED=0 GOOS=linux go build -o /go-web-app# 第二阶段:运行环境
FROM scratch# 从构建阶段复制编译好的二进制文件
COPY --from=build /go-web-app /go-web-app# 暴露端口
EXPOSE 8080# 定义入口点
ENTRYPOINT ["/go-web-app"]

步骤三:构建和运行容器

使用以下命令构建Docker镜像,并运行容器:

docker build -t go-web-app .
docker run -d -p 8080:8080 go-web-app
  • -t go-web-app:给镜像命名为go-web-app
  • -d:后台运行容器。
  • -p 8080:8080:将容器的8080端口映射到宿主机的8080端口。

测试服务

在浏览器或使用命令行工具(如curl)访问http://localhost:8080,你应该会看到“Hello, Dockerized World!”的欢迎信息。

例如,使用curl测试:

curl http://localhost:8080

输出应为:

Hello, Dockerized World!

通过这个案例,你已经学会了如何将一个简单的Go Web服务容器化。这个过程涉及到编写应用代码、创建Dockerfile以及使用Docker命令构建和运行容器。容器化不仅使得部署变得简单快捷,而且提高了应用的可移植性和一致性,为在云环境中运行提供了便利。随着你对Docker和容器化技术的进一步探索,你将能够更有效地开发、部署和管理Go应用。

10.2.3 拓展案例 1:多阶段构建优化

在Docker容器化的上下文中,多阶段构建是一种优化技术,它允许在一个Dockerfile中使用多个构建阶段,但最终只将必要的文件复制到最终镜像中。这样做的好处是可以显著减小最终镜像的大小,同时保持构建过程的清晰和高效。

功能描述

为了展示多阶段构建优化,我们将使用前面创建的Go Web服务案例,并优化其Dockerfile,以减小最终产生的Docker镜像的大小。

步骤一:优化 Dockerfile

以下是针对Go Web服务的多阶段构建优化后的Dockerfile:

# 第一阶段:构建环境
FROM golang:1.16-alpine AS builderWORKDIR /app# 复制Go模块和依赖文件
COPY go.mod go.sum ./
RUN go mod download# 复制源代码
COPY . .# 编译Go应用为静态链接的二进制文件
RUN CGO_ENABLED=0 GOOS=linux go build -a -installsuffix cgo -o go-web-app .# 第二阶段:运行环境
FROM alpine:latest  RUN apk --no-cache add ca-certificatesWORKDIR /root/# 从构建阶段复制编译好的二进制文件
COPY --from=builder /app/go-web-app .# 暴露端口
EXPOSE 8080# 定义入口点
CMD ["./go-web-app"]

在这个优化后的Dockerfile中,我们在第二阶段使用了alpine:latest作为基础镜像,而不是scratch。这是因为alpine镜像虽然相对较小,但包含了运行大多数应用所需的最小系统和库,包括ca-certificates,这对于执行HTTPS请求非常重要。同时,通过使用CGO_ENABLED=0编译Go应用,我们确保生成的二进制文件是静态链接的,没有依赖于C库,这让它可以在几乎任何Linux环境下运行。

步骤二:构建和运行容器

使用优化后的Dockerfile,按照之前的步骤构建并运行容器:

docker build -t go-web-app-optimized .
docker run -d -p 8080:8080 go-web-app-optimized

步骤三:验证镜像大小的优化

你可以使用以下命令来比较优化前后镜像的大小,看到多阶段构建优化带来的效果:

docker images | grep go-web-app

你应该会注意到,使用多阶段构建优化后的镜像大小要比原始镜像小得多。

测试服务

确保服务正常运行,通过访问http://localhost:8080或使用curl命令测试:

curl http://localhost:8080

应返回“Hello, Dockerized World!”的欢迎信息。

通过这个拓展案例,你学会了如何通过多阶段构建来优化Go应用的Docker镜像大小,使其更适合生产环境部署。这种优化不仅减少了资源消耗,还加快了镜像的传输和部署速度,是容器化应用部署中的一个重要实践。随着你深入探索Docker和容器技术,你将能够构建更高效、更安全的容器化应用。

10.2.3 拓展案例 2:为 Go 微服务创建 Docker Compose 环境

在微服务架构中,通常需要同时管理多个服务。Docker Compose是一个用于定义和运行多容器Docker应用程序的工具。通过使用Docker Compose,你可以使用YAML文件来配置应用的服务,并且通过一个简单的命令来启动和停止所有服务。

功能描述

假设我们有两个Go微服务:一个是用户服务,用于处理用户的注册和登录请求;另一个是产品服务,用于管理产品信息。我们将使用Docker Compose来定义这两个服务,并确保它们可以在同一网络中相互通信。

步骤一:准备用户服务和产品服务

为了简化,我们将为用户服务和产品服务各自创建一个简单的HTTP服务器。每个服务都监听不同的端口,并提供基本的RESTful API。

用户服务(UserService):

// userService/main.go
package mainimport ("fmt""net/http"
)func main() {http.HandleFunc("/users", func(w http.ResponseWriter, r *http.Request) {fmt.Fprintf(w, "User service is up!")})fmt.Println("User service listening on port 8081...")http.ListenAndServe(":8081", nil)
}

产品服务(ProductService):

// productService/main.go
package mainimport ("fmt""net/http"
)func main() {http.HandleFunc("/products", func(w http.ResponseWriter, r *http.Request) {fmt.Fprintf(w, "Product service is up!")})fmt.Println("Product service listening on port 8082...")http.ListenAndServe(":8082", nil)
}

步骤二:编写 Dockerfile

为每个服务编写一个Dockerfile。由于这两个服务结构类似,Dockerfile也会非常相似。

# Dockerfile
FROM golang:1.16-alpineWORKDIR /appCOPY go.mod ./
COPY go.sum ./
RUN go mod downloadCOPY *.go ./RUN go build -o serviceEXPOSE 8081 # 对于用户服务
# EXPOSE 8082 # 对于产品服务CMD ["./service"]

请根据实际服务调整EXPOSE行。

步骤三:编写 Docker Compose 文件

创建docker-compose.yml文件来定义用户服务和产品服务。

version: '3.8'
services:user-service:build:context: ./userServicedockerfile: Dockerfileports:- "8081:8081"product-service:build:context: ./productServicedockerfile: Dockerfileports:- "8082:8082"

这个docker-compose.yml文件定义了两个服务:user-serviceproduct-service。它们分别映射了对应的端口到宿主机,以便你可以从宿主机访问这些服务。

步骤四:启动服务

在包含docker-compose.yml文件的目录中运行以下命令来构建和启动服务:

docker-compose up --build

这将根据每个服务的Dockerfile构建镜像,然后启动容器。--build选项确保在启动服务之前构建或重新构建镜像。

测试服务

一旦服务启动,你可以通过访问http://localhost:8081/usershttp://localhost:8082/products来测试用户服务和产品服务是否正常运行。

通过这个拓展案例,你已经学会了如何使用Docker Compose来定义和管理多个Go微服务。Docker Compose不仅简化了多容器应用的开发和测试流程,还提供了一种在生产环境中部署和扩展服务的有效方法。随着你对Docker Compose的进一步探索,你将能够更加灵活和高效地部署复杂的微服务架构。

10.3 云原生技术栈与 Go - Go 语言在云上的航行

10.3.1 基础知识讲解

云原生技术是指那些为开发者提供构建和运行可扩展应用程序在现代动态环境中(如公有云、私有云和混合云)的技术集合。这些技术使得应用更加灵活、可维护,并易于扩展。

云原生技术栈的关键组件包括:

  • 容器化:容器提供了一种轻量级的、一致的软件打包方式,使应用在不同的计算环境中运行得更加可靠。
  • 微服务架构:通过将应用拆分为一组小服务,微服务架构使得应用更容易开发和扩展。
  • 声明式自动化:使用Kubernetes等工具自动管理容器化应用,实现自我修复、自动扩展和滚动更新等。
  • DevOps和持续交付:云原生鼓励更快的迭代速度和更高的部署频率,通过自动化的构建、测试和部署来实现。

Go 在云原生中的角色

Go语言因其简单、高效和强大的并发支持,在云原生生态系统中占据了重要地位。许多关键的云原生项目,如Kubernetes、Docker和Istio,都是用Go编写的。Go的这些特性使其成为开发高性能、可扩展的云原生应用的理想选择。

10.3.2 重点案例:Go 微服务在 Kubernetes 上的部署

让我们通过一个具体的示例来演示如何将Go编写的微服务容器化并部署到Kubernetes集群上。这个过程涵盖了应用的容器化、创建Docker镜像、推送到镜像仓库,以及编写和应用Kubernetes部署配置。

步骤一:准备 Go 微服务

首先,我们复用之前创建的简单HTTP服务器代码,该服务监听8080端口并返回欢迎消息。

main.go:

package mainimport ("fmt""net/http"
)func handler(w http.ResponseWriter, r *http.Request) {fmt.Fprintf(w, "Hello, Kubernetes World!")
}func main() {http.HandleFunc("/", handler)fmt.Println("Starting server on port 8080...")http.ListenAndServe(":8080", nil)
}

步骤二:容器化 Go 微服务

为微服务创建一个Dockerfile:

# 使用Go官方镜像作为构建环境
FROM golang:1.16-alpine AS build# 设置工作目录
WORKDIR /app# 复制并下载依赖
COPY go.mod ./
COPY go.sum ./
RUN go mod download# 复制源代码并编译
COPY *.go ./
RUN CGO_ENABLED=0 GOOS=linux go build -o webapp .# 使用scratch作为运行环境
FROM scratch
COPY --from=build /app/webapp /webapp
EXPOSE 8080
ENTRYPOINT ["/webapp"]

构建并推送镜像到Docker Hub或其他容器镜像仓库:

docker build -t yourusername/go-webapp-k8s .
docker push yourusername/go-webapp-k8s

请确保替换yourusername为你的Docker Hub用户名。

步骤三:编写 Kubernetes 部署配置

创建webapp-deployment.yaml文件,定义微服务的部署和服务对象:

apiVersion: apps/v1
kind: Deployment
metadata:name: go-webapp
spec:replicas: 2selector:matchLabels:app: go-webapptemplate:metadata:labels:app: go-webappspec:containers:- name: go-webappimage: yourusername/go-webapp-k8sports:- containerPort: 8080---
apiVersion: v1
kind: Service
metadata:name: go-webapp-service
spec:type: LoadBalancerports:- port: 8080targetPort: 8080selector:app: go-webapp

替换image字段中的yourusername/go-webapp-k8s为你的镜像名称。

步骤四:部署到 Kubernetes

使用kubectl应用部署配置,将应用部署到Kubernetes集群:

kubectl apply -f webapp-deployment.yaml

查看部署状态和服务:

kubectl get deployments
kubectl get services

步骤五:访问微服务

如果你在本地使用Minikube,使用以下命令找到服务的URL:

minikube service go-webapp-service --url

在浏览器中访问该URL,或使用curl命令,你应该能够看到“Hello, Kubernetes World!”的消息。

通过这个案例,你已经学会了如何将Go微服务容器化并在Kubernetes上部署。这不仅展示了从代码到部署的完整流程,还体现了云原生应用开发中的关键实践,包括容器化、微服务架构和声明式自动化部署。随着你深入探索Kubernetes和云原生技术栈,你将能够构建和管理更加复杂和强大的应用。

10.3.3 拓展案例 1:使用 Helm 管理 Go 应用的 Kubernetes 部署

Helm是Kubernetes的包管理器,它使得定义、安装和升级Kubernetes应用变得简单。通过Helm,我们可以将应用及其依赖打包到一个chart中,然后通过简单的命令来部署和管理这个chart。这个案例将展示如何使用Helm来管理之前创建的Go微服务的部署。

步骤一:创建 Helm Chart

首先,确保你已经安装了Helm。然后在命令行中执行以下命令来创建一个新的Helm chart:

helm create go-webapp-chart

这将在当前目录下创建一个名为go-webapp-chart的文件夹,里面包含了chart的初始文件和文件夹结构。

步骤二:定制化 Chart

定制化你的Helm chart来适配Go微服务。修改go-webapp-chart/values.yaml文件来定义一些默认配置,比如镜像的仓库和标签:

# values.yamlreplicaCount: 2image:repository: yourusername/go-webapp-k8spullPolicy: IfNotPresent# tag: "If you have a specific version"service:type: LoadBalancerport: 8080

确保将image.repository的值替换为你的容器镜像地址。

接下来,修改go-webapp-chart/templates/deployment.yaml文件,确保它使用values.yaml中定义的值:

# deployment.yaml 中的部分内容
spec:replicas: {{ .Values.replicaCount }}template:spec:containers:- name: go-webappimage: "{{ .Values.image.repository }}:{{ .Values.image.tag | default .Chart.AppVersion }}"ports:- containerPort: {{ .Values.service.port }}

步骤三:打包和部署 Chart

在chart目录(go-webapp-chart)中,打包你的chart:

helm package .

然后,使用Helm安装你的chart到Kubernetes集群:

helm install go-webapp-release ./go-webapp-chart-0.1.0.tgz

这里go-webapp-release是release的名字,你可以根据需要自定义。

步骤四:验证部署

使用以下命令来检查release的状态:

helm list
kubectl get services

找到你的服务的外部IP或端口(如果你在本地如Minikube上测试,使用minikube service go-webapp-service --url获取URL),然后在浏览器中访问或使用curl命令来验证服务是否正常运行。

步骤五:更新和升级

如果需要更新应用配置,你可以修改values.yaml文件,然后使用以下命令更新部署:

helm upgrade go-webapp-release ./go-webapp-chart

通过这个案例,你学会了如何使用Helm来管理Go应用的Kubernetes部署。Helm不仅简化了Kubernetes应用的部署流程,还提供了版本控制、回滚等功能,极大地提高了云原生应用管理的效率和可靠性。随着你对Helm的深入学习,你将能够更加高效地管理复杂的Kubernetes应用。

10.3.4 拓展案例 2:实现 Go 微服务的自动扩展

Kubernetes的水平自动扩展(HPA,Horizontal Pod Autoscaler)允许根据监测到的CPU使用率或其他选定的度量自动增加或减少Pod的数量。这个案例将演示如何为Go编写的微服务实现自动扩展功能,以确保应用能够根据负载自动调整其运行实例的数量。

步骤一:准备 Go 微服务

假设我们已经有一个Go微服务,它已经被容器化并部署到Kubernetes上,如之前的“Go微服务在Kubernetes上的部署”案例所示。

步骤二:为微服务启用资源请求和限制

为了使HPA能够根据CPU使用情况自动扩展Pod,首先需要在微服务的Deployment配置中指定每个容器的资源请求和限制。编辑你的deployment.yaml文件,为containers部分添加resources字段:

apiVersion: apps/v1
kind: Deployment
metadata:name: go-webapp
spec:...template:...spec:containers:- name: go-webappimage: yourusername/go-webapp-k8sresources:requests:cpu: "100m"memory: "100Mi"limits:cpu: "200m"memory: "200Mi"ports:- containerPort: 8080

这里的requests字段指定了每个Pod启动时的最小资源需求,而limits字段则指定了Pod可以消耗的最大资源量。

步骤三:创建 HPA

接下来,使用kubectl命令创建HPA,以自动扩展你的Go微服务。以下命令创建一个HPA,它将根据目标Pod的平均CPU使用率自动调整Pod的数量。当CPU使用率超过50%时,Kubernetes会尝试增加Pod的数量,直到最多10个Pod。

kubectl autoscale deployment go-webapp --cpu-percent=50 --min=1 --max=10

步骤四:测试自动扩展

为了测试HPA,你可以通过增加向微服务发送的请求来人为增加负载。这可以通过编写简单的脚本不断请求你的服务来实现。

监控HPA和Pod的状态,以查看是否根据CPU负载自动调整了Pod的数量:

kubectl get hpa
kubectl get pods

步骤五:调整 HPA 策略(可选)

根据应用的具体需求,你可能需要调整HPA的行为。这可以通过编辑HPA的配置来实现:

kubectl edit hpa go-webapp

在编辑器中,你可以修改例如--cpu-percent--min/--max参数等HPA的配置项。

通过这个案例,你学会了如何为Go编写的微服务实现Kubernetes的自动扩展功能。利用HPA,你的应用可以根据实时负载自动调整资源使用,从而保证应用的性能和响应速度。这是构建高可用云原生应用的关键技术之一,随着你对Kubernetes和云原生技术栈的深入学习,你将能够构建更加灵活和强大的应用系统。

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/686940.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

HarmonyOS—@State装饰器:组件内状态

State装饰的变量,或称为状态变量,一旦变量拥有了状态属性,就和自定义组件的渲染绑定起来。当状态改变时,UI会发生对应的渲染改变。 在状态变量相关装饰器中,State是最基础的,使变量拥有状态属性的装饰器&a…

SpringBoot RabbitMQ收发消息、配置及原理

今天分析SpringBoot通过自动配置集成RabbitMQ的原理以及使用。 AMQP概念 RabbitMQ是基于AMQP协议的message broker,所以我们首先要对AMQP做一个简单的了解。 AMQP (Advanced Message Queuing Protocol) is a messaging protocol that enables conforming client a…

(三十九)大数据实战——Prometheus监控平台的部署搭建

前言 Prometheus监控(Prometheus Monitoring)是一种开源的系统监控和警报工具。它最初由SoundCloud开发并于2012年发布,并在2016年加入了云原生计算基金会(CNCF)。Prometheus监控旨在收集、存储和查询各种指标数据&am…

GEE使用 Sentinel-1 SAR影像 和 Otsu 方法绘制洪水地图

洪水是世界上最常见、破坏性最大的自然灾害之一,造成了巨大的生命和财产损失。此外,随着气候变化的影响,近年来,洪灾变得更加频繁和不可预测。为了最大限度地减少生命和财产损失,必须迅速发现洪水蔓延的情况,并及时采取必要的干预措施。洪水蔓延探测大多使用光学传感器或…

大模型基础架构入门

大模型架构 Prefix Decoder 和 Causal Decoder 和 Encoder-Decoder 区别 在于 attention mask不同: https://zhuanlan.zhihu.com/p/626310493 为何现在的大模型大部分是Decoder only结构? https://www.zhihu.com/question/588325646/answer/335725261…

JVM-JVM中对象的结构

对象内存布局 对象里的三个区: 对象头(Header):Java对象头占8byte。如果是数组则占12byte。因为JVM里数组size需要使用4byte存储。 标记字段MarkWord: 用于存储对象自身的运行时数据,它是synchronized实现轻…

STM32——OLED菜单

文章目录 一.补充二. 二级菜单代码 简介:首先在我的51 I2C里面有OLED详细讲解,本期代码从51OLED基础上移植过来的,可以先看完那篇文章,在看这个,然后按键我是用的定时器扫描不会堵塞程序,可以翻开我的文章有单独的定时…

MIPS指令集处理器设计(支持64条汇编指令)

一、题目背景和意义 二、国内外研究现状 (略) 三、MIPS指令集处理器设计与实现 (一).MIPS指令集功能性梳理 1.MIPS指令集架构 (1).mips基础指令集格式总结 MIPS是(Microcomputer without interlocked pipeline stages)[10]的缩写,含义是…

C++友元->全局函数做友元、类做友元、成员函数做友元

全局函数做友元代码&#xff1a; #include<iostream> using namespace std; #include<string> //建筑物类 class Building { //告诉编译器 goodGay全局函数 是 Building类的好朋友&#xff0c;可以访问类中的私有内容 friend void goodGay(Building * bu…

第14讲投票帖子详情实现

投票帖子详情实现 后端,根据id查询投票帖子信息&#xff1a; /*** 根据id查询* param id* return*/ GetMapping("/{id}") public R findById(PathVariable(value "id")Integer id){Vote vote voteService.getById(id);WxUserInfo wxUserInfo wxUserInf…

电商+支付双系统项目------设计数据库

这篇文章将详细介绍电商支付双系统项目的数据库设计。数据库在该项目中扮演着至关重要的角色&#xff0c;它负责存储和管理用户信息、商品数据、订单记录以及支付交易等关键数据。通过精心设计和优化数据库结构&#xff0c;可以实现高效的数据存储和检索&#xff0c;确保系统的…

JavaScript中的常见算法

一.排序算法 1.冒泡排序 冒泡排序比较所有相邻的两个项&#xff0c;如果第一个比第二个大&#xff0c;则交换它们。元素项向上移动至 正确的顺序&#xff0c;就好像气泡升至表面一样。 function bubbleSort(arr) {const { length } arrfor (let i 0; i < length - 1; i)…

详解自定义类型:枚举与联合体!

目录 ​编辑 一、枚举类型 1.枚举类型的声明 2.枚举类型的优点 3.枚举类型的使用 二、联合体类型(共用体&#xff09; 1.联合体类型的声明 2.联合体的特点 3.相同成员的结构体和联合体的对比 4.联合体大小的计算 5.用联合体判断大小端 三.完结散花 悟已往之不谏&…

深入浅出了解谷歌「Gemini大模型」发展历程

Google在2023年12月官宣了Gemini模型&#xff0c;随后2024年2月9日才宣布Gemini 1.0 Ultra正式对公众服务&#xff0c;并且开始收费。现在2024年2月14日就宣布了Gemini 1.5 Pro&#xff0c;史诗级多模态最强MoE首破100万极限上下文纪录&#xff01;&#xff01;&#xff01;Gem…

数据分析 — Pandas 数据加载、存储和清洗

目录 一、文件读取1、常见文件读取函数2、read_csv()3、read_table()4、read_excel()5、read_json()6、read_html()7、大文件读取 二、数据保存1、csv2、excel3、json4、html5、MySQL1、连接数据库2、MySQL 存储到本地3、本地存储到 MySQL 三、数据清洗1、处理缺失值1、判断数据…

Aster实现一台电脑当两台使——副屏使用独立win账号

前言&#xff1a;笔者每年回家&#xff0c;都面临着想要和小伙伴一起玩游戏&#xff0c;但小伙伴没有电脑/只有低配电脑的问题。与此同时&#xff0c;笔者自身的电脑是高配置的电脑&#xff0c;因此笔者想到&#xff0c;能否在自己的电脑上运行游戏&#xff0c;在小伙伴的电脑上…

LaTeX中的documentclass命令:指定文档的类型和整体布局

诸神缄默不语-个人CSDN博文目录 documentclass 是 LaTeX 中一个基础且重要的命令&#xff0c;用于定义文档的整体布局和样式。这个命令告诉 LaTeX 编译器文档是属于哪一类的&#xff0c;比如是文章、报告、书籍等&#xff0c;每一类都有其预定义的格式和结构。 文章目录 基本语…

怎么恢复电脑重装前的数据?介绍几种有效的方法

在日常生活和工作中&#xff0c;电脑已成为我们不可或缺的工具。然而&#xff0c;有时候我们会遇到一些突发情况&#xff0c;比如电脑系统崩溃需要重新安装系统。在这个过程中&#xff0c;我们可能会失去一些重要的数据&#xff0c;比如照片、文档、视频等。这些数据可能包含着…

基于springboot车辆充电桩管理系统源码和论文

随着信息化时代的到来&#xff0c;管理系统都趋向于智能化、系统化&#xff0c;车辆充电桩管理系统也不例外&#xff0c;但目前国内仍都使用人工管理&#xff0c;市场规模越来越大&#xff0c;同时信息量也越来越庞大&#xff0c;人工管理显然已无法应对时代的变化&#xff0c;…

马斯克评 OpenAI 视频模型,接地气又一针见血

马斯克评 OpenAI Sora 昨天&#xff0c;OpenAI 发布了首个视频生成模型 Sora。 一位 X&#xff08;前推特&#xff09;用户分享了 Sora 官网所展示的生成视频&#xff1a;一名女子在东京街头漫步。 该用户评论称&#xff1a;"OpenAI 今天宣布了 Sora&#xff0c;它使用混合…