syntax "proto3";
package Test;
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))
有疑问加站长微信联系(非本文作者)