liuxiaolong
2019-07-01 322b358914357839fdc6b2c4d1d45fe4a2a6978b
fix url
1个文件已修改
4 ■■■■ 已修改文件
cache/cache.go 4 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
cache/cache.go
@@ -20,8 +20,8 @@
func Init(initChan chan bool,dbIp string,surveyPort int,pubSubPort int){
    urlSurvey := "tcp://" + dbIp + strconv.Itoa(surveyPort)
    urlPubSub := "tcp://" + dbIp + strconv.Itoa(pubSubPort)
    urlSurvey := "tcp://" + dbIp + ":" + strconv.Itoa(surveyPort)
    urlPubSub := "tcp://" + dbIp + ":" + strconv.Itoa(pubSubPort)
    client, _ := gopherdiscovery.ClientWithSub(urlSurvey, urlPubSub, uuid.NewV4().String())
    recvMsg := client.HeartBeatMsg()
    fmt.Println(<-recvMsg)