微服务 Spring Cloud Alibaba第一期
1.微服务的五大组件
-
Nacos:服务注册中心,配置中心
作用在集群部署服务的情况下,一个服务部署有多个实例,当我们想要去调用它时,我们该如何确定该去用哪一个,此时Nacos的作用就至关重要 -
Ribbon:负载均衡,用于微服务架构中,配合服务发现(如 Nacos、Eureka)实现请求的智能分发。
-
Fegin:远程调用,现在我们将一个单体架构进行拆分,此时我的一个模块想要使用另外一个模块的方法,哎,此时聪明的小伙伴就说了,我把方法复制一份过去不就好了,确实是可以但是耦合性,代码的重复性不就上来了,fegin,帮你解决烦恼,你值得拥有
-
sentinel:服务保护,当我们的人流量日渐增多时,项目规模也会逐步扩大,此时突然一个模块的访问量激增,就会导致其他模块也会访问速度下降,甚至无法访问,此时我们就要进行限流,线程隔离,服务熔断,确保不会因为一个瘫痪的服务导致整个系统崩溃。
-
gateway:服务网关,我们的服务模块众多,每个模块的端口号也各不相同,此时你想完成前后端交互,这个请求该发往哪一个端口,是不是很麻烦,此时网关就像一个门口的老大爷,问你想找谁,核验身份后,大爷就会告诉你应该去那个单元,这个就是网关的作用。
2.Nacos
1.在微服务远程调用的过程中,包括两个角色:
-
服务提供者:提供接口供其它微服务访问,比如
item-service
-
服务消费者:调用其它微服务提供的接口,比如
cart-service
2.流程如下:
-
服务启动时就会注册自己的服务信息(服务名、IP、端口)到注册中心
-
调用者可以从注册中心订阅想要的服务,获取服务对应的实例列表(1个服务可能多实例部署)
-
调用者自己对实例列表负载均衡,挑选一个实例
-
调用者向该实例发起远程调用
3.当服务提供者的实例宕机或者启动新实例时,调用者如何得知呢?
-
服务提供者会定期向注册中心发送请求,报告自己的健康状态(心跳请求)
-
当注册中心长时间收不到提供者的心跳时,会认为该实例宕机,将其从服务的实例列表中剔除
-
当服务有新实例启动时,会发送注册服务请求,其信息会被记录在注册中心的服务实例列表
-
当注册中心服务列表变更时,会主动通知微服务,更新本地服务列表
4.使用时首先我们要有一个nacos的数据库表,之后我们要将其中的nacos/custom.env
文件中,有一个MYSQL_SERVICE_HOST也就是mysql地址,需要修改为你自己的虚拟机IP地址,最后进行部署
docker的部署命令:
docker run -d \--name nacos \--env-file ./nacos/custom.env \-p 8848:8848 \-p 9848:9848 \-p 9849:9849 \--restart=always \nacos/nacos-server:v2.1.0-slim
启动完成后,访问下面地址:http://192.168.150.101:8848/nacos/,注意将192.168.150.101
替换为你自己的虚拟机IP地址。
首次访问会跳转到登录页,账号密码都是nacos
之后的使用就是依赖配置,这些我就不多讲了,三言两语的讲不完
3.OpenFeign
即使不使用openfign也可以进行远程调用,但是太过于繁琐,而且之后的服务降级我们也要使用到openfign,所有有简单的为什么不用
其实远程调用的关键点就在于四个:
-
请求方式
-
请求路径
-
请求参数
-
返回值类型
在使用的时候我的建议是将openfign的客户端单独抽取出来作为一个模块,这样也能体现微服务的特点,实现单一职责
首先引入依赖:
<!--openFeign--> <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-openfeign</artifactId> </dependency> <!--负载均衡器--> <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-loadbalancer</artifactId> </dependency>
之后要在你的启动类上标上@EnableFeginClients注解打开openfegin的功能
示例代码:
@FeignClient("item-service")
public interface ItemClient {
@GetMapping("/items")
List<ItemDTO> queryItemByIds(@RequestParam("ids") Collection<Long> ids);
}
这里只需要声明接口,无需实现方法。接口中的几个关键信息:
-
@FeignClient("item-service")
:声明服务名称 -
@GetMapping
:声明请求方式 -
@GetMapping("/items")
:声明请求路径 -
@RequestParam("ids") Collection<Long> ids
:声明请求参数 -
List<ItemDTO>
:返回值类型
我们通常会使用带有连接池的客户端来代替默认的HttpURLConnection。比如,我们使用OK Http.
4.网关路由
其实就是前端请求统一发到这里,之后由路由根据路由规则讲请求转给对应的服务
示例代码:
package com.hmall.gateway;import org.springframework.boot.SpringApplication;import org.springframework.boot.autoconfigure.SpringBootApplication;@SpringBootApplicationpublic class GatewayApplication { public static void main(String[] args) { SpringApplication.run(GatewayApplication.class, args); }}
配置:
server: port: 8080spring: application: name: gateway cloud: nacos: server-addr: 192.168.150.101:8848 gateway: routes: - id: item # 路由规则id,自定义,唯一 uri: lb://item-service # 路由的目标服务,lb代表负载均衡,会从注册中心拉取服务列表 predicates: # 路由断言,判断当前请求是否符合当前规则,符合则路由到目标服务 - Path=/items/**,/search/** # 这里是以请求路径作为判断规则 - id: cart uri: lb://cart-service predicates: - Path=/carts/** - id: user uri: lb://user-service predicates: - Path=/users/**,/addresses/** - id: trade uri: lb://trade-service predicates: - Path=/orders/** - id: pay uri: lb://pay-service predicates: - Path=/pay-orders/**