protobuf的bytes类型

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))

有疑问加站长微信联系(非本文作者)

• 请尽量让自己的回复能够对别人有帮助
• 支持 Markdown 格式, **粗体**、~~删除线~~、`单行代码`
• 支持 @ 本站用户;支持表情(输入 : 提示),见 Emoji cheat sheet
• 图片支持拖拽、截图粘贴等方式上传