日本免费久久久久久久网站,性高湖久久久久久久久AAAAA,欧美久久综合性欧美

grpc中的dns負(fù)載均衡

grpc中的dns負(fù)載均衡

(金慶的專欄 2018.8)

grpc-go 中如下連接服務(wù)器，請(qǐng)求將在多個(gè)IP之間輪轉(zhuǎn)。

    conn, err := grpc.Dial(
       "dns:///rng-headless:8081",
       grpc.WithBalancerName(roundrobin.Name),
       grpc.WithInsecure())

標(biāo)準(zhǔn)的目標(biāo)名應(yīng)該是這樣的：`"dns://authority/endpoint_name"`,
此處 authority 為空，詳見：https://github.com/grpc/grpc/blob/master/doc/naming.md

服務(wù)器開3個(gè)實(shí)例，所有請(qǐng)求在3個(gè)實(shí)例上輪轉(zhuǎn)：

[jinqing@host-10-2-3-4 RoundRobin]$ kubectl run -it --rm jinqing-roundrobin --image=jinq0123/roundrobin:4
If you don't see a command prompt, try pressing enter.
2018/08/28 10:18:01 request 7754383576636566559
2018/08/28 10:18:02 request 2543876599219675746
2018/08/28 10:18:03 request 927204261937181213
2018/08/28 10:18:04 request 7754383576636566559
2018/08/28 10:18:05 request 2543876599219675746
2018/08/28 10:18:06 request 927204261937181213
...

服務(wù)器返回一個(gè)隨機(jī)數(shù)，不同實(shí)例的隨機(jī)數(shù)不同。代碼是從
https://github.com/kcollasarundell/balancing-on-k8s 修改的。

...
const (
        port = ":8081"
)

type server struct{}

var r int64

func init(){
    rand.Seed(time.Now().UnixNano())
    r = rand.Int63()
}

func (s *server) Rng(context.Context, *rng.Source) (*rng.RN, error) {
        return &rng.RN{RN: r}, nil
}

func main() {
        lis, err := net.Listen("tcp", port)
        if err != nil {
                log.Fatalf("failed to listen: %v", err)
        }
        s := grpc.NewServer()
        rng.RegisterRngServer(s, &server{})
        // Register reflection service on gRPC server.
        reflection.Register(s)

        if err := s.Serve(lis); err != nil {
                log.Fatalf("failed to serve: %v", err)
        }
}

先編譯，打包成鏡像，然后用 `balancing-on-k8s\backend\kube.yaml` 運(yùn)行：
kubectl apply -f kube.yaml

`backend\kube.yaml` 創(chuàng)建了一個(gè) ClusterIP 服務(wù)和一個(gè) Headless 服務(wù)，部署了 3 個(gè)服務(wù)器實(shí)例。
[jinqing@host-10-2-3-4 RoundRobin]$ kubectl get svc
NAME           TYPE        CLUSTER-IP      EXTERNAL-IP   PORT(S)             AGE
kubernetes     ClusterIP   10.96.0.1       <none>        443/TCP             93d
rng-cluster    ClusterIP   10.111.30.205   <none>        8081/TCP            4h
rng-headless   ClusterIP   None            <none>        8081/TCP,8080/TCP   4h

客戶端是一個(gè)簡單的grpc, 定時(shí)發(fā)送請(qǐng)求，打印返回的隨機(jī)數(shù)。
`balancing-on-k8s\clientSideBalancer\RoundRobin\main.go`中的地址需要添加端口，
不然grpc會(huì)去連接 443 端口而失敗。

擴(kuò)容后，測到大概3分鐘后才看到負(fù)載轉(zhuǎn)移。縮容后會(huì)立即生效。
kubectl scale --replicas=5 deployment/rng

如果是 ClusterIP 服務(wù), 則服務(wù)名對(duì)應(yīng)一個(gè)ClusterIP;
如果是 Headless 服務(wù)，則服務(wù)名對(duì)應(yīng)各個(gè)Pod的IP:

/ # nslookup rng-headless
Server:         10.96.0.10
Address:        10.96.0.10#53

Name:   rng-headless.default.svc.cluster.local
Address: 10.244.3.27
Name:   rng-headless.default.svc.cluster.local
Address: 10.244.0.108
Name:   rng-headless.default.svc.cluster.local
Address: 10.244.2.66

/ # nslookup rng-cluster
Server:         10.96.0.10
Address:        10.96.0.10#53

Name:   rng-cluster.default.svc.cluster.local
Address: 10.111.30.205

/ #

如果去除 "dns:///", 僅僅是域名加端口：

conn, err := grpc.Dial(
       "rng-headless:8081",
       grpc.WithBalancerName(roundrobin.Name),
       ...

則只會(huì)請(qǐng)求同一個(gè)實(shí)例。只有當(dāng)該實(shí)例pod被刪除后才會(huì)切換到另一個(gè)實(shí)例。
使用縮容時(shí)發(fā)現(xiàn)會(huì)優(yōu)先刪除沒有客戶端連接的實(shí)例。
用2個(gè)客戶端連接到不同服務(wù)器實(shí)例，然后縮容為1實(shí)例，就可以看到請(qǐng)求切換。

如果客戶端和服務(wù)器數(shù)量很大，這個(gè)dns負(fù)載均衡就不合適了，因?yàn)榭蛻舳藭?huì)連接每個(gè)服務(wù)器實(shí)例。

參考：
Exploring Kubernetes Service Discovery and loadbalancing ( https://kca.id.au/post/k8s_service/ )

posted on 2018-08-29 10:59 金慶閱讀(1667) 評(píng)論(0) 編輯收藏引用所屬分類: 3. Golang

只有注冊(cè)用戶登錄后才能發(fā)表評(píng)論。
【推薦】100%開源！大型工業(yè)跨平臺(tái)軟件C++源碼提供，建模，組態(tài)！

相關(guān)文章: net.LookupSRV()查詢k8s無頭服務(wù) rpc應(yīng)答太快造成請(qǐng)求超時(shí) golang各數(shù)值類型的最大最小值參數(shù)太靈活容易出錯(cuò) grpc外部負(fù)載均衡器測試數(shù)組make參數(shù)錯(cuò)誤 go不要導(dǎo)出channel go代碼覆蓋測試考察go一致性hash庫將go函數(shù)指針轉(zhuǎn)為接口

網(wǎng)站導(dǎo)航: 博客園 IT新聞 BlogJava 博問 Chat2DB 管理

金慶的專欄

公告

留言簿(12)

隨筆分類(502)

隨筆檔案(423)

相冊(cè)

搜索

積分與排名

最新評(píng)論

閱讀排行榜

評(píng)論排行榜