测试镜像的代码和DockerFile一般位于kubernetes/test/images
1.serve_hostname
路径:gcr.io/google_containers/serve_hostname:v1.4
功能:通过flag控制使用tcp、udp、http模式返回hostname
使用：
使用docker命令的方式
docker run -p 9376:9376 gcr.io/google_containers/serve_hostname:v1.4 -tcp=true -udp=false -http=false
TCP
# telnet 127.0.0.1 9376
Trying 127.0.0.1...
Connected to 127.0.0.1.
Escape character is '^]'.
ff640c2df975
Connection closed by foreign host.
这个是TCP短连接，长连接的测试可以找个mysql的镜像来完成
HTTP
# curl 127.0.0.1:9376
ff640c2df975
root@opama-HP-EliteBook-8560w:/home/opama/workspace/k8s/src/k8s.io/kubernetes# docker ps
CONTAINER ID IMAGE COMMAND CREATED STATUS PORTS NAMES
ff640c2df975 gcr.io/google_containers/serve_hostname:v1.4 "/serve_hostname -tcp" 15 minutes ago Up 15 minutes 0.0.0.0:9376->9376/tcp modest_kowalevski
UDP:
启动命令需要改变一下
docker run -p 9376:9376/udp gcr.io/google_containers/serve_hostname:v1.4 -tcp=false -udp=true -http=false
自己用go简单写个clientudp_client.go
package main
import (
"fmt"
"net"
"os"
)
func main() {
// 获取输入
input := os.Args[1]
// 创建连接
socket, err := net.DialUDP("udp4", nil, &net.UDPAddr{
IP: net.IPv4(127, 0, 0, 1),//modify
Port: 9376,//modify
})
if err != nil {
fmt.Println("连接失败!", err)
return
}
defer socket.Close()
// 发送数据
fmt.Printf("发送数据:%s
", input)
senddata := []byte(input)
_, err = socket.Write(senddata)
if err != nil {
fmt.Println("发送数据失败!", err)
return
}
// 接收数据
data := make([]byte, 4096)
read, remoteAddr, err := socket.ReadFromUDP(data)
if err != nil {
fmt.Println("读取数据失败!", err)
return
}
fmt.Println(read, remoteAddr)
fmt.Printf("%s
", data)
}
执行udp发包:
# go run udp_client.go
13 127.0.0.1:9376
3a323826364f
或
go build -ldflags "-s -w"
./udp_client 11111
YAML样例
apiVersion: extensions/v1beta1
kind: Deployment
metadata:
name: servehostname-deployment
labels:
name: servehostname
spec:
replicas: 1
selector:
matchLabels:
name: servehostname
template:
metadata:
labels:
name: servehostname
spec:
containers:
- image: gcr.io/google_containers/serve_hostname:v1.4
args: ["-tcp=true","-http=false","-udp=false"]
imagePullPolicy: IfNotPresent
name: servehostname
ports:
- containerPort: 9376
protocol: TCP
resources: {}
terminationMessagePath: /dev/termination-log
若想使用env的方式，可以修改原有serve_hostname.go文件
func getEnvValueBool(name string,orin bool) bool{
if os.Getenv(name) == "true" {
return true
}
if os.Getenv(name) == "false" {
return false
}
return orin
}
func getEnvValueInt(name string,orin int) int{
if os.Getenv(name) != "" {
value, _ := strconv.Atoi(os.Getenv(name))
return value
}
return orin
}
func main() {
flag.Parse()
*doTCP = getEnvValueBool("mytcp",*doTCP)
*doUDP = getEnvValueBool("myudp",*doUDP)
*doHTTP = getEnvValueBool("myhttp",*doHTTP)
*port = getEnvValueInt("myport",*port
2.clusterapi-tester
路径：gcr.io/google_containers/clusterapi-tester:1.0
功能：在pod里使用serviceAccount访问apiserver，主要逻辑：
1.从pod的环境变量里获取KUBERNETES_SERVICE_HOST和KUBERNETES_SERVICE_PORT
2.获取/var/run/secrets/kubernetes.io/serviceaccount/下的token
3.带token访问https://host+port
4.去做list node，list service等操作，访问成功则起一个8080端口，设置的健康检查成功，失败则健康检查失败
使用：
YAML样例
apiVersion: v1 kind: Pod metadata: name: clusterapi-tester spec: containers: - image: gcr.io/google_containers/clusterapi-tester:1.0 name: clusterapi-tester readinessProbe: httpGet: path: /healthz port: 8080 scheme: HTTP initialDelaySeconds: 10 timeoutSeconds: 5 failureThreshold: 3 periodSeconds: 10 successThreshold: 1 restartPolicy: OnFailure
实际使用时可去容器里查看env，这里local起的访问不通KUBERNETES_PORT
# docker exec -it fd0eb9f6d3a6 /bin/sh / # env KUBERNETES_PORT=tcp://10.0.0.1:443 KUBERNETES_SERVICE_PORT=443 HOSTNAME=clusterapi-tester SHLVL=1 HOME=/root KUBERNETES_PORT_443_TCP_ADDR=10.0.0.1 PATH=/usr/local/sbin:/usr/local/bin:/usr/sbin:/usr/bin:/sbin:/bin KUBERNETES_PORT_443_TCP_PORT=443 KUBERNETES_PORT_443_TCP_PROTO=tcp KUBERNETES_PORT_443_TCP=tcp://10.0.0.1:443 KUBERNETES_SERVICE_PORT_HTTPS=443 PWD=/ KUBERNETES_SERVICE_HOST=10.0.0.1 / # ping 10.0.0.1 PING 10.0.0.1 (10.0.0.1): 56 data bytes
访问失败，pod重启
6m 30s 6 {kubelet 127.0.0.1} spec.containers{clusterapi-tester} Normal Pulled Container image "gcr.io/google_containers/clusterapi-tester:1.0" already present on machine 30s 30s 1 {kubelet 127.0.0.1} spec.containers{clusterapi-tester} Normal Created Created container with docker id aa9a0151abd8 30s 30s 1 {kubelet 127.0.0.1} spec.containers{clusterapi-tester} Normal Started Started container with docker id aa9a0151abd8 5m 7s 13 {kubelet 127.0.0.1} spec.containers{clusterapi-tester} Warning Unhealthy Readiness probe failed: Get http://172.17.0.2:8080/healthz: dial tcp 172.17.0.2:8080: getsockopt: connection refused
对于serviceAccount的使用可以见http://www.jianshu.com/p/415c5fc6ddcf