带你读《Apache Dubbo微服务开发从入门到精通》——二、 HTTP/2(Triple)协议(5)

简介: 带你读《Apache Dubbo微服务开发从入门到精通》——二、 HTTP/2(Triple)协议(5)
+关注继续查看

《Apache Dubbo微服务开发从入门到精通》——通信协议——二、 HTTP/2(Triple)协议(4) https://developer.aliyun.com/article/1224945



c) Streaming 方式

Java 接口

image.png


实现

public class IStreamGreeterImpl implements IStreamGreeter {
 @Override
 public StreamObserver<HelloRequest> 
sayHello(StreamObserver<HelloReply> replyObserver) {
 return new StreamObserver<HelloRequest>() {
 private List<HelloReply> replyList = new ArrayList<>();
 @Override
 public void onNext(HelloRequest helloRequest) {
 System.out.println("onNext receive request name:" + 
helloRequest.getName());
 replyList.add(HelloReply.newBuilder()
 .setMessage("receive name:" +
helloRequest.getName())
 .build());
 }
 @Override
 public void onError(Throwable cause) {
 System.out.println("onError");
 replyObserver.onError(cause);
 }
 @Override
 public void onCompleted() {
 System.out.println("onComplete receive request size:" 
+ replyList.size());
 for (HelloReply reply : replyList) {
 replyObserver.onNext(reply);
 }
 replyObserver.onCompleted();
 }
 };
 }
}


Provider

image.png


Consumer


public class StreamConsumer {
 public static void main(String[] args) throws 
InterruptedException, IOException {
 ReferenceConfig<IStreamGreeter> ref = new 
ReferenceConfig<>();
 ref.setInterface(IStreamGreeter.class);
 ref.setCheck(false);
 ref.setProtocol(CommonConstants.TRIPLE);
 ref.setLazy(true);
 ref.setTimeout(100000);
 ref.setApplication(new ApplicationConfig("streamconsumer"));
 ref.setRegistry(new RegistryConfig("zookeeper://mse-
6e9fda00-p.zk.mse.aliyuncs.com:2181"));
 final IStreamGreeter iStreamGreeter = ref.get();
 System.out.println("dubbo ref started");
 try {
 StreamObserver<HelloRequest> streamObserver = 
iStreamGreeter.sayHello(new StreamObserver<HelloReply>() {
 @Override
 public void onNext(HelloReply reply) {
 System.out.println("onNext");
 System.out.println(reply.getMessage());
 }
 @Override
 public void onError(Throwable throwable) {
 System.out.println("onError:" + 
throwable.getMessage());
 }
 @Override
 public void onCompleted() {
 System.out.println("onCompleted");
 }
 });
 streamObserver.onNext(HelloRequest.newBuilder()
 .setName("tony")
 .build());
 streamObserver.onNext(HelloRequest.newBuilder()
 .setName("nick")
 .build());
 streamObserver.onCompleted();
 } catch (Throwable t) {
 t.printStackTrace();
 }
 System.in.read();
 }
}


运行 Provider Consumer,可以正常返回

image.png

注:

本文的示例可以在 triple-samples


《Apache Dubbo微服务开发从入门到精通》——通信协议——二、 HTTP/2(Triple)协议(6) https://developer.aliyun.com/article/1224940


相关文章
|
18天前
|
Dubbo JavaScript 应用服务中间件
浏览器可直接访问 Dubbo、gRPC 后端微服务,Dubbo-js 首个alpha 版本来了!
浏览器可直接访问 Dubbo、gRPC 后端微服务,Dubbo-js 首个alpha 版本来了!
|
19天前
|
Dubbo JavaScript 应用服务中间件
浏览器可直接访问 Dubbo、gRPC 后端微服务,Dubbo-js 首个 alpha 版本来了!
Dubbo-js 已于 9 月份发布支持 Dubbo3 协议的首个 alpha 版本,它的发布将有机会彻底改变微服务前后端的架构与通信模式,让你能直接在浏览器页面或 web 服务器中访问后端 Dubbo、gRPC 服务。
|
24天前
|
Dubbo Java 应用服务中间件
掌握微服务:Spring Cloud 对比 Dubbo
Spring Cloud 框架为开发人员提供了快速构建健壮云应用程序的工具。我们还可以构建基于微服务的应用程序,例如配置管理、服务发现、断路器、智能路由、集群状态、微代理、控制总线、一次性令牌等。
|
2月前
|
Dubbo Java 应用服务中间件
开源微服务如何选型?Spring Cloud、Dubbo、gRPC、Istio 详细对比
开源微服务如何选型?Spring Cloud、Dubbo、gRPC、Istio 详细对比
|
2月前
|
Dubbo 前端开发 网络协议
微服务最佳实践,零改造实现 Spring Cloud & Apache Dubbo 互通
微服务最佳实践,零改造实现 Spring Cloud & Apache Dubbo 互通
47294 55
|
3月前
java初中级面试题(SSM+Mysql+微服务(SpringCloud+Dubbo)+消息队列(RocketMQ)+缓存(Redis+MongoDB)+设计模式+搜索引擎(ES)+JVM
java初中级面试题(SSM+Mysql+微服务(SpringCloud+Dubbo)+消息队列(RocketMQ)+缓存(Redis+MongoDB)+设计模式+搜索引擎(ES)+JVM
142 0
|
3月前
java初中级面试题(SSM+Mysql+微服务(SpringCloud+Dubbo)+消息队列(RocketMQ)+缓存(Redis+MongoDB)+设计模式+搜索引擎(ES)+JVM
java初中级面试题(SSM+Mysql+微服务(SpringCloud+Dubbo)+消息队列(RocketMQ)+缓存(Redis+MongoDB)+设计模式+搜索引擎(ES)+JVM
146 0
|
3月前
java初中级面试题(SSM+Mysql+微服务(SpringCloud+Dubbo)+消息队列(RocketMQ)+缓存(Redis+MongoDB)+设计模式+搜索引擎(ES)+JVM
java初中级面试题(SSM+Mysql+微服务(SpringCloud+Dubbo)+消息队列(RocketMQ)+缓存(Redis+MongoDB)+设计模式+搜索引擎(ES)+JVM
186 0
|
3月前
|
Dubbo 安全 Java
阿里巴巴微服务核心手册:Spring Boot+Spring cloud+Dubbo
微服务作为一项在云中部署应用和服务的新技术已成为当下最新的热门话题。但大部分围绕微服务的争论都集中在容器或其他技术是否能很好的实施微服务,而红帽说API应该是重点。
|
3月前
|
JSON Dubbo JavaScript
Dubbo Triple 协议重磅升级:支持通过 HTTP 连通 Web 与后端微服务
Dubbo Triple 协议重磅升级:支持通过 HTTP 连通 Web 与后端微服务
相关产品
云消息队列 MQ
微服务引擎
云消息队列 Kafka 版
推荐文章
更多
推荐镜像
更多