servicerd/server/serverLoadService.go

package main

import (
	"app.yhyue.com/BP/servicerd/proto"
	"log"
)

/**
服务器load监控服务
*/
type ServerLoad struct {
}

//客户端单向流，作为服务端，仅仅需要持续接受数据即可
func (s *ServerLoad) PutStream(cliStr proto.ServerLoad_PutStreamServer) error {
	for {
		if tem, err := cliStr.Recv(); err == nil {
			log.Printf("Server Load1 %s--%f \n", tem.Ip, tem.Load)
			UpdateServerLoad(tem.Ip, tem.Load)
		} else {
			log.Println("break, err :", err)
			break
		}
	}
	return nil
}