1. 全栈程序员必看首页

SpringBoot整合dubbo详述「建议收藏」

全栈程序员-用户IM • • 未分类

环境：jdk1.8+springboot-2.2.1+dubbo-2.5.3+zookeeper-3.5.5+maven构建工具:IDEA我们知道，dubbo的本质就是一个远程服务调用的分布式框架。为了演示分布式架构的大致流程，我们项目里首先要建立对应的角色节点，即服务提供者、消费者以及公共接口服务，总体结构为:dubbo_demo：是总项目duboo-api：主要是…

大家好，又见面了，我是你们的朋友全栈君。

环境：jdk1.8+springboot-2.2.1+dubbo-2.5.3+zookeeper-3.5.5+maven

构建工具:IDEA

      我们知道，dubbo的本质就是一个远程服务调用的分布式框架。为了演示分布式架构的大致流程，我们项目里首先要建立对应的角色节点，即服务提供者、消费者以及公共接口服务，总体结构为:

SpringBoot整合dubbo详述「建议收藏」

dubbo_demo：是总项目
duboo-api：主要是实体类和接口服务
dubbo-customer：调用远程服务的服务消费方
duboo-provider：暴露服务的服务提供方

创建各个module的过程就不贴出来了，就是普通的springboot项目。需要注意的一点是在创建的时候每个module的GroupId要完全一致，否则在互相调用资源的时候会出现无法引入资源的问题。

 

一、dubbo_demo的pom.xml配置:

<?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 https://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>
    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.2.1.RELEASE</version>
        <relativePath/> <!-- lookup parent from repository -->
    </parent>
    <groupId>com.dubbo</groupId>
    <artifactId>dubbo</artifactId>
    <version>0.0.1-SNAPSHOT</version>
    <name>dubbo</name>
    <description>Demo project for Spring Boot</description>

    <properties>
        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
        <java.version>1.8</java.version>
        <zkclient.version>0.10</zkclient.version>
        <dubbo.version>2.5.3</dubbo.version>
    </properties>
    <modules>
        <!-- 主要放实体、接口、也可以放一些公用的工具类工程-->
        <module>dubbo-api</module>
        <!-- 服务消费者工程 -->
        <module>dubbo-customer</module>
        <!-- 服务提供者工程-->
        <module>dubbo-provider</module>
    </modules>
    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-thymeleaf</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
            <exclusions>
                <exclusion>
                    <groupId>org.junit.vintage</groupId>
                    <artifactId>junit-vintage-engine</artifactId>
                </exclusion>
            </exclusions>
        </dependency>
        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>dubbo</artifactId>
            <version>${dubbo.version}</version>
            <exclusions>
                <exclusion>
                    <groupId>log4j</groupId>
                    <artifactId>log4j</artifactId>
                </exclusion>
                <exclusion>
                    <groupId>org.springframework</groupId>
                    <artifactId>spring</artifactId>
                </exclusion>
            </exclusions>
        </dependency>
        <dependency>
            <groupId>com.101tec</groupId>
            <artifactId>zkclient</artifactId>
            <version>${zkclient.version}</version>
        </dependency>


    </dependencies>

    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
            </plugin>
        </plugins>
    </build>

</project>

由于dubbo的jar中也引入了spring依赖，所以在引入dubbo依赖时，需要将spring相关排除掉，否则会和项目本身的spring冲突。

即上面pom中的：

 <exclusion>
         <groupId>org.springframework</groupId>
         <artifactId>spring</artifactId>
 </exclusion>

二、接下来是dubbo-api的pom.xml配置,这个就比较简单了，这里不用引入dubbo等依赖 ：

<?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 https://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>
    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.2.1.RELEASE</version>
        <relativePath/> <!-- lookup parent from repository -->
    </parent>
    <groupId>com.dubbo</groupId>
    <artifactId>dubbo-api</artifactId>
    <version>0.0.1-SNAPSHOT</version>
    <name>dubbo-api</name>
    <description>Demo project for Spring Boot</description>
    <packaging>jar</packaging>

    <properties>
        <java.version>1.8</java.version>
    </properties>

    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
            <exclusions>
                <exclusion>
                    <groupId>org.junit.vintage</groupId>
                    <artifactId>junit-vintage-engine</artifactId>
                </exclusion>
            </exclusions>
        </dependency>
    </dependencies>

    <build>
        <finalName>dubbo-api</finalName>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
            </plugin>
        </plugins>
    </build>

</project>

在dubbo-api中新建service包,添加测试接口

SpringBoot整合dubbo详述「建议收藏」

 

package com.dubbo.api.service;


public interface TestService {
    String sayHello(String name);
}

三、1.dubbo-provider的pom.xml配置：

<?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 https://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>
    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.2.1.RELEASE</version>
        <relativePath/> <!-- lookup parent from repository -->
    </parent>
    <groupId>com.dubbo</groupId>
    <artifactId>provider</artifactId>
    <version>0.0.1-SNAPSHOT</version>
    <name>dubbo-provider</name>
    <description>Demo project for Spring Boot</description>

    <properties>
        <java.version>1.8</java.version>
        <zkclient.version>0.10</zkclient.version>
        <dubbo.version>2.5.3</dubbo.version>
    </properties>

    <dependencies>
        <dependency>
            <groupId>com.dubbo</groupId>
            <artifactId>dubbo-api</artifactId>
            <version>0.0.1-SNAPSHOT</version>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>dubbo</artifactId>
            <version>${dubbo.version}</version>
            <exclusions>
                <exclusion>
                    <groupId>log4j</groupId>
                    <artifactId>log4j</artifactId>
                </exclusion>
                <exclusion>
                    <groupId>org.springframework</groupId>
                    <artifactId>spring</artifactId>
                </exclusion>
            </exclusions>
        </dependency>
        <!-- zookeeper客户端 -->
        <dependency>
            <groupId>com.101tec</groupId>
            <artifactId>zkclient</artifactId>
            <version>${zkclient.version}</version>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
            <exclusions>
                <exclusion>
                    <groupId>org.junit.vintage</groupId>
                    <artifactId>junit-vintage-engine</artifactId>
                </exclusion>
            </exclusions>
        </dependency>
    </dependencies>

    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
            </plugin>
        </plugins>
    </build>

</project>

2.创建TestService的实现类TestServiceImpl:

SpringBoot整合dubbo详述「建议收藏」

package com.dubbo.provider.impl;

import com.alibaba.dubbo.config.annotation.Service;
import com.dubbo.api.service.TestService;

@Service(version = "1.0.0",timeout = 3000)
 public class TestServiceImpl  implements TestService {

    @Override
     public String sayHello(String name) {
        return "哈哈哈，hello "+name;
    }
}

需要注意的是这里的@Service注解是dubbo的而不是spring的，不要用错了。

3.接下来在resources下创建spring-dubbo.xml文件，向zookeeper及dubbo注册并暴露服务

<?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="dubbo-provider"/>
    <!-- 注册中心的ip地址 -->
    <!-- 将服务提供者的地址暴露出去。这个过程通过zookeeper实现服务注册中心，进行注册暴露 -->
    <dubbo:registry address="zookeeper://192.168.4.54:2181"/>
    <!-- 扫描注解包路径，多个包用逗号分隔，不填pacakge表示扫描当前ApplicationContext中所有的类 -->
    <dubbo:annotation package="com.dubbo.provider.impl"/>

    <!-- 将服务提供者的端口号暴露出去 -->
    <dubbo:protocol name="dubbo" port="20880"/>

    <!-- service implementation, as same as regular local bean -->
    <bean id="testService" class="com.dubbo.provider.impl.TestServiceImpl"/>
    <!-- 将服务提供者需要对外提供的功能暴露出去 -->
    <dubbo:service interface="com.dubbo.api.service.TestService" ref="testService"/>

</beans>

4.application.yml 中配置服务端口号:

server:
 port: 9010

 

四、1.dubbo-customer的pom.xml配置文件:

<?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 https://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>
    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.2.1.RELEASE</version>
        <relativePath/> <!-- lookup parent from repository -->
    </parent>
    <groupId>com.dubbo</groupId>
    <artifactId>customer</artifactId>
    <version>0.0.1-SNAPSHOT</version>
    <name>customer</name>
    <description>Demo project for Spring Boot</description>
    <packaging>jar</packaging>

    <properties>
        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
        <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
        <java.version>1.8</java.version>
        <zkclient.version>0.10</zkclient.version>
        <dubbo.version>2.5.3</dubbo.version>
    </properties>

    <dependencies>
        <dependency>
            <groupId>com.dubbo</groupId>
            <artifactId>dubbo-api</artifactId>
            <version>0.0.1-SNAPSHOT</version>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>dubbo</artifactId>
            <version>${dubbo.version}</version>
            <exclusions>
                <exclusion>
                    <groupId>log4j</groupId>
                    <artifactId>log4j</artifactId>
                </exclusion>
                <exclusion>
                    <groupId>org.springframework</groupId>
                    <artifactId>spring</artifactId>
                </exclusion>
            </exclusions>
        </dependency>
        <dependency>
            <groupId>com.101tec</groupId>
            <artifactId>zkclient</artifactId>
            <version>${zkclient.version}</version>
        </dependency>


        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
            <exclusions>
                <exclusion>
                    <groupId>org.junit.vintage</groupId>
                    <artifactId>junit-vintage-engine</artifactId>
                </exclusion>
            </exclusions>
        </dependency>
    </dependencies>

    <build>
        <finalName>customer</finalName>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
            </plugin>
        </plugins>
    </build>

</project>

2.创建消费端服务调用类 TestController

SpringBoot整合dubbo详述「建议收藏」

package com.dubbo.customer.controller;

import com.alibaba.dubbo.config.annotation.Reference;
import com.dubbo.api.service.TestService;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;

@RestController
public class TestController {

    @Reference(version = "1.0.0",timeout = 300)
    private TestService testService;

    @RequestMapping("/sayHello")
    public String sayHello(@RequestParam String name) {
        System.out.println("name=="+name);
        System.out.println("testService=="+testService);
        return testService.sayHello(name);
    }





}

3.同样在resources下创建spring-dubbo.xml文件，配置注册中心地址等信息

<?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="dubbo-consumer"/>
    <!-- 注册中心的ip地址 -->
    <dubbo:registry address="zookeeper://192.168.4.54:2181"/>
    <!-- 扫描注解包路径，多个包用逗号分隔，不填pacakge表示扫描当前ApplicationContext中所有的类 -->
    <dubbo:annotation package="com.dubbo.customer.controller"/>

    <!-- use dubbo protocol to export service on port 20880 -->
    <dubbo:protocol name="dubbo" port="20880"/>

    <dubbo:reference id="testService" check="false" interface="com.dubbo.api.service.TestService"/>

</beans>

4.application.yml 中配置服务端口号:

server:
 port: 9011

五、接下来就可以测试服务提供者和消费者是否能成功注册到dubbo上了，先启动放置dubbo-admin的tomcat以及zookeeper,再依次启动dubbo-provider和dubbo-customer服务，登录dubbo-admin控制台页面，可以看到provider和customer都已成功注册。

SpringBoot整合dubbo详述「建议收藏」

 

SpringBoot整合dubbo详述「建议收藏」

 

访问消费者服务customer也能成功调用provider

SpringBoot整合dubbo详述「建议收藏」

至此，所有流程算是成功了。下面说一下过程中遇到的一些问题。

 

构建过程中遇到的问题

1.最初在provider中调用com.dubbo.api.service.TestService类时一开始报错ClassNotFound,提示在dubbo-provider中 找不到TestService，虽然我们在pom中已经引入了要调用的项目配置。经过各种调试，因为被调用者是dubbo-api module中的类，
最终我这里的解决方法是重新clean并编译一遍dubbo-api

SpringBoot整合dubbo详述「建议收藏」

然后执行Rebuild Project

SpringBoot整合dubbo详述「建议收藏」

再次强调，如果要想各个module相互调用，它们的GroupId必须是一致的。

2.通过执行以上操作，虽然在IDEA中没问题了，但是当我将dubbo-customer打成jar放到其它机器上运行时，又报了空指针异常，经调试发现原来是这里通过@Reference引入的testService为null

SpringBoot整合dubbo详述「建议收藏」

解决方法:

在被依赖项目dubbo-api的pom.xml文件spring-boot-maven-plugin依赖中加入配置<classifier>exec</classifier>,即:

 <build>
        <finalName>dubbo-api</finalName>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
                <configuration>
                    <classifier>exec</classifier>
                </configuration>
            </plugin>
        </plugins>
    </build>

另外，打包顺序也要注意，要先编译被依赖项dubbo-api，再编译dubbo-customer。

 

参考文章:

https://blog.csdn.net/qq_19419233/article/details/86678035#dubbo_1

https://www.cnblogs.com/gaopengfirst/p/9555240.html

版权声明：本文内容由互联网用户自发贡献，该文观点仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 举报，一经查实，本站将立刻删除。

发布者：全栈程序员-用户IM，转载请注明出处：https://javaforall.cn/127505.html原文链接：https://javaforall.cn

【正版授权，激活自己账号】： Jetbrains全家桶Ide使用，1年售后保障，每天仅需1毛

【官方授权 正版激活】： 官方授权 正版激活 支持Jetbrains家族下所有IDE 使用个人JB账号...

赞 (0)
全栈程序员-用户IM全栈程序员-用户IM
0 0


相关推荐

  • ip route 添加默认网关_用route命令添加永久路由

    ip route 添加默认网关_用route命令添加永久路由

    ip route 添加默认网关_用route命令添加永久路由[color=green]Route在本地IP路由表中显示和修改条目。使用不带参数的route可以显示帮助。语法route[-f][-p][Command[Destination][maskNetmask][Gateway][metricMetric]][ifInterface]]参数-f清除所有不是主路由（网掩码为255.255.255…

    全栈程序员-用户IM 全栈程序员-用户IM
    2022年8月11日
  • pythoncharm怎么保存_pycharm怎么设置代码自动保存「建议收藏」

    pythoncharm怎么保存_pycharm怎么设置代码自动保存「建议收藏」

    pythoncharm怎么保存_pycharm怎么设置代码自动保存「建议收藏」pycharm一般安装完毕，就是默认是自动保存的，但是……但是….既然是程序，既然是软件，就难免出现bug。也许会有码友出现头天晚上写好的代码，打开一看，第二天白花花一片！！！泪奔有没有最简单的，就是每次编写完毕，习惯按ctrl+s手动保存。但是，提醒你务必检查一下你的设置里面，是不是码友弄好自动保存！步骤如下：菜单File->Settings…->Ap…

    全栈程序员-用户IM 全栈程序员-用户IM
    2022年8月26日
  • django笔记_django 异步

    django笔记_django 异步

    django笔记_django 异步前言Django是一个开放源代码的Web应用框架，由Python写成，最初用于管理劳伦斯出版集团旗下的一些以新闻内容为主的网站，即CMS（内容管理系统）软件，于2005年7月在BSD许可证下发布，这

    全栈程序员-用户IM 全栈程序员-用户IM
    2022年7月31日
  • go 布隆过滤器_布隆过滤器 redis

    go 布隆过滤器_布隆过滤器 redis

    go 布隆过滤器_布隆过滤器 redis最近面临这样的场景：2亿+数据需要调用后端服务A，业务需要1min处理完成，那么A服务承载的tps达到惊人的300w……必须想办法降低tps。那么方案来了：1、把时间窗口拉长2、降低待处理数据量。拉长时间业务肯定是接受不了的，但是按照以往的经验，这部分数据并不全部需要处理，可能仅有一半真正需要调用A服务，所以我们可以把1亿数据给过滤掉。这里我们维护一个布隆过滤器来进行数据的过滤。—————-以上都是导语—————-1.布隆过滤器的概

    全栈程序员-用户IM 全栈程序员-用户IM
    2022年10月6日
  • 卸载dpkg安装的软件_ubuntu卸载deb软件

    卸载dpkg安装的软件_ubuntu卸载deb软件

    卸载dpkg安装的软件_ubuntu卸载deb软件deb文件是linux发行版debian系统的安装包格式，还有像基于debian系统的发型版ubuntu等系统就是使用的deb格式安装包，我们可以使用dpkg命令进行安装管理这些deb安装包文件。方法/步骤这里我使用的ubuntu系统做演示，首先把deb文件放到一个文件夹中，例如我这里的dolphin_emu文件。在文件夹里右键“在终端打开”。使用dpkg命令进行安装…

    全栈程序员-用户IM 全栈程序员-用户IM
    2022年10月6日
  • raid5和raid10区别和特性_你适合哪种恋爱测试

    raid5和raid10区别和特性_你适合哪种恋爱测试

    raid5和raid10区别和特性_你适合哪种恋爱测试【IT168专稿】存储是目前IT产业发展的一大热点，而RAID技术是构造高性能、海量存储的基础技术，也是构建网络存储的基础技术。专家认为，磁盘阵列的性能优势得益于磁盘运行的并行性，提高设备运行并行度

    全栈程序员-用户IM 全栈程序员-用户IM
    2022年8月2日

发表回复

您的电子邮箱地址不会被公开。

关注全栈程序员社区公众号