1. 基本操作测试

简单的例子来测试下基本的操作：

  1. package main
  3. /**
  4. 客户端doc地址：github.com/samuel/go-zookeeper/zk
  5. **/
  6. import (
  7.     "fmt"
  8.     "time"
  10.     zk "github.com/samuel/go-zookeeper/zk"
  11. )
  13. /**
  14.  * 获取一个zk连接
  15.  * @return {[type]}
  16.  */
  17. func getConnect(zkList []string) (conn *zk.Conn) {
  18.     conn, _, err := zk.Connect(zkList, 10*time.Second)
  19.     if err != nil {
  20.         fmt.Println(err)
  21.     }
  22.     return
  23. }
  25. /**
  26.  * 测试连接
  27.  * @return
  28.  */
  29. func test1() {
  30.     zkList := []string{"localhost:2181"}
  31.     conn := getConnect(zkList)
  33.     defer conn.Close()
  34.     var flags int32 = 0
  35.     //flags有4种取值：
  36.     //0:永久，除非手动删除
  37.     //zk.FlagEphemeral = 1:短暂，session断开则改节点也被删除
  38.     //zk.FlagSequence  = 2:会自动在节点后面添加序号
  39.     //3:Ephemeral和Sequence，即，短暂且自动添加序号
  40.     conn.Create("/go_servers", nil, flags, zk.WorldACL(zk.PermAll)) // zk.WorldACL(zk.PermAll)控制访问权限模式
  42.     time.Sleep(20 * time.Second)
  43. }
  45. /*
  46. 删改与增不同在于其函数中的version参数,其中version是用于 CAS支持
  47. func (c *Conn) Set(path string, data []byte, version int32) (*Stat, error)
  48. func (c *Conn) Delete(path string, version int32) error
  50. demo：
  51. if err = conn.Delete(migrateLockPath, -1); err != nil {
  52.     log.Error("conn.Delete(\"%s\") error(%v)", migrateLockPath, err)
  53. }
  54. */
  56. /**
  57.  * 测试临时节点
  58.  * @return {[type]}
  59.  */
  60. func test2() {
  61.     zkList := []string{"localhost:2181"}
  62.     conn := getConnect(zkList)
  64.     defer conn.Close()
  65.     conn.Create("/testadaadsasdsaw", nil, zk.FlagEphemeral, zk.WorldACL(zk.PermAll))
  67.     time.Sleep(20 * time.Second)
  68. }
  70. /**
  71.  * 获取所有节点
  72.  */
  73. func test3() {
  74.     zkList := []string{"localhost:2181"}
  75.     conn := getConnect(zkList)
  77.     defer conn.Close()
  79.     children, _, err := conn.Children("/go_servers")
  80.     if err != nil {
  81.         fmt.Println(err)
  82.     }
  83.     fmt.Printf("%v \n", children)
  84. }
  86. func main() {
  87.     test3()
  88. }