目录
一、服务注册中心搭建二、服务注册三、服务调用四、完整删除课程业务五、整合Hystrix一、服务注册中心搭建
需要将nacos和mysql放在自定义的同一个网络中并通过服务名连接，否则每次重新启动容器都会重新分配虚拟ip
1、创建自定义网络
docker network create guli
2、运行mysql（用于保存nacos配置信息）
mkdir -p /mydata/guli/mysql/confvim /mydata/guli/mysql/conf/f ############## f #####################[client]default-character-set=utf8[mysql]default-character-set=utf8[mysqld]init_connect='SET collation_connection = utf8_unicode_ci'init_connect='SET NAMES utf8'character-set-server=utf8collation-server=utf8_unicode_ciskip-character-set-client-handshakeskip-name-resolve###########################################
docker run -p 3306:3306 --name guli_mysql \--privileged=true \-v /mydata/guli/mysql/log:/var/log/mysql \-v /mydata/guli/mysql/data:/var/lib/mysql \-v /mydata/guli/mysql/conf:/etc/mysql \-e MYSQL_ROOT_PASSWORD=root \--network guli \--restart=always \-d mysql:5.7
3、创建数据库nacos（Character-set：utf8，Collation: utf8_bin）执行 数据库脚本
4、运行nacos测试容器
mkdir -p /mydata/guli/nacos/logsmkdir -p /mydata/guli/nacos/confdocker run -d --name test nacos/nacos-serverdocker cp test:/home/nacos/conf /mydata/guli/nacosdocker rm -f test
5、运行Nacos容器（MYSQL_SERVICE_HOST=guli_mysql通过服务名连接）
docker run --name guli_nacos \-e JVM_XMS=256m \-e JVM_XMX=256m \-e PREFER_HOST_MODE=ip \-e MODE=standalone \-e SPRING_DATASOURCE_PLATFORM=mysql \-e MYSQL_SERVICE_HOST=guli_mysql \-e MYSQL_SERVICE_PORT=3306 \-e MYSQL_SERVICE_USER=root \-e MYSQL_SERVICE_PASSWORD=root \-e MYSQL_SERVICE_DB_NAME=nacos \-v /mydata/guli/nacos/logs:/home/nacos/logs \-v /mydata/guli/nacos/conf:/home/nacos/conf \-p 8848:8848 \--network guli \--restart=always \-d nacos/nacos-server
6、访问 -IP地址:8848/nacos创建配置并查看是否持久化成功
二、服务注册
1、service模块 POM引入依赖
<dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId></dependency>
2、每个子模块配置YML
spring: cloud:nacos:discovery:server-addr: ip:8848
3、每个主启动类添加注解@EnableDiscoveryClient
4、效果
三、服务调用
需求：删除课时的同时删除云端视频
1、在service模块添加pom依赖
<!--服务调用--><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-openfeign</artifactId></dependency>
2、调用端 service_edu 启动类添加注解 （如删除课时同时删除云端视频）
@EnableFeignClients(basePackages = "com.laptoy.eduservice.client")
3、远程调用业务
package com.laptoy.eduservice.client;@FeignClient("service-vod")//指定调用的服务名，前提要注册到nacos注册中心中public interface VodClient {// 根据视频id删除阿里云视频@DeleteMapping("/eduvod/video/removeAliyunVideoById/{id}")public R removeAliyunVideoById(@PathVariable("id") String id);}
4、优化控制层
//删除小节同时删除云端视频@DeleteMapping("/deleteVideo/{id}")public R deleteVideo(@PathVariable String id) {eduVideoService.removeVideoByVideoId(id);return R.ok();}
5、优化删除小节业务
@Servicepublic class EduVideoServiceImpl extends ServiceImpl<EduVideoMapper, EduVideo> implements EduVideoService {@AutowiredVodClient vodClient;// 根据小节id删除小节视频@Overridepublic void removeVideoByVideoId(String id) {EduVideo eduVideo = this.getById(id);String videoSourceId = eduVideo.getVideoSourceId();if (!StringUtils.isEmpty(videoSourceId)) {// 删除小节的视频vodClient.removeAliyunVideoById(videoSourceId);}// 删除小节baseMapper.deleteById(id);}}
6、测试
添加小节并上传视频 - 删除小节查看云端
四、完整删除课程业务
需求：删除课程的同时删除云端视频，要求添加一个可以删除多个视频的方法
4.1、service_vod服务
1、控制层
//根据id删除多个阿里云视频@DeleteMapping("/removeBatch")public R removeBatch(@RequestParam("videoIdList") List<String> videoIdList){vodService.removeMoreVideo(videoIdList);return R.ok();}
2、业务层
//根据id集合删除多个视频@Overridepublic void removeMoreVideo(List<String> videoIdList) {//将集合转换为1,2,3格式String str = StringUtils.join(videoIdList.toArray(), ",");try {//初始化对象DefaultAcsClient client = initVodClient(accessKeyId, accessKeySecret);//创建删除视频request对象DeleteVideoRequest request = new DeleteVideoRequest();//向request设置要删除视频的id值request.setVideoIds(str);//调用初始化对象的方法实现删除DeleteVideoResponse response = client.getAcsResponse(request);log.info("RequestId = " + response.getRequestId() + "\n");log.info("批量删除云端视频成功");} catch (Exception e) {throw new LaptoyException(20001, "视频删除失败");}}
3、测试多个视频id是否能删除成功
4.2、service_edu服务
1、控制层流程
@Api(tags = "课程模块")@CrossOrigin //解决跨域问题@RestController@RequestMapping("/eduservice/course")public class EduCourseController {//课程列表中删除课程方法@DeleteMapping("/removeCourseById/{id}")public R removeCourseById(@PathVariable String id) {boolean flag = eduCourseService.removeCourse(id);if (flag) {return R.ok();} else {return R.error();}}}@Servicepublic class EduCourseServiceImpl extends ServiceImpl<EduCourseMapper, EduCourse> implements EduCourseService {//删除课程@Transactional@Overridepublic boolean removeCourse(String id) {//1、根据课程id删除小节eduVideoService.removeVideoByCourseId(id);...}}
2、业务层
@Servicepublic class EduVideoServiceImpl extends ServiceImpl<EduVideoMapper, EduVideo> implements EduVideoService {// 根据课程id删除小节@Overridepublic void removeVideoByCourseId(String id) {List<String> list = new ArrayList<>();QueryWrapper<EduVideo> wrapper = new QueryWrapper<>();wrapper.eq("course_id", id);// 向list集合填充待删除视频idList<EduVideo> eduVideos = this.list(wrapper);for (EduVideo eduVideo : eduVideos) {String videoSourceId = eduVideo.getVideoSourceId();if (!StringUtils.isEmpty(videoSourceId)) {list.add(videoSourceId);}}// 批量删除所有云端视频if (list.size() > 0) {vodClient.removeBatch(list);}// 删除所有小节this.remove(wrapper);}}
3、新建课程并新建章节小节进行测试，删除课程同时所有云端小节视频应该同时删除
五、整合Hystrix
当调用远程服务时若远程服务不稳定或者宕机，需要进行降级处理，否则导致链路无法正常运行，这里使用自定义服务降级
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>
2、edu模块配置文件添加
feign:hystrix:enabled: true
主启动类添加注解
@EnableHystrix
3、远程调用接口实现类
@Componentpublic class VodClientImpl implements VodClient {@Overridepublic R removeAliyunVideoById(String id) {return R.error().message("执行服务熔断器---删除云端视频失败");}@Overridepublic R removeBatch(List<String> videoIdList) {return R.error().message("执行服务熔断器---批量删除云端视频失败");}}
4、远程调用接口指定该实现类
@FeignClient(value = "service-vod", fallback = VodClientImpl.class)public interface VodClient {// 根据视频id删除阿里云视频@DeleteMapping("/eduvod/video/removeAliyunVideoById/{id}")public R removeAliyunVideoById(@PathVariable("id") String id);//根据多个视频id删除多个阿里云视频@DeleteMapping("/eduvod/video/removeBatch")public R removeBatch(@RequestParam("videoIdList") List<String> videoIdList);}
5、优化删除小节业务 - EduVideoServiceImpl
当发生熔断时状态码自然为20001，此时直接抛出自定义异常给前端，作为弹框的错误信息进行展示
6、优化批量删除小节业务 - EduVideoServiceImpl
测试
添加小节并上传云端视频，停用8003服务
删除小节
删除章节
