nacos集成dubbo实现远程服务调用多服务端2

喜欢ヅ旅行 2022-08-29 09:50 270阅读 0赞

### 文章目录 ###

*   *   *   *   *  一、版本选取、需求和项目简述
                 *   *  1. 版本选取
                     *  2. 项目模块说明
                     *  2. 需求说明
                 *  二、需求实战-依赖初始化
                 *   *  2.1. 创建maven父工程EShopParent
                     *  2.2. 创建子模块DubboApi
                     *  2.3. 创建服务端Stock-serv
                     *  2.4. 创建服务端product-serv
                     *  2.5. 创建消费端端Order-serv
                 *  三、需求实战-代码编写
                 *   *  3.1. 创建公共接口
                     *  3.2. 扣库存服务端编写
                     *  3.3. 产品服务端编写
                     *  3.5. 消费端编写
                 *  四、需求实战-配置编写
                 *   *  4.1. 扣库存服务端配置
                     *  4.2. 产品服务端配置
                     *  4.3.消费端配置
                 *  五、需求测试实战
                 *   *  5.1. 启动nacos
                     *  5.2. 启动服务端
                     *  5.3. 启消费端
                     *  5.4. 查看nacos
                     *  5.5. 项目模块分布结构
                 *  六、测试实战
                 *   *  6.1. 请求扣库存链路
                     *  6.2. 请求产品链路
                     *  6.3. 常见的异常

##### 一、版本选取、需求和项目简述 #####

###### 1. 版本选取 ######

<table> 
 <thead> 
  <tr> 
   <th align="left">框架</th> 
   <th>版本</th> 
   <th>说明</th> 
  </tr> 
 </thead> 
 <tbody> 
  <tr> 
   <td align="left">spring-cloud-alibaba</td> 
   <td>2.2.6.RELEASE</td> 
   <td>版本要对应</td> 
  </tr> 
  <tr> 
   <td align="left">spring-boot</td> 
   <td>2.3.2.RELEASE</td> 
   <td>版本要对应</td> 
  </tr> 
  <tr> 
   <td align="left">nacos</td> 
   <td>1.4.2</td> 
   <td>版本要对应</td> 
  </tr> 
  <tr> 
   <td align="left">org.apache.dubbo</td> 
   <td>2.7.8</td> 
   <td>版本要对应</td> 
  </tr> 
 </tbody> 
</table>

###### 2. 项目模块说明 ######

<table> 
 <thead> 
  <tr> 
   <th>模块</th> 
   <th>说明</th> 
  </tr> 
 </thead> 
 <tbody> 
  <tr> 
   <td>EShopParent</td> 
   <td>父工程</td> 
  </tr> 
  <tr> 
   <td>DubboApi</td> 
   <td>接口子模块</td> 
  </tr> 
  <tr> 
   <td>Order-serv</td> 
   <td>订单模块</td> 
  </tr> 
  <tr> 
   <td>Stock-serv</td> 
   <td>扣库存模块</td> 
  </tr> 
  <tr> 
   <td>product-serv</td> 
   <td>产品模块</td> 
  </tr> 
 </tbody> 
</table>

###### 2. 需求说明 ######

订单模块调用扣库存模块完成库库存的业务

##### 二、需求实战-依赖初始化 #####

###### 2.1. 创建maven父工程EShopParent ######

<?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>com.gblfy</groupId>
        <artifactId>EShopParent</artifactId>
        <packaging>pom</packaging>
        <version>1.0-SNAPSHOT</version>
        <modules>
            <module>Order-serv</module>
            <module>Stock-serv</module>
            <module>DubboApi</module>
            <module>product-serv</module>
        </modules>
        <description>父工程 所有子工程需要依赖此工程</description>
        <parent>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-parent</artifactId>
            <version>2.3.2.RELEASE</version>
        </parent>
    
        <dependencies>
            
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-web</artifactId>
            </dependency>
            
            <dependency>
                <groupId>com.alibaba.cloud</groupId>
                <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
            </dependency>
            
            <dependency>
                <groupId>com.alibaba.cloud</groupId>
                <artifactId>spring-cloud-starter-dubbo</artifactId>
            </dependency>
        </dependencies>
        <dependencyManagement>
            <dependencies>
                
                <dependency>
                    <groupId>com.alibaba.cloud</groupId>
                    <artifactId>spring-cloud-alibaba-dependencies</artifactId>
                    <version>2.2.6.RELEASE</version>
                    <scope>import</scope>
                    <type>pom</type>
                </dependency>
            </dependencies>
        </dependencyManagement>
    </project>

###### 2.2. 创建子模块DubboApi ######

###### 2.3. 创建服务端Stock-serv ######

###### 2.4. 创建服务端product-serv ######

###### 2.5. 创建消费端端Order-serv ######

##### 三、需求实战-代码编写 #####

###### 3.1. 创建公共接口 ######

在DubboApi子模块中创建调用扣库存模块（Stock-serv）的接口IStockService

package com.gblfy.stock.api;
    
    public interface IStockService { 
        public String reduce(Integer productId, Integer userId);
    }

在DubboApi子模块中创建调用产品（product-serv）模块的接口

package com.gblfy.product.api;
    
    public interface IProductService { 
        public String buyProduct(Integer productId, Integer userId);
    }

###### 3.2. 扣库存服务端编写 ######

在Stock-serv子模块中实现接口实现类StockServiceimpl

package com.gblfy.service.impl;
    
    import com.gblfy.stock.api.IStockService;
    import org.apache.dubbo.config.annotation.DubboService;
    
    @DubboService
    public class StockServiceimpl implements IStockService { 
    
        @Override
        public String reduce(Integer productId, Integer userId) { 
            return "用户编号: " + userId + "产品编码: " + productId + "减库存1个";
        }
    }

启动类上添加@EnableDiscoveryClient注解

package com.gblfy;
    
    import org.springframework.boot.SpringApplication;
    import org.springframework.boot.autoconfigure.SpringBootApplication;
    import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
    
    @EnableDiscoveryClient
    @SpringBootApplication
    public class StockApplication { 
        public static void main(String[] args) { 
            SpringApplication.run(StockApplication.class);
        }
    }

###### 3.3. 产品服务端编写 ######

在product-serv子模块中实现接口实现类ProductServiceImpl

package com.gblfy.service.impl;
    
    import com.gblfy.product.api.IProductService;
    import org.apache.dubbo.config.annotation.DubboService;
    
    @DubboService
    public class ProductServiceImpl implements IProductService { 
    
        @Override
        public String buyProduct(Integer productId, Integer userId) { 
            return "用户编号: " + userId + "产品编码: " + productId + "购买PHONE SUCCESS";
        }
    }

启动类添加@EnableDiscoveryClient注解

package com.gblfy;
    
    import org.springframework.boot.SpringApplication;
    import org.springframework.boot.autoconfigure.SpringBootApplication;
    import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
    
    @SpringBootApplication
    @EnableDiscoveryClient
    public class ProductApplication { 
    
        public static void main(String[] args) { 
            SpringApplication.run(ProductApplication.class);
        }
    }

###### 3.5. 消费端编写 ######

在Order-serv子模块的启动类上添加@EnableDiscoveryClient开启服务发现扫描

package com.gblfy;
    
    import org.springframework.boot.SpringApplication;
    import org.springframework.boot.autoconfigure.SpringBootApplication;
    import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
    
    
    @SpringBootApplication
    @EnableDiscoveryClient
    public class OrderAppliaction { 
    
        public static void main(String[] args) { 
            SpringApplication.run(OrderAppliaction.class);
        }
    }

创建一个客户端类发起请求OrderController分别向扣库存模块和产品模块发起请求

package com.gblfy.controller;
    
    import com.gblfy.product.api.IProductService;
    import com.gblfy.stock.api.IStockService;
    import org.apache.dubbo.config.annotation.DubboReference;
    import org.springframework.web.bind.annotation.GetMapping;
    import org.springframework.web.bind.annotation.RestController;
    
    
    @RestController
    public class OrderController { 
    
        @DubboReference
        private IStockService stockService;
        @DubboReference
        private IProductService productService;
    
        @GetMapping("/order/create")
        public String createOrder(Integer productId, Integer userId) { 
            //调用扣库存模块服务
            return stockService.reduce(productId, userId);
        }
        //http://127.0.0.1:8080/order/create?productId=2&userId=8
    
        @GetMapping("/buyProduct")
        public String buyProduct(Integer productId, Integer userId) { 
            //调用产品模块服务
            return productService.buyProduct(productId, userId);
        }
        // http://127.0.0.1:8080/buyProduct?productId=2&userId=8
    }

##### 四、需求实战-配置编写 #####

###### 4.1. 扣库存服务端配置 ######

# 应用端口
    server:
      port: 8082
    
    # nacos服务发现配置
    spring:
      cloud:
        nacos:
          server-addr: 127.0.0.1:8848
          discovery:
            service: stock-serv
      application:
        name: stock-serv
    
    # Dubbo服务配置
    dubbo:
      scan:
        base-packages: com.gblfy.service.impl
      protocol:
        name: dubbo
        port: -1
      registry:
        address: spring-cloud://127.0.0.1

###### 4.2. 产品服务端配置 ######

server:
      port: 8081
    spring:
      cloud:
        nacos:
          server-addr: 127.0.0.1:8848
          discovery:
            service: product-serv
      application:
        name: product-serv
    
    # Dubbo服务配置
    dubbo:
      scan:
        base-packages: com.gblfy.service.impl
      protocol:
        name: dubbo
        port: -1
      registry:
        address: spring-cloud://127.0.0.1

###### 4.3.消费端配置 ######

server:
      port: 8080
    spring:
      application:
        name: order-serv
      cloud:
        nacos:
          discovery:
            server-addr: http://127.0.0.1:8848
          config:
            server-addr: http://127.0.0.1:8848
            
    # Dubbo服务配置
    dubbo:
      protocol:
        name: dubbo
        port: -1
      registry:
        address: spring-cloud://127.0.0.1
      cloud:
        subscribed-services:
          - stock-serv
          - product-serv

##### 五、需求测试实战 #####

###### 5.1. 启动nacos ######

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MDgxNjczOA_size_16_color_FFFFFF_t_70]  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MDgxNjczOA_size_16_color_FFFFFF_t_70 1]

###### 5.2. 启动服务端 ######

分别依次启动扣库存服务端和产品服务端  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MDgxNjczOA_size_16_color_FFFFFF_t_70 2]  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MDgxNjczOA_size_16_color_FFFFFF_t_70 3]

###### 5.3. 启消费端 ######

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MDgxNjczOA_size_16_color_FFFFFF_t_70 4]

###### 5.4. 查看nacos ######

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MDgxNjczOA_size_16_color_FFFFFF_t_70 5]

###### 5.5. 项目模块分布结构 ######

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MDgxNjczOA_size_16_color_FFFFFF_t_70 6]

##### 六、测试实战 #####

###### 6.1. 请求扣库存链路 ######

[http://127.0.0.1:8080/order/create?productId=2&userId=8][http_127.0.0.1_8080_order_create_productId_2_userId_8]  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MDgxNjczOA_size_16_color_FFFFFF_t_70 7]  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MDgxNjczOA_size_16_color_FFFFFF_t_70 8]  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MDgxNjczOA_size_16_color_FFFFFF_t_70 9]

###### 6.2. 请求产品链路 ######

[http://127.0.0.1:8080/buyProduct?productId=2&userId=8][http_127.0.0.1_8080_buyProduct_productId_2_userId_8]

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MDgxNjczOA_size_16_color_FFFFFF_t_70 10]  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MDgxNjczOA_size_16_color_FFFFFF_t_70 11]  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MDgxNjczOA_size_16_color_FFFFFF_t_70 12]

###### 6.3. 常见的异常 ######

没有服务的提供者，启动客户端  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MDgxNjczOA_size_16_color_FFFFFF_t_70 13]  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MDgxNjczOA_size_16_color_FFFFFF_t_70 14]

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MDgxNjczOA_size_16_color_FFFFFF_t_70]: /images/20220829/4d2f2422a3604ecf94fce9abdb48be71.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MDgxNjczOA_size_16_color_FFFFFF_t_70 1]: /images/20220829/b89b150d3041400b9f378f52018a3185.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MDgxNjczOA_size_16_color_FFFFFF_t_70 2]: /images/20220829/d063670bb9694b2c872763a2b9811f40.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MDgxNjczOA_size_16_color_FFFFFF_t_70 3]: /images/20220829/c0daf0f026ab4ddcbf8ba32799bb97a1.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MDgxNjczOA_size_16_color_FFFFFF_t_70 4]: /images/20220829/d2b9d00a4dcc4f0ba5a028f898fe587b.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MDgxNjczOA_size_16_color_FFFFFF_t_70 5]: /images/20220829/e80c7999e5b24f2b854c390d1c36cb0d.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MDgxNjczOA_size_16_color_FFFFFF_t_70 6]: /images/20220829/a9c6452cb4684ceea6c7fb5f34ead8d6.png
[http_127.0.0.1_8080_order_create_productId_2_userId_8]: http://127.0.0.1:8080/order/create?productId=2&userId=8
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MDgxNjczOA_size_16_color_FFFFFF_t_70 7]: /images/20220829/e7e566b0f5ec4694a078a8ca8a36fbce.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MDgxNjczOA_size_16_color_FFFFFF_t_70 8]: /images/20220829/23eea6b880bd49f0b677ab28c0104a57.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MDgxNjczOA_size_16_color_FFFFFF_t_70 9]: /images/20220829/10d889a0d59d41c39966986beee8796e.png
[http_127.0.0.1_8080_buyProduct_productId_2_userId_8]: http://127.0.0.1:8080/buyProduct?productId=2&userId=8
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MDgxNjczOA_size_16_color_FFFFFF_t_70 10]: /images/20220829/27f2955a7c504047ac2ff7f34d27028b.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MDgxNjczOA_size_16_color_FFFFFF_t_70 11]: /images/20220829/20df387e463446b1adb5c801c783d724.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MDgxNjczOA_size_16_color_FFFFFF_t_70 12]: /images/20220829/005e14dacf2e475fb166f182625273d1.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MDgxNjczOA_size_16_color_FFFFFF_t_70 13]: /images/20220829/8c507476072f4129b746f886b0152ba3.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MDgxNjczOA_size_16_color_FFFFFF_t_70 14]: /images/20220829/1b102d3e21e4498da770d1ff0a9a2566.png