protobuf的bytes型別
摘要：
syntax "proto3";
packageTest;
service Test{
rpc KeepAlive(Hello) returns (Hello){}
}
message Hello{
int64 timestamp=1;
bytes ...
syntax "proto3";
packageTest;
service Test{
rpc KeepAlive(Hello) returns (Hello){}
}
message Hello{
int64 timestamp=1;
bytes alert=2;
}
python:
channel = grpc.insecure_channel('%s:%d'%(ADDR, PORT))
stub = Test_pb2_grpc.TestStub(channel=channel)
hello = Hello()
hello.timestamp=datetime.now().timestamp()
hello.alert=bytes("hello", encoding="ascii")
ret = stub.KeepAlive(hello)
print(ret.alert.decode("ascii"))
Android(kotlin):
val channel = ManagedChannelBuilder.forAddress(ADDR, PORT)
.usePlaintext(true)
.build()
synchronized(this){
if(channel.isShutdown || channel.isTerminated){
val channel = ManagedChannelBuilder.forAddress(ADDR, PORT)
.usePlaintext(true)
.build()
}
val stub = TestGrpc.newBlockingStub(channel)
}
var hello = Hello()
hello.timestamp = (Date().time/1000).toInt()
hello.alert = ByteString.copyFrom("hello".toByteArray())
val ack = stub!!.KeepAlive(hello)
println(ByteString.copyTo(ack.alert).toString())
golang
conn, err := grpc.Dial(ADDRESS, grpc.WithInsecure()) if err != nil { log.Fatal(err) } defer conn.Close() c := pb.NewTestClient(conn) ctx := context.Background() hello := pb.Hello{ Timestamp:time.Now().Unix(), Alert:[]byte("hello"), } ack, err:= c.KeepAlive(ctx, &hello) if err!=nil{ log.Fatal(err) } fmt.Println(string(ack.Alert))