Dubbo

节点角色说明
Provider暴露服务的服务提供方
Consumer调用远程服务的服务消费方
Registry服务注册与发现的注册中心
Monitor统计服务的调用次数和调用时间的监控中心
Container服务运行容器

dubbo架构

生产者-消费者模型,加上注册中心、监控中心

发布-订阅过程

启动容器,加载,运行服务提供者、服务消费者

服务提供者在启动时,在注册中心发布注册自己提供的服务

服务消费者在启动时,在注册中心订阅自己所需的服务

容错模式

注册中心返回服务提供者地址列表给消费者,如果有变更,注册中心将基于长连接推送变更数据给消费者

服务消费者,从提供者地址列表中,基于软负载均衡算法,选一台提供者进行调用,如果调用失败,再选另一台调用

服务消费者和提供者,在内存中累计调用次数和调用时间,定时每分钟发送一次统计数据到监控中心

服务端

给消费端提供接口

 1  2  3  4  5  6  7  8  9 10 11 12 13 14 15
/** * xml方式服务提供者接口 */ public interface ProviderService { String SayHello(String word); } /** * xml方式服务提供者实现类 */ public class ProviderServiceImpl implements ProviderService{ public String SayHello(String word) { return word; } }

maven依赖

使用zookeeper作为注册中心,配置dubbo、netty、curator依赖

 1  2  3  4  5  6  7  8  9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51
<?xml version="1.0" encoding="UTF-8"?> <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"> <modelVersion>4.0.0</modelVersion> <groupId>com.ouyangsihai</groupId> <artifactId>dubbo-provider</artifactId> <version>1.0-SNAPSHOT</version> <dependencies> <dependency> <groupId>junit</groupId> <artifactId>junit</artifactId> <version>3.8.1</version> <scope>test</scope> </dependency> <!-- https://mvnrepository.com/artifact/com.alibaba/dubbo --> <dependency> <groupId>com.alibaba</groupId> <artifactId>dubbo</artifactId> <version>2.6.6</version> </dependency> <dependency> <groupId>org.apache.zookeeper</groupId> <artifactId>zookeeper</artifactId> <version>3.4.10</version> </dependency> <dependency> <groupId>com.101tec</groupId> <artifactId>zkclient</artifactId> <version>0.5</version> </dependency> <dependency> <groupId>io.netty</groupId> <artifactId>netty-all</artifactId> <version>4.1.32.Final</version> </dependency> <dependency> <groupId>org.apache.curator</groupId> <artifactId>curator-framework</artifactId> <version>2.8.0</version> </dependency> <dependency> <groupId>org.apache.curator</groupId> <artifactId>curator-recipes</artifactId> <version>2.8.0</version> </dependency> </dependencies> </project>

暴露接口(xml配置方法)

首先在resource目录下创建META-INF.spring包,然后创建provider.xml

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、webserovice、Thrift、Hessain、http等协议

6、节点:dubbo:service

这个节点就是我们的重点了,当我们服务发布的时候,我们就是通过这个配置将我们的服务发布出去的。interface是接口的包路径,ref是第7点配置的接口的bean

7、最后,我们需要像配置spring的接口一样,配置接口的bean

 1  2  3  4  5  6  7  8  9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31
<?xml version="1.0" encoding="UTF-8"?> <beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:dubbo="http://code.alibabatech.com/schema/dubbo" xsi:schemaLocation="http://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 name="provider" owner="sihai"> <dubbo:parameter key="qos.enable" value="true"/> <dubbo:parameter key="qos.accept.foreign.ip" value="false"/> <dubbo:parameter key="qos.port" value="55555"/> </dubbo:application> <dubbo:monitor protocol="registry"/> <!--dubbo这个服务所要暴露的服务地址所对应的注册中心--> <!--<dubbo:registry address="N/A"/>--> <dubbo:registry address="N/A" /> <!--当前服务发布所依赖的协议;webserovice、Thrift、Hessain、http--> <dubbo:protocol name="dubbo" port="20880"/> <!--服务发布的配置,需要暴露的服务接口--> <dubbo:service interface="com.sihai.dubbo.provider.service.ProviderService" ref="providerService"/> <!--Bean bean定义--> <bean id="providerService" class="com.sihai.dubbo.provider.service.ProviderServiceImpl"/> </beans>

发布接口

 1  2  3  4  5  6  7  8  9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25
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暴露的url

1
dubbo://192.168.234.1:20880/com.sihai.dubbo.provider.service.ProviderService?anyhost=true&application=provider&bean.name=com.sihai.dubbo.provider.service.ProviderService&bind.ip=192.168.234.1&bind.port=20880&dubbo=2.0.2&generic=false&interface=com.sihai.dubbo.provider.service.ProviderService&methods=SayHello&owner=sihai&pid=8412&qos.accept.foreign.ip=false&qos.enable=true&qos.port=55555&side=provider&timestamp=1562077289380

1、首先,在形式上我们发现,其实这么牛逼的dubbo也是用类似于http的协议发布自己的服务的,只是这里我们用的是dubbo协议

2、这段链接就是?之前的链接,构成:协议://ip:端口/接口。发现是不是也没有什么神秘的

1
dubbo://192.168.234.1:20880/com.sihai.dubbo.provider.service.ProviderService

3、?之后的字符串,分析后你发现,这些都是刚刚在provider.xml中配置的字段,然后通过&拼接而成的,闻到了http的香味了吗

1
anyhost=true&application=provider&bean.name=com.sihai.dubbo.provider.service.ProviderService&bind.ip=192.168.234.1&bind.port=20880&dubbo=2.0.2&generic=false&interface=com.sihai.dubbo.provider.service.ProviderService&methods=SayHello&owner=sihai&pid=8412&qos.accept.foreign.ip=false&qos.enable=true&qos.port=55555&side=provider&timestamp=1562077289380

消费端

在消费端的resource下建立配置文件consumer.xml

1、发现这里的dubbo:application和dubbo:registry是一致的

2、dubbo:reference:我们这里采用点对点的方式,所以,需要配置在服务端暴露的url

 1  2  3  4  5  6  7  8  9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24
<?xml version="1.0" encoding="UTF-8"?> <beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:dubbo="http://code.alibabatech.com/schema/dubbo" xsi:schemaLocation="http://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 name="consumer" owner="sihai"/> <!--dubbo这个服务所要暴露的服务地址所对应的注册中心--> <!--点对点的方式--> <dubbo:registry address="N/A" /> <!--<dubbo:registry address="zookeeper://localhost:2181" check="false"/>--> <!--生成一个远程服务的调用代理--> <!--点对点方式--> <dubbo:reference id="providerService" interface="com.sihai.dubbo.provider.service.ProviderService" url="dubbo://192.168.234.1:20880/com.sihai.dubbo.provider.service.ProviderService"/> <!--<dubbo:reference id="providerService" interface="com.sihai.dubbo.provider.service.ProviderService"/>--> </beans>

maven依赖

与服务端一样

调用服务

 1  2  3  4  5  6  7  8  9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25
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 context=new ClassPathXmlApplicationContext("consumer.xml"); context.start(); ProviderService providerService = (ProviderService) context.getBean("providerService"); String str = providerService.SayHello("hello"); System.out.println(str); System.in.read(); } }

zookeeper作为注册中心

dubbo+zookeeper

服务端

修改provider.xml,在address中,使用我们的zookeeper地址

1
<dubbo:registry address="zookeeper://localhost:2181" />

如果是zookeeper集群,使用下面的方式

1
<dubbo:registry protocol="zookeeper" address="192.168.11.129:2181,192.168.11.137:2181,192.168.11.138:2181"/>

 1  2  3  4  5  6  7  8  9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31
<?xml version="1.0" encoding="UTF-8"?> <beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:dubbo="http://code.alibabatech.com/schema/dubbo" xsi:schemaLocation="http://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 name="provider" owner="sihai"> <dubbo:parameter key="qos.enable" value="true"/> <dubbo:parameter key="qos.accept.foreign.ip" value="false"/> <dubbo:parameter key="qos.port" value="55555"/> </dubbo:application> <dubbo:monitor protocol="registry"/> <!--dubbo这个服务所要暴露的服务地址所对应的注册中心--> <!--<dubbo:registry address="N/A"/>--> <dubbo:registry address="zookeeper://localhost:2181" check="false"/> <!--当前服务发布所依赖的协议;webserovice、Thrift、Hessain、http--> <dubbo:protocol name="dubbo" port="20880"/> <!--服务发布的配置,需要暴露的服务接口--> <dubbo:service interface="com.sihai.dubbo.provider.service.ProviderService" ref="providerService"/> <!--Bean bean定义--> <bean id="providerService" class="com.sihai.dubbo.provider.service.ProviderServiceImpl"/> </beans>

消费端

修改consumer.xml

1、注册中心配置跟服务端一样

1
<dubbo:registry address="zookeeper://localhost:2181"/>

2、dubbo:reference

由于我们这里使用zookeeper作为注册中心,所以,跟点对点的方式是不一样的,这里不再需要dubbo服务端提供的url了,只需要直接引用服务端提供的接口即可

1 2
<dubbo:reference id="providerService" interface="com.sihai.dubbo.provider.service.ProviderService"/>

好了,消费端也配置好了,这样就可以使用修改的入门案例,重新启动运行了

与直连方式区别

区别在于,将dubbo发布的url注册到了zookeeper,消费端从zookeeper消费,zookeeper相当于一个中介,给消费者提供服务

 1  2  3  4  5  6  7  8  9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24
<?xml version="1.0" encoding="UTF-8"?> <beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:dubbo="http://code.alibabatech.com/schema/dubbo" xsi:schemaLocation="http://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 name="consumer" owner="sihai"/> <!--dubbo这个服务所要暴露的服务地址所对应的注册中心--> <!--点对点的方式--> <!--<dubbo:registry address="N/A" />--> <dubbo:registry address="zookeeper://localhost:2181" check="false"/> <!--生成一个远程服务的调用代理--> <!--点对点方式--> <!--<dubbo:reference id="providerService" interface="com.sihai.dubbo.provider.service.ProviderService" url="dubbo://192.168.234.1:20880/com.sihai.dubbo.provider.service.ProviderService"/>--> <dubbo:reference id="providerService" interface="com.sihai.dubbo.provider.service.ProviderService"/> </beans>

浙ICP备11005866号-8