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

本文涉及的产品
服务治理 MSE Sentinel/OpenSergo,Agent数量 不受限
性能测试 PTS,5000VUM额度
云原生网关 MSE Higress,422元/月
简介: 带你读《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


相关文章
|
21天前
|
Rust 前端开发 API
Tauri 开发实践 — Tauri HTTP 请求开发
本文介绍了如何在 Tauri 中发起 HTTP 请求。首先通过安装 Tauri 生态中的工具包并配置 `tauri.conf.json` 文件来允许特定域名的 HTTP 通信。接着封装了一个简单的 HTTP 客户端类,并在页面中使用该客户端实现 GET 和 POST 请求。最后提供了完整的源码地址以供参考。此功能使得桌面应用能够与远程服务器进行交互,增强了应用的实用性。
56 1
Tauri 开发实践 — Tauri HTTP 请求开发
|
12天前
|
Dubbo Java 应用服务中间件
Spring Cloud Dubbo:微服务通信的高效解决方案
【10月更文挑战第15天】随着信息技术的发展,微服务架构成为企业应用开发的主流。Spring Cloud Dubbo结合了Dubbo的高性能RPC和Spring Cloud的生态系统,提供高效、稳定的微服务通信解决方案。它支持多种通信协议,具备服务注册与发现、负载均衡及容错机制,简化了服务调用的复杂性,使开发者能更专注于业务逻辑的实现。
37 2
|
2月前
|
监控 安全 搜索推荐
设置 HTTPS 协议以确保数据传输的安全性
设置 HTTPS 协议以确保数据传输的安全性
|
2月前
|
安全 应用服务中间件 API
微服务分布式系统架构之zookeeper与dubbo-2
微服务分布式系统架构之zookeeper与dubbo-2
|
27天前
|
安全 网络协议 算法
HTTPS网络通信协议揭秘:WEB网站安全的关键技术
HTTPS网络通信协议揭秘:WEB网站安全的关键技术
130 4
HTTPS网络通信协议揭秘:WEB网站安全的关键技术
|
15天前
|
Dubbo Java 应用服务中间件
Dubbo学习圣经:从入门到精通 Dubbo3.0 + SpringCloud Alibaba 微服务基础框架
尼恩团队的15大技术圣经,旨在帮助开发者系统化、体系化地掌握核心技术,提升技术实力,从而在面试和工作中脱颖而出。本文介绍了如何使用Dubbo3.0与Spring Cloud Gateway进行整合,解决传统Dubbo架构缺乏HTTP入口的问题,实现高性能的微服务网关。
|
27天前
|
存储 网络安全 对象存储
缺乏中间证书导致通过HTTPS协议访问OSS异常
【10月更文挑战第4天】缺乏中间证书导致通过HTTPS协议访问OSS异常
54 4
|
2月前
|
Dubbo 应用服务中间件 Apache
Star 4w+,Apache Dubbo 3.3 全新发布,Triple X 领衔,开启微服务通信新时代
在 Apache Dubbo 突破 4w Star 之际,Apache Dubbo 团队正式宣布,Dubbo 3.3 正式发布!作为全球领先的开源微服务框架,Dubbo 一直致力于为开发者提供高性能、可扩展且灵活的分布式服务解决方案。此次发布的 Dubbo 3.3,通过 Triple X 的全新升级,突破了以往局限,实现了对南北向与东西向流量的全面支持,并提升了对云原生架构的友好性。
125 9
|
2月前
|
安全 网络协议 网络安全
在实现HTTPS时,有哪些常见的安全协议
在实现HTTPS时,有哪些常见的安全协议
|
26天前
|
安全 应用服务中间件 Shell
网站在后台启用了https协议之后重新登录就不进去后台的解决方法
网站在后台启用了https协议之后重新登录就不进去后台的解决方法

推荐镜像

更多