簡單的例子來測試下基本的操作： ~~~ package main /** 客戶端doc地址：github.com/samuel/go-zookeeper/zk **/ import ( "fmt" "time" zk "github.com/samuel/go-zookeeper/zk" ) /** * 獲取一個zk連接 * @return {[type]} */ func getConnect(zkList []string) (conn *zk.Conn) { conn, _, err := zk.Connect(zkList, 10*time.Second) if err != nil { fmt.Println(err) } return } /** * 測試連接 * @return */ func test1() { zkList := []string{"localhost:2181"} conn := getConnect(zkList) defer conn.Close() var flags int32 = 0 //flags有4種取值： //0:永久，除非手動刪除 //zk.FlagEphemeral = 1:短暫，session斷開則改節點也被刪除 //zk.FlagSequence = 2:會自動在節點后面添加序號 //3:Ephemeral和Sequence，即，短暫且自動添加序號 conn.Create("/go_servers", nil, flags, zk.WorldACL(zk.PermAll)) // zk.WorldACL(zk.PermAll)控制訪問權限模式 time.Sleep(20 * time.Second) } /* 刪改與增不同在于其函數中的version參數,其中version是用于 CAS支持 func (c *Conn) Set(path string, data []byte, version int32) (*Stat, error) func (c *Conn) Delete(path string, version int32) error demo： if err = conn.Delete(migrateLockPath, -1); err != nil { log.Error("conn.Delete(\"%s\") error(%v)", migrateLockPath, err) } */ /** * 測試臨時節點 * @return {[type]} */ func test2() { zkList := []string{"localhost:2181"} conn := getConnect(zkList) defer conn.Close() conn.Create("/testadaadsasdsaw", nil, zk.FlagEphemeral, zk.WorldACL(zk.PermAll)) time.Sleep(20 * time.Second) } /** * 獲取所有節點 */ func test3() { zkList := []string{"localhost:2181"} conn := getConnect(zkList) defer conn.Close() children, _, err := conn.Children("/go_servers") if err != nil { fmt.Println(err) } fmt.Printf("%v \n", children) } func main() { test3() } ~~~