SpringCLoud全部学习笔记一

2024-06-09 18:38
文章标签 springcloud 笔记 学习 全部 java spring

本文主要是介绍SpringCLoud全部学习笔记一，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

1、Feign主要是用来注册服务名称调用的 

一种声明式的web 客户端，可以使用它的注解创建接口，它也支持自定义编解码。Spring Cloud 集成了Ribbon 和Eureka 为客户端提供了负载均衡策略。Feing有两个主要注解： （@EnableFeignClients 用于开启feign功能，@FeignClient 用于定义feign 接口）。 

@RestController
public class OrderServiceImpl extends BaseApiService implements IOrderService {// 订单服务继承会员服务接口，用来实现feign客户端 减少重复接口代码@Autowiredprivate MemberServiceFeigin memberServiceFeigin;@RequestMapping("/orderToMember")public ResponseBase orderToMember(String name) {System.out.println("name:" + name);UserEntity user = memberServiceFeigin.getMember(name);if (user == null) {return setResultError("没有查询到用户信息");}return setResultSuccess(user);}// 没有解决服务雪崩效应@RequestMapping("/orderToUserInfo")public ResponseBase orderToUserInfo() {// 线程名称组合： 使用通过线程池名称+线程id组合System.out.println("orderToUserInfo:" + "当前线程池名称:" + Thread.currentThread().getName());return memberServiceFeigin.getUserInfo();}//@RequestMapping("/getOrderInfo")public ResponseBase getOrderInfo() {System.out.println("getOrderInfo:" + "当前线程池名称:" + Thread.currentThread().getName());return setResultSuccess("getOrderInfo");}// 使用Hystrix解决服务雪崩效应@HystrixCommand(fallbackMethod = "orderToUserInfoFallback")@RequestMapping("/orderToUserInfoHystrix")public ResponseBase orderToUserInfoHystrix() {System.out.println("orderToUserInfo:" + "当前线程池名称:" + Thread.currentThread().getName());return memberServiceFeigin.getUserInfo();}@RequestMapping("/orderToUserInfoFallback")public ResponseBase orderToUserInfoFallback() {return setResultError("系统错误");}}

2、负载均衡 限流断路器 的熔断机制的返回码

@Component
public class BaseApiService {public ResponseBase setResultError(Integer code, String msg) {return setResult(code, msg, null);}// 返回错误，可以传msgpublic ResponseBase setResultError(String msg) {return setResult(500, msg, null);}// 返回成功，可以传data值public ResponseBase setResultSuccess(Object data) {return setResult(200, "处理成功", data);}// 返回成功，沒有data值public ResponseBase setResultSuccess() {return setResult(200, "处理成功", null);}// 返回成功，沒有data值public ResponseBase setResultSuccess(String msg) {return setResult(200, msg, null);}// 通用封装public ResponseBase setResult(Integer code, String msg, Object data) {return new ResponseBase(code, msg, data);}}

@Data
@Slf4j
public class ResponseBase {private Integer rtnCode;private String msg;private Object data;public ResponseBase() {}public ResponseBase(Integer rtnCode, String msg, Object data) {super();this.rtnCode = rtnCode;this.msg = msg;this.data = data;}public static void main(String[] args) {ResponseBase responseBase = new ResponseBase();responseBase.setData("123456");responseBase.setMsg("success");responseBase.setRtnCode(200);System.out.println(responseBase.toString());//log.info("itmayiedu...");}@Overridepublic String toString() {return "ResponseBase [rtnCode=" + rtnCode + ", msg=" + msg + ", data=" + data + "]";}/*** 额外处理：TODO** @return */public Integer getRtnCode() {return rtnCode;}/*** 额外处理：TODO** @param rtnCode */public void setRtnCode(Integer rtnCode) {this.rtnCode = rtnCode;}/*** 额外处理：TODO** @return */public String getMsg() {return msg;}/*** 额外处理：TODO** @param msg */public void setMsg(String msg) {this.msg = msg;}/*** 额外处理：TODO** @return */public Object getData() {return data;}/*** 额外处理：TODO** @param data */public void setData(Object data) {this.data = data;}}

 3、SpringCloud的配置服务器端忽略数据库连接

@EnableConfigServer
@EnableDiscoveryClient
@SpringBootApplication(exclude = { DataSourceAutoConfiguration.class } /* 忽略数据源加载 */)
public class ConfigServerApplication {public static void main(String[] args) {SpringApplication.run(ConfigServerApplication.class, args);}
}

4、 Hystrix的熔断机制配置

Hystrix是Spring Cloud提供的一种带有熔断机制的框架，由于在微服务系统中同一个操作会由多个不同的微服务来共同完成，所以微服务与微服务之间会由很多相互的调用，由于在分布式环境中经常会出现某个微服务节点故障的情况，所以会由调用失败发生，而熔断器的作用就是当出现远程调用失败的时候提供一种机制来保证程序的正常运行而不会卡死在某一次调用。

 

//服务降级处理	
@HystrixCommand(fallbackMethod = "orderToUserInfoFallback")@GetMapping("/orderToUserInfo")public ResponseBase orderToUserInfoHystrix() {System.out.println("orderToUserInfo:" + "当前线程池名称:" + Thread.currentThread().getName());return memberServiceFeigin.getUserInfo();}@RequestMapping("/orderToUserInfoFallback")public ResponseBase orderToUserInfoFallback() {return setResultError("系统错误!!!!");}
//Fallback回调@RequestMapping("/orderToUserInfo")public ResponseBase orderToUserInfo() {return memberServiceFeigin.getUserInfo();}@Component
public class MemberServiceFallback extends BaseApiService implements   MemberServiceFeigin {public ResponseBase getUserInfo() {// 服务降级处理return setResultError("系统错误,请稍后重试!");}}
//开启Hystrix断路器feign:hystrix:
enabled: true#### hystrix禁止服务超时时间
hystrix:  command: default: execution: timeout: enabled: false

5、SpringCLoud的客户端的yml配置 

SpringCloud Feign客户端Http调用工具，默认已经整合了Ribbon负载均衡客户端。配置Feign客户端超时时间###设置feign客户端超时时间
ribbon:
###指的是建立连接所用的时间，适用于网络状况正常的情况下，两端连接所用的时间。ReadTimeout: 5000
###指的是建立连接后从服务器读取到可用资源所用的时间。 ConnectTimeout: 5000

 6、SpringCLoud的SPringCloud的Config配置

//当一个系统中的配置文件发生改变的时候，我们需要重新启动该服务，才能使得新的配置文件生效，spring //cloud config可以实现微服务中的所有系统的配置文件的统一管理，而且还可以实现当配置文件发生变化的时//候，系统会自动更新获取新的配置。
//bootstrap.yml
spring:application:####注册中心应用名称name:  config-clientcloud:config:####读取后缀profile: dev####读取config-server注册地址discovery:service-id: config-serverenabled: true
#####    eureka服务注册地址    
eureka:client:service-url:defaultZone: http://localhost:8100/eureka    
server:port: 8882

 7、SpringCloud的读取远程配置的配置文件YML

//application.yml配置###服务注册到eureka地址
eureka:client:service-url:defaultZone: http://localhost:8100/eureka
spring:application:####注册中心应用名称name: config-servercloud:config:server:git:###git环境地址uri: https://gitee.com/hengheng/config.git####搜索目录search-paths:- config  ####读取分支      label: master
####端口号      
server:port: 8888

8、SpringCloud的配置的俩种刷新配置动态和静态配置

动态刷新数据
在SpringCloud中有手动刷新配置文件和实时刷新配置文件两种方式。
手动方式采用actuator端点刷新数据
实时刷新采用SpringCloud Bus消息总线
手动刷新接口
Post请求手动刷新http://127.0.0.1:8882/actuator/refresh  启动刷新器 从cofnig server读取

 9、SpringCloud的application.yml心跳检测

###会员服务启动端口号
server:port: 8090
###服务名称(服务注册到eureka名称)  
spring:application:name: app-memberzipkin:base-url: http://localhost:9411sleuth:sampler: probability: 1 #样本采集量，默认为0.1，为了测试这里修改为1，正式环境一般使用默认值。                 
###服务注册到eureka地址
eureka:client:service-url:defaultZone: http://localhost:8100/eureka# 心跳检测检测与续约时间
# 测试时将值设置设置小些，保证服务关闭后注册中心能及时踢出服务instance:
###Eureka客户端向服务端发送心跳的时间间隔，单位为秒（客户端告诉服务端自己会按照该规则）  lease-renewal-interval-in-seconds: 1
####Eureka服务端在收到最后一次心跳之后等待的时间上限，单位为秒，超过则剔除（客户端告诉服务端按照此规则等待自己）lease-expiration-duration-in-seconds: 2

10 、网关配置路由Zuul   application.yml

zuul 是netflix开源的一个API Gateway 服务器, 本质上是一个web servlet应用

zuul的核心是一系列的filters, 其作用可以类比Servlet框架的Filter，或者AOP。

zuul把Request route到 用户处理逻辑 的过程中，这些filter参与一些过滤处理，比如Authentication，Load Shedding等。  


###服务注册地址
eureka:client:serviceUrl:defaultZone: http://localhost:8100/eureka/
###api网关端口号      
server:port: 82
###网关名称  
spring:application:name: service-zuulcloud:config:####读取后缀profile: dev####读取config-server注册地址discovery:service-id: config-serverenabled: true    
zuul:routes:###定义转发服务规则api-a:### 当客户端发送请求 127.0.0.1:80/api-member开头的 都会转发到会员服务path: /api-member/**###服务别名  zuul网关默认整合ribbon 自动实现负载均衡轮训效果serviceId: app-itmayiedu-memberapi-b:### 当客户端发送请求 127.0.0.1:80/api-order开头的 都会转发到订单服务path: /api-order/**##订单服务别名serviceId: app-itmayiedu-orderapi-c:### 当客户端发送请求 127.0.0.1:80/api-pay开头的 都会转发到支付服务path: /api-pay/**##订单服务别名serviceId: app-itmayiedu-pay
###默认服务读取eureka注册服务列表 默认间隔30秒###开启所有监控中心接口
management:endpoints:web:exposure:include: "*"

 

11 、swagger自己生成doc说明文档的   application.yml

@Api("客服接口")
@RestController
public class SwaggerController {@ApiOperation(value = "swagger接口", nickname = "swagger别名")@GetMapping("/swaggerDemo")public String swaggerDemo() {return "swaggerDemo";}@ApiOperation(value = "获取会员信息接口", nickname = "根据userName获取用户相关信息")@ApiImplicitParam(name = "userName", value = "用户名称", required = true, dataType = "String")@PostMapping("/getMember")public String getMember(String userName) {System.out.println("userName:" + userName);return "getMember" + ",userName:" + userName;}}

12.Dubbo的配置

consumer.xml

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsdhttp://code.alibabatech.com/schema/dubbo http://code.alibabatech.com/schema/dubbo/dubbo.xsd"><dubbo:application name="demotest-consumer" /><!--向 zookeeper 订阅 provider 的地址，由 zookeeper 定时推送 --><dubbo:registry address="zookeeper://192.168.184.128:2181" /><!--使用 dubbo 协议调用定义好的 api.PermissionService 接口 --><dubbo:reference id="permissionService"interface="com.itmayiedu.demo.api.service.DemoApiService" />
</beans>

provider.xml

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"xsi:schemaLocation="http://www.springframework.org/schema/beanshttp://www.springframework.org/schema/beans/spring-beans.xsdhttp://code.alibabatech.com/schema/dubbohttp://code.alibabatech.com/schema/dubbo/dubbo.xsd"><!--定义了提供方应用信息，用于计算依赖关系；在 dubbo-admin 或 dubbo-monitor 会显示这个名字，方便辨识 --><dubbo:application name="demotest-provider" /><!--使用 zookeeper 注册中心暴露服务，注意要先开启 zookeeper --><dubbo:registry address="zookeeper://192.168.184.128:2181" /><!-- 用dubbo协议在20880端口暴露服务 --><dubbo:protocol name="dubbo" port="20882" /><!--使用 dubbo 协议实现定义好的 api.PermissionService 接口 --><dubbo:service interface="com.api.service.DemoApiService"ref="demoService" protocol="dubbo" /><!--具体实现该接口的 bean --><bean id="demoService" class="com.api.service.impl.DemoApiServiceImpl" />
</beans>

application.yml

###服务端口号
server:port: 8000
###服务名称
spring: dubbo: application: name: dubbo-memberregistry: address: zookeeper://192.168.184.128:2181protocol: name: dubboport: 20880scan: com.api.member.implapplication:name: dubbo_member
###服务端口号
server:port: 8001
###服务名称
spring: dubbo: application: name: dubbo-orderregistry: address: zookeeper://192.168.184.128:2181scan: com.api.order.controller

 

 

 

 

 

 

 

 

 

 

 

 

 

 

 

 

 

 

 

 

 

 

这篇关于SpringCLoud全部学习笔记一的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


http://www.chinasem.cn/article/1045986。

相关文章

51单片机学习记录———定时器

51单片机学习记录———定时器

文章目录 前言一、定时器介绍二、STC89C52定时器资源三、定时器框图四、定时器模式五、定时器相关寄存器六、定时器练习 前言 一个学习嵌入式的小白~ 有问题评论区或私信指出~ 提示：以下是本篇文章正文内容，下面案例可供参考 一、定时器介绍 定时器介绍：51单片机的定时器属于单片机的内部资源，其电路的连接和运转均在单片机内部完成。 定时器作用： 1.用于计数系统，可
阅读更多...
问题：第一次世界大战的起止时间是 #其他#学习方法#微信

问题：第一次世界大战的起止时间是 #其他#学习方法#微信

问题：第一次世界大战的起止时间是 A.1913 ~1918 年 B.1913 ~1918 年 C.1914 ~1918 年 D.1914 ~1919 年 参考答案如图所示
阅读更多...
Java五子棋之坐标校正

Java五子棋之坐标校正

上篇针对了Java项目中的解构思维，在这篇内容中我们不妨从整体项目中拆解拿出一个非常重要的五子棋逻辑实现：坐标校正，我们如何使漫无目的鼠标点击变得有序化和可控化呢？ 目录 一、从鼠标监听到获取坐标 1.MouseListener和MouseAdapter 2.mousePressed方法 二、坐标校正的具体实现方法 1.关于fillOval方法 2.坐标获取 3.坐标转换 4.坐
阅读更多...
Spring Cloud：构建分布式系统的利器

Spring Cloud：构建分布式系统的利器

引言 在当今的云计算和微服务架构时代，构建高效、可靠的分布式系统成为软件开发的重要任务。Spring Cloud 提供了一套完整的解决方案，帮助开发者快速构建分布式系统中的一些常见模式（例如配置管理、服务发现、断路器等）。本文将探讨 Spring Cloud 的定义、核心组件、应用场景以及未来的发展趋势。 什么是 Spring Cloud Spring Cloud 是一个基于 Spring
阅读更多...
[word] word设置上标快捷键 #学习方法#其他#媒体

[word] word设置上标快捷键 #学习方法#其他#媒体

word设置上标快捷键 办公中，少不了使用word，这个是大家必备的软件，今天给大家分享word设置上标快捷键，希望在办公中能帮到您！ 1、添加上标 在录入一些公式，或者是化学产品时，需要添加上标内容，按下快捷键Ctrl+shift++就能将需要的内容设置为上标符号。 word设置上标快捷键的方法就是以上内容了，需要的小伙伴都可以试一试呢！
阅读更多...
Tolua使用笔记（上）

Tolua使用笔记（上）

目录   1.准备工作 2.运行例子 01.HelloWorld：在C#中，创建和销毁Lua虚拟机 和 简单调用。 02.ScriptsFromFile：在C#中，对一个lua文件的执行调用 03.CallLuaFunction：在C#中，对lua函数的操作 04.AccessingLuaVariables：在C#中，对lua变量的操作 05.LuaCoroutine：在Lua中，
阅读更多...
AssetBundle学习笔记

AssetBundle学习笔记

AssetBundle是unity自定义的资源格式，通过调用引擎的资源打包接口对资源进行打包成.assetbundle格式的资源包。本文介绍了AssetBundle的生成，使用，加载，卸载以及Unity资源更新的一个基本步骤。 目录 1.定义： 2.AssetBundle的生成： 1）设置AssetBundle包的属性——通过编辑器界面 补充：分组策略 2）调用引擎接口API
阅读更多...
Javascript高级程序设计(第四版)--学习记录之变量、内存

Javascript高级程序设计(第四版)--学习记录之变量、内存

原始值与引用值 原始值：简单的数据即基础数据类型，按值访问。 引用值：由多个值构成的对象即复杂数据类型，按引用访问。 动态属性 对于引用值而言，可以随时添加、修改和删除其属性和方法。 let person = new Object();person.name = 'Jason';person.age = 42;console.log(person.name,person.age);//'J
阅读更多...
java8的新特性之一（Java Lambda表达式）

java8的新特性之一（Java Lambda表达式）

1：Java8的新特性 Lambda 表达式： 允许以更简洁的方式表示匿名函数（或称为闭包）。可以将Lambda表达式作为参数传递给方法或赋值给函数式接口类型的变量。 Stream API： 提供了一种处理集合数据的流式处理方式，支持函数式编程风格。 允许以声明性方式处理数据集合（如List、Set等）。提供了一系列操作，如map、filter、reduce等，以支持复杂的查询和转
阅读更多...
大学湖北中医药大学法医学试题及答案，分享几个实用搜题和学习工具 #微信#学习方法#职场发展

大学湖北中医药大学法医学试题及答案，分享几个实用搜题和学习工具 #微信#学习方法#职场发展

今天分享拥有拍照搜题、文字搜题、语音搜题、多重搜题等搜题模式，可以快速查找问题解析，加深对题目答案的理解。 1.快练题 这是一个网站 找题的网站海量题库,在线搜题,快速刷题~为您提供百万优质题库,直接搜索题库名称,支持多种刷题模式:顺序练习、语音听题、本地搜题、顺序阅读、模拟考试、组卷考试、赶快下载吧! 2.彩虹搜题 这是个老公众号了 支持手写输入，截图搜题，详细步骤，解题必备
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2