go-websocket
go-websocket copied to clipboard
etcd服务注册和发现
//监听续租情况
func (this *ServiceReg) ListenLeaseRespChan() {
for {
select {
case leaseKeepResp := <-this.keepAliveChan:
if leaseKeepResp == nil {
log.Error("已经关闭续租功能")
return
} else {
//log.Info("续租成功")
}
}
}
}
只是做到通知,假如A服务不提供了,grpc还是有可能调用到A这台服务器是吗,这里是否还要完善
//监听续租情况 func (this *ServiceReg) ListenLeaseRespChan() { for { select { case leaseKeepResp := <-this.keepAliveChan: if leaseKeepResp == nil { log.Error("已经关闭续租功能") return } else { //log.Info("续租成功") } } } }只是做到通知,假如A服务不提供了,grpc还是有可能调用到A这台服务器是吗,这里是否还要完善
点对点通知的时候,并没有用到etcd的服务发现,调度到crash的机器之后,只能发送失败;只有点对组的时候才从serverList里获取了信息。感觉etcd的作用并不大呢