gogrpc设置返回头信息_demo4grpc

brew install protobuf

go get -u google.golang.org/grpc

go get -u github.com/golang/protobuf/protoc-gen-go

protoc --proto_path hello/ --go_out&＃61;plugins&＃61;grpc:hello hello.proto

syntax &＃61; "proto3"; //语法声明package hello; //包名// 定义服务
service Greeter {rpc SayHello (HelloRequest) returns (HelloReply) {}
}// 请求数据格式
message HelloRequest {string name &＃61; 1;
}// 响应数据格式
message HelloReply {string message &＃61; 1;
}

// main.go
package mainimport ("context""log""net""google.golang.org/grpc"pb "local.com/sai/game/grpc/hello"
)const (port &＃61; ":50051"
)// server is used to implement helloworld.GreeterServer.
type server struct {pb.UnimplementedGreeterServer
}// SayHello implements helloworld.GreeterServer
func (s *server) SayHello(ctx context.Context, in *pb.HelloRequest) (*pb.HelloReply, error) {log.Printf("Received: %v", in.GetName())return &pb.HelloReply{Message: "Hello " &＃43; in.GetName()}, nil
}func main() {lis, err :&＃61; net.Listen("tcp", port)if err !&＃61; nil {log.Fatalf("failed to listen: %v", err)}s :&＃61; grpc.NewServer()pb.RegisterGreeterServer(s, &server{})if err :&＃61; s.Serve(lis); err !&＃61; nil {log.Fatalf("failed to serve: %v", err)}
}

// client.go
package mainimport ("context""log""os""time""google.golang.org/grpc"pb "local.com/sai/game/grpc/hello"
)const (address &＃61; "127.0.0.1:50051"defaultName &＃61; "13sai"
)func main() {// Set up a connection to the server.conn, err :&＃61; grpc.Dial(address, grpc.WithInsecure(), grpc.WithBlock())if err !&＃61; nil {log.Fatalf("did not connect: %v", err)}defer conn.Close()c :&＃61; pb.NewGreeterClient(conn)// Contact the server and print out its response.name :&＃61; defaultNameif len(os.Args) > 1 {name &＃61; os.Args[1]}ctx, cancel :&＃61; context.WithTimeout(context.Background(), time.Second)defer cancel()r, err :&＃61; c.SayHello(ctx, &pb.HelloRequest{Name: name})if err !&＃61; nil {log.Fatalf("could not greet: %v", err)}log.Printf("Greeting: %s", r.GetMessage())
}&＃96;

extension&＃61;grpc.so
extension&＃61;protobuf.so

protoc --php_out&＃61;client hello/hello.proto

require __DIR__ . &＃39;/vendor/autoload.php&＃39;;class Client extends GrpcBaseStub{public function __construct($hostname, $opts, $channel &＃61; null) {parent::__construct($hostname, $opts, $channel);}/*** rpc SayHello(HelloRequest) returns (HelloReply) {}* 方法名尽量和 (gprc 定义 Greeter 服务)的方法一样* 用于请求和响应该服务*/public function SayHello(HelloHelloRequest $argument){// (/hello.Greeter/SayHello) 是请求服务端那个服务和方法&＃xff0c;基本和 proto 文件定义一样return $this->_simpleRequest(&＃39;/hello.Greeter/SayHello&＃39;,$argument,[&＃39;HelloHelloReply&＃39;, &＃39;decode&＃39;]);}}//用于连接 服务端
$client &＃61; new Client(&＃39;127.0.0.1:50051&＃39;, [&＃39;credentials&＃39; &＃61;> GrpcChannelCredentials::createInsecure()
]);//实例化 TestRequest 请求类
$request &＃61; new HelloHelloRequest();
$request->setName("fairy");//调用远程服务
$get &＃61; $client->SayHello($request)->wait();//返回数组
//$reply 是 TestReply 对象
//$status 是数组
list($reply, $status) &＃61; $get;echo $reply->getMessage().PHP_EOL;
// print_r($client->SayHello($request));

git clone -b $(curl -L https://grpc.io/release) https://github.com/grpc/grpc
cd grpc
#这一步很慢&＃xff0c;暂未找到什么好方法
git submodule update --init
make grpc_php_plugin

protoc -I&＃61;./hello hello.proto --php_out&＃61;./php-client/ --grpc_out&＃61;php-client/ --plugin&＃61;protoc-gen-grpc&＃61;/Users/wangzetao/www/grpc1/bins/opt/grpc_php_plugin

// client.php
require __DIR__ . &＃39;/vendor/autoload.php&＃39;;//用于连接 服务端
$client &＃61; new HelloGreeterClient(&＃39;127.0.0.1:50051&＃39;, [&＃39;credentials&＃39; &＃61;> GrpcChannelCredentials::createInsecure()
]);//实例化 TestRequest 请求类
$request &＃61; new HelloHelloRequest();
$request->setName("world");//调用远程服务
$get &＃61; $client->SayHello($request)->wait();//返回数组
//$status 是数组
list($reply, $status) &＃61; $get;echo $reply->getMessage().PHP_EOL;
// print_r($client->SayHello($request));