Dubbo基础培训课件.ppt

1、功能介绍Dubbo简要介绍 Dubbo-RPC基本功能 Dubbo-RPC高级功能 最佳实践 分布式服务框架 高性能和透明化的RPC远程服务调用方案 SOA服务治理方案 Dubbo可以选择协议Dubbo可选用多种序列化方式本地服务 远程服务 透明化的远程方法调用 就像调用本地方法一样调用远程方法 只需简单配置，没有任何API侵入。软负载均衡及容错机制 可在内网替代F5等硬件负载均衡器 服务自动注册与发现 不再需要写死服务提供方地址，注册中心基于接口名查询服务提供者的IP地址，并且能够平滑添加或删除服务提供者 配置 配置继承 可配置可编程 服务匹配 服务分组、多版本 指定调用 只订阅 多协议 不

2、同服务不同协议 同一服务多协议 本地服务调用 集群&容错 集群原理 容错规则 Graceful shutdown优雅停机 实际使用中发现，服务提供者比消费者更清楚一个方法的执行时间，是否允许重试等信息，所以增加允许服务提供者为消费者设置缺省值，并采用继承风格：/服务实现 XxxService xxxService=new XxxServiceImpl();/当前应用配置 ApplicationConfig application=new ApplicationConfig();application.setName(xxx);/连接注册中心配置 RegistryConfig registry=

3、new RegistryConfig();registry.setAddress(10.20.130.230:9090);registry.setUsername(aaa);registry.setPassword(bbb);/服务提供者协议配置 ProviderConfig provider=new ProviderConfig();provider.setProtocol(dubbo);provider.setPort(12345);provider.setThreads(200);/服务提供者暴露服务配置 ServiceConfig service=new ServiceConfig()

4、;service.setApplication(application);service.setRegistry(registry);/多个注册中心可以用setRegistries()service.setProvider(provider);/多个提供者可以用setProviders()service.setInterfaceClass(XxxService.class);service.setRef(xxxService);service.setVersion(1.0.0);service.export();/触发服务注册 编程配置：Schema配置：/当前应用配置 Application

5、Config application=new ApplicationConfig();application.setName(yyy);/连接注册中心配置 RegistryConfig registry=new RegistryConfig();registry.setAddress(10.20.130.230:9090);registry.setUsername(aaa);registry.setPassword(bbb);/服务消费者缺省值配置 ConsumerConfig consumer=new ConsumerConfig();consumer.setTimeout(5000);co

6、nsumer.setRetries(2);/引用远程服务 ReferenceConfig reference=new ReferenceConfig();reference.setApplication(application);reference.setRegistry(registry);/多个注册中心可以用setRegistries()reference.setConsumer(consumer);reference.setInterfaceClass(XxxService.class);reference.setVersion(1.0.0);XxxService xxxService=

7、reference.get();/获取远程xxxService代理 编程配置：Schema配置：当一个接口有多种实现时，可以用group区分 服务提供者 服务消费者 服务提供者 服务消费者 当一个接口实现，出现不兼容升级时，可以用版本号过渡，版本号不同的服务相互间不引用 点对点直连/指定调用需求（开发/测试环境）方式一 Spring配置 方式二 Java D参数方式 java-Dcom.alibaba.xxx.XxxService=dubbo:/localhost:20890 方式三 映射文件方式 java-Ddubbo.resolve.file=xxx.propertiescom.aliba

8、ba.xxx.XxxService=dubbo:/localhost:20890 共用注册中心，开发人员机器上的服务提供者被误调，影响其他开发人员（开发、测试环境）FeatureMaturityStrengthProblemAdviseUserRandom LoadBalanceStable随机，按权重设置随机概率（推荐使用）在一个截面上碰撞的概率高，重试时，可能出现瞬间压力不均可用于生产环境AlibabaRoundRobin LoadBalanceStable轮循，按公约后的权重设置轮循比率存在慢的机器累积请求问题，极端情况可能产生雪崩可用于生产环境 LeastActive LoadBala

9、nceStable最少活跃调用数，相同活跃数的随机，活跃数指调用前后计数差，使慢的机器收到更少请求不支持权重，在容量规划时，不能通过权重把压力导向一台机器压测容量可用于生产环境 ConsistentHash LoadBalanceStable一致性Hash，相同参数的请求总是发到同一提供者，当某一台提供者挂时，原本发往该提供者的请求，基于虚拟节点，平摊到其它提供者，不会引起剧烈变动压力分摊不均可用于生产环境 FeatureMaturityStrengthProblemAdviseUserFailover ClusterStable失败自动切换，当出现失败，重试其它服务器，通常用于读操作（推荐使

10、用）重试会带来更长延迟可用于生产环境AlibabaFailfast ClusterStable快速失败，只发起一次调用，失败立即报错,通常用于非幂等性的写操作如果有机器正在重启，可能会出现调用失败可用于生产环境AlibabaFailsafe ClusterStable失败安全，出现异常时，直接忽略，通常用于写入审计日志等操作调用信息丢失可用于生产环境MonitorFailback ClusterTested失败自动恢复，后台记录失败请求，定时重发，通常用于消息通知操作不可靠，重启丢失可用于生产环境RegistryForking ClusterTested并行调用多个服务器，只要一个成功即返回，

11、通常用于实时性要求较高的读操作需要浪费更多服务资源可用于生产环境 Broadcast ClusterTested广播调用所有提供者，逐个调用，任意一台报错则报错，通常用于更新提供方本地状态速度慢，任意一台报错则报错可用于生产环境 FeatureMaturityStrengthProblemAdviseUserHessian SerializationStable性能较好，多语言支持（推荐使用）Hessian的各版本兼容性不好，可能和应用使用的Hessian冲突，Dubbo内嵌了hessian3.2.1的源码可用于生产环境AlibabaDubbo SerializationTested通过不传送

12、POJO的类元信息，在大量POJO传输时，性能较好当参数对象增加字段时，需外部文件声明试用 Json SerializationTested纯文本，可跨语言解析，缺省采用FastJson解析性能较差试用 Java SerializationStableJava原生支持性能较差可用于生产环境 数据序列化格式FeatureMaturityStrengthProblemAdviseUserDubbo协议Stable采用NIO复用单一长连接，并使用线程池并发处理请求，减少握手和加大并发效率，性能较好（推荐使用）在大文件传输时，单一连接会成为瓶颈可用于生产环境AlibabaRmi协议Stable可与原生

13、RMI互操作，基于TCP协议偶尔会连接失败，需重建Stub可用于生产环境AlibabaHessian协议Stable可与原生Hessian互操作，基于HTTP协议需hessian.jar支持，http短连接的开销大可用于生产环境 传输数据协议不同服务不同协议 比如：不同服务在性能上适用不同协议进行传输，比如大数据用短连接协议，小数据大并发用长连接协议 不同服务不同协议 比如：不同服务在性能上适用不同协议进行传输，比如大数据用短连接协议，小数据大并发用长连接协议。InJvm调用 同一个jvm内部的服务调用采用短路的方式 先本地服务化，再做物理远程调用 Dubbo是通过JDK的ShutdownHo

14、ok来完成优雅停机的，所以如果用户使用kill-9 PID等强制关闭指令，是不会执行优雅停机的，只有通过kill PID时，才会执行Provider Only Telnet 并发控制Consumer&Provider 显式回调CallBack 隐式传参 C:telnet localhost 20880 dubbo help ls-l ps-l status-l trace XxxService 10 count XxxService invoke XxxService.xxxMethod(args)log 100 http:/ InterfaceListener ImplUserService

15、ImplListener Interfacexxxyyy argument使用场景:注册中心 缓存信息更新 隐式传参，比如：验权扩展点需要携带一些用户凭证信息 ThreadLocal Context RpcContext.setAttachment(“password,“xxx);RpcContext.getAttachment(password);actives:Consumer并发数限制 executes:Provider并发数上限 connections:Consumer的连接数 accepts:Provider的连接上限#短连接是连接上限，长连接则是启用的连接数 LeastActive LoadBalance:调用并发数最小的Provider（从Consumer端并发）调节Provider间并发