和大象装冰箱一样：开发gRPC总共分三步 【掘金签约文章】

syntax = "proto3";

option go_package = "./;hello";

package hello;

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

message HelloRequest {
string name = 1;
}

message HelloReply {
string message = 1;
}

cd protos/helloword/

protoc --go_out=. helloworld.proto

go mod tidy

package greeter_server

import "context"

//导入我们在protos文件中定义的服务
import pb "juejin/rpc/protos/helloworld"

//定义一个结构体，作用是实现helloworld中的GreeterServer
type server struct{}

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

go get google.golang.org/grpc

package main

import (
   "context"
   "flag"
   "fmt"
   "google.golang.org/gRPC"
   "log"
   "net"
)

//导入我们在protos文件中定义的服务
import pb "juejin/rpc/protos/helloworld"

//定义一个结构体，作用是实现helloworld中的GreeterServer
type server struct {
   pb.UnimplementedGreeterServer
}

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

//定义端口号 支持启动的时候输入端口号
var (
   port = flag.Int("port", 50051, "The server port")
)

func main() {
   //解析输入的端口号 默认50051
   flag.Parse()
   //tcp协议监听指定端口号
   lis, err := net.Listen("tcp", fmt.Sprintf(":%d", *port))
   if err != nil {
      log.Fatalf("failed to listen: %v", err)
   }
   //实例化gRPC服务
   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"
   "flag"
   "google.golang.org/gRPC" //这个依赖不要搞错
   "google.golang.org/gRPC/credentials/insecure"
   pb "juejin/rpc/protos/helloworld"
   "log"
   "time"
)

//默认数据 也支持在控制台自定义
const (
   defaultName = "world"
)

//监听地址和传入的name
var (
   addr = flag.String("addr", "localhost:50051", "the address to connect to")
   name = flag.String("name", defaultName, "Name to greet")
)

func main() {
   flag.Parse()
   //通过gRPC.Dial()方法建立服务连接
   conn, err := gRPC.Dial(*addr, gRPC.WithTransportCredentials(insecure.NewCredentials()))
   if err != nil {
      log.Fatalf("did not connect: %v", err)
   }
   //连接要记得关闭
   defer func(conn *gRPC.ClientConn) {
      err := conn.Close()
      if err != nil {

      }
   }(conn)
   //实例化客户端连接
   c := pb.NewGreeterClient(conn)

   //设置请求上下文，因为是网络请求，我们需要设置超时时间
   ctx, cancel := context.WithTimeout(context.Background(), time.Second)
   defer cancel()
   //客户端调用在proto中定义的SayHello()rpc方法，发起请求，接收服务端响应
   r, err := c.SayHello(ctx, &pb.HelloRequest{Name: *name})
   if err != nil {
      log.Fatalf("could not greet: %v", err)
   }
   log.Printf("Greeting: %s", r.GetMessage())
}

name = flag.String("name", "world", "Name to greet")

go run main.go --name 王中阳

protoc-gen-php -i . -o . ./helloworld.proto

<?php
//命名空间
namespace Helloworld;

//定义PHP客户端
class GreeterClient extends \gRPC\BaseStub
{

  //定义构造方法
  public function __construct($hostname, $opts, $channel = null)
  {
    parent::__construct($hostname, $opts, $channel);
  }

  /**
   * 实现proto文件中定义的SayHello()方法
   * Sends a greeting
   * @param \Helloworld\HelloRequest $argument input argument
   * @param array $metadata metadata
   * @param array $options call options
   * @return \gRPC\UnaryCall
   */
  public function SayHello(\Helloworld\HelloRequest $argument,
                           $metadata = [], $options = [])
  {
    return $this->_simpleRequest('/helloworld.Greeter/SayHello',
      $argument,
      ['\Helloworld\HelloReply', 'decode'],
      $metadata, $options);
  }

}

<?php
require dirname(__FILE__).'/vendor/autoload.php';

function greet($hostname, $name)
{
    $client = new Helloworld\GreeterClient($hostname, [
        'credentials' => gRPC\ChannelCredentials::createInsecure(),
    ]);
    $request = new Helloworld\HelloRequest();
    $request->setName($name);
    list($response, $status) = $client->SayHello($request)->wait();
    if ($status->code !== gRPC\STATUS_OK) {
        echo "ERROR: " . $status->code . ", " . $status->details . PHP_EOL;
        exit(1);
    }
    echo $response->getMessage() . PHP_EOL;
}

$name = !empty($argv[1]) ? $argv[1] : 'world';
$hostname = !empty($argv[2]) ? $argv[2] : 'localhost:50051';
greet($hostname, $name);