SpringCloud 演讲文稿(上)—— 搭建SpringCloud项目

一、分布式与微服务

1. 分布式的概念

分布式与微服务的区别
分布式是系统部署方式,微服务是架构设计方式,两者概念不同。
单体应用:所有资源(nginx,tomcat,数据库等)都在同一台服务器上。



分布式系统:将资源分散到各个服务器上,是一种架构模式



分布式集群:将服务进行集群,当这种模式构成一个完整的应用了,就叫分布式应用

微服务架构:将单一应用程序拆分成多个小型服务

什么是分布式?

将一个系统拆分成多个子系统并分布到多个服务器上。

什么是微服务?

微服务是一种将一个单一应用程序开发为一组小型服务的方法。每个服务运行在自己的进程中,服务间通信采用轻量级通信机制(通常是HHTP资源API)。这些服务围绕业务能力构建并且可通过全自动部署机制独立部署。这些服务共用一个最小型的集中式管理,服务可用不同的语言开发,使用不同的数据存储技术。

微服务的优点、缺点与选择

优点:服务之间的耦合度低,每台服务器的压力分散,提升访问处理能力。
缺点:服务拆分得越小,服务器数量越多,维护成本高。

选择:访问量大,业务耗时时间长,服务器处理能力要求高,选择微服务。

2. SpringBoot与SpringCloud

1)SpringBoot专注于快速方便开发单个个体服务
2)SpringCloud关注全局的微服务协调整理治理框架,将SpringBoot开发的单个个体服务整合并管理起来,为各个微服务之间提供:配置管理,服务发现,断路器,路由等等集成服务。
3)SpringBoot可以离开SpringCloud独立开发,SpringCloud依赖于SpringBoot。
4)SpringCloud的版本,是伦敦的地铁名,最新的版本是Hoxton。

二、注册中心

服务的注册和发现

没有注册中心的时候

1)每个远程服务的地址都要写死在服务调用方,服务越多,记录的地址越多,远程URL管理非常复杂。
2)无法动态增加/停机服务器,新增一台会员服务,需要停下调用方,将新地址从源码添加上去。停止一台服务器,也需要从源码删除该服务。


没有注册中心的情况

注册中心的特点:

1)服务端启动时,往注册中心注册服务地址
2)当其中一个服务关闭时,会向注册中心发送一个请求,告诉注册中心这个服务关闭了,注册中心会把这个地址从列表中删掉
3)客户端每隔一段时间会从注册中心重新拉取地址


使用注册中心后

注册中心 consul

主流注册中心有zookeeper,Eureka,consul等,本次演示使用consul。
consul官网地址:https://www.consul.io/
下载下来后单独放置一个文件夹,为了方便启动,单独编写一个bat文件。

image.png

启动命令:

consul agent -dev

启动成功


启动成功

启动成功后可打开consul管理页面:http://localhost:8500

三、搭建SpringCloud项目

  1. 创建一个空的Maven框架shop,将其他服务包在框架内;


    Maven 空框架
  2. 在shop里面添加Module,Module采用Spring Initializr,创建默认Springboot项目,


    添加module
Spring Initializr

Dependencies选择Web -> Spring Web 和 Spring Cloud Discovery -> Consul Discovery。这是添加spring-boot-starter-web 和 spring-cloud-starter-consul-discovery 依赖。


选择Spring Web和Consul Discovery
  1. 创建好的Module中,打开POM文件,添加依赖
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-actuator</artifactId>
    </dependency>

actuator是Spring监控系统健康检查的依赖,SpringCloud利用它进行心跳连接检查。

  1. 修改application.yml配置文件:
server:
  port: 8081
spring:
  application:
    name: product-service
  cloud:
    consul:
      host: localhost
      port: 8500
      discovery:
        serviceName: product-service
  1. 重复步骤2,添加product-web和product-common两个Module。其中product-common放在通用domain和api,给product-web和product-service依赖。
        <dependency>
            <groupId>com.pillow.cloud</groupId>
            <artifactId>product-common</artifactId>
            <version>0.0.1-SNAPSHOT</version>
        </dependency>

修改product-web工程配置文件,server.port, application name 和 discovery serviceName

server:
  port: 8082

spring:
  application:
    name: product-web
  cloud:
    consul:
      host: localhost
      port: 8500
      discovery:
        serviceName: product-web

修改product-common配置文件

spring:
  application:
    name: product-common
  cloud:
    consul:
      host: localhost
      port: 8500
      discovery:
        serviceName: product-common
        register: false
项目结构

四、远程服务调用

  1. product-common工程:调用远程服务需要添加openfeign包,因为product-web和product-service都有依赖common,只需要在common包添加依赖即可。
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-openfeign</artifactId>
        </dependency>

创建Product实体类,实体类需要远程序列化,因此要实现于Serializable

@Setter
@Getter
@ToString
public class Product implements Serializable {
    private Long id;
    private String name;
    private BigDecimal price;
    /**
     * ip + port,后续用于显示来源
     */
    private String comeFrom;
}
  1. product-service工程:启动类ProductServiceApplication添加注解 @EnableDiscoveryClient,表示客户端可以被远程发现。
@EnableDiscoveryClient
@SpringBootApplication
public class ProductServiceApplication {
    public static void main(String[] args) {
        SpringApplication.run(ProductServiceApplication.class, args);
    }
}

编写ProductController控制器。

@RestController
public class ProductController  {
    @Value("${server.port}")
    private String port;

    @RequestMapping("/save")
    public Product saveProduct(Product product) throws Exception {
        System.out.println("保存商品:" + product);
        String ip = InetAddress.getLocalHost().getHostAddress();
        product.setComeFrom(ip + ":" + port);
        return product;
    }
}

启动项目,用postman测试访问接口成功。


  1. product-common工程:编写ProductServiceApi,作为服务调用api。@FeignClient 注解标志这是一个服务调用接口,Spring会通过动态代理生成实现类。'name' 属性标志要代理的远程服务名:
spring:
  application:
    name: product-service

编写与product-service同名的接口方法。注意:传递复杂参数的时候,需要使用@RequestBody 注解。

@FeignClient(name = "product-service")
public interface ProductServiceApi {

    @RequestMapping("/save")
    Product saveProduct(@RequestBody Product product) throws Exception;
}
  1. product-service工程:改造ProductController,实现 ProductServiceApi,覆盖同名方法。
@RestController
public class ProductController implements ProductServiceApi {
    @Value("${server.port}")
    private String port;

    @Override
    public Product saveProduct(Product product) throws Exception {
        System.out.println("保存商品:" + product);

        String ip = InetAddress.getLocalHost().getHostAddress();
        product.setComeFrom(ip + ":" + port);
        return product;
    }
}
  1. product-web工程:启动类ProductWebApplication添加注解@EnableFeignClients,表示支持远程feign调用。编写ProductController控制器。
@RestController
public class ProductController {

    @Autowired
    private ProductServiceApi productServiceApi;

    @RequestMapping("/insert")
    public Product saveProduct() throws Exception {
        Product product = new Product();
        product.setId(1L);
        product.setName("苹果手机");
        product.setPrice(new BigDecimal("2000"));

        Product newProduct = productServiceApi.saveProduct(product);
        System.out.println(newProduct);
        return newProduct;
    }
}

用postman测试web端接口,远程服务调用成功


`

最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
【社区内容提示】社区部分内容疑似由AI辅助生成,浏览时请结合常识与多方信息审慎甄别。
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。

友情链接更多精彩内容