1
在聊天服务中,我们从客户端获取请求并发送基于它的响应。 但我的情况是,服务器必须从类的外部方法发送一些不同的对象。Grpc - 将不同的对象传递给grpc服务方法
例如,
public StreamObserver<SalaryDetails> message(StreamObserver<Employee> responseObserver) {
observers.add(responseObserver);
return new StreamObserver<SalaryDetails>() {
@Override
public void onCompleted() {
observers.remove(responseObserver);
}
@Override
public void onError(Throwable arg0) {
observers.remove(responseObserver);
}
@Override
public void onNext(SalaryDetails details) {
for(StreamObserver<MetricsToVE> observer : observers) {
**observer.onNext(Employee.newBuilder()
.setName("AA")
.setCity("B")
.build());**
}
}
};
}
在下面陈述我已硬编码的字段,应该怎么传递一个对象从一个不同的方法进入GRPC服务类。
如果服务器发送不同的对象到客户端,听起来像那些应该是不同的rpc方法。否则,客户端将不知道返回什么样的对象。 – jeffaudio