介紹

技術(shù)

之前有用eureka 現(xiàn)在用nacos
工作流和gateway

接口數(shù)據(jù)流向

數(shù)據(jù)表

新建項(xiàng)目

新建cloud-刪除src-新建modle

Eurak（發(fā)現(xiàn)）

 Eureka的作用

114、物業(yè) （注冊(cè)中心、心跳機(jī)制60s失效踢除）

沒(méi)有服務(wù)注冊(cè)于發(fā)現(xiàn)可以，但是會(huì)引來(lái)無(wú)窮無(wú)盡的麻煩
靜態(tài)ip變更，影響多服務(wù)模塊

架構(gòu)

Eurak Server代碼

新建moudle，和業(yè)務(wù)完全獨(dú)立
pom依賴，最外層pomcloud版本號(hào)
新建配置文件
注解啟動(dòng)

驗(yàn)證http://localhost:8000/

Eureka客戶端代碼

配置dom
配置properties
啟動(dòng)client

利用Feign實(shí)現(xiàn)服務(wù)間調(diào)用

介紹

歷史
netflex -> open （捐給spring cloud）

非常方便
基于接口和注解，和本地方法一樣爽的http請(qǐng)求

代碼

價(jià)格中調(diào)用課程服務(wù)

引入依賴

<!--  openfeign -->  <dependency>   <groupId>org.springframework.cloud</groupId>   <artifactId>spring-cloud-starter-openfeign</artifactId>  </dependency>

配置文件

#openfeign消費(fèi)的負(fù)載均衡后期再配

加注解

//啟動(dòng)類的客戶端@EnableFeignClients

客戶端(在調(diào)用類寫(xiě)接口，復(fù)制被調(diào)用服務(wù)的controller方法)

package com.bennyrhys.course.client;import com.bennyrhys.entity.Course;import org.springframework.cloud.openfeign.FeignClient;import org.springframework.web.bind.annotation.GetMapping;import java.util.List;/** * @Author bennyrhys * @Date 12/27/20 8:04 PM * 課程列表的Feign客戶端 */@FeignClient("course-list")public interface CourseListClient { @GetMapping("/course") List<Course> getList();}

驗(yàn)證pom中（自動(dòng)引入其他服務(wù)的依賴）

controller(在price服務(wù)中調(diào)用course服務(wù)的方法)

驗(yàn)證

利用Ribbon實(shí)現(xiàn)負(fù)載均衡

修改配置文件

price服務(wù)調(diào)用course服務(wù)的負(fù)載均衡設(shè)置

#openfeign消費(fèi)的負(fù)載均衡course-list.ribbon.NFLoadBanlancerRuleClassName=com.netflix.loadbalancer.RoundRobinRule

利用Hystrix實(shí)現(xiàn)斷路器

比如獲取用戶信息卡住，但數(shù)據(jù)庫(kù)的連接池一直未被釋放。系統(tǒng)崩潰
斷路器保護(hù)，某一處出現(xiàn)問(wèn)題，保證不影響全部不可用，避免故障蔓延

依賴pom

<!--  斷路器 客戶端-->  <dependency>   <groupId>org.springframework.cloud</groupId>   <artifactId>spring-cloud-starter-netflix-hystrix</artifactId>  </dependency>

配置

#斷路器 客戶端（默認(rèn)關(guān)閉）feign.hystrix.enabled=true

啟動(dòng)類注解

@EnableCircuitBreaker

斷路器實(shí)現(xiàn)類CourseListClientHystrix

package com.bennyrhys.course.client;import com.bennyrhys.entity.Course;import java.util.ArrayList;import java.util.List;import org.springframework.stereotype.Component;/** * 描述：  斷路器實(shí)現(xiàn)類 */@Componentpublic class CourseListClientHystrix implements CourseListClient{ @Override public List<Course> getList() {  List<Course> defaultCourses = new ArrayList<>();  Course course = new Course();  course.setId(1);  course.setCourseId(1);  course.setCourseName("默認(rèn)課程");  course.setValid(1);  defaultCourses.add(course);  return defaultCourses; }}

指明調(diào)用服務(wù)的斷路器類

/** * @Author bennyrhys * @Date 12/27/20 8:04 PM * 課程列表的Feign客戶端 */@FeignClient(value = "course-list", fallback = CourseListClientHystrix.class)@Primary //防止調(diào)用服務(wù)的controller爆紅線不好看public interface CourseListClient { @GetMapping("/course") List<Course> getList();}

斷路器效果

整合兩個(gè)服務(wù)

將課程列表和課程價(jià)格進(jìn)行整合

返回實(shí)體CourseAndPrice

 Integer id; Integer courseId; String name; Integer price;

service

 @Override public List<CourseAndPrice> getCoursesAndPrice() {  List<CourseAndPrice> courseAndPriceList = new ArrayList<>();  List<Course> courses = courseListClient.courseList();  for (int i = 0; i < courses.size(); i++) {   Course course = courses.get(i);   if (course != null) {    CoursePrice coursePrice = getCoursePrice(course.getCourseId());    CourseAndPrice courseAndPrice = new CourseAndPrice();    courseAndPrice.setPrice(coursePrice.getPrice());    courseAndPrice.setName(course.getCourseName());    courseAndPrice.setId(course.getId());    courseAndPrice.setCourseId(course.getCourseId());    courseAndPriceList.add(courseAndPrice);   }  }  return courseAndPriceList; }}

通過(guò)網(wǎng)關(guān)Zuul實(shí)現(xiàn)路由功能

兩個(gè)特點(diǎn)

Zuul集成

新建mudle模塊sourse-zuul

引入依賴

<dependencies> <dependency>  <groupId>org.springframework.cloud</groupId>  <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId> </dependency> <dependency>  <groupId>org.springframework.cloud</groupId>  <artifactId>spring-cloud-starter-netflix-zuul</artifactId> </dependency> </dependencies> <build> <plugins>  <plugin>  <groupId>org.springframework.boot</groupId>  <artifactId>spring-boot-maven-plugin</artifactId>  </plugin> </plugins> </build>

配置文件

spring.application.name=course-gatewayserver.port=9000logging.pattern.console=%clr(%d{${LOG_DATEFORMAT_PATTERN:HH:mm:ss.SSS}}){faint} %clr(${LOG_LEVEL_PATTERN:-%5p}) %clr(${PID:- }){magenta} %clr(---){faint} %clr([%15.15t]){faint} %clr(%-40.40logger{39}){cyan} %clr(:){faint} %m%n${LOG_EXCEPTION_CONVERSION_WORD:%wEx}mybatis.configuration.map-underscore-to-camel-case=trueeureka.client.service-url.defaultZone=http://localhost:8000/eureka/#zuul.prefix=/bennyrhyszuul.routes.course-list.path=/list/**zuul.routes.course-list.service-id=course-listzuul.routes.course-price.path=/price/**zuul.routes.course-price.service-id=course-price

啟動(dòng)類 注解

package com.bennyrhys.course;import org.springframework.boot.SpringApplication;import org.springframework.cloud.client.SpringCloudApplication;import org.springframework.cloud.netflix.zuul.EnableZuulProxy;/** * 描述：  網(wǎng)關(guān)啟動(dòng)類 */@EnableZuulProxy@SpringCloudApplicationpublic class ZuulGatewayApplication { public static void main(String[] args) {  SpringApplication.run(ZuulGatewayApplication.class, args); }}

效果圖

實(shí)現(xiàn)網(wǎng)關(guān)過(guò)濾器

過(guò)濾前

package com.bennyrhys.course.filter;import com.netflix.zuul.ZuulFilter;import com.netflix.zuul.context.RequestContext;import com.netflix.zuul.exception.ZuulException;import org.springframework.cloud.netflix.zuul.filters.support.FilterConstants;import org.springframework.stereotype.Component;/** * 描述：  記錄請(qǐng)求時(shí)間 */@Componentpublic class PreRequestFilter extends ZuulFilter { @Override public String filterType() {  //過(guò)濾器的類型  return FilterConstants.PRE_TYPE; } @Override public int filterOrder() {  return 0; } @Override public boolean shouldFilter() {  //是否啟用過(guò)濾器  return true; } @Override public Object run() throws ZuulException {  RequestContext currentContext = RequestContext.getCurrentContext();  currentContext.set("startTime", System.currentTimeMillis());  System.out.println("過(guò)濾器已經(jīng)記錄時(shí)間");  return null; }}

過(guò)濾后

package com.bennyrhys.course.filter;import com.netflix.zuul.ZuulFilter;import com.netflix.zuul.context.RequestContext;import com.netflix.zuul.exception.ZuulException;import org.springframework.cache.annotation.Cacheable;import org.springframework.cloud.netflix.zuul.filters.support.FilterConstants;import org.springframework.stereotype.Component;/** * 描述：  請(qǐng)求處理后的過(guò)濾器 */@Componentpublic class PostRequestFilter extends ZuulFilter { @Override public String filterType() {  return FilterConstants.POST_TYPE; } @Override public int filterOrder() {  return FilterConstants.SEND_RESPONSE_FILTER_ORDER - 1; } @Override public boolean shouldFilter() {  return true; } @Override public Object run() throws ZuulException {  RequestContext currentContext = RequestContext.getCurrentContext();  Long startTime = (Long) currentContext.get("startTime");  long duration = System.currentTimeMillis() - startTime;  String requestURI = currentContext.getRequest().getRequestURI();  System.out.println("uri:" + requestURI + ",處理時(shí)長(zhǎng)：" + duration);  return null; }}

uri:/bennyrhys/list/course,處理時(shí)長(zhǎng)：919

到此這篇關(guān)于SpringCloud開(kāi)發(fā)課程查詢功能的文章就介紹到這了,更多相關(guān)SpringCloud課程查詢內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

最新評(píng)論