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

本文涉及的产品
云原生网关 MSE Higress,422元/月
任务调度 XXL-JOB 版免费试用,400 元额度,开发版规格
服务治理 MSE Sentinel/OpenSergo,Agent数量 不受限
简介: 带你读《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


相关文章
|
3月前
|
人工智能 网络协议 Linux
MCP 协议: Streamable HTTP 是最佳选择
随着AI应用变得越来越复杂并被广泛部署,原有的通信机制面临着一系列挑战。近期MCP仓库的PR #206引入了一个全新的Streamable HTTP传输层替代原有的HTTP+SSE传输层。本文将详细分析该协议的技术细节和实际优势。
1780 98
|
2月前
|
数据采集 数据可视化 API
QUIC协议优化:HTTP/3环境下的超高速异步抓取方案
本文介绍了一种基于QUIC和HTTP/3的异步爬虫方案,用于抓取知乎热榜数据并生成趋势图。通过HTTPX与aioquic结合实现高性能连接复用,配合代理IP绕过反爬限制,提取标题、热度等信息。利用Python代码示例展示了异步抓取流程,并借助Matplotlib绘制话题热度变化图表。分析显示突发热点生命周期短,而深度话题热度更稳定。此方案可优化内容运营策略,快速捕捉潜在爆款话题。
107 4
QUIC协议优化:HTTP/3环境下的超高速异步抓取方案
|
17天前
|
缓存 监控 搜索推荐
301重定向实现原理全面解析:从HTTP协议到SEO最佳实践
301重定向是HTTP协议中的永久重定向状态码,用于告知客户端请求的资源已永久移至新URL。它在SEO中具有重要作用,能传递页面权重、更新索引并提升用户体验。本文详解其工作原理、服务器配置方法(如Apache、Nginx)、对搜索引擎的影响及最佳实践,帮助实现网站平稳迁移与优化。
177 68
|
3月前
|
人工智能 Java API
MCP协议重大升级,Spring AI Alibaba联合Higress发布业界首个Streamable HTTP实现方案
本文由Spring AI Alibaba Contributor刘军、张宇撰写,探讨MCP官方引入的全新Streamable HTTP传输层对原有HTTP+SSE机制的重大改进。文章解析Streamable HTTP的设计思想与技术细节,并介绍Spring AI Alibaba开源框架提供的Java实现,包含无状态服务器模式、流式进度反馈模式等多种场景的应用示例。同时,文章还展示了Spring AI Alibaba + Higress的完整可运行示例,分析当前实现限制及未来优化方向,为开发者提供参考。
|
1天前
|
存储 网络协议 安全
HTTP 协议及会话跟踪机制详解
本文详解了 HTTP 协议的核心知识,包括其定义(超文本传输协议,基于 TCP,规定客户端与服务器通信规则)及与 HTTPS 的区别(安全性、端口、资源消耗)。 介绍了 GET 与 POST 请求的差异(参数限制、安全性、应用场景),以及 Restful 风格(通过 URL 定位资源,请求方式决定操作)。列举了常见 HTTP 状态码(如 200 成功、404 资源未找到),对比了转发与重定向的区别(服务器端一次请求 vs 客户端两次请求)。 还阐述了会话跟踪机制:Cookie 基于客户端存储,通过Set-Cookie和Cookie头实现,安全性较低;Session 基于服务端存储,依赖 C
|
1月前
|
缓存
HTTP协议深度剖析:常见请求头信息讲解
这就是HTTP请求头背后的工作原理,希望通过比作“邮差”和“标签”,可以让你对这个繁琐技术更有感触,更得心应手。尽管这些信息可能很琐碎,但了解了它们的含义和工作方式,就等于揭开了HTTP协议神秘的面纱,掌控了网络交流的核心。你还等什么,赶快动手尝试一下吧!
70 17
|
3天前
HTTP协议中常见的状态码 ?
HTTP协议状态码分为1xx、2xx、3xx、4xx、5xx五类。常见状态码包括:101(切换协议)、200(请求成功)、302(重定向)、401(未认证)、404(资源未找到)、500(服务器错误)。
26 0
|
1月前
HTTP协议探究:常用方法一网打尽
总的来说,HTTP协议的命令犹如一把钥匙,解锁了互联网世界的大门。它是规则,也是工具,了解了它,就等于掌握了互联网的一把通行证。我们每天都在用,也常常无视它,但是只有深刻理解了它,才能更好地运用它。如此,我们的互联网世界旅程就会变得更加顺畅,更加有趣。
57 14
|
2月前
|
安全 网络协议 Linux
Linux网络应用层协议展示:HTTP与HTTPS
此外,必须注意,从HTTP迁移到HTTPS是一项重要且必要的任务,因为这不仅关乎用户信息的安全,也有利于你的网站评级和粉丝的信心。在网络世界中,信息的安全就是一切,选择HTTPS,让您的网站更加安全,使您的用户满意,也使您感到满意。
88 18
|
1月前
|
存储 缓存 前端开发
http协议调试代理工具,Fiddler免费版下载,抓包工具使用教程
Fiddler是一款功能强大的HTTP协议调试代理工具,能记录并检查电脑与互联网间的HTTP通信,支持断点设置和数据编辑。相比其他网络调试器,Fiddler操作更简单且用户友好,支持查看Cookie、HTML、JS、CSS等文件内容。它还具备HTTPS抓包、过滤设置、统计页面总重量等功能,适用于安全测试与功能测试。通过插件扩展,用户可自定义视图或分析缓存行为。支持多种HTTP请求方法(如GET、POST等)及状态码分类(1xx-5xx),是开发者调试网络请求的得力工具。同类工具有HttpWatch、Firebug、Wireshark等。
205 1

推荐镜像

更多