Etcd

发布者

package main
import (
    "flag"
    "fmt"
    "log"
    "time"
    "github.com/tal-tech/go-zero/core/discov"
)
/*
    函数flag.StringVar接受 4 个参数
        第 1 个参数是用于存储该命令参数值的地址，具体到这里就是在前面声明的变量name的地址了，由表达式&name表示。
        第 2 个参数是为了指定该命令参数的名称，这里是name。
        第 3 个参数是为了指定在未追加该命令参数时的默认值，这里是everyone。
        至于第 4 个函数参数，即是该命令参数的简短说明了，这在打印命令说明时会用到。
     go run .\pub.go -v=EdcdTest
*/
var value = flag.String("v", "value", "the value")
func main() {
    flag.Parse()
    client := discov.NewPublisher([]string{"127.0.0.1:2379"}, "028F2C35852D", *value)
    if err := client.KeepAlive(); err != nil {
        log.Fatal(err)
    }
    defer client.Stop()
    for {
        time.Sleep(time.Second)
        fmt.Println(*value)
    }
}

PS D:\Projects\Github\NoobWu\zero-examples\etcd\pub> go run .\pub.go -v=EdcdTest

订阅

package main
import (
    "fmt"
    "time"
    "github.com/tal-tech/go-zero/core/discov"
    "github.com/tal-tech/go-zero/core/logx"
)
func main() {
    sub, err := discov.NewSubscriber([]string{"127.0.0.1:2379"}, "028F2C35852D", discov.Exclusive())
    logx.Must(err)
    ticker := time.NewTicker(time.Second * 3)
    defer ticker.Stop()
    for {
        select {
        case <-ticker.C:
            fmt.Println("values:", sub.Values())
        }
    }
}

PS D:\Projects\Github\NoobWu\zero-examples\etcd\sub> go run .\sub.go

原文链接

https://github.com/zeromicro/zero-examples/tree/main/etcd

d