dubbo入门--原理应用实例

Posted 程序猿knight

tags:

篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了dubbo入门--原理应用实例相关的知识，希望对你有一定的参考价值。

要说dubbo就先了解一下RPC：

概念：

RPC（Remote Procedure Call）：远程过程调用，是一种通过网络从远程计算机程序上请求服务，而不需要了解底层网络技术的协议。它使得在本地调用远端的程序就好像是在调用本地的程序一样。

RPC协议假定某些传输协议是存在的，如TCP或UDP，为通信程序之间携带信息数据。在OSI网络通信模型（七层模型）中，RPC跨越了传输层和应用层。RPC使得开发包括网络分布式多程序在内的应用程序更加容易。

RPC调用过程：

  1. 客户端以本地服务方式调用服务

  2. client stub作为代理，然后处理调用与调用的参数

  3. client stub发送调用到远端的系统，通过TCP或UDP

  4. server stub处理client stub发过来的调用与参数

  5. server stub调用真正提供的服务

  6. server stub处理回复，然后发送给客户端

Dubbo

1、什么是dubbo ：

Dubbo是阿里巴巴SOA服务化治理方案的核心框架，是一个分布式服务框架，致力于提供高性能和透明化的RPC远程服务调用方案，以及SOA服务治理方案。

　　 soa：“面向服务架构”，它提供的是一种架构风格和理念，而并非是一种技术或者产品。SOA提倡将不同应用程序的业务功能封装成“服务”并宿主起来，通常以接口和契约的形式暴露并提供给外界应用访问（通过交换消息），达到不同系统可重用的目的。

2、Dubbo的技术架构图如下：

dubbo入门--原理、应用、实例

我们解释一下这个架构图：

  • a、Consumer服务消费者（花钱的），Provider服务提供者（给钱的），Container服务容器（领钱的地方）。

  • b、服务提供者先启动，然后注册服务（registry）。

  • c、Monitor这是一个监控，图中虚线表明Consumer 和Provider通过异步的方式发送消息至Monitor，Consumer和Provider会将信息存放在本地磁盘，平均1min会发送一次信息。Monitor在整个架构中是可选的。

  • d、Monitor功能需要单独配置，不配置或者配置以后，Monitor挂掉并不会影响服务的调用。

3、Dubbo服务消费者调用过程

dubbo入门--原理、应用、实例

上图是服务消费的主过程：

首先通过 ReferenceConfig 类的 private void init() 方法会先检查初始化所有的配置信息后，调用 private T createProxy(Map map) 创建代理，消费者最终得到的是服务的代理， 在 createProxy 接着调用 Protocol 接口实现的 Invoker refer(Class type, URL url) 方法生成 Invoker 实例(如上图中的红色部分)，这是服务消费的关键。接下来把 Invoker 通过 ProxyFactory 代理工厂转换为客户端需要的接口(如： HelloWorld )，创建服务代理并返回。

消费端的初始化过程

  • 1、把服务引用的信息封装成URL并注册到zk注册中心;

  • 2、监听注册中心的服务的上下线;

  • 3、连接服务提供端，创建NettyClient对象;

  • 4、将这些信息包装成DubboInvoker消费端的调用链，创建消费端Invoker实例的服务代理并返回;

消费端的服务引用过程

  • 1、经过负载均衡策略，调用提供者;

  • 2、选择其中一个服务的URL与提供者netty建立连接，使用ProxyFactory 创建远程通信，或者本地通信的，Invoker发到netty服务端;

  • 3、服务器端接收到该Invoker信息后，找到对应的本地Invoker，处理Invocation请求;

  • 4、获取异步，或同步处理结果;

    • 异步 不需要返回值：直接调用ExchangeClient.send()方法;

    • 同步 需要返回值：使用ExchangeClient.request()方法，返回一个ResponseFuture，一直阻塞到服务端返回响应结果;

最简单的dubbo实例

服务提供方和消费方都需要的包（这里我新建的maven工程为pom工程，将共同的项目依赖写到pom.xml中）

总的项目结构为

dubbo入门--原理、应用、实例

pom.xml文件内容为

 
   
   
 
    
  
    
    
  
  1. <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">
    2. 
  
    
    
  
  2.   <modelVersion>4.0.0</modelVersion>
    3. 
  
    
    
  
  3.   <groupId>com.test</groupId>
    4. 
  
    
    
  
  4.   <artifactId>dubbo-demo</artifactId>
    5. 
  
    
    
  
  5.   <version>0.0.1-SNAPSHOT</version>
    6. 
  
    
    
  
  6.   <packaging>pom</packaging>
    7. 
  
    
    
  
    8. 
  
    
    
  
  8.    <properties>
    9. 
  
    
    
  
  9.         <motan.version>0.3.0</motan.version>
    10. 
  
    
    
  
  10.         <!-- 在阿里巴巴内部广泛使用的GA版本为：2.4.9，强烈推荐此版本 -->
    11. 
  
    
    
  
  11.         <dubbo.version>2.5.3</dubbo.version>
    12. 
  
    
    
  
  12.         <dubbox.version>2.8.4</dubbox.version>
    13. 
  
    
    
  
  13.         <spring.version>4.3.6.RELEASE</spring.version>
    14. 
  
    
    
  
  14.         <java.version>1.7</java.version>
    15. 
  
    
    
  
  15.         <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
    16. 
  
    
    
  
  16.     </properties>
    17. 
  
    
    
  
    18. 
  
    
    
  
  18.     <dependencies>
    19. 
  
    
    
  
  19.       <dependency>
    20. 
  
    
    
  
  20.             <groupId>com.alibaba</groupId>
    21. 
  
    
    
  
  21.             <artifactId>dubbo</artifactId>
    22. 
  
    
    
  
  22.             <version>2.5.3</version>
    23. 
  
    
    
  
  23.             <exclusions>
    24. 
  
    
    
  
  24.                 <exclusion>
    25. 
  
    
    
  
  25.                     <groupId>org.springframework</groupId>
    26. 
  
    
    
  
  26.                     <artifactId>spring</artifactId>
    27. 
  
    
    
  
  27.                 </exclusion>
    28. 
  
    
    
  
  28.             </exclusions>
    29. 
  
    
    
  
  29.         </dependency>
    30. 
  
    
    
  
  30.         <dependency>
    31. 
  
    
    
  
  31.             <groupId>com.github.sgroschupf</groupId>
    32. 
  
    
    
  
  32.             <artifactId>zkclient</artifactId>
    33. 
  
    
    
  
  33.             <version>0.1</version>
    34. 
  
    
    
  
  34.         </dependency>
    35. 
  
    
    
  
  35.         <!-- spring相关 -->
    36. 
  
    
    
  
  36.         <dependency>
    37. 
  
    
    
  
  37.             <groupId>org.springframework</groupId>
    38. 
  
    
    
  
  38.             <artifactId>spring-core</artifactId>
    39. 
  
    
    
  
  39.             <version>${spring.version}</version>
    40. 
  
    
    
  
  40.         </dependency>
    41. 
  
    
    
  
  41.         <dependency>
    42. 
  
    
    
  
  42.             <groupId>org.springframework</groupId>
    43. 
  
    
    
  
  43.             <artifactId>spring-beans</artifactId>
    44. 
  
    
    
  
  44.             <version>${spring.version}</version>
    45. 
  
    
    
  
  45.         </dependency>
    46. 
  
    
    
  
  46.         <dependency>
    47. 
  
    
    
  
  47.             <groupId>org.springframework</groupId>
    48. 
  
    
    
  
  48.             <artifactId>spring-context</artifactId>
    49. 
  
    
    
  
  49.             <version>${spring.version}</version>
    50. 
  
    
    
  
  50.         </dependency>
    51. 
  
    
    
  
  51.         <dependency>
    52. 
  
    
    
  
  52.             <groupId>org.springframework</groupId>
    53. 
  
    
    
  
  53.             <artifactId>spring-jdbc</artifactId>
    54. 
  
    
    
  
  54.             <version>${spring.version}</version>
    55. 
  
    
    
  
  55.         </dependency>
    56. 
  
    
    
  
  56.         <dependency>
    57. 
  
    
    
  
  57.             <groupId>org.springframework</groupId>
    58. 
  
    
    
  
  58.             <artifactId>spring-web</artifactId>
    59. 
  
    
    
  
  59.             <version>${spring.version}</version>
    60. 
  
    
    
  
  60.         </dependency>
    61. 
  
    
    
  
  61.         <dependency>
    62. 
  
    
    
  
  62.             <groupId>org.springframework</groupId>
    63. 
  
    
    
  
  63.             <artifactId>spring-webmvc</artifactId>
    64. 
  
    
    
  
  64.             <version>${spring.version}</version>
    65. 
  
    
    
  
  65.         </dependency>
    66. 
  
    
    
  
  66.         <dependency>
    67. 
  
    
    
  
  67.             <groupId>org.springframework</groupId>
    68. 
  
    
    
  
  68.             <artifactId>spring-aop</artifactId>
    69. 
  
    
    
  
  69.             <version>${spring.version}</version>
    70. 
  
    
    
  
  70.         </dependency>
    71. 
  
    
    
  
  71.         <dependency>
    72. 
  
    
    
  
  72.             <groupId>org.springframework</groupId>
    73. 
  
    
    
  
  73.             <artifactId>spring-tx</artifactId>
    74. 
  
    
    
  
  74.             <version>${spring.version}</version>
    75. 
  
    
    
  
  75.         </dependency>
    76. 
  
    
    
  
  76.         <dependency>
    77. 
  
    
    
  
  77.             <groupId>org.springframework</groupId>
    78. 
  
    
    
  
  78.             <artifactId>spring-orm</artifactId>
    79. 
  
    
    
  
  79.             <version>${spring.version}</version>
    80. 
  
    
    
  
  80.         </dependency>
    81. 
  
    
    
  
  81.         <dependency>
    82. 
  
    
    
  
  82.             <groupId>org.springframework</groupId>
    83. 
  
    
    
  
  83.             <artifactId>spring-context-support</artifactId>
    84. 
  
    
    
  
  84.             <version>${spring.version}</version>
    85. 
  
    
    
  
  85.         </dependency>
    86. 
  
    
    
  
  86.         <dependency>
    87. 
  
    
    
  
  87.             <groupId>org.springframework</groupId>
    88. 
  
    
    
  
  88.             <artifactId>spring-test</artifactId>
    89. 
  
    
    
  
  89.             <version>${spring.version}</version>
    90. 
  
    
    
  
  90.         </dependency>
    91. 
  
    
    
  
  91.         <dependency>
    92. 
  
    
    
  
  92.             <groupId>org.springframework</groupId>
    93. 
  
    
    
  
  93.             <artifactId>spring-jms</artifactId>
    94. 
  
    
    
  
  94.             <version>${spring.version}</version>
    95. 
  
    
    
  
  95.         </dependency>
    96. 
  
    
    
  
  96.         <dependency>
    97. 
  
    
    
  
  97.             <groupId>org.aspectj</groupId>
    98. 
  
    
    
  
  98.             <artifactId>aspectjrt</artifactId>
    99. 
  
    
    
  
  99.             <version>1.6.11</version>
    100. 
  
    
    
  
  100.         </dependency>
    101. 
  
    
    
  
  101.         <dependency>
    102. 
  
    
    
  
  102.             <groupId>org.aspectj</groupId>
    103. 
  
    
    
  
  103.             <artifactId>aspectjweaver</artifactId>
    104. 
  
    
    
  
  104.             <version>1.6.11</version>
    105. 
  
    
    
  
  105.         </dependency>
    106. 
  
    
    
  
  106.     </dependencies>
    107. 
  
    
    
  
  107.    <modules>
    108. 
  
    
    
  
  108.     <module>demo-api</module>
    109. 
  
    
    
  
  109.     <module>dubbo-consumer</module>
    110. 
  
    
    
  
  110.     <module>dubbo-provider</module>
    111. 
  
    
    
  
  111.    </modules>
    112. 
  
    
    
  
  112. </project>
    113.

在demo-api中定义服务接口（注意服务提供方和消费方都需要依赖这个项目）

 
   
   
 
    
  
    
    
  
  1. package com.test;
    2. 
  
    
    
  
    3. 
  
    
    
  
  3. public interface DemoService{  
    4. 
  
    
    
  
  4.      String sayHello(String name);  
    5. 
  
    
    
  
  5. } 
    6.

服务提供方实现

项目结构

dubbo入门--原理、应用、实例

实现接口

 
   
   
 
    
  
    
    
  
  1. package com.test;
    2. 
  
    
    
  
  2. import org.springframework.stereotype.Service;
    3. 
  
    
    
  
    4. 
  
    
    
  
  4. import com.test.DemoService;
    5. 
  
    
    
  
  5. @Service("demoService")
    6. 
  
    
    
  
  6. public class DemoServiceImpl implements DemoService{
    7. 
  
    
    
  
    8. 
  
    
    
  
  8.     @Override
    9. 
  
    
    
  
  9.     public String sayHello(String name) {
    10. 
  
    
    
  
  10.         // TODO Auto-generated method stub
    11. 
  
    
    
  
  11.         return name; 
    12. 
  
    
    
  
  12.     }  
    13. 
  
    
    
  
  13. }
    14.

声明暴露服务：

 
   
   
 
    
  
    
    
  
  1. <?xml version="1.0" encoding="UTF-8"?>
    2. 
  
    
    
  
  2. <beans xmlns="http://www.springframework.org/schema/beans"
    3. 
  
    
    
  
  3.     xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    4. 
  
    
    
  
  4.     xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"
    5. 
  
    
    
  
  5.     xsi:schemaLocation="http://www.springframework.org/schema/beans
    6. 
  
    
    
  
  6.     http://www.springframework.org/schema/beans/spring-beans.xsd
    7. 
  
    
    
  
  7.     http://code.alibabatech.com/schema/dubbo
    8. 
  
    
    
  
  8.     http://code.alibabatech.com/schema/dubbo/dubbo.xsd">
    9. 
  
    
    
  
    10. 
  
    
    
  
  10.     <!-- 提供方应用信息，用于计算依赖关系 -->  
    11. 
  
    
    
  
  11.     <dubbo:application name="dubbo_provider"  />  
    12. 
  
    
    
  
    13. 
  
    
    
  
  13. 
  
    
    
  
  14.     <dubbo:registry address="zookeeper://127.0.0.1:2181" />   
    15. 
  
    
    
  
    16. 
  
    
    
  
  16.     <!-- 用dubbo协议在20880端口暴露服务 -->  
    17. 
  
    
    
  
  17.     <dubbo:protocol name="dubbo" port="20880" />  
    18. 
  
    
    
  
    19. 
  
    
    
  
  19.     <!-- 声明需要暴露的服务接口 -->  
    20. 
  
    
    
  
  20.     <dubbo:service interface="com.test.DemoService" ref="demoService" />  
    21. 
  
    
    
  
  21. </beans>
    22.

在springmvc.xml中扫描service注解并将dubbo-provider.xml中的相关的dubbo配置引入进来

 
   
   
 
    
  
    
    
  
  1. <?xml version="1.0" encoding="UTF-8"?>
    2. 
  
    
    
  
  2. <beans xmlns="http://www.springframework.org/schema/beans" xmlns:aop="http://www.springframework.org/schema/aop"
    3. 
  
    
    
  
  3.     xmlns:context="http://www.springframework.org/schema/context"
    4. 
  
    
    
  
  4.     xmlns:util="http://www.springframework.org/schema/util" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    5. 
  
    
    
  
  5.     xsi:schemaLocation="http://www.springframework.org/schema/aop   
    6. 
  
    
    
  
  6.         http://www.springframework.org/schema/aop/spring-aop-4.0.xsd   
    7. 
  
    
    
  
  7.         http://www.springframework.org/schema/beans   
    8. 
  
    
    
  
  8.         http://www.springframework.org/schema/beans/spring-beans-4.0.xsd   
    9. 
  
    
    
  
  9.         http://www.springframework.org/schema/context
    10. 
  
    
    
  
  10.         http://www.springframework.org/schema/context/spring-context-4.0.xsd   
    11. 
  
    
    
  
  11.         http://www.springframework.org/schema/util 
    12. 
  
    
    
  
  12.         http://www.springframework.org/schema/util/spring-util-4.0.xsd"
    13. 
  
    
    
  
  13.     default-autowire="byName">
    14. 
  
    
    
  
    15. 
  
    
    
  
  15.     <aop:aspectj-autoproxy />
    16. 
  
    
    
  
  16.     <context:component-scan base-package="com.test" />
    17. 
  
    
    
  
  17.     <import resource="classpath:dubbo-provider.xml" />
    18. 
  
    
    
  
  18. </beans>
    19.

加载Spring配置，启动服务：

 
   
   
 
    
  
    
    
  
  1. package com.test;
    2. 
  
    
    
  
    3. 
  
    
    
  
  3. import java.io.IOException;
    4. 
  
    
    
  
    5. 
  
    
    
  
  5. import org.springframework.context.support.ClassPathXmlApplicationContext;
    6. 
  
    
    
  
    7. 
  
    
    
  
  7. public class Test {
    8. 
  
    
    
  
  8.     public static void main(String[] args) throws Exception {
    9. 
  
    
    
  
  9.         ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext("classpath:springmvc.xml");
    10. 
  
    
    
  
  10.         context.start();
    11. 
  
    
    
  
    12. 
  
    
    
  
  12.         System.out.println("Dubbo provider start...");
    13. 
  
    
    
  
    14. 
  
    
    
  
  14.         try {
    15. 
  
    
    
  
  15.             System.in.read();   // 按任意键退出
    16. 
  
    
    
  
  16.         } catch (IOException e) {
    17. 
  
    
    
  
  17.             e.printStackTrace();
    18. 
  
    
    
  
  18.         } 
    19. 
  
    
    
  
  19.     }
    20. 
  
    
    
  
  20. }
    21.

服务消费者实现

项目结构

dubbo入门--原理、应用、实例

在dubbo-consumer.xml中声明所所需要消费的服务

 
   
   
 
    
  
    
    
  
  1. <?xml version="1.0" encoding="UTF-8"?>    
    2. 
  
    
    
  
  2. <beans xmlns="http://www.springframework.org/schema/beans"    
    3. 
  
    
    
  
  3.     xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"    
    4. 
  
    
    
  
  4.     xsi:schemaLocation="http://www.springframework.org/schema/beans    
    5. 
  
    
    
  
  5.         http://www.springframework.org/schema/beans/spring-beans.xsd    
    6. 
  
    
    
  
  6.         http://code.alibabatech.com/schema/dubbo    
    7. 
  
    
    
  
  7.         http://code.alibabatech.com/schema/dubbo/dubbo.xsd ">          
    8. 
  
    
    
  
  8.     <!-- 消费方应用名，用于计算依赖关系，不是匹配条件，不要与提供方一样 -->    
    9. 
  
    
    
  
  9.     <dubbo:application name="dubbo_consumer" />       
    10. 
  
    
    
  
  10. 
  
    
    
  
  11.     <dubbo:registry  protocol="zookeeper" address="zookeeper://127.0.0.1:2181" />         
    12. 
  
    
    
  
  12.       <!-- 生成远程服务代理，可以和本地bean一样使用demoService -->    
    13. 
  
    
    
  
  13.     <dubbo:reference id="demoService" interface="com.test.DemoService" />    
    14. 
  
    
    
  
  14. </beans>  
    15.

在springmvc.xml中扫描service注解并将dubbo-consumer.xml中的相关的dubbo配置引入进来

 
   
   
 
    
  
    
    
  
  1. <?xml version="1.0" encoding="UTF-8"?>
    2. 
  
    
    
  
  2. <beans xmlns="http://www.springframework.org/schema/beans" xmlns:aop="http://www.springframework.org/schema/aop"
    3. 
  
    
    
  
  3.     xmlns:context="http://www.springframework.org/schema/context"
    4. 
  
    
    
  
  4.     xmlns:util="http://www.springframework.org/schema/util" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    5. 
  
    
    
  
  5.     xsi:schemaLocation="http://www.springframework.org/schema/aop   
    6. 
  
    
    
  
  6.         http://www.springframework.org/schema/aop/spring-aop-4.0.xsd   
    7. 
  
    
    
  
  7.         http://www.springframework.org/schema/beans   
    8. 
  
    
    
  
  8.         http://www.springframework.org/schema/beans/spring-beans-4.0.xsd   
    9. 
  
    
    
  
  9.         http://www.springframework.org/schema/context
    10. 
  
    
    
  
  10.         http://www.springframework.org/schema/context/spring-context-4.0.xsd   
    11. 
  
    
    
  
  11.         http://www.springframework.org/schema/util 
    12. 
  
    
    
  
  12.         http://www.springframework.org/schema/util/spring-util-4.0.xsd"
    13. 
  
    
    
  
  13.     default-autowire="byName">
    14. 
  
    
    
  
    15. 
  
    
    
  
  15.     <aop:aspectj-autoproxy />
    16. 
  
    
    
  
  16.     <context:component-scan base-package="com.test" />
    17. 
  
    
    
  
  17.     <import resource="classpath:/dubbo-consumer.xml" />
    18. 
  
    
    
  
  18. </beans>
    19.

加载Spring配置，调用服务：

 
   
   
 
    
  
    
    
  
  1. package com.test;
    2. 
  
    
    
  
    3. 
  
    
    
  
  3. import java.io.IOException;
    4. 
  
    
    
  
    5. 
  
    
    
  
  5. import org.springframework.context.support.ClassPathXmlApplicationContext;
    6. 
  
    
    
  
    7. 
  
    
    
  
  7. public class Test {
    8. 
  
    
    
  
  8.     public static void main(String[] args) {
    9. 
  
    
    
  
  9.         ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext(new String[] { "classpath:springmvc.xml" });
    10. 
  
    
    
  
    11. 
  
    
    
  
  11.         context.start();
    12. 
  
    
    
  
  12.         DemoService demoService = (DemoService) context.getBean("demoService");
    13. 
  
    
    
  
    14. 
  
    
    
  
  14.         System.out.println(demoService.sayHello("哈哈哈"));
    15. 
  
    
    
  
  15.         try {
    16. 
  
    
    
  
  16.             System.in.read();
    17. 
  
    
    
  
  17.         } catch (IOException e) {
    18. 
  
    
    
  
  18.             e.printStackTrace();
    19. 
  
    
    
  
  19.         }
    20. 
  
    
    
  
    21. 
  
    
    
  
  21.     }
    22. 
  
    
    
  
  22. }
    23.

如果出现以下结果则调用成功

dubbo入门--原理、应用、实例

通过dubbo-admin管理后台可以看到服务的提供方与消费方

提供方：

dubbo入门--原理、应用、实例

消费者：

推荐阅读










微信：Yuanping1510



以上是关于dubbo入门--原理应用实例的主要内容，如果未能解决你的问题，请参考以下文章

Dubbo入门实例

Dubbo点滴 SPI入门

Dubbo入门基础与实例讲解（转）

Dubbo快速入门

Dubbo入门实例

dubbo学习--简单的入门搭建实例