SSM-Dubbo入门教程

转x33g5p2x  于2021-09-27 转载在 其他  
字(16.6k)|赞(0)|评价(0)|浏览(1349)

在学习之前我们需要,安装Zookeeper,和Dubbo管理控制台,这方面我博客里有教程自行查找

介绍

http://dubbo.apache.org/zh/docs/v2.7/user/examples/ (官方文档)

当服务越来越多时，容量的评估，小服务资源的浪费等问题逐渐显现，此时需要增加一个调度中心基于访问压力实时管理集群容量，提供集群利用率。其中，用于提高机器利用率的资源调度和治理中心是关键。

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

原理图

调用关系说明：

服务容器启动、加载和运行服务提供者；
1.
服务提供者在启动时，向注册中心注册自己提供的服务；
1.
服务消费者在启动时，向注册中心订阅自己所需的服务；
1.
注册中心返回服务提供者地址列表给消费者，如果有变更，注册中心将基于长连接推送变更给消费者；
1.
服务消费者从地址列表中，基于软负载均衡算法选一台服务提供者进行调用，如果调用失败再选另一台；
1.
服务消费者和服务提供者在内存中累计调用次数和调用时间，定时每分钟发送一次统计数据到监控中心。

节点角色说明

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

Dubbo 采用全 Spring 配置方式，透明化接入应用，对应用没有任何 API 入侵，只需用 Spring 加载 Dubbo 配置即可。

官方推荐使用 Zookeeper 作为注册中心，因此本次测试使用 Zookeeper, 具体相关教程,在本人博客里都能找到

搭建服务提供者

创建 Maven web项目 项目名 dubbodemo_provider

添加Maven依赖

  1. <properties>
  2.     <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
  3.     <maven.compiler.source>1.8</maven.compiler.source>
  4.     <maven.compiler.target>1.8</maven.compiler.target>
  5.     <spring.version>5.0.5.RELEASE</spring.version>
  6.   </properties>
  7. <dependencies>
  8.     
  9.   <dependency>
  10.     <groupId>org.springframework</groupId>
  11.     <artifactId>spring-context</artifactId>
  12.     <version>${spring.version}</version>
  13.   </dependency>
  14.     
  15.   <dependency>
  16.     <groupId>org.springframework</groupId>
  17.     <artifactId>spring-beans</artifactId>
  18.     <version>${spring.version}</version>
  19.   </dependency>
  20.     
  21.   <dependency>
  22.     <groupId>org.springframework</groupId>
  23.     <artifactId>spring-webmvc</artifactId>
  24.     <version>${spring.version}</version>
  25.   </dependency>
  26.   <dependency>
  27.     <groupId>org.springframework</groupId>
  28.     <artifactId>spring-jdbc</artifactId>
  29.     <version>${spring.version}</version>
  30.   </dependency>
  31.     
  32.   <dependency>
  33.     <groupId>org.springframework</groupId>
  34.     <artifactId>spring-aspects</artifactId>
  35.     <version>${spring.version}</version>
  36.   </dependency>
  37.     
  38.   <dependency>
  39.     <groupId>org.springframework</groupId>
  40.     <artifactId>spring-jms</artifactId>
  41.     <version>${spring.version}</version>
  42.   </dependency>
  43.     
  44.   <dependency>
  45.     <groupId>org.springframework</groupId>
  46.     <artifactId>spring-context-support</artifactId>
  47.     <version>${spring.version}</version>
  48.   </dependency>
  49.   <!-- dubbo相关 -->
  50.   <dependency>
  51.     <groupId>com.alibaba</groupId>
  52.     <artifactId>dubbo</artifactId>
  53.     <version>2.6.0</version>
  54.   </dependency>
  56.   <dependency>
  57.     <groupId>org.apache.zookeeper</groupId>
  58.     <artifactId>zookeeper</artifactId>
  59.     <version>3.4.6</version>
  60.   </dependency>
  61.   <dependency>
  62.     <groupId>com.github.sgroschupf</groupId>
  63.     <artifactId>zkclient</artifactId>
  64.     <version>0.1</version>
  65.   </dependency>
  66.   <dependency>
  67.     <groupId>javassist</groupId>
  68.     <artifactId>javassist</artifactId>
  69.     <version>3.12.1.GA</version>
  70.   </dependency>
  71.   <dependency>
  72.     <groupId>com.alibaba</groupId>
  73.     <artifactId>fastjson</artifactId>
  74.     <version>1.2.47</version>
  75.   </dependency>
  76. </dependencies>

配置web.xml

  1. <!DOCTYPE web-app PUBLIC "-//Sun Microsystems, Inc.//DTD Web Application 2.3//EN" "http://java.sun.com/dtd/web-app_2_3.dtd" >
  2. <web-app>
  3.   <display-name>Archetype Created Web Application</display-name>
  4.   <context-param>
  5.     <param-name>contextConfigLocation</param-name>
  6.     <param-value>classpath:applicationContext-service.xml</param-value>
  7.   </context-param>
  8.   <listener>
  9.     <listener-class>org.springframework.web.context.ContextLoaderListener</listener-class>
  10.   </listener>
  11. </web-app>

配置applicationContext-service.xml

  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:p="http://www.springframework.org/schema/p" xmlns:context="http://www.springframework.org/schema/context" xmlns:dubbo="http://code.alibabatech.com/schema/dubbo" xmlns:mvc="http://www.springframework.org/schema/mvc" xmlns:tx="http://www.springframework.org/schema/tx" xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://www.springframework.org/schema/mvc http://www.springframework.org/schema/mvc/spring-mvc.xsd http://code.alibabatech.com/schema/dubbo http://code.alibabatech.com/schema/dubbo/dubbo.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx.xsd">
  4.     <!-- 当前应用名称，用于注册中心计算应用间依赖关系，注意：消费者和提供者应用名不要一样 -->
  5.     <dubbo:application name="dubbodemo_provider" />
  6.     <!-- 连接服务注册中心zookeeper ip为zookeeper所在服务器的ip地址-->
  7.     <dubbo:registry address="zookeeper://49.232.169.170:2181"/>
  9.     <!-- 注册 协议和port 端口默认是20880 别和其他服务重复-->
  10.     <dubbo:protocol name="dubbo" port="20885"></dubbo:protocol>
  11.     <!-- 扫描指定包，加入@Service注解的类会被发布为服务 -->
  12.     <dubbo:annotation package="com.itheima.service.impl" />
  14. </beans>

编写服务

服务接口HelloService

  1. package com.itheima.service;
  3. public interface HelloService {
  4.     public String sayHello();
  5. }

服务实现类HelloServiceImpl

注意@Service不是spring的包 而是com.alibaba.dubbo.config.annotation.Service;

  1. package com.itheima.service.impl;
  3. import com.alibaba.dubbo.config.annotation.Service;
  4. import com.itheima.service.HelloService;
  6. @Service
  7. public class HelloServiceImpl implements HelloService {
  8.     public String sayHello() {
  9.         return "hello1-我是web ";
  10.     }
  11. }

然后配置 Tomcat 运行

然后到Dubbo Amin里查看

搭建消费者

创建消费者也有两种方式 spring web 和 springboot

而且这二种 都可以访问 springboot 和spring web 创建的服务

消费者访问 服务提供者的实现类 需要服务者的接口 而且接口的包路径还必须是服务提供者的包路径

创建 Maven web 项目 名称 dubbodemo_consumer

添加Maven

  1. <properties>
  2.     <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
  3.     <maven.compiler.source>1.8</maven.compiler.source>
  4.     <maven.compiler.target>1.8</maven.compiler.target>
  5.     <spring.version>5.0.5.RELEASE</spring.version>
  6.   </properties>
  8.   <dependencies>
  9.     <dependency>
  10.       <groupId>junit</groupId>
  11.       <artifactId>junit</artifactId>
  12.       <version>4.11</version>
  13.       <scope>test</scope>
  14.     </dependency>
  16.     <!-- SpringMvc-->
  17.     <dependency>
  18.       <groupId>org.springframework</groupId>
  19.       <artifactId>spring-web</artifactId>
  20.       <version>${spring.version}</version>
  21.     </dependency>
  23.     <dependency>
  24.       <groupId>org.springframework</groupId>
  25.       <artifactId>spring-context</artifactId>
  26.       <version>${spring.version}</version>
  27.     </dependency>
  28.       
  29.     <dependency>
  30.       <groupId>org.springframework</groupId>
  31.       <artifactId>spring-beans</artifactId>
  32.       <version>${spring.version}</version>
  33.     </dependency>
  34.     <dependency>
  35.       <groupId>org.springframework</groupId>
  36.       <artifactId>spring-webmvc</artifactId>
  37.       <version>${spring.version}</version>
  38.     </dependency>
  39.     <dependency>
  40.       <groupId>org.springframework</groupId>
  41.       <artifactId>spring-jdbc</artifactId>
  42.       <version>${spring.version}</version>
  43.     </dependency>
  44.     <dependency>
  45.       <groupId>org.springframework</groupId>
  46.       <artifactId>spring-aspects</artifactId>
  47.       <version>${spring.version}</version>
  48.     </dependency>
  49.     <dependency>
  50.       <groupId>org.springframework</groupId>
  51.       <artifactId>spring-jms</artifactId>
  52.       <version>${spring.version}</version>
  53.     </dependency>
  54.     <dependency>
  55.       <groupId>org.springframework</groupId>
  56.       <artifactId>spring-context-support</artifactId>
  57.       <version>${spring.version}</version>
  58.     </dependency>
  60.     <!-- 解析 jsp 和servlet-->
  61.     <dependency>
  62.       <groupId>javax.servlet</groupId>
  63.       <artifactId>javax.servlet-api</artifactId>
  64.       <version>3.1.0</version>
  65.       <scope>provided</scope>
  66.     </dependency>
  67.       
  68.     <dependency>
  69.       <groupId>javax.servlet</groupId>
  70.       <artifactId>jsp-api</artifactId>
  71.       <version>2.0</version>
  72.       <scope>provided</scope>
  73.     </dependency>
  75.     <!-- MVC json 解析-->
  77.     <dependency>
  78.       <groupId>com.fasterxml.jackson.core</groupId>
  79.       <artifactId>jackson-annotations</artifactId>
  80.       <version>2.9.8</version>
  81.     </dependency>
  83.     <dependency>
  84.       <groupId>com.fasterxml.jackson.core</groupId>
  85.       <artifactId>jackson-core</artifactId>
  86.       <version>2.9.8</version>
  87.     </dependency>
  89.     <dependency>
  90.       <groupId>com.fasterxml.jackson.core</groupId>
  91.       <artifactId>jackson-databind</artifactId>
  92.       <version>2.9.8</version>
  93.     </dependency>
  95.     <dependency>
  96.       <groupId>com.alibaba</groupId>
  97.       <artifactId>fastjson</artifactId>
  98.       <version>1.2.68</version>
  99.     </dependency>
  100.     <!-- dubbo相关 -->
  101.     <dependency>
  102.       <groupId>com.alibaba</groupId>
  103.       <artifactId>dubbo</artifactId>
  104.       <version>2.6.0</version>
  105.     </dependency>
  107.     <dependency>
  108.       <groupId>org.apache.zookeeper</groupId>
  109.       <artifactId>zookeeper</artifactId>
  110.       <version>3.4.9</version>
  111.     </dependency>
  112.     <dependency>
  113.       <groupId>com.github.sgroschupf</groupId>
  114.       <artifactId>zkclient</artifactId>
  115.       <version>0.1</version>
  116.     </dependency>
  117.     <dependency>
  118.       <groupId>javassist</groupId>
  119.       <artifactId>javassist</artifactId>
  120.       <version>3.12.1.GA</version>
  121.     </dependency>
  123.   </dependencies>

web.xml

  1. <!DOCTYPE web-app PUBLIC "-//Sun Microsystems, Inc.//DTD Web Application 2.3//EN" "http://java.sun.com/dtd/web-app_2_3.dtd" >
  2. <web-app>
  3.   <display-name>Archetype Created Web Application</display-name>
  4.   <servlet>
  5.     <servlet-name>springmvc</servlet-name>
  6.     <servlet-class>org.springframework.web.servlet.DispatcherServlet</servlet-class>
  7.     <!-- 指定加载的配置文件 ，通过参数contextConfigLocation加载 -->
  8.     <init-param>
  9.       <param-name>contextConfigLocation</param-name>
  10.       <param-value>classpath:applicationContext-web.xml</param-value>
  11.     </init-param>
  12.     <load-on-startup>1</load-on-startup>
  13.   </servlet>
  14.   <servlet-mapping>
  15.     <servlet-name>springmvc</servlet-name>
  16.     <url-pattern>/</url-pattern>
  17.   </servlet-mapping>
  18. </web-app>

applicationContext-web.xml

  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:p="http://www.springframework.org/schema/p" xmlns:context="http://www.springframework.org/schema/context" xmlns:dubbo="http://code.alibabatech.com/schema/dubbo" xmlns:mvc="http://www.springframework.org/schema/mvc" xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://www.springframework.org/schema/mvc http://www.springframework.org/schema/mvc/spring-mvc.xsd http://code.alibabatech.com/schema/dubbo http://code.alibabatech.com/schema/dubbo/dubbo.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd">
  4.     <!-- 当前应用名称，用于注册中心计算应用间依赖关系，注意：消费者和提供者应用名不要一样 -->
  5.     <dubbo:application name="dubbodemo-consumer" />
  6.     <!-- 连接服务注册中心zookeeper ip为zookeeper所在服务器的ip地址-->
  7.     <dubbo:registry address="zookeeper://49.232.169.170:2181"/>
  8.     <!-- 扫描的方式暴露接口 -->
  9.     <dubbo:annotation package="com.itheima.controller" />
  11. <!--启动时检查 (关闭 ) 建议在开发阶段将check值设置为false，在生产环境下改为true。 -->
  12.     <dubbo:consumer check="false"/>
  15.     <!--注解适配器 设置 @ResponseBody 和 @RequestBody 的请求 和响应 的模式 防止中文乱码-->
  16.     <bean class="org.springframework.web.servlet.mvc.method.annotation.RequestMappingHandlerAdapter">
  17.         <property name="messageConverters">
  18.             <list>
  19.                 <bean id="stringHttpMessageConverter" class="org.springframework.http.converter.StringHttpMessageConverter">
  20.                     <property name="supportedMediaTypes">
  21.                         <list>
  22.                             <value>text/plain;charset=UTF-8</value>
  23.                             <value>text/html;charset=UTF-8</value>
  24.                             <value>application/json;charset=UTF-8</value>
  25.                         </list>
  26.                     </property>
  27.                 </bean>
  28.                 <bean class="org.springframework.http.converter.json.MappingJackson2HttpMessageConverter">
  29.                     <property name="supportedMediaTypes">
  30.                         <list>
  31.                             <value>text/plain;charset=UTF-8</value>
  32.                             <value>text/html;charset=UTF-8</value>
  33.                             <value>application/json;charset=UTF-8</value>
  34.                         </list>
  35.                     </property>
  36.                 </bean>
  37.             </list>
  38.         </property>
  40.     </bean>
  42. </beans>

服务提供者的接口

HelloService

  1. package com.itheima.service;
  3. public interface HelloService {
  4.     public String sayHello();
  5. }

User1Service

  1. package com.example.service;
  3. /** * 该地方只定义接口, 一般为公用接口 * 可以定义许多接口; 这里为了演示, 只定义一个 */
  4. public interface User1Service {
  6.     String getUserById();
  7. }

controller

HelloController

  1. package cn.consumer.controller;
  3. import com.alibaba.dubbo.config.annotation.Reference;
  4. import com.example.service.User1Service;
  5. import com.itheima.service.HelloService;
  6. import org.springframework.stereotype.Controller;
  7. import org.springframework.web.bind.annotation.GetMapping;
  8. import org.springframework.web.bind.annotation.RequestMapping;
  9. import org.springframework.web.bind.annotation.ResponseBody;
  11. @Controller
  12. @RequestMapping("/demo")
  13. public class HelloController {
  14.     @Reference
  15.     private HelloService helloService;
  16.     @Reference   
  17.     private User1Service user1Service;
  19.         @GetMapping("/hello")
  20.         @ResponseBody
  21.         public String getName(){
  22.             //远程调用
  23.             String result = helloService.sayHello();
  24.             System.out.println(result);
  25.             return result;
  26.         }
  28.         @GetMapping("/user")
  29.         @ResponseBody
  30.         public String getName1(){
  31.             //远程调用
  32.             String result = user1Service.getUserById();
  33.             System.out.println(result);
  34.             return result;
  35.         }
  37. }

然后配置Tomcat启动 (注意 端口号别一样 我是这个消费者Tomcat端口是8083)

查看Dubbo Admin

可以看到每个 服务都是正常的

进入每个服务里

一个消费者 获取2个服务 提供者

在浏览器输入http://localhost:8083/demo/hello，查看浏览器输出结果

在浏览器输入http://localhost:8083/demo/user，查看浏览器输出结果

负载均衡

特别特别简单 有两种方式 第一种在代码里配置 第二种是在 Dubbo Amin 里配置 而我们选择第二种方式

进入DubboAdmin 里

在创建一个相同的服务配置代码全部都相同 除了 [ Tomcat端口号,Dubbo服务的端口号]

spirngweb 和 Springboot 一样 我们以Springboot 举例 因为好创建

创建普通Maven项目 名称为 dubbo-provide-springboot1
1.
将dubbo-provide-springboot里的代码和配置文件全部复制到dubbo-provide-springboot1里
1.
修改dubbo-provide-springboot1 里的application.yml (Tomcat 端口号 和Dubbo端口 )

  1. server:
  2.   port: 8072
  3.   
  4. dubbo:
  5.   protocol:     # 协议和port 端口默认是20880
  6.     name: dubbo
  7.     port: 30323

修改User1ServiceImpl里的代码 (主要是测试负载均衡 区分)

  1. @Override
  2.     public String getUserById() {
  3.         return "hello-springboot1" ;
  4.     }

启动Stringboot 的启动类
1.
查看DubboAmdin

我们来访问 com.example.service.User1Service 这个服务

在浏览器输入http://localhost:8068/demo/user， 查看浏览器输出结果 (多次访问)

可以发现 游览器 结果 在 hello-springboot1 和 hello-springboot 来回切换 这样就代表 负载均衡成功

解决Dubbo无法发布被事务代理的Service问题

前面我们已经完成了Dubbo的入门案例，通过入门案例我们可以看到通过Dubbo提供的标签配置就可以进行包扫描，扫描到@Service注解的类就可以被发布为服务。

但是我们如果在服务提供者类上加入@Transactional事务控制注解后，服务就发布不成功了。原因是事务控制的底层原理是为服务提供者类创建代理对象，而默认情况下Spring是基于JDK动态代理方式创建代理对象，而此代理对象的完整类名为com.sun.proxy.$Proxy42（最后两位数字不是固定的），导致Dubbo在发布服务前进行包匹配时无法完成匹配，进而没有进行服务的发布。

解决方式操作步骤：

（1）修改applicationContext-service.xml配置文件，开启事务控制注解支持时指定proxy-target-class属性，值为true。其作用是使用cglib代理方式为Service类创建代理对象

  1. <!--开启事务控制的注解支持-->
  2. <tx:annotation-driven transaction-manager="transactionManager" proxy-target-class="true"/>

（2）修改HelloServiceImpl类，在Service注解中加入interfaceClass属性，值为HelloService.class，作用是指定服务的接口类型

此处也是必须要修改的，否则会导致发布的服务接口为SpringProxy，而不是HelloService接口

  1. @Service(interfaceClass = HelloService.class)
  2. @Transactional
  3. public class HelloServiceImpl implements HelloService {
  4.     public String sayHello(String name) {
  5.         return "hello " + name;
  6.     }
  7. }

如果是Springboot 的话 就没必要 因为 Springboot2x 默认使用的就是 cglib代理方式

但是在使用类上添加指定接口还是需要的

  1. @Service(interfaceClass = HelloService.class)

解决上面案例中问题

思考一： 上面的Dubbo入门案例中我们是将HelloService接口从服务提供者工程(dubbodemo_provider)复制到服务消费者工程(dubbodemo_consumer)中，这种做法是否合适？还有没有更好的方式？

答： 这种做法显然是不好的，同一个接口被复制了两份，不利于后期维护。更好的方式是单独创建一个maven工程 然后打包进入Maven仓库里，需要依赖此接口的工程只需要在自己工程的pom.xml文件中引入maven坐标即可。

思考二： 在服务消费者工程(dubbodemo_consumer)中只是引用了HelloService接口，并没有提供实现类，Dubbo是如何做到远程调用的？

答： Dubbo底层是基于代理技术为HelloService接口创建代理对象，远程调用是通过此代理对象完成的。另外，Dubbo实现网络传输底层是基于Netty框架完成的。

思考三： 上面的Dubbo入门案例中我们使用Zookeeper作为服务注册中心，服务提供者需要将自己的服务信息注册到Zookeeper，服务消费者需要从Zookeeper订阅自己所需要的服务，此时Zookeeper服务就变得非常重要了，那如何防止Zookeeper单点故障呢？

答： Zookeeper其实是支持集群模式的，可以配置Zookeeper集群来达到Zookeeper服务的高可用，防止出现单点故障。

版权说明 : 本文为转载文章, 版权归原作者所有 版权申明

原文链接 : https://blog.csdn.net/weixin_45203607/article/details/120494499

内容来源于网络，如有侵权，请联系作者删除！

Javaspringzookeeperssm# ssm

相关文章

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com