金慶的專(zhuān)欄

net.LookupSRV()查詢(xún)k8s無(wú)頭服務(wù)

(金慶的專(zhuān)欄 2021.2)

如下創(chuàng)建 StatefulSet 和 Headless Service: test.yaml

```
apiVersion: v1
kind: Service
metadata:
  name: headless-svc
  labels:
    app: headless-svc
spec:
  ports:
  - port: 80
    name: aaaa
  - port: 20080
    name: bbbb
  selector:
    app: headless-pod
  clusterIP: None
 
---
apiVersion: apps/v1
kind: StatefulSet
metadata:
  name: statefulset-test
spec:
  serviceName: headless-svc
  replicas: 3
  selector:
    matchLabels:
      app: headless-pod
  template:
    metadata:
      labels:
        app: headless-pod
    spec:
      containers:
      - name: myhttpd
        image: httpd
        ports:
        - containerPort: 80
        - containerPort: 20080
```

部署：
```
kubectl apply -f test.yaml
```

然后開(kāi)一個(gè) shell:
```
kubectl run mygolang -it --image golang -- bash
If you don't see a command prompt, try pressing enter.
root@mygolang:/go#
```

先裝個(gè) vim:
```
apt install vim
```

然后寫(xiě)個(gè) golang 測(cè)試程序，向 DNS 查詢(xún) bbbb 服務(wù)的地址與端口：
```
root@mygolang:/jinqing# cat main.go
package main

import (
    "fmt"
    "github.com/davecgh/go-spew/spew"
    "net"
)

func main() {
    cname, addresses, err := net.LookupSRV("bbbb", "tcp", "headless-svc.default.svc.cluster.local")
    if err != nil {
        fmt.Printf("failed: %s\n", err)
    }
    fmt.Printf("cname: %s\n", cname)
    spew.Dump(addresses)
}
root@mygolang:/jinqing#
```

運(yùn)行結(jié)果為：
```
cname: _bbbb._tcp.headless-svc.default.svc.cluster.local.
([]*net.SRV) (len=3 cap=4) {
 (*net.SRV)(0xc00000e220)({
  Target: (string) (len=58) "statefulset-test-0.headless-svc.default.svc.cluster.local.",
  Port: (uint16) 20080,
  Priority: (uint16) 0,
  Weight: (uint16) 33
 }),
 (*net.SRV)(0xc00000e1e0)({
  Target: (string) (len=58) "statefulset-test-2.headless-svc.default.svc.cluster.local.",
  Port: (uint16) 20080,
  Priority: (uint16) 0,
  Weight: (uint16) 33
 }),
 (*net.SRV)(0xc00000e200)({
  Target: (string) (len=58) "statefulset-test-1.headless-svc.default.svc.cluster.local.",
  Port: (uint16) 20080,
  Priority: (uint16) 0,
  Weight: (uint16) 33
 })
}
```

多次運(yùn)行發(fā)現(xiàn)結(jié)果項(xiàng)次序固定，并沒(méi)有按權(quán)重隨機(jī)。

Service yaml 定義中，必須為每個(gè)端口命名，不然沒(méi)法查詢(xún)。

```
    cname, addresses, err := net.LookupSRV("bbbb", "tcp", "headless-svc.default.svc.cluster.local")
```
可利用默認(rèn)域名后綴簡(jiǎn)寫(xiě)為
```
    cname, addresses, err := net.LookupSRV("bbbb", "tcp", "headless-svc")
```
輸出相同。