吉林市教做网站,系统优化的例子,南山网站建设-信科网络,1核1g可以做几个网站一、分布式服务调用_什么是RPC
RPC(Remote Procedure Call)远程过程调用#xff0c;它是一种通过网络从远程计算机程序上请求服务。
大白话理解就是#xff1a;RPC让你用别人家的东西就像自己家的一样。 RPC两个作用#xff1a;
屏蔽远程调用跟本地调用的区别#xff0c…
一、分布式服务调用_什么是RPC
RPC(Remote Procedure Call)远程过程调用它是一种通过网络从远程计算机程序上请求服务。
大白话理解就是RPC让你用别人家的东西就像自己家的一样。 RPC两个作用
屏蔽远程调用跟本地调用的区别让我们感觉就是调用项目内的方法隐藏底层网络通信的复杂性让我们更加专注业务逻辑。
常用的RPC框架
RPC是一种技术思想而非一种规范或协议。
常见 RPC 技术和框架
阿里的 Dubbo/Dubbox、Google gRPC、Spring Cloud。 二、Dubbo是什么
Apache Dubbo 是一款 RPC 服务开发框架用于解决微服务架构下的服务治理与通信问题官方提供了 Java、Golang、Rust 等多语言 SDK 实现。
2.1 为什么需要Dubbo它能做什么
按照微服务架构的定义采用它的组织能够很好的提高业务迭代效率与系统稳定性但前提是要先能保证微服务按照期望的方式运行要做到这一点需要解决服务拆分与定义、数据通信、地址发现、流量管理、数据一致性、系统容错能力等一系列问题。 Dubbo 可以帮助解决如下微服务实践问题
微服务编程范式和工具
Dubbo 支持基于 IDL 或语言特定方式的服务定义提供多种形式的服务调用形式如同步、异步、流式等
高性能的 RPC 通信
Dubbo 帮助解决微服务组件之间的通信问题提供了基于 HTTP、HTTP/2、TCP 等的多种高性能通信协议实现并支持序列化协议扩展在实现上解决网络连接管理、数据传输等基础问题。
微服务监控与治理
Dubbo 官方提供的服务发现(可用nacos)、动态配置(可用nacos)、负载均衡、流量路由等基础组件可以很好的帮助解决微服务基础实践的问题。除此之外您还可以用 Admin 控制台监控微服务状态通过周边生态完成限流降级、数据一致性、链路追踪等能力。
部署在多种环境
Dubbo 服务可以直接部署在容器、Kubernetes、Service Mesh等多种架构下。
活跃的社区
Dubbo 项目托管在 Apache 社区有来自国际、国内的活跃贡献者维护着超 10 个生态项目贡献者包括来自海外、阿里巴巴、工商银行、携程、蚂蚁、腾讯等知名企业技术专家确保 Dubbo 及时解决项目缺陷、需求及安全漏洞跟进业界最新技术发展趋势。
庞大的用户群体
Dubbo3 已在阿里巴巴成功取代 HSF 框架实现全面落地成为阿里集团面向云原生时代的统一服务框架庞大的用户群体是 Dubbo 保持稳定性、需求来源、先进性的基础。
2.2 Dubbo 不是什么 不是应用开发框架的替代者
Dubbo 设计为让开发者以主流的应用开发框架的开发模式工作它不是各个语言应用开发框架的替代者如它不是 Spring/Spring Boot 的竞争者当你使用 Spring 时Dubbo 可以无缝的与 Spring Spring Boot 集成在一起。
不仅仅只是一款 RPC 框架
Dubbo 提供了内置 RPC 通信协议实现但它不仅仅是一款 RPC 框架。首先它不绑定某一个具体的 RPC 协议开发者可以在基于 Dubbo 开发的微服务体系中使用多种通信协议其次除了 RPC 通信之外Dubbo 提供了丰富的服务治理能力与生态。
不是 gRPC 协议的替代品
Dubbo 支持基于 gRPC 作为底层通信协议在 Dubbo 模式下使用 gRPC 可以带来更好的开发体验享有统一的编程模型和更低的服务治理接入成本
不只有 Java 语言实现
自 Dubbo3 开始Dubbo 提供了 Java、Golang、Rust、Node.js 等多语言实现未来会有更多的语言实现。
2.3 任意通信协议
Dubbo 微服务间远程通信实现细节支持 HTTP、HTTP/2、gRPC、TCP 等所有主流通信协议。与普通 RPC 框架不同Dubbo 不是某个单一 RPC 协议的实现它通过上层的 RPC 抽象可以将任意 RPC 协议接入 Dubbo 的开发、治理体系。 2.4 多语言 SDK
Dubbo 提供几乎所有主流语言的 SDK 实现定义了一套统一的微服务开发范式。Dubbo 与每种语言体系的主流应用开发框架做了适配总体编程方式、配置符合大多数开发者已有编程习惯。 三、项目所需要引入的依赖 dependencygroupIdorg.springframework.boot/groupIdartifactIdspring-boot-starter-web/artifactId
/dependency
!-- Dubbo和springboot整合依赖 --
dependencygroupIdorg.apache.dubbo/groupIdartifactIddubbo-spring-boot-starter/artifactId
/dependency
!-- dubbo注册中心nacos依赖 --
dependencygroupIdorg.apache.dubbo/groupIdartifactIddubbo-registry-nacos/artifactId
/dependency
四、启动时检查
DubboReference注解:
使用在调用者处.如果配置check为false(默认为true),表示在启动时检查服务是否可用, 如果不可用, 则抛出异常. 设置为false, 表示不检查.即使服务不可用也可以正常启动服务.
DubboReference(check false)五、Dubbo地址缓存
如果当Nacos突然故障,是否还能够保证Dubbo远程调用服务的正常使用(远端服务没有故障,只是nacos出现了问题).
答案是可以正常访问的,这也是Dubbo的强大之处.
Dubbo服务消费者在第一次调用时会将服务提供方地址缓存到本地以后在调用则不会访问注册中心。服务提供者地址发生变化时注册中心会通知服务消费者。
六、服务发布
dubbo的服务要 被nacos检测,首先需要在对应服务接口加上DubboService注解.这样我们将在nacos中看见dubbo所属服务的接口.
DubboService
public class IPaymentServiceImpl implements IPaymentService {Overridepublic String payment(Integer id) throws InterruptedException {return hello world;}
}
七、超时时间
在其注解当中加入timeout属性.单位为毫秒ms. DubboReference(check false,timeout 1000)//对于某个方法也可以设置超时
DubboReference(methods {Method(name payment,timeout 1000)})
服务端也是可以设置超时时间的
DubboService(timeout 1000)
超时是针对消费端为什么服务端也可以设置超时呢
这其实是一种策略其实服务端的超时配置是消费端的缺省配置即如果服务端设置了超时任务消费端可以不设置超时时间简化了配置。另外针对控制的粒度Dubbo支持了接口级别也支持方法级别可以根据不同的实际情况精确控制每个方法的超时时间。
但是如果你实际去测试,会发现一个奇怪的事情,你设计了1s的超时时间,但是你去请求一个超过1秒的服务(可利用Thread.sleep()制造一个异常).你会发现实际请求的时间却是大于1s的.大概在3s左右.这是为什么呢?
这就跟后面的超时重试有关啦.
八、超时重试
dubbo中默认会重试两次,所以在刚刚的示例当中,请求了一次,重试了两次.最后结果就是三次,也就是过了3秒后就结束啦.
但注意的是,不是在3秒内这个接口能够完成业务并返回结果就可以了,就不会抛出异常了.这是不正确的.
超时时间针对的是每一次的请求,你一次请求超过了1秒那就会进入第二次重试,重试后还是超过了1秒那接着就是最后一次.也就是设置超时时间表明了这一次请求需要在你设置的超时时间内完成.
我们可以通过其属性retries配置其重试次数(默认为2次)
DubboReference(retries 0)九、多版本机制
服务发布是可以多版本的,在DubboService中配置version属性
DubboService(version 1.0.0)
调用者可以指定使用哪个版本的服务
DubboReference(version 1.0.0)
多版本的作用:
可以不停机更新服务, 而不影响客户端的调用.少量的放入新版本,慢慢的切换到新版本.实现平滑升级.灰度发布.当出现新功能时会让一部分用户先使用新功能用户反馈没问题时再将所有用户迁移到新功能。
(一) 版本迁移步骤
在低压力时间段先升级一半提供者为新版本再将所有消费者升级为新版本然后将剩下的一半提供者升级为新版本
十、负载均衡
在调用远程服务时,可能存在多个远程服务的实例.这个时候我们需要负载均衡.其实也就是跟Nginx,openFeign的负载均衡都是一个样子.
牵扯到负载均衡,那么dubbo提供了哪些常用的负载均衡的算法呢?
random: 随机roundrobin: 轮询leastactive: 最少活跃调用数(也就是哪个服务器压力小)consistenthash: 参数一致性hash 将服务实例经过hash运算放入到散列表中,然后调用服务的接口,经过hash计算看落在哪个位置对应的服务就调用哪个服务.如果所落在位置没有实例(服务出了故障),则将会向后移动,直到找到对应的实例.
如果记不住这些也没关系,通过Idea双击shift,查找loadbalance关键字,找到所属dubbo包下的loadbalance
然后通过接口上按下ctrlh即可查看到所有的实例. 随便点击一个负载均衡实现的类.里面显示的NAME属性就是我们需要配置的名称. 落实到代码层面怎么配置呢,像下面这样
DubboReference(loadbalance roundrobin)
其属性名的值就是按上述方法当中查找. 十一、集群容错
当调用处出了问题时,我们要以何种方法进行容错处理呢?
dubbo默认是失败了重试,即Failover机制.它还提供了其他的容错策略
1. Failover(失败自动切换)
策略说明当调用失败时自动切换到其他服务器重试。这是Dubbo的默认容错策略适用于读操作或幂等性的写操作。举例说明假设有一个商品查询服务当查询第一个服务器失败时Dubbo会自动将请求切换到另一个服务器进行重试直到查询成功或达到重试次数上限。配置示例dubbo:reference interfacecom.example.DemoService retries2/其中retries表示重试次数不包括第一次调用。
2. Failfast (快速失败)
策略说明只发起一次调用失败立即报错。适用于非幂等性的写操作如新增记录以避免重复处理。举例说明在订单生成场景中如果第一次调用创建订单服务失败Dubbo会立即报错不再重试以防止生成重复的订单。
3. Failsafe(失败安全)
策略说明调用失败时直接忽略错误继续执行后续逻辑。适用于记录日志等非核心业务逻辑。举例说明在写入审计日志的场景中如果日志服务调用失败Dubbo会忽略该错误继续执行后续操作以保证主业务流程不受影响。
4. Failback(失败自动恢复)
策略说明调用失败后不会立即报错而是将失败请求缓存起来定时重试直到请求成功。适用于那些偶尔出现故障但期望未来可以恢复的服务调用。举例说明在发送消息通知的场景中如果第一次发送失败Dubbo会将失败的消息缓存起来并在后台定时重试直到消息成功发送。需要注意的是Failback策略目前有一些局限如失败调用列表没有上限可能导致堆积异步重试的执行间隔无法调整等
5. Broadcast(广播)
策略说明向所有服务提供者广播调用逐个调用任意一个报错则报错。适用于通知所有提供者更新缓存或日志文件等场景。举例说明在缓存更新场景中Dubbo会向所有缓存服务提供者广播更新请求以确保所有缓存都得到更新。
记不住也可以同样查找cluster关键字,找到对应的接口,从这样我们也可以看见默认为什么是Failover 其他的策略接口 代码配置 DubboReference(cluster failover)十二、序列化协议
网络传输的数据必须是二进制数据但调用方请求的出入参数都是对象。此时对象需要实现Serializable接口,否则将会报错.
