protobuf的bytes类型

栏目: 服务器 · 发布时间: 5年前

内容简介:python:Android(kotlin):golang
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))

以上就是本文的全部内容,希望本文的内容对大家的学习或者工作能带来一定的帮助,也希望大家多多支持 码农网

查看所有标签

猜你喜欢:

本站部分资源来源于网络,本站转载出于传递更多信息之目的,版权归原作者或者来源机构所有,如转载稿涉及版权问题,请联系我们

编码

编码

查尔斯•佩措尔德 (Charles Petzold) / 左飞、薛佟佟 / 电子工业出版社 / 2012-10-1 / 59.00元

编码:隐匿在计算机软硬件背后的语言,ISBN:9787121181184,作者:(美)佩措尔德(Petzold,C.)著 左飞,薛佟佟译一起来看看 《编码》 这本书的介绍吧!

HTML 压缩/解压工具
HTML 压缩/解压工具

在线压缩/解压 HTML 代码

Markdown 在线编辑器
Markdown 在线编辑器

Markdown 在线编辑器

HSV CMYK 转换工具
HSV CMYK 转换工具

HSV CMYK互换工具