谷粒学院（十二）Nacos服务 | Fegin | 完善删除课程业务 | Hystrix

一、微服务与springcloud

1、什么是微服务

（1）微服务是架构风格 （2）把一个项目拆分成独立的多个服务，多个服务是独立运行，每个服务占用独立进程

我们的项目就是一个微服务项目

2、springcloud说明

（1）springcloud并不是一种技术，是很多技术总成，很多框架集合

（2）springcloud里面有很多框架（技术），使用springcloud里面这些框架实现微服务操作

（3）使用springcloud，需要依赖springboot技术

3、Spring Cloud相关基础服务组件

服务发现——Netflix Eureka （Nacos）服务调用——Netflix Feign熔断器——Netflix Hystrix服务网关——Spring Cloud GateWay分布式配置——Spring Cloud Config （Nacos）消息总线 —— Spring Cloud Bus （Nacos）

4、Spring Cloud的版本

Spring Cloud并没有熟悉的数字版本号，而是对应一个开发代号。

5、Spring Cloud 小版本分为

SNAPSHOT： 快照版本，随时可能修改

M： MileStone，M1表示第1个里程碑版本，一般同时标注PRE，表示预览版版。

SR： Service Release，SR1表示第1个正式版本，一般同时标注GA：(GenerallyAvailable),表示稳定版本。

二、服务发现 – 搭建Nacos服务

1、Nacos基本概念

（1）Nacos 是阿里巴巴推出来的一个新开源项目，是一个更易于构建云原生应用的动态服务发现、配置管理和服务管理平台。Nacos 致力于帮助您发现、配置和管理微服务。Nacos 提供了一组简单易用的特性集，帮助您快速实现动态服务发现、服务配置、服务元数据及流量管理。Nacos 帮助您更敏捷和容易地构建、交付和管理微服务平台。 Nacos 是构建以“服务”为中心的现代应用架构 (例如微服务范式、云原生范式) 的服务基础设施。

（2）常见的注册中心：

Eureka（原生，2.0遇到性能瓶颈，停止维护）

Zookeeper（支持，专业的独立产品。例如：dubbo）

Consul（原生，GO语言开发）

Nacos

相对于 Spring Cloud Eureka 来说，Nacos 更强大。Nacos = Spring Cloud Eureka + Spring Cloud Config

Nacos 可以与 Spring, Spring Boot, Spring Cloud 集成，并能代替 Spring Cloud Eureka, Spring Cloud Config

通过 Nacos Server 和 spring-cloud-starter-alibaba-nacos-discovery 实现服务的注册与发现。

（3）Nacos是以服务为主要服务对象的中间件，Nacos支持所有主流的服务发现、配置和管理。

Nacos主要提供的大功能：

服务限流降级：默认支持Servlet、Feign、 RestTemplate、 Dubbo 和RocketMQ限流降级功能的接入，可以在运行时通过控制台实时修改限流降级规则，还支持查看限流降级Metrics监控。服务注册与发现：适配Spring Cloud服务注册与发现标准，默认集成了Ribbon的支持。分布式配置管理：支持分布式系统中的外部化配置，配置更改时自动刷新。消息驱动能力：基于Spring Cloud Stream为微服务应用构建消息驱动能力。阿里云对象存储：阿里云提供的海量、安全、低成本、舸靠的云存储服务。支持在任何应用、任何时间、任何地点存储和访问任意类型的数据。分布式任务调度：提供秒级、精准、可靠可用的定时(基纡Cron表达式)任务调度服务。同时提供分布式的任务执行模型，如网格任务。网 格任务支持海量子任务均匀分配到所有Worker（schedulerx-client）上执行。

（4）Nacos结构图

2、Nacos下载和安装

（1）下载地址和版本 下载地址：https://github.com/alibaba/nacos/releases

下载版本：nacos-server-1.1.4.tar.gz 或 nacos-server-1.1.4.zip，解压任意目录即可

（2）启动nacos服务

Linux/Unix/Mac

启动命令(standalone代表着单机模式运行，非集群模式)

启动命令：sh startup.sh -m standalone

Windows

启动命令：cmd startup.cmd 或者双击startup.cmd运行文件。

访问：http://localhost:8848/nacos

用户名密码：nacos/nacos

三、服务注册（service_edu为例）

把service-edu微服务注册到注册中心中，service-vod步骤相同

1、在service模块配置pom

配置Nacos客户端的pom依赖

<!--服务注册--> <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId> </dependency>

2、添加服务配置信息

配置application.properties，在客户端微服务中添加注册Nacos服务的配置信息

# nacos服务地址 spring.cloud.nacos.discovery.server-addr=127.0.0.1:8848

3、添加Nacos客户端注解

在客户端微服务启动类中添加注解

@EnableDiscoveryClient

4、启动客户端微服务

启动注册中心

启动已注册的微服务，可以在Nacos服务列表中看到被注册的微服务

四、服务调用 – Fegin

1、Feign基本概念

Feign是Netflix开发的声明式、模板化的HTTP客户端， Feign可以帮助我们更快捷、优雅地调用HTTP API。Feign支持多种注解，例如Feign自带的注解或者JAX-RS注解等。Spring Cloud对Feign进行了增强，使Feign支持了Spring MVC注解，并整合了Ribbon和Eureka，从而让Feign的使用更加方便。Spring Cloud Feign是基于Netflix feign实现，整合了Spring Cloud Ribbon和Spring Cloud Hystrix，除了提供这两者的强大功能外，还提供了一种声明式的Web服务客户端定义的方式。Spring Cloud Feign帮助我们定义和实现依赖服务接口的定义。在Spring Cloud feign的实现下，只需要创建一个接口并用注解方式配置它，即可完成服务提供方的接口绑定，简化了在使用Spring Cloud Ribbon时自行封装服务调用客户端的开发量。

2、实现服务调用

1、需求

删除课时的同时删除云端视频

2、在service模块添加pom依赖

<!--服务调用--> <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-openfeign</artifactId> </dependency>

3、在调用端的启动类添加注解

@EnableFeignClients

4、创建包和接口

创建client包

@FeignClient注解用于指定从哪个服务中调用功能 ，名称与被调用的服务名保持一致。@GetMapping注解用于对被调用的微服务进行地址映射@PathVariable注解一定要指定参数名称，否则出错@Component注解防止，在其他位置注入CodClient时idea报错 @FeignClient("service-vod") @Component public interface VodClient { //定义调用的方法路径 //根据视频id删除阿里云视频 //@PathVariable 注解一定要指定参数名称，否则会报错 @DeleteMapping("/eduvod/video/removeAliyVideo/{id}") public R removeAliyVideo(@PathVariable("id") String id); }

注意：这里的访问路径是全路径

5、调用微服务 在调用端的EduVideoController中调用client中的方法

//TODO 后面这个方法需要完善：删除小节时候，同时要把里面的视频删除 @ApiOperation(value = "删除小节") @DeleteMapping("deleteVideo/{id}") public R deleteVideo(@PathVariable String id){ //根据小节id获取视频id，调用方法实现视频删除 EduVideo eduVideo = videoService.getById(id); String videoSourceId = eduVideo.getVideoSourceId(); //判断小节里面是否有视频id if(!StringUtils.isEmpty(videoSourceId)) { //根据视频id，远程调用实现视频删除 vodClient.removeAliyVideo(videoSourceId); } //删除小节 videoService.removeById(id); return R.ok(); }

6、测试

五、完善删除课程业务

需求：

删除课程的同时删除云端视频

1、在service-vod模块的Controller中 创建接口，删除多个视频

@ApiOperation(value = "删除多个阿里云视频") @DeleteMapping("deleteBatch") public R deleteBatch(@RequestParam("videoIdList") List videoIdList){ vodService.removeMoreAlyVideo(videoIdList); return R.ok(); }

2、编写service 方法

@Override public void removeMoreAlyVideo(List videoIdList) { try{ //初始化对象 DefaultAcsClient client = InitVodClient.initVodClient(ConstantVodUtils.ACCESS_KEY_ID, ConstantVodUtils.ACCESS_KEY_SECRET); //创建删除视频request对象 DeleteVideoRequest request = new DeleteVideoRequest(); //videoIdList值转换成1,2,3 String videoIds = StringUtils.join(videoIdList.toArray(), ","); //想request设置视频id request.setVideoIds(videoIds); //调用初始化对象的方法实现删除 client.getAcsResponse(request); }catch (Exception e){ e.printStackTrace(); throw new GuliException(20001,"删除视频失败"); } }

3、在service-edu中调用 service-vod 接口实现删除多个视频的功能

在VodClient 类

//删除多个阿里云视频 @DeleteMapping("/eduvod/video/deleteBatch") public R deleteBatch(@RequestParam("videoIdList") List<String> videoIdList);

在 EduVideoServiceImpl 类

//注入VodClient @Autowired private VodClient vodClient; //TODO 删除小节，删除对应视频文件 @Override public void removeVideoByCourseId(String courseId) { //根据课程id查询所有课程所有的视频id QueryWrapper<EduVideo> wrapperVideo = new QueryWrapper<>(); wrapperVideo.eq("course_id",courseId); wrapperVideo.select("video_source_id");//只查询video_source_id单独一列数据 List<EduVideo> eduVideoList = baseMapper.selectList(wrapperVideo); //List<EduVideo> 变成 List<String> List<String> videoIds = new ArrayList<>(); for (int i = 0; i < eduVideoList.size(); i++) { EduVideo eduVideo = eduVideoList.get(i); String videoSourceId = eduVideo.getVideoSourceId(); if (!StringUtils.isEmpty(videoSourceId)) { //放到videoIds集合中 videoIds.add(videoSourceId); } } if (videoIds.size() >0){ //根据多个视频id删除多个视频 vodClient.deleteBatch(videoIds); } //删除小节 QueryWrapper<EduVideo> wrapper = new QueryWrapper<>(); wrapper.eq("course_id",courseId); baseMapper.delete(wrapper); }

4、启动服务测试删除功能

六、熔断器 – Hystrix

1、Spring Cloud调用接口过程

Spring Cloud 在接口调用上，大致会经过如下几个组件配合：

Feign —>Hystrix —>Ribbon —>Http Client（apache http components 或者 Okhttp） 具体交互流程上，如下图所示：

（1）接口化请求调用当调用被@FeignClient注解修饰的接口时，在框架内部，将请求转换成Feign的请求实例feign.Request，交由Feign框架处理。

（2）Feign ：转化请求Feign是一个http请求调用的轻量级框架，可以以Java接口注解的方式调用Http请求，封装了Http调用流程。

（3）Hystrix：熔断处理机制 Feign的调用关系，会被Hystrix代理拦截，对每一个Feign调用请求，Hystrix都会将其包装成HystrixCommand,参与Hystrix的流控和熔断规则。如果请求判断需要熔断，则Hystrix直接熔断，抛出异常或者使用FallbackFactory返回熔断Fallback结果；如果通过，则将调用请求传递给Ribbon组件。

（4）Ribbon：服务地址选择 当请求传递到Ribbon之后,Ribbon会根据自身维护的服务列表，根据服务的服务质量，如平均响应时间，Load等，结合特定的规则，从列表中挑选合适的服务实例，选择好机器之后，然后将机器实例的信息请求传递给Http Client客户端，HttpClient客户端来执行真正的Http接口调用；

（5）HttpClient ：Http客户端，真正执行Http调用根据上层Ribbon传递过来的请求，已经指定了服务地址，则HttpClient开始执行真正的Http请求

2、Hystrix概念

Hystrix 是一个供分布式系统使用，提供延迟和容错功能，保证复杂的分布系统在面临不可避免的失败时，仍能有其弹性。

比如系统中有很多服务，当某些服务不稳定的时候，使用这些服务的用户线程将会阻塞，如果没有隔离机制，系统随时就有可能会挂掉，从而带来很大的风险。SpringCloud使用Hystrix组件提供断路器、资源隔离与自我修复功能。下图表示服务B触发了断路器，阻止了级联失败。

七、feign结合Hystrix使用

改造service-edu模块

1、在service的pom中添加依赖

<dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-netflix-ribbon</artifactId> </dependency> <!--hystrix依赖，主要是用 @HystrixCommand --> <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-netflix-hystrix</artifactId> </dependency> <!--服务注册--> <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId> </dependency> <!--服务调用--> <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-openfeign</artifactId> </dependency>

2、在配置文件中添加hystrix配置

#开启熔断机制 feign.hystrix.enabled=true # 设置hystrix超时时间，默认1000ms #hystrix.command.default.execution.isolation.thread.timeoutInMilliseconds=6000

3、在service-edu的client包里面创建熔断器的实现类

@Component public class VodFileDegradeFeignClient implements VodClient { //出错之后执行的方法 @Override public R removeAliyVideo(String id) { return R.error().message("删除视频出错了"); } @Override public R deleteBatch(List<String> videoIdList) { return R.error().message("删除视频出错了"); } }

4、修改VodClient接口的注解

5、修改EduVideoController 类

6、使用debug测试熔断器效果

---

如果有收获！！！ 希望老铁们来个三连，点赞、收藏、转发。 创作不易，别忘点个赞，可以让更多的人看到这篇文章，顺便鼓励我写出更好的博客