Введение в даббо -- принцип, применение, пример

Dubbo

Чтобы поговорить о dubbo, давайте сначала разберемся с RPC:

концепция:

RPC (удаленный вызов процедур): удаленный вызов процедур — это протокол, который запрашивает услуги из удаленной компьютерной программы через сеть, не зная базовой сетевой технологии. Это делает вызов удаленной программы локальным, как если бы он вызывал локальную программу.

Протокол RPC предполагает, что существует какой-то транспортный протокол, такой как TCP или UDP, для передачи информационных данных между взаимодействующими программами. В модели сетевой связи OSI (семиуровневая модель) RPC охватывает транспортный уровень и прикладной уровень. RPC упрощает разработку приложений, включая сетевое распределенное мультипрограммирование.

Процесс вызова RPC:

  1. Клиент вызывает службу как локальную службу

  2. Клиентская заглушка действует как прокси, а затем обрабатывает вызов и параметры вызова.

  3. Клиентская заглушка отправляет вызовы удаленной системе по TCP или UDP.

  4. Серверная заглушка обрабатывает вызовы и параметры, отправленные клиентской заглушкой.

  5. Заглушка сервера вызывает реальную услугу, предоставляемую

  6. Заглушка сервера обрабатывает ответ и отправляет его клиенту.

Dubbo

1. Что такое даббо:

Dubbo — это базовая структура решения Alibaba по управлению на основе сервисов SOA.Это распределенная платформа сервисов, предназначенная для предоставления высокопроизводительных и прозрачных решений удаленного вызова RPC-сервисов и решений по управлению сервисами SOA.

soa: «Сервис-ориентированная архитектура», которая обеспечивает архитектурный стиль и концепцию, а не технологию или продукт. SOA выступает за инкапсуляцию бизнес-функций различных приложений в «сервисы» и их размещение, которые обычно предоставляются в виде интерфейсов и контрактов и предоставляются внешним приложениям (посредством обмена сообщениями) для достижения цели повторного использования различных систем.

2. Схема технической архитектуры Dubbo выглядит следующим образом:

Давайте объясним эту архитектурную диаграмму:

  • а. Потребители потребительских услуг (платят деньги), поставщики услуг (дают деньги) и Контейнерные сервисные контейнеры (где получают деньги).

  • б) сначала запускает сервис-провайдер, а потом регистрирует сервис (реестр).

  • в) Монитор Это мониторинг. Пунктирная линия на рисунке показывает, что Потребитель и Провайдер отправляют сообщения на Монитор асинхронно. Потребитель и Провайдер будут хранить информацию на локальном диске, и информация будет отправляется один раз в среднем 1 минуту. Мониторы являются необязательными для всей архитектуры.

  • г. Функцию Монитор нужно настраивать отдельно.Если она не настроена или не настроена, если Монитор зависнет, это не повлияет на вызов службы.

3. Процесс вызова потребителя услуги Dubbo

На приведенном выше рисунке показан основной процесс потребления услуги:

Во-первых, метод private void init() класса ReferenceConfig сначала проверит и инициализирует всю информацию о конфигурации, а затем вызовет private T createProxy(Map map) для создания прокси.Покупатель, наконец, получает прокси службы, который реализуется путем вызова интерфейса протокола в createProxy.Метод Invoker refer(тип класса, URL-адрес) генерирует экземпляр Invoker (как показано красным на рисунке выше), который является ключом к потреблению службы. Затем пропустите Invoker через ProxyFactory. Фабрика прокси преобразуется в интерфейс, требуемый клиентом (например, HelloWorld ), создает прокси службы и возвращает его.

Процесс инициализации потребителя

  • 1. Инкапсулировать информацию, на которую ссылается сервис, в URL-адрес и зарегистрировать его в центре регистрации zk;

  • 2. Мониторинг онлайн и оффлайн сервисов регистрационного центра;

  • 3. Подключитесь к поставщику услуг и создайте объект NettyClient;

  • 4. Упаковать информацию в цепочку вызовов потребителя DubboInvoker, создать служебный прокси экземпляра потребителя Invoker и вернуть его;

Процесс ссылки на услугу на стороне потребителя

  • 1. После стратегии балансировки нагрузки звоните провайдеру;

  • 2. Выберите URL-адрес одного из сервисов, чтобы установить соединение с провайдером netty, используйтеProxyFactory создает удаленную связь или локальную связь, Invoker отправляет ее на сетевой сервер.;

  • 3. После получения сервером информации об Invoker он находит соответствующий локальный Invoker и обрабатывает запрос Invocation;

  • 4. Получить результаты асинхронной или синхронной обработки;

    • Асинхронный Возвращаемое значение не требуется: вызовите метод ExchangeClient.send() напрямую;

    • Синхронизация требует возвращаемого значения: используйте метод ExchangeClient.request(), верните ResponseFuture и заблокируйте, пока сервер не вернет результат ответа;

Самый простой пример даббо

Пакеты, требуемые как поставщиком услуг, так и потребителем (здесь мой новый проект maven — это проект pom, а общие зависимости проекта записываются в pom.xml)

Общая структура проекта

Содержимое файла 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. 

скопировать код

реализация поставщика услуг

Структура проекта

реализовать интерфейс

    

  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.     <!-- 使用zookeeper注册中心暴露服务地址 -->  
    14. 

  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 и импортируйте соответствующую конфигурацию dubbo в dubbo-provider.xml.

    

  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-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.       <!-- 使用multicast广播注册中心暴露发现服务地址 -->    
    11. 

  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 и импортируйте соответствующую конфигурацию dubbo в dubbo-consumer.xml.

    

  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-admin вы можете увидеть поставщика и потребителя услуги.

провайдер:

потребитель:

Рекомендуемое чтение

WeChat: Юаньпин1510

Эта официальная учетная запись время от времени будет давать вам преимущества, включая учебные ресурсы и т. д., так что следите за обновлениями!

Если push-контент сейчас не нужен для работы, вы можете сначала перенаправить его в «Моменты» или «Избранное», чтобы легко найти его при использовании.

Также добро пожаловатьОбратите внимание на публичный аккаунт илиДобавить WeChat Друзья, учитесь друг у друга.

Категории