dubbo（3）：环境搭建：服务消费者和服务提供者

深碍√TFBOYSˉ_ 2023-01-22 05:54 17阅读 0赞

# 三、创建服务提供者消费者工程 #

## （1）提出需求 ##

某个电商系统，订单服务需要调用用户服务获取某个用户的所有地址。我们需要创建两个服务模块进行测试

<table style="width:500px;"> 
 <tbody> 
  <tr> 
   <td>模块</td> 
   <td>功能</td> 
  </tr> 
  <tr> 
   <td>订单服务web模块</td> 
   <td>创建订单等</td> 
  </tr> 
  <tr> 
   <td>用户服务service模块</td> 
   <td>查询用户地址等</td> 
  </tr> 
 </tbody> 
</table>

订单服务web模块在A服务器，用户模块在B服务器，A可以远程调用B的功能。

## （2）创建多模块项目 ##

<?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>
    
        <groupId>org.example</groupId>
        <artifactId>dubbo-demo</artifactId>
        <packaging>pom</packaging>
        <version>1.0-SNAPSHOT</version>
        <modules>
            <module>user-service-provider</module>
        </modules>
    
        
        <properties>
            <project.build-sourceEncoding>utf-8</project.build-sourceEncoding>
            <maven.compiler.source>11</maven.compiler.source>
            <maven.compiler.target>11</maven.compiler.target>
            <log4j.version>1.2.17</log4j.version>
            <junit.version>4.12</junit.version>
            <lombok.version>1.18.16</lombok.version>
        </properties>
    
        <dependencyManagement>
            <dependencies>
                
                <dependency>
                    <groupId>org.springframework.boot</groupId>
                    <artifactId>spring-boot-dependencies</artifactId>
                    <version>2.4.2</version>
                    <type>pom</type>
                    <scope>import</scope>
                </dependency>
                
                <dependency>
                    <groupId>org.mybatis.spring.boot</groupId>
                    <artifactId>mybatis-spring-boot-starter</artifactId>
                    <version>2.1.4</version>
                </dependency>
                
                <dependency>
                    <groupId>junit</groupId>
                    <artifactId>junit</artifactId>
                    <version>${junit.version}</version>
                </dependency>
                <dependency>
                    <groupId>org.projectlombok</groupId>
                    <artifactId>lombok</artifactId>
                    <version>${lombok.version}</version>
                </dependency>
                <dependency>
                    <groupId>log4j</groupId>
                    <artifactId>log4j</artifactId>
                    <version>${log4j.version}</version>
                </dependency>
                <dependency>
                    <groupId>ch.qos.logback</groupId>
                    <artifactId>logback-core</artifactId>
                    <version>1.2.3</version>
                </dependency>
            </dependencies>
        </dependencyManagement>
    </project>

##     （3）创建用户服务提供者模块 ##

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQwMjk4MzUx_size_16_color_FFFFFF_t_70][]

编写javaBean代码

package com.buba.pojo;
    
    import lombok.AllArgsConstructor;
    import lombok.Data;
    
    import java.io.Serializable;
    
    @Data
    @AllArgsConstructor
    public class UserAddress implements Serializable {
        private Integer id;
        private String userAddress;
        private String userId;
        private String consignee; // 收货人
        private String phoneNum;
        private String isDefault; // 默认地址
    }

编写业务接口和实现类

package com.buba.service;
    
    import com.buba.pojo.UserAddress;
    
    import java.util.List;
    
    public interface UserService {
        List<UserAddress> getUserAddressList(String userId);
    }

package com.buba.service.impl;
    
    import com.buba.pojo.UserAddress;
    import com.buba.service.UserService;
    
    import java.util.Arrays;
    import java.util.List;
    
    public class UserServiceImpl implements UserService {
        @Override
        public List<UserAddress> getUserAddressList(String userId) {
            UserAddress userAddress1 = new UserAddress(1, "北京", "1", "张三", "17611112222", "是");
            UserAddress userAddress2 = new UserAddress(2, "天津", "1", "张三", "17611112222", "是");
            return Arrays.asList(userAddress1, userAddress2);
        }
    }

## （4）服务消费者模块 ##

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQwMjk4MzUx_size_16_color_FFFFFF_t_70 1][]

编写Controller、Service和Impl。

package com.buba.controller;
    
    import com.buba.service.OrderService;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.web.bind.annotation.RequestMapping;
    import org.springframework.web.bind.annotation.RestController;
    
    @RestController
    @RequestMapping("/Order")
    public class OrderController {
    
        private OrderService orderService;
    
        @RequestMapping("/initOrder")
        public void initOrder() {
            orderService.initOrder("1");
        }
    
        @Autowired
        public void setOrderService(OrderService orderService) {
            this.orderService = orderService;
        }
    }

package com.buba.service;
    
    public interface OrderService {
        void initOrder(String userId);
    }

package com.buba.service.impl;
    
    import com.buba.service.OrderService;
    
    public class OrderServiceImpl implements OrderService {
        @Override
        public void initOrder(String userId) {
            // 查询用户收货地址
    
        }
    }

## （5）创建公共的javaBean和接口模块 ##

在dubbo官方文档中建议将接口、模型、异常等均放在单独的模块中。

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQwMjk4MzUx_size_16_color_FFFFFF_t_70 2][]

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQwMjk4MzUx_size_16_color_FFFFFF_t_70 3][]

把刚才创建的两个模块的接口和实体类移过来。

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQwMjk4MzUx_size_16_color_FFFFFF_t_70 4][]

删除原先模块的接口和实体类。

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQwMjk4MzUx_size_16_color_FFFFFF_t_70 5][]

把公共的api添加到需要的模块中。

这样服务消费者和提供者就基本搭建完成。

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQwMjk4MzUx_size_16_color_FFFFFF_t_70]: /images/20221020/00dc565d8a9449cc8830dd96d4e93e47.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQwMjk4MzUx_size_16_color_FFFFFF_t_70 1]: /images/20221020/1ece120d9870416684705e5c1931cfb7.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQwMjk4MzUx_size_16_color_FFFFFF_t_70 2]: /images/20221020/0b0f4f7b2edb43d381729e9400b87215.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQwMjk4MzUx_size_16_color_FFFFFF_t_70 3]: /images/20221020/d099a079b54445308c8dcab33cc5f8eb.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQwMjk4MzUx_size_16_color_FFFFFF_t_70 4]: /images/20221020/6da7a66e392748a1bfe6087083bbc934.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQwMjk4MzUx_size_16_color_FFFFFF_t_70 5]: /images/20221020/7daae80128034c2caa43cb562a534b82.png