小言_互联网的博客

Spring Boot集成dubbo+zookeeper

2020-05-09 09:12 341人阅读  评论(0)

版本环境

名称 版本号
JDK 1.8
Spring Boot 1.5.8
dubbo 2.5.6
zookeeper 3.4.9
zkclient 0.2
Nodejs 0.2
Vue 2.0
Maven 3.0.5
IDEA 2018.3

Zookeeper

ZooKeeper是一个分布式的，开放源码的分布式应用程序协调服务。很多中间件，比如Kafka、Hadoop、HBase，都用到了 Zookeeper。可以说在分布式系统中，Zookeeper已经已经占据举足轻重的地位。
Zookeeper下载地址

Dubbo

Dubbo是阿里巴巴公司开源的一个高性能优秀的服务框架，使得应用可通过高性能的 RPC 实现服务的输出和输入功能，可以和Spring框架无缝集成。

Dubbo是一款高性能、轻量级的开源Java RPC框架，它提供了三大核心能力：面向接口的远程方法调用，智能容错和负载均衡，以及服务自动注册和发现。
dubbo官网

集成方式

Spring Boot集成dubbo有多种方式，有通过注解实现，也有通过配置文件的方式

创建Spring Boot工程



建好dubbo空工程后然后新建4个module分别是：

  • dubbo-api目录：接口工程
  • dubbo-consumer目录：服务消费者工程
  • dubbo-parent目录：父依赖工程
  • dubbo-provider目录：服务提供者工程

最终的工程目录如下图

dubbo-parent(父工程)

这个父工程只是用来管理依赖和版本，src目录可以删掉

<?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>1.5.8.RELEASE</version>
    </parent>
    <groupId>com.laowang</groupId>
    <artifactId>dubbo-parent</artifactId>
    <version>0.0.1-SNAPSHOT</version>
    <name>dubbo-parent</name>


    <packaging>pom</packaging>
    <modules>
        <module>../dubbo-api</module>
        <module>../dubbo-consumer</module>
        <module>../dubbo-provider</module>
    </modules>

    <properties>
        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
        <maven.compiler.source>1.8</maven.compiler.source>
        <maven.compiler.target>1.8</maven.compiler.target>
        <java.version>1.8</java.version>
        <dubbo.version>2.5.6</dubbo.version>
        <zookeeper.version>3.4.9</zookeeper.version>
        <zkclient.version>0.2</zkclient.version>
    </properties>
    <dependencyManagement>
        <dependencies>

            <!--Dubbo 依赖 -->
            <dependency>
                <groupId>com.alibaba</groupId>
                <artifactId>dubbo</artifactId>
                <version>${dubbo.version}</version>
                <exclusions>
                    <exclusion>
                        <artifactId>spring</artifactId>
                        <groupId>org.springframework</groupId>
                    </exclusion>
                </exclusions>
            </dependency>
            <dependency>
                <groupId>org.apache.zookeeper</groupId>
                <artifactId>zookeeper</artifactId>
                <version>${zookeeper.version}</version>
                <exclusions>
                    <exclusion>
                        <artifactId>slf4j-log4j12</artifactId>
                        <groupId>org.slf4j</groupId>
                    </exclusion>
                </exclusions>
            </dependency>
            <dependency>
                <groupId>com.101tec</groupId>
                <artifactId>zkclient</artifactId>
                <version>${zkclient.version}</version>
            </dependency>
        </dependencies>

    </dependencyManagement>


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

</project>

dubbo-api(接口模块)

新建库存接口类，写一个添加库存的接口，如下图

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>com.laowang</groupId>
        <artifactId>dubbo-parent</artifactId>
        <version>0.0.1-SNAPSHOT</version>
        <relativePath>../dubbo-parent/pom.xml</relativePath>
    </parent>

    <groupId>com.laowang</groupId>
    <artifactId>dubbo-provider</artifactId>
    <version>0.0.1-SNAPSHOT</version>
    <name>dubbo-provider</name>


    <dependencies>

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <dependency>
            <groupId>com.laowang</groupId>
            <artifactId>dubbo-api</artifactId>
            <version>${project.version}</version>
        </dependency>


        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>dubbo</artifactId>
        </dependency>
        <dependency>
            <groupId>org.apache.zookeeper</groupId>
            <artifactId>zookeeper</artifactId>
        </dependency>

        <dependency>
            <groupId>com.101tec</groupId>
            <artifactId>zkclient</artifactId>
        </dependency>

    </dependencies>

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

</project>

新建实现类，实现OrderService接口，并且加入Service注解

application.properties配置

#服务启动端口
server.port=8090
#zookeeper地址
zkAddress=127.0.0.1:2181
#dubbo端口
dubbo.port=20880
#dubbo-version
dubbo-version=1.0

在resources目录新建dubbo-provider.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-provider" owner="dubbo-provider" />
    
    <!-- 定义 zookeeper 注册中心地址及协议 -->
    <dubbo:registry protocol="zookeeper" address="${zkAddress}"/>

    <!-- 用dubbo协议在20880端口暴露服务 -->
    <dubbo:protocol name="dubbo" port="${dubbo.port}"/>

    <!-- 声明需要暴露的服务接口 -->
    <dubbo:service interface="com.laowang.dubboapi.service.OrderService" ref="orderService" timeout="5000" version="${dubbo-version}"/>

</beans>

启动类

在DubboProviderApplication中加入注解@ImportResource(value = “classpath:dubbo-provider.xml”)

然后启动，如下图控制台打印信息说明成功，dubbo服务提供完成

dubbo-consumer(服务消费者)

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>com.laowang</groupId>
        <artifactId>dubbo-parent</artifactId>
        <version>0.0.1-SNAPSHOT</version>
        <relativePath>../dubbo-parent/pom.xml</relativePath>
    </parent>
    <groupId>com.laowang</groupId>
    <artifactId>dubbo-consumer</artifactId>
    <version>0.0.1-SNAPSHOT</version>
    <name>dubbo-consumer</name>


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

        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>dubbo</artifactId>
        </dependency>
        <dependency>
            <groupId>org.apache.zookeeper</groupId>
            <artifactId>zookeeper</artifactId>
        </dependency>
        <dependency>
            <groupId>com.101tec</groupId>
            <artifactId>zkclient</artifactId>
        </dependency>
        <dependency>
            <groupId>com.laowang</groupId>
            <artifactId>dubbo-api</artifactId>
            <version>0.0.1-SNAPSHOT</version>
        </dependency>

    </dependencies>

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

</project>

新建controller

注入service 的时候用dubbo的Reference实现远程调用

application.properties配置文件

server.port=8091
#zookeeper地址
zkAddress=127.0.0.1:2181

在resources目录新建dubbo-consumer.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" owner="dubbo-consumer" />
    
    <!-- 定义 zookeeper 注册中心地址及协议 -->
    <dubbo:registry protocol="zookeeper" address="${zkAddress}"/>

    <!--数据接口-->
    <dubbo:annotation package="com.laowang.dubboconsumer.controller" />
</beans>

启动类

加上@ImportResource(locations={“classpath:dubbo-consumer.xml”})注解

然后启动，控制台打印如下信息说明成功

然后测试一下

在浏览器输入http://localhost:8091/helloDubbo，如下图，说明成功，然后去dubbo admin 中去看看

注意这里有个坑，就是可能会有controller中Reference注入service空指针错误，那就肯定是版本问题了，检查一下自己版本

dubbo管理平台（最新版）

从dubbo2.6.1之后，dubbo admin 管理平台已经分离出来单独维护了，也新增了很多功能。最新的管理平台也前后台分离，后台用的spring boot，前台用的vue，所有需要node来安装依赖
dubbo管理平台下载地址

下载完成后解压，目录如下图

修改application.properties配置文件
主要是看看端口号，ip地址是否需要修改，如果是127.0.0.1可忽略此步骤

admin.registry.address=zookeeper://127.0.0.1:2181
admin.config-center=zookeeper://127.0.0.1:2181
admin.metadata-report.address=zookeeper://127.0.0.1:2181



admin.registry.group=dubbo
admin.apollo.token=e16e5cd903fd0c97a116c873b448544b9d086de9
admin.apollo.appId=test
admin.apollo.env=dev
admin.apollo.cluster=default
admin.apollo.namespace=dubbo

然后cmd进入dubbo-admin-server目录下

分别执行mvn claen package命令，如下图代表成功

然后cmd进入dubbo-admin-server\target目录，就是刚刚打包编译后的目录
执行java -jar dubbo-admin-server-0.1.jar启动项目
如下图说明启动成功

然后浏览器打开http://localhost:8080/swagger-ui.html，说明后台已经启动成功

然后进入dubbo-admin-ui，打包vue组件
首先需要nodejs的环境，如果没有安装过node可以参考: Nodejs环境搭建

进入dubbo-admin-ui目录，执行npm install安装依赖，这里需要几分钟时间，如果嫌慢试试cnpm install，这个是用的阿里国内镜像，要稍微快点。然后安装完成时候执行cnpm run dev启动，如下图

然后浏览器输入http://localhost:8081

点击查看详情，如果使用dubbo2.7以上版本还可以查看元数据

源码下载

点击进入CSDN下载
包含demo源码和dubbo admin源码


转载：https://blog.csdn.net/u013254183/article/details/105935247
查看评论
* 以上用户言论只代表其个人观点，不代表本网站的观点或立场