32 lines
770 B
Go
32 lines
770 B
Go
package main
|
|
|
|
import (
|
|
"context"
|
|
"time"
|
|
|
|
log "github.com/sirupsen/logrus"
|
|
"google.golang.org/grpc"
|
|
"myschools.me/suguo/consul-demo/consul"
|
|
pb "myschools.me/suguo/consul-demo/proto"
|
|
)
|
|
|
|
func main() {
|
|
consul.FindServer()
|
|
ctx, cancel := context.WithTimeout(context.Background(), 5*time.Second)
|
|
conn, err := grpc.DialContext(ctx, "consul://192.168.8.254:8500/demo", grpc.WithBlock(), grpc.WithInsecure(), grpc.WithBalancerName("round_robin"))
|
|
if err != nil {
|
|
cancel()
|
|
}
|
|
defer conn.Close()
|
|
c := pb.NewHelloClient(conn)
|
|
resp, err := c.Say(ctx, &pb.SayRequest{Name: "jiale", Day: "2008-08-08"})
|
|
if err != nil {
|
|
log.WithFields(log.Fields{
|
|
"func": "main",
|
|
}).Errorf("%v", err)
|
|
}
|
|
log.WithFields(log.Fields{
|
|
"func": "main",
|
|
}).Infof("%s", resp.Reply)
|
|
}
|