Golang微服务通信失败怎么办？GolangRPC框架使用教程

syntax = "proto3";

package proto;

service Greeter {
  rpc SayHello (HelloRequest) returns (HelloReply) {}
}

message HelloRequest {
  string name = 1;
}

message HelloReply {
  string message = 1;
}

protoc --go_out=. --go_opt=paths=source_relative --go-grpc_out=. --go-grpc_opt=paths=source_relative your_proto_file.proto

package main

import (
    "context"
    "log"
    "net"

    pb "your_proto_package" // 替换为你的proto包名
    "google.golang.org/grpc"
)

type server struct {
    pb.UnimplementedGreeterServer
}

func (s *server) SayHello(ctx context.Context, req *pb.HelloRequest) (*pb.HelloReply, error) {
    return &pb.HelloReply{Message: "Hello " + req.Name}, nil
}

func main() {
    lis, err := net.Listen("tcp", ":50051")
    if err != nil {
        log.Fatalf("failed to listen: %v", err)
    }
    s := grpc.NewServer()
    pb.RegisterGreeterServer(s, &server{})
    log.Printf("server listening at %v", lis.Addr())
    if err := s.Serve(lis); err != nil {
        log.Fatalf("failed to serve: %v", err)
    }
}

package main

import (
    "context"
    "log"
    "time"

    pb "your_proto_package" // 替换为你的proto包名
    "google.golang.org/grpc"
)

func main() {
    conn, err := grpc.Dial("localhost:50051", grpc.WithInsecure(), grpc.WithBlock())
    if err != nil {
        log.Fatalf("did not connect: %v", err)
    }
    defer conn.Close()
    c := pb.NewGreeterClient(conn)

    ctx, cancel := context.WithTimeout(context.Background(), time.Second)
    defer cancel()
    r, err := c.SayHello(ctx, &pb.HelloRequest{Name: "World"})
    if err != nil {
        log.Fatalf("could not greet: %v", err)
    }
    log.Printf("Greeting: %s", r.Message)
}

package main

import (
    "context"
    "log"

    "go-micro.dev/v4"
    "go-micro.dev/v4/server"
)

type Greeter struct{}

func (g *Greeter) Hello(ctx context.Context, req *string, rsp *string) error {
    *rsp = "Hello " + *req
    return nil
}

func main() {
    srv := micro.NewService(
        micro.Name("greeter"),
        micro.Version("latest"),
    )

    srv.Init()

    if err := srv.Server().Handle(
        srv.Server().NewHandler(
            new(Greeter),
            server.WithEndpoint(&server.Endpoint{
                Name:    "Greeter.Hello",
                Handler: "Greeter.Hello",
            }),
        ),
    ); err != nil {
        log.Fatal(err)
    }

    if err := srv.Run(); err != nil {
        log.Fatal(err)
    }
}

package main

import (
    "context"
    "fmt"
    "log"

    "go-micro.dev/v4"
)

func main() {
    srv := micro.NewService()
    srv.Init()

    greeter := srv.Client()

    req := greeter.NewRequest("greeter", "Greeter.Hello", "World")

    var rsp string

    if err := greeter.Call(context.Background(), req, &rsp); err != nil {
        log.Fatal(err)
    }

    fmt.Println(rsp)
}

// 示例：使用grpc-go提供的重试机制
conn, err := grpc.Dial("localhost:50051", grpc.WithInsecure(),
    grpc.WithUnaryInterceptor(grpc_retry.UnaryClientInterceptor(
        grpc_retry.WithMax(5), // 最大重试次数
        grpc_retry.WithBackoff(grpc_retry.BackoffLinear(100*time.Millisecond)), // 重试间隔
    )),
)
if err != nil {
    log.Fatalf("did not connect: %v", err)
}
defer conn.Close()