内容简介: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))
以上就是本文的全部内容,希望本文的内容对大家的学习或者工作能带来一定的帮助,也希望大家多多支持 码农网
猜你喜欢:- golang的值类型,指针类型和引用类型&值传递&指针传递
- Scala 类型的类型(三)
- Scala 类型的类型(二)
- Scala 类型的类型(三)
- Scala 类型的类型(二)
- golang: 类型转换和类型断言
本站部分资源来源于网络,本站转载出于传递更多信息之目的,版权归原作者或者来源机构所有,如转载稿涉及版权问题,请联系我们。