本例以 VMware 虚拟机进行演示，旨在搭建一个萌新级别的 demo，开始教程之前，请确保 Kubernetes 环境正常。

查看 kube-system 各个 pod 组件状态

1. 环境准备:

   • Windows 宿主机 (192.168.244.1)、多个虚拟主机节点，包括 master 节点 (192.168.244.143)、其他 worker 节点 (node1、node2...需确保主机间网络互通)

2. 构建镜像与发布到 Docker Hub:

   • 这里以 Go 语言 json 方式实现一个 RPC 远程调用的 demo 代码为例，项目结构如下：

   [root@master rpcproject]# tree
   ├── client.go
   ├── Dockerfile
   ├── go_deployment.yaml
   ├── go.mod
   ├── go_service.yaml
   ├── message
   │   └── message.go
   └── server.go
   

   • Dockerfile 内容:

     # 使用官方的 Go 镜像作为基础镜像
     FROM golang:latest
     
     # 设置工作目录
     WORKDIR /app
     
     # 将本地的代码复制到容器中的工作目录
     COPY . .
     
     # 构建 Go 应用程序
     RUN go build -o server server.go
     
     # 暴露应用程序运行的端口
     EXPOSE 1234
     
     # 运行应用程序
     CMD ["./server"]
     

   • Docker 构建本地镜像: docker build -t rpc-go-demo .
   • 打个发布标签备后续推送到 Docker Hub 远程仓库:
     docker tag rpc-go-demo:latest dys12345678/rpc-go-demo:v1
   • 使用 docker login 登录到 Docker Hub (请事先登录官网注册个账号)，docker push 推送镜像到远程仓库:
     docker push dys12345678/rpc-go-demo:v1

3. 以 Deployment 方式部署以上应用程序：

   • go_deployment.yaml 文件内容:

     kind: Deployment
     metadata:
       name: gorpc-app-deployment
     spec:
       replicas: 3  # 根据需要调整副本数量
       selector:
         matchLabels:
           app: gorpc-app
       template:
         metadata:
           labels:
             app: gorpc-app
         spec:
           containers:
             - name: gorpc-app
               image: docker.io/dys12345678/rpc-go-demo:v1  # 使用你的镜像名称和版本
               imagePullPolicy: Always
               ports:
                 - containerPort: 1234
     

   • 执行 kubectl apply -f go_deployment.yaml 部署应用
   • 以上 replicas 了三份，查看 pod 状态:
     
     success

4. 构建部署 Service，使用 NodePort 类型进行部署，暴露节点端口，这样 Windows 宿主机能远程调用内部集群:

   • go_service.yaml 文件内容:

     ---
     apiVersion: v1
     kind: Service
     metadata:
       name: gorpc-app-service
     spec:
       selector:
         app: gorpc-app
       ports:
         - protocol: TCP
           port: 80
           targetPort: 1234
           nodePort: 30003
       type: NodePort  # 根据需要选择 Service 的类型
     

   • 执行 kubectl apply -f go_service.yaml 部署 service

   • 查看 Service 状态:

     
     
     success

   • 以上 service 是在 master 节点部署，暴露的节点端口为 30003，只要能互通到该节点的网络机子都能通过 192.168.244.143:30003 调用到目标集群

5. 宿主机执行客户端代码成功访问:

   • client.go:

     package main
     
     import (
         "fmt"
         "net/rpc/jsonrpc"
         "rpcproject/message"
     )
     
     func main() {
         // 连接到 RPC 服务
         client, err := jsonrpc.Dial("tcp", "192.168.244.143:30003")
         if err != nil {
             fmt.Println("Error connecting to server:", err)
             return
         }
         defer client.Close()
     
         // 准备远程方法的参数
         args := &message.Args{7, 3}
     
         // 调用远程方法 Multiply
         var reply int
         err = client.Call("Arith.Multiply", args, &reply)
         if err != nil {
             fmt.Println("Error calling Multiply:", err)
             return
         }
         fmt.Printf("Arith: %d * %d = %d\n", args.A, args.B, reply)
     
         // 调用远程方法 Divide
         var quo message.Quotient
         err = client.Call("Arith.Divide", args, &quo)
         if err != nil {
             fmt.Println("Error calling Divide:", err)
             return
         }
         fmt.Printf("Arith: %d / %d = %d remainder %d\n", args.A, args.B, quo.Quo, quo.Rem)
     }
     

     success

Tip: 示例中的源码请参见 GitHub