SpringCloud开发课程查询功能

介绍

技术


之前有用eureka 现在用nacos
工作流和gateway

接口数据流向

数据表

新建项目

新建cloud-删除src-新建modle

Eurak(发现)

Eureka的作用

114、物业 (注册中心、心跳机制60s失效踢除)

没有服务注册于发现可以,但是会引来无穷无尽的麻烦
静态ip变更,影响多服务模块

架构


Eurak Server代码

新建moudle,和业务完全独立
pom依赖,最外层pomcloud版本号
新建配置文件
注解启动

验证http://localhost:8000/

Eureka客户端代码

配置dom
配置properties
启动client

利用Feign实现服务间调用

介绍

历史
netflex -> open (捐给spring cloud)

非常方便
基于接口和注解,和本地方法一样爽的http请求

代码

价格中调用课程服务

引入依赖

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

配置文件

#openfeign消费的负载均衡后期再配

加注解

//启动类的客户端@EnableFeignClients

客户端(在调用类写接口,复制被调用服务的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();}

验证pom中(自动引入其他服务的依赖)

controller(在price服务中调用course服务的方法)

验证

利用Ribbon实现负载均衡

修改配置文件

price服务调用course服务的负载均衡设置

#openfeign消费的负载均衡course-list.ribbon.NFLoadBanlancerRuleClassName=com.netflix.loadbalancer.RoundRobinRule

利用Hystrix实现断路器

比如获取用户信息卡住,但数据库的连接池一直未被释放。系统崩溃
断路器保护,某一处出现问题,保证不影响全部不可用,避免故障蔓延


依赖pom

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

配置

#断路器 客户端(默认关闭)feign.hystrix.enabled=true

启动类注解

@EnableCircuitBreaker

断路器实现类CourseListClientHystrix

package com.bennyrhys.course.client;import com.bennyrhys.entity.Course;import java.util.ArrayList;import java.util.List;import org.springframework.stereotype.Component;/** * 描述:  断路器实现类 */@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("默认课程");  course.setValid(1);  defaultCourses.add(course);  return defaultCourses; }}

指明调用服务的断路器类

/** * @Author bennyrhys * @Date 12/27/20 8:04 PM * 课程列表的Feign客户端 */@FeignClient(value = "course-list", fallback = CourseListClientHystrix.class)@Primary //防止调用服务的controller爆红线不好看public interface CourseListClient { @GetMapping("/course") List<Course> getList();}

断路器效果

整合两个服务

将课程列表和课程价格进行整合

返回实体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; }}

通过网关Zuul实现路由功能

两个特点

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

启动类 注解

package com.bennyrhys.course;import org.springframework.boot.SpringApplication;import org.springframework.cloud.client.SpringCloudApplication;import org.springframework.cloud.netflix.zuul.EnableZuulProxy;/** * 描述:  网关启动类 */@EnableZuulProxy@SpringCloudApplicationpublic class ZuulGatewayApplication { public static void main(String[] args) {  SpringApplication.run(ZuulGatewayApplication.class, args); }}

效果图

实现网关过滤器

过滤前

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;/** * 描述:  记录请求时间 */@Componentpublic class PreRequestFilter extends ZuulFilter { @Override public String filterType() {  //过滤器的类型  return FilterConstants.PRE_TYPE; } @Override public int filterOrder() {  return 0; } @Override public boolean shouldFilter() {  //是否启用过滤器  return true; } @Override public Object run() throws ZuulException {  RequestContext currentContext = RequestContext.getCurrentContext();  currentContext.set("startTime", System.currentTimeMillis());  System.out.println("过滤器已经记录时间");  return null; }}

过滤后

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;/** * 描述:  请求处理后的过滤器 */@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 + ",处理时长:" + duration);  return null; }}

uri:/bennyrhys/list/course,处理时长:919

到此这篇关于SpringCloud开发课程查询功能的文章就介绍到这了,更多相关SpringCloud课程查询内容请搜索我们以前的文章或继续浏览下面的相关文章希望大家以后多多支持我们!

(0)

相关推荐

  • Spring cloud 查询返回广告创意实例代码

    根据三个维度继续过滤 在上一节中我们实现了根据流量信息过滤的代码,但是我们的条件有可能是多条件一起传给我们的检索服务的,本节我们继续实现根据推广单元的三个维度条件的过滤. 在SearchImpl类中添加过滤方法 public class SearchImpl implements ISearch { @Override public SearchResponse fetchAds(SearchRequest request) { ... // 根据三个维度过滤 if (featureRelati

  • SpringCloud开发课程查询功能

    介绍 技术 之前有用eureka 现在用nacos 工作流和gateway 接口数据流向 数据表 新建项目 新建cloud-删除src-新建modle Eurak(发现) Eureka的作用 114.物业 (注册中心.心跳机制60s失效踢除) 没有服务注册于发现可以,但是会引来无穷无尽的麻烦 静态ip变更,影响多服务模块 架构 Eurak Server代码 新建moudle,和业务完全独立 pom依赖,最外层pomcloud版本号 新建配置文件 注解启动 验证http://localhost:8

  • 微信支付开发订单查询实例

    因为某一方技术的原因,可能导致商户在预期时间内都收不到最终支付通知,此时商户可以通过该API来查询订单的详细支付状态. 订单查询API的URL为: https://api.weixin.qq.com/pay/orderquery?access_token=xxxxxx URL中的参数只包含目前微信公众平台凭证access_token,而订单查询的真正数据是放在PostData中的,格式如下: {     "appid" : "wwwwb4f85f3a797777",

  • 微信小程序开发实现的IP地址查询功能示例

    本文实例讲述了微信小程序开发实现的IP地址查询功能.分享给大家供大家参考,具体如下: 微信小程序 开发 参考   https://mp.weixin.qq.com/debug/wxadoc/dev/component/ search.wxml <view class="container"> <view class="page-body"> <view class="weui-search-bar {{searchFocusC

  • 微信小程序 开发之快递查询功能的实现

    微信小程序 快递查询功能: 产品需求, 准备api, 代码编写.  第一步:产品需求,我们需要实现如下图的一个功能,在文本框输入快递单号,点击查询,下面出来我们需要的快递信息 第二步:准备 我们先找一个快递的api接口,通过http://apistore.baidu.com/我们可以看到很多的api,我们找一个快递查询的 我们可以看到有接口地址,和一些参数.做好这个准备接下来就开始编码工作了---- 第三步:编码工作 我们新建一个Express的文件,然后默认文件准备齐全 我们现在app.js中

  • 运用JSP+ajax实现分类查询功能的实例代码

    本文主要是介绍了运用JSP+ajax实现分类查询功能的实例代码,分享给大家供大家参考,具体如下: 这次是对小学期关于大学毕业生信息管理系统课程设计中遇到的一些问题和解决方法进行记录和分享. 题目要求:提供企业招聘信息(本年度或历年)查询功能: 首先建立一个jsp文件用来显示数据库信息,并在上面加输入条件的文本框和查询按钮,在这个jsp文件中需要完成一个js函数在用于完成查询功能. <%@ page language="java" pageEncoding="UTF-8&

  • Android实现有道辞典查询功能实例详解

    本文实例讲述了Android实现有道辞典查询功能的方法.分享给大家供大家参考,具体如下: 这是我做的一个简单的有道Android的DEMO,只是简单的雏形.界面设计也有点丑陋呵呵~ 看看下面的效果图: 第一步:思路解析 从界面看一共用了三个控件EditText,Button,WebView.其实是四个,是当我们查询内容为空的时候用来提示的Toast控件. 我们在EditText输入查询内容,这里包括中文,英文.然后通过参数的形式,从http://dict.youdao.com/m取出数据把结果

  • 微信公众平台开发之天气预报功能

    最近有项目需求给微信公众号上增加了天气预报功能,使用百度提供的车联网API V3.0中的天气查询功能实现.先上一张最终效果图: 项目需求:有连接好的微信平台,有百度注册帐号,需要在百度LBS开放云平台,添加应用,获取AK代码,PHP代码编辑器,如EditPlus等 下面详细介绍下开发步骤: 第一步:准备工作 登录微信公众平台,检查服务器配置是否已启用,URL(服务器地址) 是否已配置Token(令牌),与自己写的微信入口文件中的Token(令牌一致),如下图:然后点击提交,只至网页上提示绿色背景

  • 通过Web Service实现IP地址查询功能的示例

    实例01 实现一个简单的Web服务访问 本实例将实现IP地址查询接口服务,根据用户传入的IP地址返回IP所在的省.市.地区,实例中将会用到IP地址库用于查询信息,由于数据较多,所以读者可在光盘资源文件中直接附加数据库文件,这里将不再介绍导入数据的过程. 程序实现步骤如下: (1)打开Visual Studio 2017开发环境,然后依次点击文件→新建→项目,在弹出的新建项目对话框中选择"ASP.NET Web应用程序"选项,然后更改项目名称和项目路径,如图12.1所示. 图12.1 新

  • java实现的连接数据库及模糊查询功能示例

    本文实例讲述了java实现的连接数据库及模糊查询功能.分享给大家供大家参考,具体如下: 模糊查询是比较常见的一种查询方式,例如在订单表中,包含有订单的具体日期.如果要查询某年某月的订单信息,最好的方式就是使用模糊查询.进行模糊查询需要使用关键字LIKE.在使用LIKE关键字进行模糊查询时,可以使用通配符"%",来代替0个或者多个字符,使用下划线_来代表一个字符. 注释:需要注意的是在使用LIKE的时候,后面的查询条件需要加 '  ',英文状态下的单引号引起来,不然报错如下 You ha

  • Oracle递归树形结构查询功能

    oracle树状结构查询即层次递归查询,是sql语句经常用到的,在实际开发中组织结构实现及其层次化实现功能也是经常遇到的. 概要:树状结构通常由根节点.父节点.子节点和叶节点组成,简单来说,一张表中存在两个字段,dept_id,par_dept_id,那么通过找到每一条记录的父级id即可形成一个树状结构,也就是par_dept_id(子)=dept_id(父),通俗的说就是这条记录的par_dept_id是另外一条记录也就是父级的dept_id,其树状结构层级查询的基本语法是: SELECT [

随机推荐