SpringCloud详解02-分布式架构

叁歲伎倆 2024-03-25 15:40 130阅读 0赞

系列文章目录

SpringCloud详解01

文章目录

  • 系列文章目录
  • 前言
  • 一、入门案例
    • 1.创建maven父工程
    • 2.创建子工程 springcloudalibaba-micro-service-commons
    • 3.创建子工程 springcloudalibaba-micro-service-provider-7070
    • 4.创建子工程 springcloudalibaba-micro-service-consumer-8080
  • 二、测试
  • 总结

前言

接着上篇的详解01继续

一、入门案例

因为最新版的某些组件已经不再更新了，此次案例使用的版本是

  • Spring Boot Version： 2.3.2.RELEASE
  • Spring Cloud Version：Spring Cloud Hoxton.SR9
  • Spring Cloud Alibaba Version：2.2.6.RELEASE

接下来，创建分布式模拟案例，我会在一个父工程下创建三个子工程，充当三个服务

1.创建maven父工程

使用IDEA创建一个maven项目，命名为：springcloudalibaba-micro-service-manager，然后导入以下依赖：

  1. <packaging>pom</packaging>
  3.   <parent>
  4.     <groupId>org.springframework.boot</groupId>
  5.     <artifactId>spring-boot-starter-parent</artifactId>
  6.     <version>2.3.2.RELEASE</version>
  7.     <relativePath/> <!-- lookup parent from repository -->
  8.   </parent>
  10.   <dependencyManagement>
  11.     <dependencies>
  12.       <dependency>
  13.         <groupId>com.alibaba.cloud</groupId>
  14.         <artifactId>spring-cloud-alibaba-dependencies</artifactId>
  15.         <version>2.2.6.RELEASE</version>
  16.         <type>pom</type>
  17.         <scope>import</scope>
  18.       </dependency>
  20.       <dependency>
  21.         <groupId>org.springframework.cloud</groupId>
  22.         <artifactId>spring-cloud-dependencies</artifactId>
  23.         <version>Spring Cloud Hoxton.SR9</version>
  24.       </dependency>
  25.     </dependencies>
  26.   </dependencyManagement>

需要注意的是，要修改父工程的打包方式为pom，并且父工程不要留src文件目录，只留一个pom.xml文件即可，第二个依赖会爆红，不过无所谓，不影响代码运行
整体文件内容如下：

  1. <?xml version="1.0" encoding="UTF-8"?>
  3. <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  4.   xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
  5.   <modelVersion>4.0.0</modelVersion>
  7.   <groupId>com.lzl</groupId>
  8.   <artifactId>springcloudalibaba-micro-service-manager</artifactId>
  9.   <version>1.0-SNAPSHOT</version>
  10.   <modules>
  11.     <module>springcloudalibaba-micro-service-commons</module>
  12.     <module>springcloudalibaba-micro-service-provider-7070</module>
  13.     <module>springcloudalibaba-micro-service-consumer-8080</module>
  14.   </modules>
  15.   <packaging>pom</packaging>
  17.   <parent>
  18.     <groupId>org.springframework.boot</groupId>
  19.     <artifactId>spring-boot-starter-parent</artifactId>
  20.     <version>2.3.2.RELEASE</version>
  21.     <relativePath/> <!-- lookup parent from repository -->
  22.   </parent>
  24.   <dependencyManagement>
  25.     <dependencies>
  26.       <dependency>
  27.         <groupId>com.alibaba.cloud</groupId>
  28.         <artifactId>spring-cloud-alibaba-dependencies</artifactId>
  29.         <version>2.2.6.RELEASE</version>
  30.         <type>pom</type>
  31.         <scope>import</scope>
  32.       </dependency>
  34.       <dependency>
  35.         <groupId>org.springframework.cloud</groupId>
  36.         <artifactId>spring-cloud-dependencies</artifactId>
  37.         <version>Spring Cloud Hoxton.SR9</version>
  38.       </dependency>
  39.     </dependencies>
  40.   </dependencyManagement>
  43. </project>

2.创建子工程 springcloudalibaba-micro-service-commons

在父工程下创建maven子工程springcloudalibaba-micro-service-commons，pom.xml文件如下：

  1. <?xml version="1.0" encoding="UTF-8"?>
  3. <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  4.          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
  5.     <parent>
  6.         <artifactId>springcloudalibaba-micro-service-manager</artifactId>
  7.         <groupId>com.lzl</groupId>
  8.         <version>1.0-SNAPSHOT</version>
  9.     </parent>
  10.     <modelVersion>4.0.0</modelVersion>
  12.     <artifactId>springcloudalibaba-micro-service-commons</artifactId>
  14.     <dependencies>
  15.         <dependency>
  16.             <groupId>org.projectlombok</groupId>
  17.             <artifactId>lombok</artifactId>
  18.             <version>1.18.24</version>
  19.         </dependency>
  20.     </dependencies>
  23. </project>

这个子工程用来充当基本服务组件的提供，所以我们在该工程下创建实体类和工具类，并填入相关内容，此处我初始化一个UserDto实体类，并copy了一个返回值的工具类过来，内容如下：

UserDto：

  1. package com.lzl.dto;
  3. import lombok.AllArgsConstructor;
  4. import lombok.Data;
  5. import lombok.NoArgsConstructor;
  7. /**
  8.  * --效率，是成功的核心关键--
  9.  *
  10.  * @Author lzl
  11.  * @Date 2023/3/15 15:00
  12.  */
  14. @Data
  15. @AllArgsConstructor
  16. @NoArgsConstructor
  17. public class UserDto {
  20.     private Integer id;
  21.     private String name;
  23. }

JsonResult：

  1. package com.lzl.utils;
  2. import lombok.Data;
  3. /**
  4.  * --效率，是成功的核心关键--
  5.  *
  6.  * @Author lzl
  7.  * @Date 2023/3/15 15:01
  8.  */
  10. @Data
  11. public class JsonResult<T> {
  14.     private Integer code;//状态码
  15.     private String msg;//返回消息说明
  16.     private T data;
  18.     /**
  19.      * 成功返回方法
  20.      * @return
  21.      */
  22.     public static JsonResult ok(){
  24.         JsonResult jsonResult = new JsonResult<>();
  25.         jsonResult.setCode(200);
  26.         jsonResult.setMsg("success");
  28.         return jsonResult;
  29.     }
  31.     /**
  32.      * 失败返回方法
  33.      * @return
  34.      */
  35.     public static JsonResult error(){
  37.         JsonResult jsonResult = new JsonResult<>();
  38.         jsonResult.setCode(-1);
  39.         jsonResult.setMsg("fail");
  41.         return jsonResult;
  42.     }
  44. }

目录如下：
在这里插入图片描述

3.创建子工程 springcloudalibaba-micro-service-provider-7070

在父工程下创建子工程springcloudalibaba-micro-service-provider-7070，pom.xml文件如下：

  1. <?xml version="1.0" encoding="UTF-8"?>
  3. <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  4.          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
  5.     <parent>
  6.         <artifactId>springcloudalibaba-micro-service-manager</artifactId>
  7.         <groupId>com.lzl</groupId>
  8.         <version>1.0-SNAPSHOT</version>
  9.     </parent>
  10.     <modelVersion>4.0.0</modelVersion>
  12.     <artifactId>springcloudalibaba-micro-service-provider-7070</artifactId>
  14.     <dependencies>
  16.         <dependency>
  17.             <groupId>org.springframework.boot</groupId>
  18.             <artifactId>spring-boot-starter-web</artifactId>
  19.         </dependency>
  21.         <!-- 注册到Nacos上 -->
  22.         <dependency>
  23.             <groupId>com.alibaba.cloud</groupId>
  24.             <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
  25.         </dependency>
  27.         <!-- 引入公共模块 -->
  28.         <dependency>
  29.             <groupId>com.lzl</groupId>
  30.             <artifactId>springcloudalibaba-micro-service-commons</artifactId>
  31.             <version>1.0-SNAPSHOT</version>
  32.         </dependency>
  34.     </dependencies>
  37. </project>

配置yml文件：

  1. spring:
  2.   application:
  3.     name: provider
  4.   cloud:
  5.     nacos:
  6.       discovery:
  7.         register-enabled: true
  8.         server-addr: 127.0.0.1:8848
  9. server:
  10.   port: 7070

作为服务提供方，需要提供功能方法的具体实现，这里我简化一下，不再编写service层，直接在controller层模拟数据库查询功能

  1. package com.lzl.controller;
  3. import com.lzl.dto.UserDto;
  4. import com.lzl.utils.JsonResult;
  5. import org.springframework.web.bind.annotation.*;
  7. import java.util.Arrays;
  8. import java.util.List;
  9. /**
  10.  * --效率，是成功的核心关键--
  11.  *
  12.  * @Author lzl
  13.  * @Date 2023/3/15 15:19
  14.  */
  16. @RestController
  17. @RequestMapping("user-provider")
  18. public class UserController {
  21.     @RequestMapping("findAll")
  22.     public JsonResult findAll(){
  24.         //模拟数据库中的数据
  25.         List<UserDto> userList = Arrays.asList(
  26.                 new UserDto(1001, "张三"),
  27.                 new UserDto(1002, "李四"),
  28.                 new UserDto(1003, "王五")
  29.         );
  31.         JsonResult jsonResult = JsonResult.ok();
  32.         jsonResult.setData(userList);
  34.         return jsonResult;
  35.     }
  37. }

创建启动类，开启服务扫描

  1. package com.lzl;
  3. import org.springframework.boot.SpringApplication;
  4. import org.springframework.boot.autoconfigure.SpringBootApplication;
  5. import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
  6. /**
  7.  * --效率，是成功的核心关键--
  8.  *
  9.  * @Author lzl
  10.  * @Date 2023/3/15 15:20
  11.  */
  13. @SpringBootApplication
  14. @EnableDiscoveryClient//发现服务
  15. public class ProviderApplication {
  17.     public static void main(String[] args) {
  19.         SpringApplication.run(ProviderApplication.class,args);
  20.     }
  21. }

目录结构如下：
在这里插入图片描述

4.创建子工程 springcloudalibaba-micro-service-consumer-8080

在父工程下创建子工程 springcloudalibaba-micro-service-consumer-8080作为服务消费，pom.xml文件如下：

  1. <?xml version="1.0" encoding="UTF-8"?>
  3. <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  4.          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
  5.     <parent>
  6.         <artifactId>springcloudalibaba-micro-service-manager</artifactId>
  7.         <groupId>com.lzl</groupId>
  8.         <version>1.0-SNAPSHOT</version>
  9.     </parent>
  10.     <modelVersion>4.0.0</modelVersion>
  12.     <artifactId>springcloudalibaba-micro-service-consumer-8080</artifactId>
  14.     <dependencies>
  16.         <dependency>
  17.             <groupId>org.springframework.boot</groupId>
  18.             <artifactId>spring-boot-starter-web</artifactId>
  19.         </dependency>
  21.         <!-- 注册到Nacos上 -->
  22.         <dependency>
  23.             <groupId>com.alibaba.cloud</groupId>
  24.             <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
  25.         </dependency>
  27.         <!-- 引入公共模块 -->
  28.         <dependency>
  29.             <groupId>com.lzl</groupId>
  30.             <artifactId>springcloudalibaba-micro-service-commons</artifactId>
  31.             <version>1.0-SNAPSHOT</version>
  32.         </dependency>
  33.         <!-- Feign -->
  34.         <dependency>
  35.             <groupId>org.springframework.cloud</groupId>
  36.             <artifactId>spring-cloud-starter-openfeign</artifactId>
  37.             <version>2.2.6.RELEASE</version>
  38.         </dependency>
  39.     </dependencies>
  41. </project>

yml配置文件

  1. spring:
  2.   application:
  3.     name: consumer
  4.   cloud:
  5.     nacos:
  6.       discovery:
  7.         register-enabled: true
  8.         server-addr: 127.0.0.1:8848
  9. server:
  10.   port: 8081

添加配置类WebConfig

  1. package com.lzl.config;
  3. import com.netflix.loadbalancer.IRule;
  4. import com.netflix.loadbalancer.RandomRule;
  5. import org.springframework.cloud.client.loadbalancer.LoadBalanced;
  6. import org.springframework.context.annotation.Bean;
  7. import org.springframework.context.annotation.Configuration;
  8. import org.springframework.web.client.RestTemplate;
  10. /**
  11.  * --效率，是成功的核心关键--
  12.  *
  13.  * @Author lzl
  14.  * @Date 2023/3/15 15:11
  15.  */
  16. @Configuration
  17. public class WebConfig {
  19.     @Bean
  20.     public RestTemplate restTemplate(){
  22.         return new RestTemplate();
  23.     }
  25. }

controller

  1. package com.lzl.controller;
  3. import com.lzl.utils.JsonResult;
  4. import org.springframework.beans.factory.annotation.Autowired;
  5. import org.springframework.cloud.client.ServiceInstance;
  6. import org.springframework.cloud.client.discovery.DiscoveryClient;
  7. import org.springframework.web.bind.annotation.RequestMapping;
  8. import org.springframework.web.bind.annotation.RestController;
  9. import org.springframework.web.client.RestTemplate;
  12. import java.util.List;
  13. /**
  14.  * --效率，是成功的核心关键--
  15.  *
  16.  * @Author lzl
  17.  * @Date 2023/3/15 15:12
  18.  */
  20. @RestController
  21. @RequestMapping("user-consumer")
  22. public class UserController {
  25.     @Autowired
  26.     private RestTemplate restTemplate;//调用服务
  28.     @Autowired
  29.     private DiscoveryClient discoveryClient;//获取服务参数
  31.     //消费方应该调用生产方的服务
  33.     @RequestMapping("findAll")
  34.     public JsonResult findAll(){
  36.        //获取服务提供方的ip，端口
  37.        //通过名称去获取
  38.       List<ServiceInstance> provider = discoveryClient.getInstances("provider");
  39.         //服务提供方对象
  40.       ServiceInstance serviceInstance = provider.get(0);
  41.         //拿ip
  42.       String host = serviceInstance.getHost();
  43.        //拿端口
  44.       int port = serviceInstance.getPort();
  45.         //访问地址
  46.       String url = "http://" + host + ":" + port + "/user-provider/findAll";
  47.         //调用服务
  48.       JsonResult jsonResult = restTemplate.getForObject(url, JsonResult.class);
  50.       return jsonResult;
  51.     }
  53. }

设置启动类

  1. package com.lzl;
  3. import org.springframework.boot.SpringApplication;
  4. import org.springframework.boot.autoconfigure.SpringBootApplication;
  5. import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
  6. import org.springframework.cloud.openfeign.EnableFeignClients;
  8. /**
  9.  * --效率，是成功的核心关键--
  10.  *
  11.  * @Author lzl
  12.  * @Date 2023/3/15 15:16
  13.  */
  14. @SpringBootApplication
  15. @EnableDiscoveryClient//服务扫描注解
  16. public class ConsumerApplication {
  18.     public static void main(String[] args) {
  20.         SpringApplication.run(ConsumerApplication.class,args);
  22.     }
  23. }

整体的目录结构如下

在这里插入图片描述

ps：马赛克部分是其它的功能

二、测试

首先打开我们的nacos，出现运行成功界面，然后在浏览器访问http://localhost:8848/nacos/\#/login，输入默认的帐号密码，进入，

在这里插入图片描述

然后在IDEA启动提供服务方springcloudalibaba-micro-service-provider-7070，接着启动服务消费方springcloudalibaba-micro-service-consumer-8080

启动成功后访问http://localhost:8081/user-consumer/findAll

在这里插入图片描述

成功

总结

本篇主要记录了nacos和分布式架构的模拟案例，接下来的内容会在下一篇更新

发表评论

表情：
评论列表 （有 0 条评论，130人围观）

还没有评论，来说两句吧...

相关阅读

    相关 SpringCloud分布式架构权限管理

    概述 本文讨论分布式架构权限管理的两种情况，一种是针对统一授权访问的，一种是跨平台接口访问的。 虽然分布式架构会做业务的切割，将整体的业务切割为独立的子业务或者子平台，

    港控/mmm°港控/mmm°/ 0 赞/ 310 阅读