|
@@ -10,12 +10,13 @@ import (
|
|
|
"github.com/shirou/gopsutil/load"
|
|
|
"google.golang.org/grpc"
|
|
|
_ "google.golang.org/grpc/balancer/grpclb"
|
|
|
+ "log"
|
|
|
"time"
|
|
|
)
|
|
|
|
|
|
var (
|
|
|
rdServer = flag.String("rd", "127.0.0.1:10021", "服务治理服务器地址")
|
|
|
- localIp = flag.String("lip", "192.168.3.100", "注册到服务的本机IP")
|
|
|
+ localIp = flag.String("lip", "192.168.20.100", "注册到服务的本机IP")
|
|
|
interval = flag.Int64("interval", 60, "上报时间间隔(Load1=1分钟,太小无意义)")
|
|
|
)
|
|
|
|
|
@@ -38,6 +39,7 @@ func uploadServerLoad() {
|
|
|
select {
|
|
|
case <-tm.C:
|
|
|
l, _ := load.Avg()
|
|
|
+ log.Println("load1", l.Load1)
|
|
|
reqstreamData := &proto.ServerLoadStreamReqData{Ip: *localIp, Load: l.Load1}
|
|
|
_ = resp.Send(reqstreamData)
|
|
|
}
|