Intellij IDEA 2018.2 搭建springboot+dubbo+zookeeper+mybatis简单的分布式框架(二）

系统管理员 2024-04-18 14:37 78阅读 0赞

搭建springboot+dubbo+zookeeper+mybatis具体操作：（注意必须启动zookeeper服务哦！）

**一、打开IDE创建springboot父项目demo,再新建三个module:**

1. dubbo-api(对外RPC接口)

2. dubbo-provider(dubbo接口提供者)

3. dubbo-customer(dubbo接口消费者)  
如图所示:

![20190908101152912.png][]

**二、 父项目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.1.8.RELEASE</version>
            <relativePath/> 
        </parent>
        <groupId>com.dubbo</groupId>
        <artifactId>demo</artifactId>
        <version>0.0.1-SNAPSHOT</version>
        <name>demo</name>
        <description>Demo project for Spring Boot</description>
    
    
        
        <modules>
            <module>dubbo-api</module>
            <module>dubbo-provider</module>
            <module>dubbo-customer</module>
        </modules>
    
        <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>
    
            
            
            <dependency>
                <groupId>com.alibaba.spring.boot</groupId>
                <artifactId>dubbo-spring-boot-starter</artifactId>
                <version>1.0.1</version>
            </dependency>
            
            <dependency>
                <groupId>com.101tec</groupId>
                <artifactId>zkclient</artifactId>
                <version>0.10</version>
            </dependency>
            
            <dependency>
                <groupId>org.apache.zookeeper</groupId>
                <artifactId>zookeeper</artifactId>
                <version>3.4.9</version>
            </dependency>
        </dependencies>
    
        <build>
            <plugins>
                <plugin>
                    <groupId>org.springframework.boot</groupId>
                    <artifactId>spring-boot-maven-plugin</artifactId>
                </plugin>
            </plugins>
        </build>
    
    </project>

**三、 3个子项目相关配置与文件**

3.1 dubbo-api(对外RPC接口) -->主要放实体、接口、也可以放一些公用的工具类工程

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2hseDIwMDgwODA4_size_16_color_FFFFFF_t_70][] ![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2hseDIwMDgwODA4_size_16_color_FFFFFF_t_70 1][]

业务接口

![20190908102547724.png][]

3.2 dubbo-provider(dubbo接口提供者) -->主要是服务提供者

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2hseDIwMDgwODA4_size_16_color_FFFFFF_t_70 2][]![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2hseDIwMDgwODA4_size_16_color_FFFFFF_t_70 3][]

mapper接口:

import com.dubbo.demo.api.entity.Userinfo;
    import org.apache.ibatis.annotations.Mapper;
    import org.apache.ibatis.annotations.Result;
    import org.apache.ibatis.annotations.Results;
    import org.apache.ibatis.annotations.Select;
    
    import java.util.List;
    
    /**
     * 底层数据UserinfoMapper接口
     */
    @Mapper   //扫描注入bean
    public interface UserinfoMapper {
    
        @Select("select * from userinfo")
        @Results(value = {
                @Result(property = "id", column = "id"),
                @Result(property = "userCode", column = "userCode"),
                @Result(property = "userName", column = "userName"),
                @Result(property = "userPassword", column = "userPassword")
        })
        public List<Userinfo> getAll();
    
    
        @Select("select * from userinfo where id=#{id}")
        public Userinfo findById(Integer id);
    
    }

实现接口的业务类

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2hseDIwMDgwODA4_size_16_color_FFFFFF_t_70 4][]

application.yml

spring:
      dubbo:
        appname: provider
        registry: zookeeper://47.240.20.111:2181
        port: 20080
        protocol: dubbo
      datasource:
        driver-class-name: com.mysql.jdbc.Driver
        url: jdbc:mysql://localhost:3306/smbms?useUnicode=true&characterEncoding=UTF-8&zeroDateTimeBehavior=convertToNull&allowMultiQueries=true&useSSL=false
        username: root
        password: root
    server:
      port: 8882

providerApplication运行：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2hseDIwMDgwODA4_size_16_color_FFFFFF_t_70 5][]

3.3 dubbo-customer(dubbo接口消费者) -->主要是服务消费者

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2hseDIwMDgwODA4_size_16_color_FFFFFF_t_70 6][]![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2hseDIwMDgwODA4_size_16_color_FFFFFF_t_70 7][]

控制器：

package com.hlx.demo.customer.controller;
    
    import com.alibaba.dubbo.config.annotation.Reference;
    
    
    import com.dubbo.demo.api.entity.Userinfo;
    import com.dubbo.demo.api.service.UserinfoService;
    import org.springframework.web.bind.annotation.GetMapping;
    import org.springframework.web.bind.annotation.PathVariable;
    import org.springframework.web.bind.annotation.RequestMapping;
    import org.springframework.web.bind.annotation.RestController;
    
    import java.util.List;
    
    //控制器
    @RestController
    public class UserinfoController {
    
        //业务接口bean的注入
        @Reference(check = false)  //dubbo的包
        private UserinfoService userinfoService;
    
        @RequestMapping("/say1/{name}")
        public String say1(@PathVariable("name")  String name){
            System.out.println("进来了！say1");
            //调用业务方法
            return "how are you ? "+userinfoService.hello(name);
        }
    
        @GetMapping("say2")
        public String say2(){
            System.out.println("进来了！say2");
            //调用业务方法
    
            return "你好吗? "+userinfoService.hello("mike");
        }
    
        @GetMapping("all")
       public List<Userinfo> all(){
            System.out.println("查看数据列表++++》");
           return userinfoService.getList();
       }
    
       @RequestMapping("/find/{id}")
       public Userinfo find(@PathVariable("id") Integer id){
           System.out.println("查看用户信息一条++++》");
           return userinfoService.getUserinfo(id);
       }
    }

application.yml文件:

server:
      port: 8884
      servlet:
        context-path: /
    spring:
      dubbo:
        appname: consumer-test
        registry: zookeeper://47.240.20.111:2181
        protocol: dubbo

customerApplication运行：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2hseDIwMDgwODA4_size_16_color_FFFFFF_t_70 8][]

先启动服务器，再启动消费者

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2hseDIwMDgwODA4_size_16_color_FFFFFF_t_70 9][]

运行效果:

有参数的传递方式

![20190908105310361.png][]

无参数的传递方式

![2019090810525693.png][]

查询所有的数据以JSON格式显示

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2hseDIwMDgwODA4_size_16_color_FFFFFF_t_70 10][]![20190908105511563.png][]

根据ID查询数据

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2hseDIwMDgwODA4_size_16_color_FFFFFF_t_70 11][]

[20190908101152912.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/18/cd6d346acd1746d38cd3469c8863c4c2.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2hseDIwMDgwODA4_size_16_color_FFFFFF_t_70]: https://img-blog.csdnimg.cn/2019090810243243.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2hseDIwMDgwODA4,size_16,color_FFFFFF,t_70
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2hseDIwMDgwODA4_size_16_color_FFFFFF_t_70 1]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/18/73c8d8fc9df24af2b92224d3fe6b54ab.png
[20190908102547724.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/18/f1bc5fd5c9a247e7be03957f22c5a231.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2hseDIwMDgwODA4_size_16_color_FFFFFF_t_70 2]: https://img-blog.csdnimg.cn/20190908104849121.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2hseDIwMDgwODA4,size_16,color_FFFFFF,t_70
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2hseDIwMDgwODA4_size_16_color_FFFFFF_t_70 3]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/18/0e03e697423d44d7bb958cde84511216.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2hseDIwMDgwODA4_size_16_color_FFFFFF_t_70 4]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/18/e79bad335ff846d5bd6e1e42b290663d.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2hseDIwMDgwODA4_size_16_color_FFFFFF_t_70 5]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/18/1b4da6184e594b6ca1f55555fba5199c.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2hseDIwMDgwODA4_size_16_color_FFFFFF_t_70 6]: https://img-blog.csdnimg.cn/20190908104606919.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2hseDIwMDgwODA4,size_16,color_FFFFFF,t_70
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2hseDIwMDgwODA4_size_16_color_FFFFFF_t_70 7]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/18/fe37a74d77304f10bb67f4f0db7295e6.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2hseDIwMDgwODA4_size_16_color_FFFFFF_t_70 8]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/18/b7698a632947465aa9b143a24a7a83fc.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2hseDIwMDgwODA4_size_16_color_FFFFFF_t_70 9]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/18/f4644fe1a560463d8e53c80496203bb1.png
[20190908105310361.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/18/a8c8161244324a1ab62533a3e72f40a3.png
[2019090810525693.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/18/7073549958df4aeeaeebd2c5914ba4ba.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2hseDIwMDgwODA4_size_16_color_FFFFFF_t_70 10]: https://img-blog.csdnimg.cn/2019090810532921.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2hseDIwMDgwODA4,size_16,color_FFFFFF,t_70
[20190908105511563.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/18/d321bf1c394942aaa2ef7175c6c38728.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2hseDIwMDgwODA4_size_16_color_FFFFFF_t_70 11]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/18/c77b2e57949d4a9da06ddd4b436bd4e8.png