protobuf的bytes类型

CentrosPan · · 39 次点击 · · 开始浏览    
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))

本文来自:简书

感谢作者:CentrosPan

查看原文:protobuf的bytes类型

39 次点击  
加入收藏 微博
暂无回复
添加一条新回复 (您需要 登录 后才能回复 没有账号 ?)
  • 请尽量让自己的回复能够对别人有帮助
  • 支持 Markdown 格式, **粗体**、~~删除线~~、`单行代码`
  • 支持 @ 本站用户;支持表情(输入 : 提示),见 Emoji cheat sheet
  • 图片支持拖拽、截图粘贴等方式上传