SpringBoot 整合 Spring Cloud Alibaba Nacos 连通性+负载均衡

骑猪看日落 2022-08-30 05:16 119阅读 0赞

### 文章目录 ###

*   *   *   *   *  一、整合版本说明
                 *   *  1. 毕业版本依赖关系(推荐使用)
                     *  2. 组件版本关系
                     *  3. 演示版本
                 *  二、整合实战
                 *   *  2.1. 聚合模块设计
                     *  2.2. 创建聚合parent
                     *  2.3. 依次创建子项目
                 *  三、子模块配置
                 *   *  3.1. 订单模块
                     *  3.2. 产品模块
                     *  3.3. 用户模块
                     *  3.4. 扣库存模块
                     *  3.5. 购物车模块
                 *  四、测试案例
                 *   *  4.1. 订单模块
                     *  4.2. 产品模块
                     *  4.3. 用户模块
                     *  4.4. 扣库存模块
                     *  4.5. 购物车模块
                 *  五、连通性测试
                 *   *  5.1. 请求地址
                     *  5.2. nacos服务端
                     *  5.3. 效果图
                 *  六、负载均衡测试
                 *   *  6.1. 请求地址
                     *  6.2. 测试设计
                     *  6.3. 登陆nacos
                     *  6.4. 连续请求10次，观察命中概率
                     *  6.5. nacos 将服务下线
                     *  6.6. 重新上线
                     *  6.7. 码云开源地址

##### 一、整合版本说明 #####

###### 1. 毕业版本依赖关系(推荐使用) ######

<table> 
 <thead> 
  <tr> 
   <th align="left">Spring Cloud Version</th> 
   <th>Spring Cloud Alibaba Version</th> 
   <th>Spring Boot Version</th> 
  </tr> 
 </thead> 
 <tbody> 
  <tr> 
   <td align="left">Spring Cloud 2020.0.0</td> 
   <td>2021.1</td> 
   <td>2.4.2</td> 
  </tr> 
  <tr> 
   <td align="left">Spring Cloud Hoxton.SR9</td> 
   <td>2.2.6.RELEASE</td> 
   <td>2.3.2.RELEASE</td> 
  </tr> 
  <tr> 
   <td align="left">Spring Cloud Greenwich.SR6</td> 
   <td>2.1.4.RELEASE</td> 
   <td>2.1.13.RELEASE</td> 
  </tr> 
  <tr> 
   <td align="left">Spring Cloud Hoxton.SR3</td> 
   <td>2.2.1.RELEASE</td> 
   <td>2.2.5.RELEASE</td> 
  </tr> 
  <tr> 
   <td align="left">Spring Cloud Hoxton.RELEASE</td> 
   <td>2.2.0.RELEASE</td> 
   <td>2.2.X.RELEASE</td> 
  </tr> 
  <tr> 
   <td align="left">Spring Cloud Greenwich</td> 
   <td>2.1.2.RELEASE</td> 
   <td>2.1.X.RELEASE</td> 
  </tr> 
 </tbody> 
</table>

###### 2. 组件版本关系 ######

<table> 
 <thead> 
  <tr> 
   <th align="left">Spring Cloud Alibaba Version</th> 
   <th>Sentinel Version</th> 
   <th>Nacos Version</th> 
   <th>RocketMQ Version</th> 
   <th>Dubbo Version</th> 
   <th>Seata Version</th> 
  </tr> 
 </thead> 
 <tbody> 
  <tr> 
   <td align="left">2.2.6.RELEASE</td> 
   <td>1.8.1</td> 
   <td>1.4.2</td> 
   <td>4.4.0</td> 
   <td>2.7.8</td> 
   <td>1.3.0</td> 
  </tr> 
  <tr> 
   <td align="left">2021.1 or 2.2.5.RELEASE or 2.1.4.RELEASE or 2.0.4.RELEASE</td> 
   <td>1.8.0</td> 
   <td>1.4.1</td> 
   <td>4.4.0</td> 
   <td>2.7.8</td> 
   <td>1.3.0</td> 
  </tr> 
  <tr> 
   <td align="left">2.2.3.RELEASE or 2.1.3.RELEASE or 2.0.3.RELEASE</td> 
   <td>1.8.0</td> 
   <td>1.3.3</td> 
   <td>4.4.0</td> 
   <td>2.7.8</td> 
   <td>1.3.0</td> 
  </tr> 
  <tr> 
   <td align="left">2.2.1.RELEASE or 2.1.2.RELEASE or 2.0.2.RELEASE</td> 
   <td>1.7.1</td> 
   <td>1.2.1</td> 
   <td>4.4.0</td> 
   <td>2.7.6</td> 
   <td>1.2.0</td> 
  </tr> 
  <tr> 
   <td align="left">2.2.0.RELEASE</td> 
   <td>1.7.1</td> 
   <td>1.1.4</td> 
   <td>4.4.0</td> 
   <td>2.7.4.1</td> 
   <td>1.0.0</td> 
  </tr> 
 </tbody> 
</table>

###### 3. 演示版本 ######

<table> 
 <thead> 
  <tr> 
   <th align="left">Spring Cloud Version</th> 
   <th>Spring Cloud Alibaba Version</th> 
   <th>Spring Boot Version</th> 
   <th>Nacos Version</th> 
   <th>jdk</th> 
  </tr> 
 </thead> 
 <tbody> 
  <tr> 
   <td align="left">Spring Cloud Hoxton.SR9</td> 
   <td>2.2.6.RELEASE</td> 
   <td>2.3.2.RELEASE</td> 
   <td>1.4.2</td> 
   <td>1.8.202</td> 
  </tr> 
 </tbody> 
</table>

官网地址：  
[https://github.com/alibaba/spring-cloud-alibaba/wiki/%E7%89%88%E6%9C%AC%E8%AF%B4%E6%98%8E][https_github.com_alibaba_spring-cloud-alibaba_wiki_E7_89_88_E6_9C_AC_E8_AF_B4_E6_98_8E]

##### 二、整合实战 #####

###### 2.1. 聚合模块设计 ######

<table> 
 <thead> 
  <tr> 
   <th>模块划分</th> 
   <th>微服务划分</th> 
   <th>端口</th> 
  </tr> 
 </thead> 
 <tbody> 
  <tr> 
   <td>订单模块</td> 
   <td>order-serv</td> 
   <td>8000</td> 
  </tr> 
  <tr> 
   <td>产品模块</td> 
   <td>product-serv</td> 
   <td>9000</td> 
  </tr> 
  <tr> 
   <td>用户模块</td> 
   <td>user-serv</td> 
   <td>15000</td> 
  </tr> 
  <tr> 
   <td>扣库存模块</td> 
   <td>stock-serv</td> 
   <td>11000</td> 
  </tr> 
  <tr> 
   <td>购物车模块</td> 
   <td>shopcart-serv</td> 
   <td>12000</td> 
  </tr> 
 </tbody> 
</table>

###### 2.2. 创建聚合parent ######

创建maven父工程名称为EShopParent

父工程依赖添加
    ```bash
    	 
            <dependency>
                <groupId>com.alibaba.cloud</groupId>
                <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
            </dependency>
    
        <dependencyManagement>
            <dependencies>
                
                <dependency>
                    <groupId>com.alibaba.cloud</groupId>
                    <artifactId>spring-cloud-alibaba-dependencies</artifactId>
                    <version>2.2.6.RELEASE</version>
                    <type>pom</type>
                    <scope>import</scope>
                </dependency>
            </dependencies>
        </dependencyManagement>

###### 2.3. 依次创建子项目 ######

依次创建5个子模块

##### 三、子模块配置 #####

###### 3.1. 订单模块 ######

server:
      port: 8000
    spring:
      cloud:
        nacos:
          discovery:
            service: order-serv
          server-addr: localhost:8848

启动类

package com.gblfy;
    
    import org.springframework.boot.SpringApplication;
    import org.springframework.boot.autoconfigure.SpringBootApplication;
    import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
    import org.springframework.cloud.client.loadbalancer.LoadBalanced;
    import org.springframework.context.annotation.Bean;
    import org.springframework.web.client.RestTemplate;
    
    @SpringBootApplication
    @EnableDiscoveryClient
    public class OrderApplication { 
    
        @Bean
        @LoadBalanced//负载均衡+动态路路由
        public RestTemplate restTemplate() { 
            return new RestTemplate();
        }
    
        public static void main(String[] args) { 
            SpringApplication.run(OrderApplication.class);
        }
    }

###### 3.2. 产品模块 ######

server:
      port: 9000
    spring:
      cloud:
        nacos:
          discovery:
            service: product-serv
          server-addr: localhost:8848

###### 3.3. 用户模块 ######

server:
      port: 15000
    spring:
      cloud:
        nacos:
          discovery:
            service: user-serv
          server-addr: localhost:8848

###### 3.4. 扣库存模块 ######

server:
      port: 11000
    spring:
      cloud:
        nacos:
          discovery:
            service: stock-serv
          server-addr: localhost:8848

###### 3.5. 购物车模块 ######

server:
      port: 12000
    spring:
      cloud:
        nacos:
          discovery:
            service: shop-cart-serv
          server-addr: localhost:8848

##### 四、测试案例 #####

###### 4.1. 订单模块 ######

package com.gblfy.controller;
    
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.web.bind.annotation.GetMapping;
    import org.springframework.web.bind.annotation.RestController;
    import org.springframework.web.client.RestTemplate;
    
    @RestController
    public class OrderController { 
    
        @Autowired
        private RestTemplate restTemplate;
    
        //http://localhost:8000/order/create?productId=11&userId=11222
        @GetMapping("/order/create")
        public String createOrder(Integer productId, Integer userId) { 
    
            // 调用商品服务，通过商品ID获取商品名称
            String productNmae = restTemplate.getForObject("http://product-serv/product/" + productId, String.class);
    
            // 调用用户服务，通过用户ID获取用户名称
            String userNmae = restTemplate.getForObject("http://user-serv/user/" + userId, String.class);
    
            // 调用扣库存服务，通过商品ID将已购买的商品从库存中删除
            String result = restTemplate.getForObject("http://stock-serv/stock/reduce/" + productId, String.class);
    
            // 调用个购物车服务，通过商品ID和用户ID将已购买的商品从购物车中移除
            String shopCartResult = restTemplate.getForObject("http://shop-cart-serv/shopcart/remove?productId=" + productId + "&userId=" + userId, String.class);
            return "[用户]: " + userNmae + " 购买商品 " + productNmae + " " + result + " " + shopCartResult;
        }
    }

###### 4.2. 产品模块 ######

package com.gblfy.controller;
    
    import org.springframework.web.bind.annotation.GetMapping;
    import org.springframework.web.bind.annotation.PathVariable;
    import org.springframework.web.bind.annotation.RestController;
    
    @RestController
    public class ProductController { 
    
        //http://localhost:9000/product/" + productId @GetMapping("/product/{ productId}") public String getProductName(@PathVariable Integer productId) { return "IPhone 12";
        }
    }

###### 4.3. 用户模块 ######

package com.gblfy.controller;
    
    import org.springframework.web.bind.annotation.GetMapping;
    import org.springframework.web.bind.annotation.PathVariable;
    import org.springframework.web.bind.annotation.RestController;
    
    @RestController
    public class UserController { 
    
        @GetMapping("/user/{userId}")
        public String getUserName(@PathVariable Integer userId) { 
            return "gblfy专家";
        }
    }

###### 4.4. 扣库存模块 ######

package com.gblfy.controller;
    
    import org.springframework.web.bind.annotation.GetMapping;
    import org.springframework.web.bind.annotation.PathVariable;
    import org.springframework.web.bind.annotation.RestController;
    
    @RestController
    public class StockController { 
    
        @GetMapping("/stock/reduce/{productId}")
        public String reduce(@PathVariable Integer productId) { 
            System.out.println("减库存一个成功");
            return "减库存一个成功！";
        }
    }

###### 4.5. 购物车模块 ######

package com.gblfy.controller;
    
    import org.springframework.web.bind.annotation.GetMapping;
    import org.springframework.web.bind.annotation.RestController;
    
    @RestController
    public class ShopCartController { 
    
    
        @GetMapping("/shopcart/remove")
        public String remove(Integer productId, Integer userId) { 
            return "移除购物车成功！";
        }
    }

##### 五、连通性测试 #####

###### 5.1. 请求地址 ######

http://localhost:9000/order/create?productId=11&userId=11222

###### 5.2. nacos服务端 ######

Nacos 官网：  
[https://nacos.io/zh-cn/docs/quick-start.html][https_nacos.io_zh-cn_docs_quick-start.html]  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MDgxNjczOA_size_16_color_FFFFFF_t_70]

###### 5.3. 效果图 ######

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MDgxNjczOA_size_16_color_FFFFFF_t_70 1]  
以上5个微服务集成nacos完毕！并测试连通性测试通过！

##### 六、负载均衡测试 #####

###### 6.1. 请求地址 ######

http://localhost:9000/order/create?productId=11&userId=11222

###### 6.2. 测试设计 ######

分别启动3个订单模块端口为9000、9001、9002  
分别启动3个扣库存模块端口为8000、8001、8002  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MDgxNjczOA_size_16_color_FFFFFF_t_70 2]

###### 6.3. 登陆nacos ######

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

###### 6.4. 连续请求10次，观察命中概率 ######

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

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

###### 6.5. nacos 将服务下线 ######

![在这里插入图片描述][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]  
nacos观察服务状态已下线  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MDgxNjczOA_size_16_color_FFFFFF_t_70 10]

再次测试  
请求地址：

http://localhost:9000/order/create?productId=11&userId=11222

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

###### 6.6. 重新上线 ######

将下线的项目服务重新上线  
负载均衡测试，应该和正常请求一样这里就不演示了。

###### 6.7. 码云开源地址 ######

[https://gitee.com/gb\_90/eshop-parent][https_gitee.com_gb_90_eshop-parent]

[https_github.com_alibaba_spring-cloud-alibaba_wiki_E7_89_88_E6_9C_AC_E8_AF_B4_E6_98_8E]: https://github.com/alibaba/spring-cloud-alibaba/wiki/%E7%89%88%E6%9C%AC%E8%AF%B4%E6%98%8E
[https_nacos.io_zh-cn_docs_quick-start.html]: https://nacos.io/zh-cn/docs/quick-start.html
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MDgxNjczOA_size_16_color_FFFFFF_t_70]: /images/20220829/7b328dbab1d64fb682fedd979140ca3b.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MDgxNjczOA_size_16_color_FFFFFF_t_70 1]: /images/20220829/89cb416fb2c64744847b950589c69a01.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MDgxNjczOA_size_16_color_FFFFFF_t_70 2]: /images/20220829/3038a554685b4a70b45a8087ce15b2ba.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MDgxNjczOA_size_16_color_FFFFFF_t_70 3]: /images/20220829/c535f80e8d9a46ab8835b4ab1c6ca0c0.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MDgxNjczOA_size_16_color_FFFFFF_t_70 4]: /images/20220829/ccfe49cda7e94c8ea89fd9fbb9743f3e.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MDgxNjczOA_size_16_color_FFFFFF_t_70 5]: /images/20220829/43d3cc263fe842bc823f2dddbb76c253.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MDgxNjczOA_size_16_color_FFFFFF_t_70 6]: /images/20220829/65cd55f42c534c5693d9f35eccaebc27.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MDgxNjczOA_size_16_color_FFFFFF_t_70 7]: /images/20220829/3db4b7b8d8ec484c9db4366a1453bdc0.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MDgxNjczOA_size_16_color_FFFFFF_t_70 8]: /images/20220829/58e162f5052a4d5d98f2db1813ce3461.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MDgxNjczOA_size_16_color_FFFFFF_t_70 9]: /images/20220829/8fe56304e1434fb8bd49a10099c5f5f4.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MDgxNjczOA_size_16_color_FFFFFF_t_70 10]: /images/20220829/71c4aa5f0029442db9ae063b6a3a0df3.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MDgxNjczOA_size_16_color_FFFFFF_t_70 11]: /images/20220829/8570d9486d4d4d9da18076a317c41ab2.png
[https_gitee.com_gb_90_eshop-parent]: https://gitee.com/gb_90/eshop-parent