akcms做的网站,多语言 网站,青岛网站制作方案,如何用快站做pc端网站1.1 Dubbo概述 Dubbo是阿里巴巴开源的基于 Java 的高性能RPC#xff08;一种远程调用#xff09; 分布式服务框架#xff0c;致力于提供高性能和透明化的RPC远程服务调用方案#xff0c;以及SOA服务治理方案。
每天为2千多个服务提供大于30亿次访问量支持#xff0c;并被…1.1 Dubbo概述 Dubbo是阿里巴巴开源的基于 Java 的高性能RPC一种远程调用 分布式服务框架致力于提供高性能和透明化的RPC远程服务调用方案以及SOA服务治理方案。
每天为2千多个服务提供大于30亿次访问量支持并被广泛应用于阿里巴巴集团的各成员站点以及别的公司的业务中。
简单的说Dubbo就是个服务框架如果没有分布式的需求其实是不需要用的只有在分布式的时候才有Dubbo这样的分布式服务框架的需求。
并且本质上是个远程服务调用的分布式框架告别Web Service模式中的WSdl以服务者与消费者的方式在Dubbo上注册
其核心部分包含
1、远程通讯提供对多种基于长连接的NIO框架抽象封装包括多种线程模型序列化以及“请求-响应”模式的信息交换方式。 2、集群容错提供基于接口方法的透明远程过程调用包括多协议支持以及软负载均衡失败容错地址路由动态配置等集群支持。 3、自动发现基于注册中心目录服务使服务消费方能动态的查找服务提供方使地址透明使服务提供方可以平滑增加或减少机器。
1.2 Dubbo背景 Dubbo开始于电商系统因此在这里先从电商系统的演变讲起。
1.2.1 单一应用框架(ORM) 当网站流量很小时只需一个应用将所有功能如下单支付等都部署在一起以减少部署节点和成本。 缺点单一的系统架构使得在开发过程中占用的资源越来越多而且随着流量的增加越来越难以维护 当网站流量很小时只需一个应用将所有功能如下单支付等都部署在一起以减少部署节点和成本。
缺点单一的系统架构使得在开发过程中占用的资源越来越多而且随着流量的增加越来越难以维护。
1.2.2 垂直应用框架 垂直应用框架(MVC) 垂直应用架构解决了单一应用架构所面临的扩容问题流量能够分散到各个子系统当中且系统的体积可控一定程度上降低了开发人员之间协同以及维护的成本提升了开发效率。 缺点但是在垂直架构中相同逻辑代码需要不断的复制不能复用。 垂直应用架构解决了单一应用架构所面临的扩容问题流量能够分散到各个子系统当中且系统的体积可控一定程度上降低了开发人员之间协同以及维护的成本提升了开发效率。
缺点但是在垂直架构中相同逻辑代码需要不断的复制不能复用。
1.2.3 分布式应用架构(RPC) 当垂直应用越来越多应用之间交互不可避免将核心业务抽取出来作为独立的服务逐渐形成稳定的服务中心。
1.2.4 流动计算架构(SOA) 随着服务化的进一步发展服务越来越多服务之间的调用和依赖关系也越来越复杂诞生了面向服务的架构体系(SOA)也因此衍生出了一系列相应的技术如对服务提供、服务调用、连接处理、通信协议、序列化方式、服务发现、服务路由、日志输出等行为进行封装的服务框架。
1.2.5 架构演变详解 从以上是电商系统的演变可以看出架构演变的过程 1、单应用单服务器 2、单应用拆分成多个应用并部署到多个服务器 3、单应用拆分成多个应用并实现分布式部署 4、流动计算框架用于提高机器利用率的资源调度和治理中心
1.2.6 RPC的简介 RPC(Remote Procedure Call Protocol)远程过程调用
两台服务器A、B分别部署不同的应用a,b。当A服务器想要调用B服务器上应用b提供的函数或方法的时候由于不在一个内存空间不能直接调用需要通过网络来表达调用的语义传达调用的数据。 说白了就是你在你的机器上写了一个程序我这边是无法直接调用的这个时候就出现了一个远程服务调用的概念。
RPC是一种通过网络从远程计算机程序上请求服务而不需要了解底层网络技术的协议。RPC协议假定某些传输协议的存在如TCP或UDP为通信程序之间携带信息数据。在OSI网络通信模型中RPC跨越了传输层和应用层。RPC使得开发包括网络分布式多程序在内的应用程序更加容易。 RPC采用客户机/服务器模式。请求程序就是一个客户机而服务提供程序就是一个服务器。首先客户机调用进程发送一个有进程参数的调用信息到服务进程然后等待应答信息。在服务器端进程保持睡眠状态直到调用信息到达为止。当一个调用信息到达服务器获得进程参数计算结果发送答复信息然后等待下一个调用信息最后客户端调用进程接收答复信息获得进程结果然后调用执行继续进行。 1.2.6.1 RPC需要解决的问题 通讯问题主要是通过在客户端和服务器之间建立TCP连接远程过程调用的所有交换的数据都在这个连接里传输。连接可以是按需连接调用结束后就断掉也可以是长连接多个远程过程调用共享同一个连接。 寻址问题A服务器上的应用怎么告诉底层的RPC框架如何连接到B服务器如主机或IP地址以及特定的端口方法的名称名称是什么这样才能完成调用。比如基于Web服务协议栈的RPC就要提供一个endpoint URI或者是从UDDI服务上查找。如果是RMI调用的话还需要一个RMI Registry来注册服务的地址。 序列化 与 反序列化当A服务器上的应用发起远程过程调用时方法的参数需要通过底层的网络协议如TCP传递到B服务器由于网络协议是基于二进制的内存中的参数的值要序列化成二进制的形式也就是序列化Serialize或编组marshal通过寻址和传输将序列化的二进制发送给B服务器。 同理B服务器接收参数要将参数反序列化。B服务器应用调用自己的方法处理后返回的结果也要序列化给A服务器A服务器接收也要经过反序列化的过程。 1.3 Dubbo作用 我们一起来看一下Dubbo的服务治理图 1.3.1 为什么使用Dubbo 因为是阿里开源项目国内很多互联网公司都在用已经经过很多线上考验。内部使用了Netty、Zookeeper保证了高性能高可用性。
使用Dubbo可以将核心业务抽取出来作为独立的服务逐渐形成稳定的服务中心可用于提高业务复用灵活扩展使前端应用能更快速的响应多变的市场需求。 分布式架构可以承受更大规模的并发流量。 1.3.2 Dubbo能做什么 1、透明化的远程方法调用就像调用本地方法一样调用远程方法只需简单配置没有任何API侵入。 2、软负载均衡及容错机制可在内网替代F5等硬件负载均衡器降低成本减少单点。 3.、服务自动注册与发现不再需要写死服务提供方地址注册中心基于接口名查询服务提供者的IP地址并且能够平滑添加或删除服务提供者。
Dubbo采用全Spring配置方式透明化接入应用对应用没有任何API侵入只需用Spring加载Dubbo的配置即可Dubbo基于Spring的Schema扩展进行加载。
1.4 Dubbo 和 Spring Cloud区别 1、通信方式不同Dubbo 使用的是 RPC 通信而Spring Cloud 使用的是HTTP RESTFul方式。 2、组成不一样
dubbo的服务注册中心为Zookeerper服务监控中心为dubbo-monitor无消息总线、服务跟踪、批量任务等组件 Spring Cloud的服务注册中心为spring-cloud netflix enruka服务监控中心为spring-boot admin有消息总线、数据流、服务跟踪、批量任务等组件
1.5 Dubbo技术架构 首先我们一起来看一下Dubbo官网提供的架构图 Provider: 暴露服务的服务提供方。 Consumer: 调用远程服务的服务消费方。 Registry: 服务注册与发现的注册中心。 Monitor: 统计服务的调用次数和调用时间的监控中心。
看了这几个概念后似乎发现其实Dubbo 的架构也是很简单的(其实现细节是复杂)为什么这么说呢有没有发现其实很像生产者-消费者模型。只是在这种模型上加上了注册中心和监控中心用于管理提供方提供的url以及管理整个过程。
调用关系说明
1、服务容器负责启动加载运行服务提供者。 2、服务提供者在启动时向注册中心注册自己提供的服务。 3、服务消费者在启动时向注册中心订阅自己所需的服务。 4、注册中心返回服务提供者地址列表给消费者如果有变更注册中心将基于长连接推送变更数据给消费者。 5、服务消费者从提供者地址列表中基于软负载均衡算法选一台提供者进行调用如果调用失败再选另一台调用。 6、服务消费者和提供者在内存中累计调用次数和调用时间定时每分钟发送一次统计数据到监控中心。
那么整个发布-订阅的过程就非常的简单了
启动容器加载运行服务提供者。 服务提供者在启动时在注册中心发布注册自己提供的服务。 服务消费者在启动时在注册中心订阅自己所需的服务。 如果考虑失败或变更的情况就需要考虑下面的过程
注册中心返回服务提供者地址列表给消费者如果有变更注册中心将基于长连接推送变更数据给消费者。 服务消费者从提供者地址列表中基于软负载均衡算法选一台提供者进行调用如果调用失败再选另一台调用。 服务消费者和提供者在内存中累计调用次数和调用时间定时每分钟发送一次统计数据到监控中心。
1.6 Dubbo入门案例 1.6.1 服务端 首先我们先把服务端的接口写好因为其实dubbo的作用简单来说就是给消费端提供接口。
接口定义
/*** xml方式服务提供者接口*/
public interface ProviderService {String SayHello(String word);
}这个接口非常简单只是包含一个 SayHello 的方法。
接着定义它的实现类
/*** xml方式服务提供者实现类*/
public class ProviderServiceImpl implements ProviderService{public String SayHello(String word) {return word;}
}这样我们就把我们的接口写好了那么我们应该怎么将我们的服务暴露出去呢
导入 maven 依赖
?xml version1.0 encodingUTF-8?
project xmlnshttp://maven.apache.org/POM/4.0.0xmlns:xsihttp://www.w3.org/2001/XMLSchema-instancexsi:schemaLocationhttp://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsdmodelVersion4.0.0/modelVersiongroupIdcom.ouyangsihai/groupIdartifactIddubbo-provider/artifactIdversion1.0-SNAPSHOT/versiondependenciesdependencygroupIdjunit/groupIdartifactIdjunit/artifactIdversion3.8.1/versionscopetest/scope/dependency!-- https://mvnrepository.com/artifact/com.alibaba/dubbo --dependencygroupIdcom.alibaba/groupIdartifactIddubbo/artifactIdversion2.6.6/version/dependencydependencygroupIdorg.apache.zookeeper/groupIdartifactIdzookeeper/artifactIdversion3.4.10/version/dependencydependencygroupIdcom.101tec/groupIdartifactIdzkclient/artifactIdversion0.5/version/dependencydependencygroupIdio.netty/groupIdartifactIdnetty-all/artifactIdversion4.1.32.Final/version/dependencydependencygroupIdorg.apache.curator/groupIdartifactIdcurator-framework/artifactIdversion2.8.0/version/dependencydependencygroupIdorg.apache.curator/groupIdartifactIdcurator-recipes/artifactIdversion2.8.0/version/dependency/dependencies
/project
这里使用的dubbo的版本是2.6.6需要注意的是如果你只导入dubbo的包的时候是会报错的找不到netty和curator的依赖所以在这里我们需要把这两个的依赖加上就不会报错了。
另外这里我们使用 zookeeper作为注册中心。
到目前为止dubbo 需要的环境就已经可以了下面我们就把上面刚刚定义的接口暴露出去。
暴露接口xml 配置方法 首先我们在我们项目的resource目录下创建 META-INF.spring 包然后再创建 provider.xml 文件名字可以任取哦如下图所示
?xml version1.0 encodingUTF-8?
beans xmlnshttp://www.springframework.org/schema/beansxmlns:xsihttp://www.w3.org/2001/XMLSchema-instancexmlns:dubbohttp://code.alibabatech.com/schema/dubboxsi:schemaLocationhttp://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://code.alibabatech.com/schema/dubbo http://code.alibabatech.com/schema/dubbo/dubbo.xsd!--当前项目在整个分布式架构里面的唯一名称计算依赖关系的标签--dubbo:application nameprovider ownersihaidubbo:parameter keyqos.enable valuetrue/dubbo:parameter keyqos.accept.foreign.ip valuefalse/dubbo:parameter keyqos.port value55555//dubbo:applicationdubbo:monitor protocolregistry/!--dubbo这个服务所要暴露的服务地址所对应的注册中心--!--dubbo:registry addressN/A/--dubbo:registry addressN/A /!--当前服务发布所依赖的协议webservice、Thrift、Hessain、http--dubbo:protocol namedubbo port20880/!--服务发布的配置需要暴露的服务接口--dubbo:serviceinterfacecom.sihai.dubbo.provider.service.ProviderServicerefproviderService/!--Bean bean定义--bean idproviderService classcom.sihai.dubbo.provider.service.ProviderServiceImpl//beans
说明
1、上面的文件其实就是类似 spring的配置文件而且dubbo 底层就是 spring。 2、节点dubbo:application 就是整个项目在分布式架构中的唯一名称可以在name属性中配置另外还可以配置owner字段表示属于谁。 下面的参数是可以不配置的这里配置是因为出现了端口的冲突所以配置。 3、节点dubbo:monitor 监控中心配置 用于配置连接监控中心相关信息可以不配置不是必须的参数。 4、节点dubbo:registry 配置注册中心的信息比如这里我们可以配置 zookeeper 作为我们的注册中心。address 是注册中心的地址这里我们配置的是 N/A 表示由 dubbo自动分配地址。或者说是一种直连的方式不通过注册中心。 5、节点dubbo:protocol 服务发布的时候 dubbo 依赖什么协议可以配置dubbo、webservice、http等协议。 6、节点dubbo:service 这个节点就是我们的重点了当我们服务发布的时候我们就是通过这个配置将我们的服务发布出去的。interface是接口的包路径ref是第 ⑦ 点配置的接口的bean。 7、最后我们需要像配置spring的接口一样配置接口的 bean。
到这一步关于服务端的配置就完成了下面我们通过 main 方法将接口发布出去。
package com.sihai.dubbo.provider;import com.alibaba.dubbo.config.ApplicationConfig;
import com.alibaba.dubbo.config.ProtocolConfig;
import com.alibaba.dubbo.config.RegistryConfig;
import com.alibaba.dubbo.config.ServiceConfig;
import com.alibaba.dubbo.container.Main;
import com.sihai.dubbo.provider.service.ProviderService;
import com.sihai.dubbo.provider.service.ProviderServiceImpl;
import org.springframework.context.support.ClassPathXmlApplicationContext;import java.io.IOException;/*** xml方式启动**/
public class App
{public static void main( String[] args ) throws IOException {//加载xml配置文件启动ClassPathXmlApplicationContext context new ClassPathXmlApplicationContext(META-INF/spring/provider.xml);context.start();System.in.read(); // 按任意键退出}
}
发布接口非常简单因为dubbo底层就是依赖 spring 的所以我们只需要通过 ClassPathXmlApplicationContext拿到我们刚刚配置好的 xml然后调用 context.start()方法就启动了。
看到下面的截图就算是启动成功了接口也就发布出去了。 你以为到这里就结束了了并不是的我们拿到 dubbo 暴露出去的 url分析分析。
Dubbo 暴露的 URL
dubbo://192.168.234.1:20880/com.sihai.dubbo.provider.service.ProviderService?anyhosttrueapplicationproviderbean.namecom.sihai.dubbo.provider.service.ProviderServicebind.ip192.168.234.1bind.port20880dubbo2.0.2genericfalseinterfacecom.sihai.dubbo.provider.service.ProviderServicemethodsSayHelloownersihaipid8412qos.accept.foreign.ipfalseqos.enabletrueqos.port55555sideprovidertimestamp1562077289380
分析如下
1、首先在形式上我们发现其实这么牛逼的 dubbo也是用类似于 http 的协议发布自己的服务的只是这里我们用的是dubbo协议。 2、dubbo://192.168.234.1:20880/com.sihai.dubbo.provider.service.ProviderService 上面这段链接就是 ?之前的链接构成协议://ip:端口/接口。发现是不是也没有什么神秘的。 3、anyhosttrueapplicationproviderbean.namecom.sihai.dubbo.provider.service.ProviderServicebind.ip192.168.234.1bind.port20880dubbo2.0.2genericfalseinterfacecom.sihai.dubbo.provider.service.ProviderServicemethodsSayHelloownersihaipid8412qos.accept.foreign.ipfalseqos.enabletrueqos.port55555sideprovidertimestamp1562077289380 ?之后的字符串分析后你发现这些都是刚刚在provider.xml中配置的字段然后通过 拼接而成的闻到了 http 的香味了吗
终于dubbo 服务端入门了。下面我们看看拿到了 url后怎么消费呢 1.6.2 消费端 上面提到我们在服务端提供的只是点对点的方式提供服务并没有使用注册中心所以下面的配置也是会有一些不一样的。
消费端环境配置 首先我们在消费端的 resource下建立配置文件 consumer.xml
?xml version1.0 encodingUTF-8?
beans xmlnshttp://www.springframework.org/schema/beansxmlns:xsihttp://www.w3.org/2001/XMLSchema-instancexmlns:dubbohttp://code.alibabatech.com/schema/dubboxsi:schemaLocationhttp://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://code.alibabatech.com/schema/dubbo http://code.alibabatech.com/schema/dubbo/dubbo.xsd!--当前项目在整个分布式架构里面的唯一名称计算依赖关系的标签--dubbo:application nameconsumer ownersihai/!--dubbo这个服务所要暴露的服务地址所对应的注册中心--!--点对点的方式--dubbo:registry addressN/A /!--dubbo:registry addresszookeeper://localhost:2181 checkfalse/--!--生成一个远程服务的调用代理--!--点对点方式--dubbo:reference idproviderService
interfacecom.sihai.dubbo.provider.service.ProviderService
urldubbo://192.168.234.1:20880/com.sihai.dubbo.provider.service.ProviderService/!--dubbo:reference idproviderService interfacecom.sihai.dubbo.provider.service.ProviderService/--
/beans
分析如下所示
1、发现这里的 dubbo:application 和 dubbo:registry 是一致的 2、dubbo:reference 我们这里采用点对点的方式所以需要配置在服务端暴露的 url
?xml version1.0 encodingUTF-8?
project xmlnshttp://maven.apache.org/POM/4.0.0xmlns:xsihttp://www.w3.org/2001/XMLSchema-instancexsi:schemaLocationhttp://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsdmodelVersion4.0.0/modelVersiongroupIdcom.ouyangsihai/groupIdartifactIddubbo-consumer/artifactIdversion1.0-SNAPSHOT/versiondependenciesdependencygroupIdcom.ouyangsihai/groupIdartifactIddubbo-provider/artifactIdversion1.0-SNAPSHOT/version/dependencydependencygroupIdjunit/groupIdartifactIdjunit/artifactIdversion3.8.1/versionscopetest/scope/dependency!-- https://mvnrepository.com/artifact/com.alibaba/dubbo --dependencygroupIdcom.alibaba/groupIdartifactIddubbo/artifactIdversion2.6.6/version/dependencydependencygroupIdorg.apache.zookeeper/groupIdartifactIdzookeeper/artifactIdversion3.4.10/version/dependencydependencygroupIdcom.101tec/groupIdartifactIdzkclient/artifactIdversion0.5/version/dependencydependencygroupIdio.netty/groupIdartifactIdnetty-all/artifactIdversion4.1.32.Final/version/dependencydependencygroupIdorg.apache.curator/groupIdartifactIdcurator-framework/artifactIdversion2.8.0/version/dependencydependencygroupIdorg.apache.curator/groupIdartifactIdcurator-recipes/artifactIdversion2.8.0/version/dependency/dependencies
/project
调用服务
package com.sihai.dubbo.consumer;import com.alibaba.dubbo.config.ApplicationConfig;
import com.alibaba.dubbo.config.ReferenceConfig;
import com.alibaba.dubbo.config.RegistryConfig;
import com.sihai.dubbo.provider.service.ProviderService;
import org.springframework.context.support.ClassPathXmlApplicationContext;import java.io.IOException;/*** xml的方式调用**/
public class App
{public static void main( String[] args ) throws IOException {ClassPathXmlApplicationContext contextnew ClassPathXmlApplicationContext(consumer.xml);context.start();ProviderService providerService (ProviderService) context.getBean(providerService);String str providerService.SayHello(hello);System.out.println(str);System.in.read();}
}
这里和服务端的发布如出一辙 如此我们就成功调用接口了。
1.7 加入zookeeper作为注册中心 在前面的案例中我们没有使用任何的注册中心而是用一种直连的方式进行的。但是实际上很多时候我们都是使用dubbo zookeeper的方式使用 zookeeper 作为注册中心这里我们就介绍一下 zookeeper作为注册中心的使用方法。
这里我们在前面的入门实例中进行改造。
1.7.1 服务端 在服务端中我们只需要修改provider.xml 即可。
?xml version1.0 encodingUTF-8?
beans xmlnshttp://www.springframework.org/schema/beansxmlns:xsihttp://www.w3.org/2001/XMLSchema-instancexmlns:dubbohttp://code.alibabatech.com/schema/dubboxsi:schemaLocationhttp://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://code.alibabatech.com/schema/dubbo http://code.alibabatech.com/schema/dubbo/dubbo.xsd!--当前项目在整个分布式架构里面的唯一名称计算依赖关系的标签--dubbo:application nameprovider ownersihaidubbo:parameter keyqos.enable valuetrue/dubbo:parameter keyqos.accept.foreign.ip valuefalse/dubbo:parameter keyqos.port value55555//dubbo:applicationdubbo:monitor protocolregistry/!--dubbo这个服务所要暴露的服务地址所对应的注册中心--!--dubbo:registry addressN/A/--dubbo:registry addresszookeeper://localhost:2181 checkfalse/!--当前服务发布所依赖的协议webservice、Thrift、Hessain、http--dubbo:protocol namedubbo port20880/!--服务发布的配置需要暴露的服务接口--dubbo:serviceinterfacecom.sihai.dubbo.provider.service.ProviderServicerefproviderService/!--Bean bean定义--bean idproviderService classcom.sihai.dubbo.provider.service.ProviderServiceImpl//beans
重点关注这句话
dubbo:registry addresszookeeper://localhost:2181 /在 address 中使用我们的 zookeeper 的地址。
如果是zookeeper集群的话使用下面的方式。
dubbo:registry protocolzookeeper address192.168.11.129:2181,192.168.11.137:2181,192.168.11.138:2181/
服务端的配置就好了其他的跟 入门案例 一样。
1.7.2 消费端 跟服务端一样在消费端我们也只需要修改 consumer.xml 即可。
?xml version1.0 encodingUTF-8?
beans xmlnshttp://www.springframework.org/schema/beansxmlns:xsihttp://www.w3.org/2001/XMLSchema-instancexmlns:dubbohttp://code.alibabatech.com/schema/dubboxsi:schemaLocationhttp://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://code.alibabatech.com/schema/dubbo http://code.alibabatech.com/schema/dubbo/dubbo.xsd!--当前项目在整个分布式架构里面的唯一名称计算依赖关系的标签--dubbo:application nameconsumer ownersihai/!--dubbo这个服务所要暴露的服务地址所对应的注册中心--!--点对点的方式--!--dubbo:registry addressN/A /--dubbo:registry addresszookeeper://localhost:2181 checkfalse/!--生成一个远程服务的调用代理--!--点对点方式--!--dubbo:reference idproviderServiceinterfacecom.sihai.dubbo.provider.service.ProviderServiceurldubbo://192.168.234.1:20880/com.sihai.dubbo.provider.service.ProviderService/--dubbo:reference idproviderServiceinterfacecom.sihai.dubbo.provider.service.ProviderService//beans
1、注册中心配置跟服务端一样
dubbo:registry addresszookeeper://localhost:2181/2、dubbo:reference 由于我们这里使用 zookeeper 作为注册中心所以跟点对点的方式是不一样的这里不再需要 dubbo 服务端提供的 url 了只需要直接引用服务端提供的接口即可
dubbo:reference idproviderServiceinterfacecom.sihai.dubbo.provider.service.ProviderService/好了消费端也配置好了这样就可以使用修改的入门案例重新启动运行了。
这时候的区别在于将 dubbo 发布的url注册到了 zookeeper消费端从 zookeeper消费zookeeper 相当于一个中介给消费者提供服务。
1.8 多种配置方式 在入门实例的时候我们使用的是 xml 配置的方式对 dubbo 的环境进行了配置但是官方还提供了其他的配置方式这里我们也一一分解。
1.8.1 API配置方式 这种方式其实官方是不太推荐的官方推荐使用xml配置的方式但是在有的时候测试的时候还是可以用的到的另外为了保证完整性这些内容还是有必要讲讲的。
首先还是回到服务端工程。
服务端 这里我们使用 api的方式配置所以provider.xml这个配置文件就暂时不需要了我们只需要在上面的 AppApi 这个类中的 main方法中用api配置及启动即可。
package com.sihai.dubbo.provider;import com.alibaba.dubbo.config.ApplicationConfig;
import com.alibaba.dubbo.config.ProtocolConfig;
import com.alibaba.dubbo.config.RegistryConfig;
import com.alibaba.dubbo.config.ServiceConfig;
import com.sihai.dubbo.provider.service.ProviderService;
import com.sihai.dubbo.provider.service.ProviderServiceImpl;import java.io.IOException;/*** Api方式启动* api的方式调用不需要其他的配置只需要下面的代码即可。* 但是需要注意官方建议* Api方式用于测试用例使用推荐xml的方式*/
public class AppApi
{public static void main( String[] args ) throws IOException {// 服务实现ProviderService providerService new ProviderServiceImpl();// 当前应用配置ApplicationConfig application new ApplicationConfig();application.setName(provider);application.setOwner(sihai);// 连接注册中心配置RegistryConfig registry new RegistryConfig();registry.setAddress(zookeeper://localhost:2181);
// registry.setUsername(aaa);
// registry.setPassword(bbb);// 服务提供者协议配置ProtocolConfig protocol new ProtocolConfig();protocol.setName(dubbo);protocol.setPort(20880);//protocol.setThreads(200);// 注意ServiceConfig为重对象内部封装了与注册中心的连接//以及开启服务端口// 服务提供者暴露服务配置// 此实例很重封装了与注册中心的连接请自行缓存//否则可能造成内存和连接泄漏ServiceConfigProviderService service new ServiceConfigProviderService(); service.setApplication(application);// 多个注册中心可以用setRegistries()service.setRegistry(registry); // 多个协议可以用setProtocols()service.setProtocol(protocol); service.setInterface(ProviderService.class);service.setRef(providerService);service.setVersion(1.0.0);// 暴露及注册服务service.export();}
}
分析说明如下所示
看到上面的代码是不是云里雾里不要慌我们通过对照 xml的方式分析一下。
registry 的 xml方式
dubbo:registry protocolzookeeper addresslocalhost:2181/API 的方式
RegistryConfig registry new RegistryConfig();
registry.setAddress(zookeeper://localhost:2181);dubbo:registry节点对应RegistryConfig xml的属性对应 API方式用 set方法就可以了。对比之下你就会发现如果 API的方式不熟悉可以对照xml 配置方式就可以。
其他 API
org.apache.dubbo.config.ServiceConfig
org.apache.dubbo.config.ReferenceConfig
org.apache.dubbo.config.ProtocolConfig
org.apache.dubbo.config.RegistryConfig
org.apache.dubbo.config.MonitorConfig
org.apache.dubbo.config.ApplicationConfig
org.apache.dubbo.config.ModuleConfig
org.apache.dubbo.config.ProviderConfig
org.apache.dubbo.config.ConsumerConfig
org.apache.dubbo.config.MethodConfig
org.apache.dubbo.config.ArgumentConfig
消费端 同样我们不需要 consumer.xml 配置文件了只需要在 main方法中启动即可。
package com.sihai.dubbo.consumer;import com.alibaba.dubbo.config.ApplicationConfig;
import com.alibaba.dubbo.config.ReferenceConfig;
import com.alibaba.dubbo.config.RegistryConfig;
import com.sihai.dubbo.provider.service.ProviderService;/*** api的方式调用* api的方式调用不需要其他的配置只需要下面的代码即可。* 但是需要注意官方建议* Api方式用于测试用例使用推荐xml的方式*/
public class AppApi {public static void main(String[] args) {// 当前应用配置ApplicationConfig application new ApplicationConfig();application.setName(consumer);application.setOwner(sihai);// 连接注册中心配置RegistryConfig registry new RegistryConfig();registry.setAddress(zookeeper://localhost:2181);// 注意ReferenceConfig为重对象内部封装了与注册中心的连接//以及与服务提供方的连接// 引用远程服务ReferenceConfigProviderService reference new ReferenceConfigProviderService(); // 此实例很重封装了与注册中心的连接以及与提供者的连接请自行缓存否则可能造成内存和连接泄漏reference.setApplication(application);reference.setRegistry(registry); // 多个注册中心可以用setRegistries()reference.setInterface(ProviderService.class);// 和本地bean一样使用xxxServiceProviderService providerService reference.get(); // 注意此代理对象内部封装了所有通讯细节对象较重请缓存复用providerService.SayHello(hello dubbo! I am sihai!);}
}
这部分的 API配置的方式就到这了注意官方推荐 xml 的配置方法
1.8.2 注解配置方式 注解配置方式还是需要了解一下的现在微服务都倾向于这种方式这也是以后发展的趋势0 配置应该是这几年的趋势。
那么如何对dubbo 使用注解的方式呢我们先看服务端。
服务端 第一步定义接口及实现类在上面的截图中的 annotation 包下
package com.sihai.dubbo.provider.service.annotation;/*** 注解方式接口*/
public interface ProviderServiceAnnotation {String SayHelloAnnotation(String word);
}
package com.sihai.dubbo.provider.service.annotation;import com.alibaba.dubbo.config.annotation.Service;/*** 注解方式实现类*/
Service(timeout 5000)
public class ProviderServiceImplAnnotation implements ProviderServiceAnnotation{public String SayHelloAnnotation(String word) {return word;}
}
Service
Service 用来配置 Dubbo 的服务提供方。
第二步组装服务提供方。通过 Spring 中 Java Config 的技术Configuration和 annotation 扫描EnableDubbo来发现、组装、并向外提供Dubbo的服务。
package com.sihai.dubbo.provider.configuration;import com.alibaba.dubbo.config.ApplicationConfig;
import com.alibaba.dubbo.config.ProtocolConfig;
import com.alibaba.dubbo.config.ProviderConfig;
import com.alibaba.dubbo.config.RegistryConfig;
import com.alibaba.dubbo.config.spring.context.annotation.EnableDubbo;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;/*** 注解方式配置*/
Configuration
EnableDubbo(scanBasePackages com.sihai.dubbo.provider.service.annotation)
public class DubboConfiguration {Bean // #1 服务提供者信息配置public ProviderConfig providerConfig() {ProviderConfig providerConfig new ProviderConfig();providerConfig.setTimeout(1000);return providerConfig;}Bean // #2 分布式应用信息配置public ApplicationConfig applicationConfig() {ApplicationConfig applicationConfig new ApplicationConfig();applicationConfig.setName(dubbo-annotation-provider);return applicationConfig;}Bean // #3 注册中心信息配置public RegistryConfig registryConfig() {RegistryConfig registryConfig new RegistryConfig();registryConfig.setProtocol(zookeeper);registryConfig.setAddress(localhost);registryConfig.setPort(2181);return registryConfig;}Bean // #4 使用协议配置这里使用 dubbopublic ProtocolConfig protocolConfig() {ProtocolConfig protocolConfig new ProtocolConfig();protocolConfig.setName(dubbo);protocolConfig.setPort(20880);return protocolConfig;}
}
分析说明如下
1、通过 EnableDubbo指定在com.sihai.dubbo.provider.service.annotation下扫描所有标注有 Service 的类2、通过 Configuration将 DubboConfiguration中所有的 Bean通过Java Config的方式组装出来并注入给 Dubbo服务也就是标注有Service 的类。这其中就包括了ProviderConfig服务提供方配置
ApplicationConfig应用配置
RegistryConfig注册中心配置
ProtocolConfig协议配置
第三步启动服务
package com.sihai.dubbo.provider;import com.alibaba.dubbo.config.spring.context.annotation.DubboComponentScan;
import com.sihai.dubbo.provider.configuration.DubboConfiguration;
import org.springframework.context.annotation.AnnotationConfigApplicationContext;
import sun.applet.Main;import java.io.IOException;/*** 注解启动方式*/
public class AppAnnotation {public static void main(String[] args) throws IOException {AnnotationConfigApplicationContext context new AnnotationConfigApplicationContext(DubboConfiguration.class); context.start();System.in.read(); }
}
消费端
同样我们下看看消费端的工程有一个感性认识。 第一步引用服务
package com.sihai.dubbo.consumer.Annotation;import com.alibaba.dubbo.config.annotation.Reference;
import com.sihai.dubbo.provider.service.annotation.ProviderServiceAnnotation;
import org.springframework.stereotype.Component;/*** 注解方式的service*/
Component(annotatedConsumer)
public class ConsumerAnnotationService {Referenceprivate ProviderServiceAnnotation providerServiceAnnotation;public String doSayHello(String name) {return providerServiceAnnotation.SayHelloAnnotation(name);}
}
在 ConsumerAnnotationService 类中通过 Reference 引用服务端提供的类然后通过方法调用这个类的方式给消费端提供接口。
注意如果这里找不到 ProviderServiceAnnotation 类请在服务端先把服务端工程用 Maven intall一下然后将服务端的依赖放到消费端的pom 中。如下
dependencygroupIdcom.ouyangsihai/groupIdartifactIddubbo-provider/artifactIdversion1.0-SNAPSHOT/version
/dependency
解释一下引入的jar包里面只是未被实现的接口rpc需要在客户端服务端定义一套统一的接口然后在服务端实现接口实际上还是网络通信只不过长得像本地实现
第二步组装服务消费者
这一步和服务端是类似的这里就不在重复了。
package com.sihai.dubbo.consumer.configuration;import com.alibaba.dubbo.config.ApplicationConfig;
import com.alibaba.dubbo.config.ConsumerConfig;
import com.alibaba.dubbo.config.RegistryConfig;
import com.alibaba.dubbo.config.spring.context.annotation.EnableDubbo;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.ComponentScan;
import org.springframework.context.annotation.Configuration;import java.util.HashMap;
import java.util.Map;/*** 注解配置类*/
Configuration
EnableDubbo(scanBasePackages com.sihai.dubbo.consumer.Annotation)
ComponentScan(value {com.sihai.dubbo.consumer.Annotation})
public class ConsumerConfiguration {Bean // 应用配置public ApplicationConfig applicationConfig() {ApplicationConfig applicationConfig new ApplicationConfig();applicationConfig.setName(dubbo-annotation-consumer);MapString, String stringStringMap new HashMapString, String();stringStringMap.put(qos.enable,true);stringStringMap.put(qos.accept.foreign.ip,false);stringStringMap.put(qos.port,33333);applicationConfig.setParameters(stringStringMap);return applicationConfig;}Bean // 服务消费者配置public ConsumerConfig consumerConfig() {ConsumerConfig consumerConfig new ConsumerConfig();consumerConfig.setTimeout(3000);return consumerConfig;}Bean // 配置注册中心public RegistryConfig registryConfig() {RegistryConfig registryConfig new RegistryConfig();registryConfig.setProtocol(zookeeper);registryConfig.setAddress(localhost);registryConfig.setPort(2181);return registryConfig;}
}
第三步发起远程调用
在main方法中通过启动一个Spring Context从其中查找到组装好的Dubbo的服务消费者并发起一次远程调用。
package com.sihai.dubbo.consumer;import com.sihai.dubbo.consumer.Annotation.ConsumerAnnotationService;
import com.sihai.dubbo.consumer.configuration.ConsumerConfiguration;
import com.sihai.dubbo.provider.service.ProviderService;
import org.springframework.context.annotation.AnnotationConfigApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;import java.io.IOException;/*** 注解方式启动**/
public class AppAnnotation
{public static void main( String[] args ) throws IOException {AnnotationConfigApplicationContext context new AnnotationConfigApplicationContext(ConsumerConfiguration.class); context.start(); // 启动ConsumerAnnotationService consumerAnnotationService context.getBean(ConsumerAnnotationService.class); String hello consumerAnnotationService.doSayHello(annotation); // 调用方法System.out.println(result: hello); // 输出结果}
}
1.9 常用场景 在下面的讲解中都会是以xml配置的方式来讲解的这也是dubbo官方比较推荐的方式。以下的操作都是在服务端的 xml 配置文件和消费端的配置文件来讲解的。
1.9.1 启动时检查 Dubbo 缺省会在启动时检查依赖的服务是否可用不可用时会抛出异常阻止 Spring初始化完成以便上线时能及早发现问题默认check“true”。
但是有的时候我们并不是都需要启动时就检查的比如测试的时候我们是需要更快速的启动所以这种场景的时候我们是需要关闭这个功能的。
下面我们看看如何使用这个功能。
在服务端注册的时候客户端注册时同样适用
dubbo:registry protocolzookeeper addresslocalhost:2181,localhost:2182,localhost:2183 checkfalse/
在客户端引用服务端服务的时候
dubbo:reference checkfalse idproviderServiceinterfacecom.sihai.dubbo.provider.service.ProviderService/1.9.2 集群容错 dubbo 也是支持集群容错的同时也有很多可选的方案其中默认的方案是 failover也就是重试机制。
首先我们先把所有的容错机制都整理一遍然后再看看使用。 使用实例 在发布服务或者引用服务的时候设置
!--服务发布的配置需要暴露的服务接口--dubbo:service clusterfailover retries2interfacecom.sihai.dubbo.provider.service.ProviderServicerefproviderService/dubbo:reference clusterfailover retries2 checkfalse idproviderServiceinterfacecom.sihai.dubbo.provider.service.ProviderService/
1.9.3 负载均衡 负载均衡想必是一个再熟悉不过的概念了所以dubbo 支持也是再正常不过了这里也总结一下dubbo支持的负载均衡的一些方案及使用方法。 1.9.4 直连提供者 在开发及测试环境下经常需要绕过注册中心只测试指定服务提供者所以这种情况下我们只需要直接连接服务端的地即可其实这种方法在前面的讲解已经使用到了第一种讲解的方式就是这种方式因为这种方式简单。
使用方法如下所示
dubbo:reference idproviderServiceinterfacecom.sihai.dubbo.provider.service.ProviderServiceurldubbo://192.168.234.1:20880/com.sihai.dubbo.provider.service.ProviderService/
说明可以看到只要在消费端在·dubbo:reference 节点使用url给出服务端的方法即可。
1.9.5 只订阅 只订阅就是只能够订阅服务端的服务而不能够注册。
引用官方的使用场景如下
为方便开发测试经常会在线下共用一个所有服务可用的注册中心这时如果一个正在开发中的服务提供者注册可能会影响消费者不能正常运行。 可以让服务提供者开发方只订阅服务(开发的服务可能依赖其它服务)而不注册正在开发的服务通过直连测试正在开发的服务。
dubbo:registry registerfalse protocolzookeeper addresslocalhost:2181,localhost:2182,localhost:2183 checkfalse/
1、使用只订阅方式 当在服务提供端使用 register“false” 的时候我们使用下面的方式获取服务端的服务
dubbo:reference clusterfailover retries2 checkfalse idproviderServiceinterfacecom.sihai.dubbo.provider.service.ProviderService/发现这时候并不是向注册中心 zookeeper 注册而只是做了发布服务和启动netty。
2、不使用只订阅方式
dubbo:registry protocolzookeeper addresslocalhost:2181,localhost:2182,localhost:2183 checkfalse/
可以发现这里就向注册中心 zookeeper 注册了。
1.9.6 只注册 只注册正好跟前面的只订阅相反这个时候可以向注册中心注册但是消费端却不能够读到服务。
应用场景
如果有两个镜像环境两个注册中心有一个服务只在其中一个注册中心有部署另一个注册中心还没来得及部署而两个注册中心的其它应用都需要依赖此服务。这个时候可以让服务提供者方只注册服务到另一注册中心而不从另一注册中心订阅服务。
使用说明
dubbo:registry subscribefalse addresslocalhost:2181/dubbo:registry在服务端的 dubbo:registry 节点下使用 subscribe“false” 来声明这个服务是只注册的服务。
这个时候消费端调用的时候是不能调用的。 1.9.7 多协议机制 在前面我们使用的协议都是 dubbo 协议但是 dubbo除了支持这种协议外还支持其他的协议比如rmi、hessian等另外而且还可以用多种协议同时暴露一种服务。
使用方法
1、一种接口使用一种协议
先声明多种协议 !--当前服务发布所依赖的协议webserovice、Thrift、Hessain、http--dubbo:protocol namedubbo port20880/dubbo:protocol namermi port1099 /然后在发布接口的时候使用具体协议
!--服务发布的配置需要暴露的服务接口--dubbo:service clusterfailover retries2interfacecom.sihai.dubbo.provider.service.ProviderServicerefproviderService/dubbo:service clusterfailover retries2interfacecom.sihai.dubbo.provider.service.ProviderServicerefproviderService protocolrmi/在输出日志中就可以找到rmi发布的接口。
dubbo:service clusterfailover retries2interfacecom.sihai.dubbo.provider.service.ProviderServicerefproviderService protocolrmi,dubbo/
说明protocol属性可以用,隔开使用多种协议。
1.9.8 多注册中心 Dubbo支持同一服务向多注册中心同时注册或者不同服务分别注册到不同的注册中心上去甚至可以同时引用注册在不同注册中心上的同名服务。
服务端多注册中心发布服务
一个服务可以在不同的注册中心注册当一个注册中心出现问题时可以用其他的注册中心。
注册
!--多注册中心--dubbo:registry protocolzookeeper idreg1 timeout10000 addresslocalhost:2181/dubbo:registry protocolzookeeper idreg2 timeout10000 addresslocalhost:2182/dubbo:registry protocolzookeeper idreg3 timeout10000 addresslocalhost:2183/
发布服务
!--服务发布的配置需要暴露的服务接口--dubbo:service clusterfailover retries2interfacecom.sihai.dubbo.provider.service.ProviderServicerefproviderService registryreg1/dubbo:service clusterfailover retries2interfacecom.sihai.dubbo.provider.service.ProviderServicerefproviderService protocolrmi registryreg2/明使用registryreg2指定该接口使用的注册中心同时也可以使用多个用隔开例如registry“reg1,reg2”。
消费端多注册中心引用服务
首先先向不同注册中心注册;
!--多注册中心--dubbo:registry protocolzookeeper idreg1 timeout10000 addresslocalhost:2181/dubbo:registry protocolzookeeper idreg2 timeout10000 addresslocalhost:2182/dubbo:registry protocolzookeeper idreg3 timeout10000 addresslocalhost:2183/其次不同的消费端服务引用使用不同的注册中心
!--不同的服务使用不同的注册中心--dubbo:reference clusterfailover retries2 checkfalse idproviderServiceinterfacecom.sihai.dubbo.provider.service.ProviderService registryreg1/dubbo:reference clusterfailover retries2 checkfalse idproviderService2interfacecom.sihai.dubbo.provider.service.ProviderService registryreg2/说明上面分别使用注册中心1和注册中心2。
1.9.9 多版本 不同的服务是有版本不同的版本可以更新并且升级同时不同的版本之间是不可以调用的。
!--服务发布的配置需要暴露的服务接口--dubbo:service clusterfailover retries2interfacecom.sihai.dubbo.provider.service.ProviderServicerefproviderService registryreg1 version1.0.0/dubbo:service clusterfailover retries2interfacecom.sihai.dubbo.provider.service.ProviderServicerefproviderService protocolrmi registryreg2 version1.0.0/加入了版本控制。
1.9.10 日志管理 dubbo也可以将日志信息记录或者保存到文件中的。
1、使用accesslog输出到log4j
dubbo:protocol accesslogtrue namedubbo port20880/dubbo:protocol accesslogtrue namermi port1099 /2、输出到文件
dubbo:protocol accessloghttp://localhost/log.txt namedubbo port20880/dubbo:protocol accessloghttp://localhost/log2.txt namermi port1099 /
