带你读《Apache Dubbo微服务开发从入门到精通》——三、 迁移到 HTTP/2 协议(3)

本文涉及的产品
任务调度 XXL-JOB 版免费试用,400 元额度,开发版规格
注册配置 MSE Nacos/ZooKeeper,182元/月
Serverless 应用引擎免费试用套餐包,4320000 CU,有效期3个月
简介: 带你读《Apache Dubbo微服务开发从入门到精通》——三、 迁移到 HTTP/2 协议(3)

《Apache Dubbo微服务开发从入门到精通》——迁移到 Dubbo3——三、 迁移到 HTTP/2 协议(2): https://developer.aliyun.com/article/1223559


4) 开启 Triple 新特性——Stream(流)


Stream Dubbo3 新提供的一调用类型,在以下场景时建议使用流的方式

需要量数据,这些数据在一RPC 应中,需要分应用按照传统的多次 RPC 方式和性能的问题,如需要保有序,则行发

流式场景,数据需要按照理,数据本有确定边界的。

场景,多个在同一调用的上下文中被发理。


Stream 分为以下三:

SERVER_STREAM(服务端流)

image.pngimage.png

CLIENT_STREAM户端流)

image.png

BIDIRECTIONAL_STREAM双向流)

image.png

注:

java 语言的限制,BIDIRECTIONAL_STREAM CLIENT_STREAM 的实现是一样的。


Dubbo3 中,流式SteamObserver 和使用,用户可以通过使用和实现这个接理流的数据、异结束


注:

对于 Dubbo2 用户,可能会对 StreamObserver 生,Dubbo3 定义的一类型Dubbo2 并不Stream 类型对于迁移场景有任何影响


流的语义保

提供边界,可以方便地

有序,发端的

工,发不需要等待

支持取


a) 非 PB 序列化的流


apimage.png

注:

Stream 的方入参和返回的,为错而,Dubbo3框架了对参数的检查,如出错


对于双向流(BIDIRECTIONAL_STREAM),需要注意参数中的StreamObserver 是响应流,返回参数中的 StreamObserver 求流。


实现

public class WrapGreeterImpl implements WrapGreeter {
 //...
 @Override
 public StreamObserver<String> 
sayHelloStream(StreamObserver<String> response) {
 return new StreamObserver<String>() {
 @Override
 public void onNext(String data) {
 System.out.println(data);
 response.onNext("hello,"+data);
 @Override
 public void onError(Throwable throwable) {
 throwable.printStackTrace();
 }
 @Override
 public void onCompleted() {
 System.out.println("onCompleted");
 response.onCompleted();
 }
 };
 }
 @Override
 public void sayHelloServerStream(String request, 
StreamObserver<String> response) {
 for (int i = 0; i < 10; i++) {
 response.onNext("hello," + request);
 }
 response.onCompleted();
 }
}

调用方式

delegate.sayHelloServerStream("server stream", new 
StreamObserver<String>() {
 @Override
 public void onNext(String data) {
 System.out.println(data);
 }
 @Override
 public void onError(Throwable throwable) {
 throwable.printStackTrace();
 }
 @Override
 public void onCompleted() {
 System.out.println("onCompleted");
 }
});
StreamObserver<String> request = delegate.sayHelloStream(new 
StreamObserver<String>() {
 @Override
 public void onNext(String data) {
 System.out.println(data);
 }
 @Override
 public void onError(Throwable throwable) {
 throwable.printStackTrace();
 }
 @Override
 public void onCompleted() {
 System.out.println("onCompleted");
 }
});
for (int i = 0; i < n; i++) {
 request.onNext("stream request" + i);
}
request.onCompleted();


《Apache Dubbo微服务开发从入门到精通》——迁移到 Dubbo3——三、 迁移到 HTTP/2 协议(4) https://developer.aliyun.com/article/1223556

相关文章
|
4月前
|
数据采集 数据可视化 API
QUIC协议优化:HTTP/3环境下的超高速异步抓取方案
本文介绍了一种基于QUIC和HTTP/3的异步爬虫方案,用于抓取知乎热榜数据并生成趋势图。通过HTTPX与aioquic结合实现高性能连接复用,配合代理IP绕过反爬限制,提取标题、热度等信息。利用Python代码示例展示了异步抓取流程,并借助Matplotlib绘制话题热度变化图表。分析显示突发热点生命周期短,而深度话题热度更稳定。此方案可优化内容运营策略,快速捕捉潜在爆款话题。
181 4
QUIC协议优化:HTTP/3环境下的超高速异步抓取方案
|
2月前
|
缓存 监控 搜索推荐
301重定向实现原理全面解析:从HTTP协议到SEO最佳实践
301重定向是HTTP协议中的永久重定向状态码,用于告知客户端请求的资源已永久移至新URL。它在SEO中具有重要作用,能传递页面权重、更新索引并提升用户体验。本文详解其工作原理、服务器配置方法(如Apache、Nginx)、对搜索引擎的影响及最佳实践,帮助实现网站平稳迁移与优化。
442 68
|
1月前
HTTP协议中请求方式GET 与 POST 什么区别 ?
GET和POST的主要区别在于参数传递方式、安全性和应用场景。GET通过URL传递参数,长度受限且安全性较低,适合获取数据;而POST通过请求体传递参数,安全性更高,适合提交数据。
340 2
|
3月前
|
JSON 中间件 Go
Go 网络编程:HTTP服务与客户端开发
Go 语言的 `net/http` 包功能强大,可快速构建高并发 HTTP 服务。本文从创建简单 HTTP 服务入手,逐步讲解请求与响应对象、URL 参数处理、自定义路由、JSON 接口、静态文件服务、中间件编写及 HTTPS 配置等内容。通过示例代码展示如何使用 `http.HandleFunc`、`http.ServeMux`、`http.Client` 等工具实现常见功能,帮助开发者掌握构建高效 Web 应用的核心技能。
238 61
|
2月前
|
存储 网络协议 安全
HTTP 协议及会话跟踪机制详解
本文详解了 HTTP 协议的核心知识,包括其定义(超文本传输协议,基于 TCP,规定客户端与服务器通信规则)及与 HTTPS 的区别(安全性、端口、资源消耗)。 介绍了 GET 与 POST 请求的差异(参数限制、安全性、应用场景),以及 Restful 风格(通过 URL 定位资源,请求方式决定操作)。列举了常见 HTTP 状态码(如 200 成功、404 资源未找到),对比了转发与重定向的区别(服务器端一次请求 vs 客户端两次请求)。 还阐述了会话跟踪机制:Cookie 基于客户端存储,通过Set-Cookie和Cookie头实现,安全性较低;Session 基于服务端存储,依赖 C
238 1
|
1月前
|
缓存 网络协议 UED
深度解析HTTP协议从版本0.9至3.0的演进和特性。
总的来说,HTTP的演进是互联网技术不断发展和需求日益增长的结果。每一次重要更新都旨在优化性能,增进用户体验,适应新的应用场景,而且保证了向后兼容,让互联网的基础架构得以稳定发展。随着网络技术继续进步,我们可以预期HTTP协议在未来还会继续演化。
337 0
|
3月前
|
C# 图形学 开发者
Unity开发中使用UnityWebRequest从HTTP服务器下载资源。
总之,UnityWebRequest就是游戏开发者手中的万能钓鱼竿,既可以获取文本数据,也能钓上图片资源,甚至是那声音的涟漪。使用UnityWebRequest的时候,你需要精心准备,比如确定URL、配置请求类型和头信息;发起请求;巧妙处理钓获的数据;还需要机智面对网络波澜,处理各种可能出现的错误。按照这样的过程,数据的钓取将会是一次既轻松愉快也效率高效的编程钓鱼之旅。
196 18
|
2月前
|
XML 安全 网络架构
深度对比SOAP与HTTP协议:详细理解它们的工作原理和差异
在设计服务和系统交云策略时,考虑到上述差异是至关重要的。SOAP适合需要高安全性、可靠性和事务支持的企业级应用。而HTTP适合Web界面浏览、RESTful服务和需要快速响应的轻量级通信。根据具体需求和上下文,开发者可以选择合适的协议以实现最优的系统性能和用户体验。
299 0
|
3月前
|
缓存
HTTP协议深度剖析:常见请求头信息讲解
这就是HTTP请求头背后的工作原理,希望通过比作“邮差”和“标签”,可以让你对这个繁琐技术更有感触,更得心应手。尽管这些信息可能很琐碎,但了解了它们的含义和工作方式,就等于揭开了HTTP协议神秘的面纱,掌控了网络交流的核心。你还等什么,赶快动手尝试一下吧!
131 17

热门文章

最新文章

推荐镜像

更多