当前位置: 主页 > 建站知识 > APP开发

编写程序-餐馆菜单程序编写

发布时间:2023-04-03 10:07   浏览次数:次   作者:佚名

编写爬虫程序_餐馆菜单程序编写_编写程序

一 RSocket的主要特性

首先,RSocket是高效一个二进制的网络通讯协议,能够满足很多场景下使用。其次,RSocket是一个激进的响应式捍卫者,激进到连API都跟响应式无缝集成。

1 四种通讯模式

即发即忘FireAndForget

立即发送一个请求,无需为这个请求发送响应报文。适用于监控埋点,日志上报等,这种场景下无需回执,丢失几个请求无伤大雅。

编写程序_餐馆菜单程序编写_编写爬虫程序

请求响应RequestResponse

请求方发送一条请求消息,响应方收到请求后并返回一条响应消息。传统的HTTP是典型的RequestResponse。

编写程序_编写爬虫程序_餐馆菜单程序编写

流RequestStream

请求方发送一个请求报文,响应方发回N个响应报文。传统的MQ是典型的RequestStream。

餐馆菜单程序编写_编写爬虫程序_编写程序

通道RequestChannel

创建一个通道上下文,双方可以互相发送消息。IM是个典型的RequestChannel通讯场景。

编写爬虫程序_餐馆菜单程序编写_编写程序

2 双向通讯Bi-Directional

RSocket的Client连接到Server,这个过程称为Setup,在连接成功后,会约定收发消息的方向逻辑:

餐馆菜单程序编写_编写程序_编写爬虫程序

正是因为这个奇偶性确定方向的特性,不同于传统的如HTTP请求,RSocket可以做到双向请求。

3 其他

综上与HTTP做一些比较,RSocket的效率更高,支持的通讯场景更丰富,也没有队头阻塞的问题。与SocketIO这种基于纯事件的框架相比,RSocket的请求具有很清晰的上下文,API精炼易用。

餐馆菜单程序编写_编写爬虫程序_编写程序

二 RSocket的内部实现

1 帧的设计

帧(Frame)是RSocket协议报文的最小单位。

编写程序_餐馆菜单程序编写_编写爬虫程序

2 数据载体——Payload

基于帧之上,一般开发者接触到的是Payload, 它类似一个HTTP报文,可以是一个Request,也可以是一个Response。由两个二进制部分组成:

餐馆菜单程序编写_编写程序_编写爬虫程序

3 架构

这里基于笔者在实现Golang版SDK的基础上整理的架构图,Java版基本也类似。

编写程序_餐馆菜单程序编写_编写爬虫程序

4 玩法

RSocket有很多玩法,传统的RPC自然不在话下,用来做IM也未尝不可,某些特性也可以用来做代理或者网络穿透。

IoT的场景,比如小明的家里有个智能空调,小明想在外面通过手机APP来控制空调开关,如何优雅地描述这个控制问题?最精炼的解决方案就是"小明调用空调上开关的API"。

编写爬虫程序_编写程序_餐馆菜单程序编写

另外最经典的玩法就是Broker了,Broker类似一种“软路由”的方案,可以让服务的发布访问变得简单。发布服务只要连接到Broker,调用方通过反向请求的方式来让Broker透明转发即可,摒弃了传统的注册中心,端口管理等常见的服务治理手段。

编写程序_编写爬虫程序_餐馆菜单程序编写

5 关于RSocket Broker

Broker有很多优势,发布服务不需要监听端口,无需Sidecar,服务注册变得简单,无需zk、etcd之类,LoadBalance变得简单,也更安全,没监听端口后很难攻击。也有很多劣势,网络上多了一跳编写程序,性能是有一定损耗的,Broker是中心化设计,类似我们平时全局的Nginx一样,但是Broker的优雅启停显然更加复杂,受限于整个Broker集群的瓶颈等等。上帝为你关闭了一扇门,就一定会为你打开一扇窗。

目前高德落地的FaaS中大量使用了基于RSocket架构的集团Broker,支撑了今年的五一长假,峰值QPS超20万,平稳零故障。

餐馆菜单程序编写_编写爬虫程序_编写程序

这里笔者也准备了一个教学用的Mini Broker,演示了两个浏览器之间相互上下文调用彼此服务的场景,有兴趣的同学可以查看。

编写程序_餐馆菜单程序编写_编写爬虫程序

三 响应式编程

响应式编程是个老话题了,它早已无处不在,甚至你在Excel里SUM求和,本质上也是种响应式的思维。响应式本质上就是响应变化的数据流。RSocket这个协议本身就是以响应式之名,将其扩展到网络层面。

1 响应式编程大概长这样

编写程序_餐馆菜单程序编写_编写爬虫程序

而在我们平时工作中,必然会引入各种操作和变换:

编写爬虫程序_餐馆菜单程序编写_编写程序

2 Reactive Streams

JDK推出了响应式标准API,撇开Processor之外,其核心接口就Publisher/Subscriber/Subscription,非常精炼。

Spring的Reactor是一个标准的实现,其一次完整的执行过程如下图:

编写爬虫程序_编写程序_餐馆菜单程序编写

由于Java天生的语言优势,很适合使用RxJava或Reactor之类的框架,代码逻辑清晰可读性会非常高。笔者在实现Go版的Reactor时,深深地体会到了没有泛型支持的API表现力是多么匮乏,也期待Go2的泛型能够有所改善。

四 总结

RSocket是个很有趣的网络协议,它可能不会普及流行,但贵在它解决问题的思路和设计很令人耳目一新。如果大家有兴趣,可以去它的官网了解下。

本文总结了笔者在实现Go和Rust版RSocket SDK过程中的一些心得感悟,有兴趣的同学可查看相关链接。

技术公开课

《HaaS物联网云端一体低代码开发课程》

由阿里云IoT一线技术专家精心打磨编写程序,直击当前物联网领域学习痛点,由浅入深全方位介绍物联网基础知识和网络层基础知识,帮助开发者建立物联网感知层、传输层、平台层及应用层各层的功能概念,并深入学习如何使用HaaS进行端云一体开发以及低代码开发新模式。