type Ping struct {
 
 }
 
 //接口：/Ping/Push
 func (ping *Ping) Push(ctx context.Context, req *pb.PingReq) (*pb.PingResq, error) {
 	return &pb.PingResq{Msg: "pong:" + req.Msg}, nil
 }

const port = 9527

func main() {
	server := grpc.NewServer()
	log := new(grpcServer.LogDefault)
	rpcServer := grpcServer.NewRpcRegister(server, log)

	ht := &Ping{}
	rpcServer.Register(ht)

	if err := server.Serve(createListener(port)); err != nil {
		fmt.Println("grpc server start err", err.Error())
	}
}

func createListener(port int) net.Listener {
	lis, err := net.Listen("tcp", fmt.Sprintf(":%d", port))
	if err != nil {
		panic(err.Error())
	}

	return lis
}