内容简介: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: 类型转换和类型断言
本站部分资源来源于网络,本站转载出于传递更多信息之目的,版权归原作者或者来源机构所有,如转载稿涉及版权问题,请联系我们。