gRPC: 如何在启动多个端口？

原创

尹东勋

修改于 2021-12-13 00:18:37

1.5K0

修改于 2021-12-13 00:18:37

文章被收录于专栏：开源 & 技术分享

介绍

本文介绍如何通过 rk-boot 在一个进程里启动多个 gRPC 端口。

为什么要启动多个端口？
大部分情况下，我们是不需要的。如果我们希望在一个进程里通过 flag 启动不同端口时，会用到。
我们会在下面的例子里给出用法。

请访问如下地址获取完整教程：

https://rkdev.info/cn
https://rkdocs.netlify.app/cn (备用)

安装

go get github.com/rookie-ninja/rk-boot
go get github.com/rookie-ninja/rk-grpc

快速开始

1.创建 boot.yaml

为了验证，我们启动了 commonService，commonService 里包含了一系列常用 API，例如 /rk/v1/healthy。

---
grpc:
  - name: alice
    port: 1949
    enabled: true
    commonService:
      enabled: true
  - name: bob
    port: 2008
    enabled: true
    commonService:
      enabled: true

2.创建 main.go

通过 boot.GetGrpcEntry("xxx") 来获取 gRPCEntry 进行 API 注册等操作。

package main

import (
	"context"
	"github.com/rookie-ninja/rk-boot"
	"github.com/rookie-ninja/rk-grpc/boot"
)

func main() {
	// Create a new boot instance.
	boot := rkboot.NewBoot()

	// Get alice Entry via: 
	boot.GetEntry("alice").(*rkgrpc.GrpcEntry)
	// 
	// Get bob Entry via: 
	boot.GetEntry("bob").(*rkgrpc.GrpcEntry)

	// Bootstrap
	boot.Bootstrap(context.Background())
	
	// Wait for shutdown sig
	boot.WaitForShutdownSig(context.Background())
}

3.文件夹结构

$ tree
.
├── boot.yaml
├── go.mod
├── go.sum
└── main.go

0 directories, 4 files

4.启动 main.go

$ go run main.go

5.验证

发送请求到 1949$ curl -X GET localhost:1949/rk/v1/healthy {"healthy":true}
发送请求到 2008$ curl -X GET localhost:2008/rk/v1/healthy {"healthy":true}

只启动 1949 端口

我们可以通过 --rkset 命令行参数来 disable 掉 2008 端口的 gRPC Entry。

boot.yaml 里 gRPC 是一个数组，所以使用 grpcx 来表示。

1.启动 main.go with --rkset

$ go build main.go
$ ./main --rkset "grpc[1].enabled=false"

2.验证

发送请求到 1949$ curl -X GET localhost:1949/rk/v1/healthy {"healthy":true}
发送请求到 2008$ curl -X GET localhost:2008/rk/v1/healthy curl: (7) Failed to connect to localhost port 2008: Connection refused