一、分布式与微服务
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文件。
启动命令:
consul agent -dev
启动成功
启动成功后可打开consul管理页面:http://localhost:8500
三、搭建SpringCloud项目
-
创建一个空的Maven框架shop,将其他服务包在框架内;
-
在shop里面添加Module,Module采用Spring Initializr,创建默认Springboot项目,
Dependencies选择Web -> Spring Web 和 Spring Cloud Discovery -> Consul Discovery。这是添加spring-boot-starter-web 和 spring-cloud-starter-consul-discovery 依赖。
- 创建好的Module中,打开POM文件,添加依赖
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-actuator</artifactId>
</dependency>
actuator是Spring监控系统健康检查的依赖,SpringCloud利用它进行心跳连接检查。
- 修改application.yml配置文件:
server:
port: 8081
spring:
application:
name: product-service
cloud:
consul:
host: localhost
port: 8500
discovery:
serviceName: product-service
- 重复步骤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
四、远程服务调用
- 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;
}
- 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测试访问接口成功。
- 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;
}
- 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;
}
}
- 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端接口,远程服务调用成功
`