k8s连接内部mysql_k8s使用外部mysql做内部服务

创建 mysql-endpoints.yaml

apiVersion: v1

kind: Endpoints

metadata:

name: mysql-dev

namespace: default

subsets:

- addresses:

- ip: 10.1.0.32

ports:

- port: 3306

创建mysql-service.yaml

apiVersion: v1

kind: Service

metadata:

name: mysql-dev

spec:

ports:

- port: 3306

apiVersion: v1

kind: Service

metadata:

name: mysql-dev

namespace: default

spec:

clusterIP: 10.1.61.45

ports:

- port: 3306

targetPort: 3306

protocol: TCP

使用数据库服务

main.go

package main

import (

"database/sql"

"fmt"

_ "github.com/go-sql-driver/mysql"

"net/http"

)

func IndexHandler(w http.ResponseWriter, r *http.Request) {

_, _ &＃61; fmt.Fprintln(w, "hello rushui")

}

func RowsHandler(w http.ResponseWriter, r *http.Request) {

//第⼀步&＃xff1a;打开数据库,格式是 ⽤户名&＃xff1a;密码&＃64;/数据库名称&＃xff1f;编码⽅式

db, err :&＃61; sql.Open("mysql", "root:root&＃64;tcp(mysql-dev:3306)/test?charset&＃61;utf8")

if err !&＃61; nil {

fmt.Println(err)

}

//关闭数据库

var id int

var name string

//查询数据&＃xff0c;指定字段名&＃xff0c;返回sql.Rows结果集

rows, err :&＃61; db.Query("select id,name from user")

if err !&＃61; nil {

fmt.Println(err)

}

defer rows.Close()

for rows.Next() {

_ &＃61; rows.Scan(&id, &name)

_, _ &＃61; fmt.Fprintln(w, name)

}

}

func main() {

http.HandleFunc("/", IndexHandler)

http.HandleFunc("/rows", RowsHandler)

_ &＃61; http.ListenAndServe(":8081", nil)

}