Sprinboot集成dubbo+zookeeper完成注册中心以及生产者和消费者之间的调用关系

不念不忘少年蓝@ 2022-03-21 06:15 58阅读 0赞

**一.介绍**

1.1 dubbo是阿里巴巴soa服务化治理方案的核心框架，是一个分布式服务的框架，致力于提高性能和透明化rpc远程服务调用方案，对于soa服务治理方案。看到这里会有点懵，什么是soa呢，什么是rpc呢？？？

soa：面向服务的架构，将应用程序的不同功能单元（也叫作服务）通过服务之间的定义良好的接口和契约联系起来。
    
    rpc：远程过程调用协议，是一种通过网络从远程计算机程序上请求服务，而不需要了解底层网络技术的协议。

1.2 在dubbo+zookeeper中有三个重要的角色：

1). **provider（服务提供者）**：在我们项目中可以粗糙地理解成实现类

2).**Consumer（服务消费者）**：可以理解为调用服务（调用实现类）的类，类似于controller，当然如果集成rabbitmq也有可能是消息队列的类，也有可能是实现类调用实现类，所以实现类可以身兼数职，既可以是服务提供者也可以是服务调用者。

3).**registry（zookeeper）**：也就是我们的注册中心，zookeeper是Apache下的产品。没有用dubbo之前我们一般是controller调用service，service调用mapper（dao），但是现在加上了dubbo以后就是controller（当然不止controller，所有服务消费者都可以）通过向zookeeper订阅服务，service向zookeeper注册服务，通过zookeeper这个中介，把服务提供方的服务注入到服务消费者中。  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2xpZ2hfc3Fo_size_16_color_FFFFFF_t_70]

**二.实践demo**

2.1 首先创建一个maven父级项目,然后在父级项目下创建三个子项目模块.如下图所示:  
![在这里插入图片描述][2019013109320095.png]  
解释:  
boot-dubbo-api是service接口和实体类对象  
boot-dubbo-consumer是消费者,就是controller接口  
boot-dubbo-provider是生产者,就是service接口的实现类

2.2 boot-dubbo-api内部依赖以及demo

1).依赖

2). 实体类

/**
     * Created by ${ligh} on 2019/1/29 下午7:26
     */
    public class User implements Serializable{
    
        private static final long serialVersionUID = 1L;  
        private String username;
        private String password;
        private String city;
        public String getUsername() {
            return username;
        }
        public void setUsername(String username) {
            this.username = username;
        }
        public String getPassword() {
            return password;
        }
        public void setPassword(String password) {
            this.password = password;
        }
        public String getCity() {
            return city;
        }
        public void setCity(String city) {
            this.city = city;
        }
    }

3). service接口

import com.ligh.domain.User;
    
    /**
     * Created by ${ligh} on 2019/1/29 下午7:27
     */
    public interface UserService {
    
        //测试方法
        public User getUser();
    }

2.3 boot-dubbo-provider内部依赖以及demo

1).依赖

2).配置文件application.properties

server.port=8081
    ## Dubbo 服务提供者配置
    spring.dubbo.application.name=provider
    spring.dubbo.registry.address=zookeeper://127.0.0.1:2181
    spring.dubbo.protocol.name=dubbo
    spring.dubbo.protocol.port=2088
    spring.dubbo.scan=com.ligh.serviceImpl

3).service实现类

import com.alibaba.dubbo.config.annotation.Service;
    import com.ligh.domain.User;
    import com.ligh.service.UserService;
    import javax.annotation.PostConstruct;
    /**
     * Created by ${ligh} on 2019/1/29 下午7:31
     */
    @Service
    public class UserServiceImpl implements UserService{
    
        //项目启动就会加载
        @PostConstruct
        void init(){
            System.out.println("user 测试");
        }
        @Override
        public User getUser() {
            User user = new User();
            user.setUsername("李国辉");
            user.setPassword("12345678");
            user.setCity("杭州");
            return user;
        }
    }

2.4 boot-dubbo-consumer内部依赖以及demo

1).依赖

<?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">
        <parent>
            <artifactId>boot-dubbo</artifactId>
            <groupId>com.ligh</groupId>
            <version>1.0-SNAPSHOT</version>
        </parent>
        <modelVersion>4.0.0</modelVersion>
        <artifactId>boot-dubbo-consumer</artifactId>
        <properties>
            <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
            <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
            <java.version>1.8</java.version>
        </properties>
        <dependencies>
            <dependency>
                <groupId>com.ligh</groupId>
                <artifactId>boot-dubbo-api</artifactId>
                <version>1.0</version>
            </dependency>
            <dependency>
                <groupId>io.dubbo.springboot</groupId>
                <artifactId>spring-boot-starter-dubbo</artifactId>
                <version>1.0.0</version>
                <exclusions>
                    <exclusion>
                        <groupId>org.springframework</groupId>
                        <artifactId>spring</artifactId>
                    </exclusion>
                </exclusions>
            </dependency>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-web</artifactId>
                <version>2.0.4.RELEASE</version>
                <exclusions>
                    <exclusion>
                        <groupId>org.springframework</groupId>
                        <artifactId>spring</artifactId>
                    </exclusion>
                </exclusions>
            </dependency>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-test</artifactId>
                <version>2.0.4.RELEASE</version>
                <exclusions>
                    <exclusion>
                        <groupId>org.springframework</groupId>
                        <artifactId>spring</artifactId>
                    </exclusion>
                </exclusions>
                <scope>test</scope>
            </dependency>
            <dependency>
                <groupId>junit</groupId>
                <artifactId>junit</artifactId>
                <version>4.7</version>
                <exclusions>
                    <exclusion>
                        <groupId>org.springframework</groupId>
                        <artifactId>spring</artifactId>
                    </exclusion>
                </exclusions>
            </dependency>
        </dependencies>
        <build>
            <plugins>
                <plugin>
                    <groupId>org.springframework.boot</groupId>
                    <artifactId>spring-boot-maven-plugin</artifactId>
                </plugin>
            </plugins>
        </build>
    </project>

2).配置文件application.properties

## 避免和 server 工程端口冲突
    server.port=8082
    ## Dubbo 服务消费者配置
    spring.dubbo.application.name=consumer
    spring.dubbo.registry.address=zookeeper://127.0.0.1:2181
    spring.dubbo.scan=com.ligh.controller

3).controller接口

import com.alibaba.dubbo.config.annotation.Reference;
    import com.ligh.domain.User;
    import com.ligh.service.AddService;
    import com.ligh.service.UserService;
    import org.springframework.web.bind.annotation.RequestMapping;
    import org.springframework.web.bind.annotation.RestController;
    import javax.annotation.PostConstruct;
    /**
     * Created by ${ligh} on 2019/1/30 上午8:12
     */
    @RestController
    public class UserController {
    
        @Reference  
        UserService userService;
        @Reference
        AddService addService;
        
        @RequestMapping("hello")
        public String hello(){
            addService.sayhello();
            return "success";
        }
        @RequestMapping(value = "getUser")
        public User getUser(){
            User user = userService.getUser();
            return user;
        }
    }

2.5 启动顺序  
   首先启动生产者(boot-dubbo-provider)–>然后就是消费者(boot-dubbo-consumer),如果启动都没有报错,就成功了一大半。

**三. 搭建dubbo-admin环境,通过界面查看生产者和消费者之间是否产生调用关系**

3.1 搭建环境之前首先要搭建zookeeper环境,如果不会的朋友可以点击下面链接[zookeeper安装启动教程][zookeeper]

3.2 下载dubbo-admin源码包,[源码包下载地址][Link 1],修改/dubbo-admin/src/main/webapp/WEB-INF/dubbo.properties的配置文件,如果是本地无需配置

dubbo.registry.address=zookeeper://127.0.0.1:2181
    dubbo.admin.root.password=root
    dubbo.admin.guest.password=root

3.3 配置完成之后在dubbo-admin的目录下直接执行打包编译命令

mvn clean install -Dmaven.test.skip=true

3.4 然后进入到target目录下找到dubbo-admin-2.8.4.war,把改war包放在tomcat的webapps目录下,然后启动tomcat,在浏览器中输入地址**http://localhost:8080/dubbo-admin-2.8.4**提示输入用户名和密码都是root,然后输入进入以下界面表示成功  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2xpZ2hfc3Fo_size_16_color_FFFFFF_t_70 1]  
   3.5 输入本机ip地址localhost可以进行查看接口是否已经注册到注册中心  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2xpZ2hfc3Fo_size_16_color_FFFFFF_t_70 2]  
两个在boot-dubbo-api中的service接口已经注册到注册中心中,可以供消费者消费了。

3.6 在浏览器中输入消费者项目中的controller,查看dubbo-admin是否有消费记录  
![在这里插入图片描述][20190131101030863.png]  
然后查看dubbo-admin是否有消费记录

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2xpZ2hfc3Fo_size_16_color_FFFFFF_t_70 3]

从图中可以清楚的看到已经通知消费记录了。

以上就完成了基于Springboot搭建zookeeper做注册中心,dubbo做生产者和消费者,并且通过dubbo-admin进行界面的管理。

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2xpZ2hfc3Fo_size_16_color_FFFFFF_t_70]: /images/20220321/aff1b18346e9419f83817481252a2599.png
[2019013109320095.png]: /images/20220321/4a43b736b26945cb99fc460da8bd99f6.png
[zookeeper]: https://blog.csdn.net/ligh_sqh/article/details/80334938
[Link 1]: https://codeload.github.com/dangdangdotcom/dubbox/tar.gz/dubbox-2.8.4
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2xpZ2hfc3Fo_size_16_color_FFFFFF_t_70 1]: /images/20220321/127f9d4569174ab7a0f1f2cc392d0603.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2xpZ2hfc3Fo_size_16_color_FFFFFF_t_70 2]: /images/20220321/560b362306e04794a34ef09a44ecbdad.png
[20190131101030863.png]: /images/20220321/bff1c6b8e77e4b4ab1e398b76e64c0d7.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2xpZ2hfc3Fo_size_16_color_FFFFFF_t_70 3]: /images/20220321/132e8c28d9ba449cb9df5b114e2170c3.png