SpringBoot 集成 Dubbo + zookeeper全注解,无xml方式(+各种坑的说明))

2020-06-10 15:14:25 浏览数 (1)

大家知道springBoot发明的初衷是为了减少xml的配置,而dubbo的传统方式就是xml配置,所以既然用了springBoot就应该遵循它的规则,在集成dubbo时改为全编程式注解的方式。下面我来为大家详细介绍集成的步骤:

一:安装zookeeper 首先去官网下载zookeeper,下载地址为:http://mirror.bit.edu.cn/apache/zookeeper/;我选择的版本是 zookeeper-3.5.4; 下载完以后解压到本地目录,然后复制conf目录下的zoo_sample.cfg文件,并改名为zoo.cfg。在安装目录下新建data和log文件夹,随后编辑该文件: 注意:dataDir和dataLogDir是zookeeper解压的本地目录,视自己放的位置而更改。

代码语言:javascript复制


    # The number of milliseconds of each tick
    tickTime=2000
    # The number of ticks that the initial 
    # synchronization phase can take
    initLimit=10
    # The number of ticks that can pass between 
    # sending a request and getting an acknowledgement
    syncLimit=5
    # the directory where the snapshot is stored.
    # do not use /tmp for storage, /tmp here is just 
    # example sakes.
    dataDir=C:/zookeeper-3.4.13/data
    dataLogDir=C:/zookeeper-3.4.13/log
 
    # the port at which the clients will connect
    clientPort=2181
    # the maximum number of client connections.
    # increase this if you need to handle more clients
    #maxClientCnxns=60
    #
    # Be sure to read the maintenance section of the 
    # administrator guide before turning on autopurge.
    #
    # http://zookeeper.apache.org/doc/current/zookeeperAdmin.html#sc_maintenance
    #
    # The number of snapshots to retain in dataDir
    #autopurge.snapRetainCount=3
    # Purge task interval in hours
    # Set to "0" to disable auto purge feature
    #autopurge.purgeInterval=1

完成以上步骤后就可以进入C:zookeeper-3.4.13bin 双击zkserver.cmd启动zookper。 二:创建服务提供者工程 建议使用idea工具!!!我先是在本地磁盘建了一个文件夹springBoot-dubbo,然后选择File - open打开这个文件夹,接着在这个文件夹上创建model工程,如下图所示:

选择spring initializr

如果相同的依赖太多,你也可以考虑创建pom父工程,统一依赖管理。 1.服务者的pom.xml:

代码语言:javascript复制


    <?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>
        <parent>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-parent</artifactId>
            <version>2.1.2.RELEASE</version>
            <relativePath/>
        </parent>
        <groupId>com.wenxue</groupId>
        <artifactId>springBoot-dubbo-provider</artifactId>
        <packaging>jar</packaging>
        <version>0.0.1-SNAPSHOT</version>
        <name>springBoot-dubbo-provider</name>
        <description>Demo project for Spring Boot</description>
 
        <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>
            </dependency>
 
            <!--sproingBoot整合dubbo的依赖-->
            <dependency>
                <groupId>io.dubbo.springboot</groupId>
                <artifactId>spring-boot-starter-dubbo</artifactId>
                <version>1.0.0</version>
            </dependency>
 
            <dependency>
                <groupId>log4j</groupId>
                <artifactId>log4j</artifactId>
                <version>1.2.17</version>
            </dependency>
 
        </dependencies>
 
        <build>
            <plugins>
                <plugin>
                    <groupId>org.springframework.boot</groupId>
                    <artifactId>spring-boot-maven-plugin</artifactId>
                </plugin>
            </plugins>
        </build>
 
    </project>

2.添加application.propertis文件,配置dubbo相关信息

    #提供服务名称,可任意抒写
    spring.dubbo.application.name=provider
    #zookeeper地址及端口号
    spring.dubbo.registry.address=zookeeper://127.0.0.1:2181
    #dubbo协议
    spring.dubbo.protocol.name=dubbo
    #duboo端口号
    spring.dubbo.protocol.port=20880
    #这是你要发布到dubbo提供服务的接口所在包位置
    spring.dubbo.scan=com.wenxue.demo.dubboService
 
    #tomcat端口号
    server.port=8888

3.编写接口及实现类(重点):

    package com.wenxue.demo.dubboService.impl;
 
    import com.alibaba.dubbo.config.annotation.Service;
    import com.wenxue.demo.dubboService.TestDubboService;
 
    @Service(version = "1.0.0")//该注解的作用就是发布服务
    public class TestDubboServiceImpl implements TestDubboService {
 
        @Override
        public void toProvider() throws Exception {
            System.out.println("恭喜你连接成功");
        }
    }

 注意:上面的@Service注解是“com.alibaba.dubbo.config.annotation” 包下的,不是spring的,如果导错了包将会无法发布服务。

 工程目录结构如下:

 

三:创建消费者工程 创建过程同上。 1.消费者的pom.xml:

代码语言:javascript复制


    <?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>
        <parent>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-parent</artifactId>
            <version>2.1.2.RELEASE</version>
            <relativePath/>
        </parent>
        <groupId>com.wenxue</groupId>
        <artifactId>springBoot-dubbo-consumer</artifactId>
        <version>0.0.1-SNAPSHOT</version>
        <name>springBoot-dubbo-consumer</name>
        <description>Demo project for Spring Boot</description>
 
        <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>
            </dependency>
 
            <!--springBoot整合dubbo的依赖-->
            <dependency>
                <groupId>io.dubbo.springboot</groupId>
                <artifactId>spring-boot-starter-dubbo</artifactId>
                <version>1.0.0</version>
            </dependency>
 
            <dependency>
                <groupId>log4j</groupId>
                <artifactId>log4j</artifactId>
                <version>1.2.17</version>
            </dependency>
 
        </dependencies>
 
        <build>
            <plugins>
                <plugin>
                    <groupId>org.springframework.boot</groupId>
                    <artifactId>spring-boot-maven-plugin</artifactId>
                </plugin>
            </plugins>
        </build>
 
    </project>

2.编写applicat.properties:

代码语言:javascript复制


    #消费者名称,可任意抒写
    spring.dubbo.application.name=consumer
    #zookeeper地址及端口号
    spring.dubbo.registry.address=zookeeper://127.0.0.1:2181
    #消费方 调用 服务费 @Reference注入 所在包位置
    spring.dubbo.scan=com.wenxue.demo.controller
 
    #tomcat端口号
    server.port=8889

这里要特别注意,消费方的spring.dubbo.scan是消费方调用服务费所在包的位置,也就是打注解@Reference的包位置。我看过网上很多人都把服务费和消费方的spring.dubbo.scan都说成是服务方接口所在的包位置,经过本人测试这是不准确的。 3.编写Controller:

代码语言:javascript复制


    package com.wenxue.demo.controller;
 
    import com.alibaba.dubbo.config.annotation.Reference;
    import com.wenxue.demo.dubboService.TestDubboService;
    import org.springframework.stereotype.Component;
    import org.springframework.web.bind.annotation.RequestMapping;
 
    @Component
    @RequestMapping("/")
    public class TestDubboController {
 
        @Reference(version = "1.0.0")//该注解的作用就是订阅服务
        private TestDubboService testServices;
 
        @RequestMapping("/testDubbo")
        public void testDubbo() throws Exception {
            testServices.toProvider();
        }
    }

4.定义服务方接口 方式一: 由于消费方和服务方不在同一个工程,所以需要将服务方的接口拷贝过来。 方式二:如果你觉得拷贝包太麻烦了的话,还可以有第二种方案,那就是导入服务方的工程依赖 <!--引入服务方工程的目的为了注入服务方的接口--> <!--<dependency>--> <!--<groupId>com.wenxue</groupId>--> <!--<artifactId>springBoot-dubbo-provider</artifactId>--> <!--<version>0.0.1-SNAPSHOT</version>--> <!--</dependency>--> 以上两种方式任君选择,不过本人建议使用第一种,以免增加maven仓库的导入量。或许读者你也会疑问:“导入了服务费的工程,不需要dubbo不也可以调用吗?”但是经过我测试是不可以的。这说明了springBoot的底层做了某些特殊的封装。 5.启动工程 接下来先启动服务者,再启动消费者就可以了。(如果你想看的更加清楚,可以下载dubbo-admin.war,放入tomcat启动后访问http://localhost:8088/dubbo-admin-2.5.4 。 就可以看见服务的发布与订阅是否成功与失败。密码账户默认都是是root)

6.测试调用: *如果不出意外,你会发现,在controller调用远程服务时出现了“java.lang.NullPointerException: null”的异常,那就恭喜你已经中了第一坑。哈哈。 那是因为TestDubboService并没有成功被订阅,所以是空对象。造成这种现象的原因一般都是:“因为你消费方的接口的包路径与服务方的包路径不同所导致的!所以,一定要从服务方连包带接口拷贝到消费方!一定要从服务方连包带接口拷贝到消费方!一定要从服务方连包带接口拷贝到消费方! 重要的事情说三遍!!!” 如下图所示:

最后测试调用: 访问:http://localhost:8889/testDubbo ,如果控制台打印出“恭喜你连接成功了!” 那就没问题了

其它可能存在的问题说明: 1.一定要导入log4j的jar,否则会报错; 2.使用debug时,会出现服务端连续执行三次的情况; 3.在执行远程调用时可能会出现空指针异常,那是因为服务端的接口没有注入进来,可能是因为消费方接口包路径与服务方的接口路径不一致,或者是消费方的spring.dubbo.scan=xxx 路径定义错了。

作者:龚文学 原文:https://blog.csdn.net/qq_41899174/article/details/86751255

0 人点赞