SpringCLoud全部学习笔记一

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

本文主要是介绍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。

相关文章

Spring Boot中WebSocket常用使用方法详解

Spring Boot中WebSocket常用使用方法详解

《SpringBoot中WebSocket常用使用方法详解》本文从WebSocket的基础概念出发,详细介绍了SpringBoot集成WebSocket的步骤,并重点讲解了常用的使用方法,包括简单消... 目录一、WebSocket基础概念1.1 什么是WebSocket1.2 WebSocket与HTTP
阅读更多...
SpringBoot+Docker+Graylog 如何让错误自动报警

SpringBoot+Docker+Graylog 如何让错误自动报警

《SpringBoot+Docker+Graylog如何让错误自动报警》SpringBoot默认使用SLF4J与Logback,支持多日志级别和配置方式,可输出到控制台、文件及远程服务器,集成ELK... 目录01 Spring Boot 默认日志框架解析02 Spring Boot 日志级别详解03 Sp
阅读更多...
java中反射Reflection的4个作用详解

java中反射Reflection的4个作用详解

《java中反射Reflection的4个作用详解》反射Reflection是Java等编程语言中的一个重要特性,它允许程序在运行时进行自我检查和对内部成员（如字段、方法、类等）的操作,本文将详细介绍... 目录作用1、在运行时判断任意一个对象所属的类作用2、在运行时构造任意一个类的对象作用3、在运行时判断
阅读更多...
java如何解压zip压缩包

java如何解压zip压缩包

《java如何解压zip压缩包》：本文主要介绍java如何解压zip压缩包问题,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录Java解压zip压缩包实例代码结果如下总结java解压zip压缩包坐在旁边的小伙伴问我怎么用 java 将服务器上的压缩文件解压出来，
阅读更多...
SpringBoot中SM2公钥加密、私钥解密的实现示例详解

SpringBoot中SM2公钥加密、私钥解密的实现示例详解

《SpringBoot中SM2公钥加密、私钥解密的实现示例详解》本文介绍了如何在SpringBoot项目中实现SM2公钥加密和私钥解密的功能,通过使用Hutool库和BouncyCastle依赖,简化... 目录一、前言1、加密信息(示例)2、加密结果(示例)二、实现代码1、yml文件配置2、创建SM2工具
阅读更多...
Spring WebFlux 与 WebClient 使用指南及最佳实践

Spring WebFlux 与 WebClient 使用指南及最佳实践

《SpringWebFlux与WebClient使用指南及最佳实践》WebClient是SpringWebFlux模块提供的非阻塞、响应式HTTP客户端,基于ProjectReactor实现,... 目录Spring WebFlux 与 WebClient 使用指南1. WebClient 概述2. 核心依
阅读更多...
Spring Boot @RestControllerAdvice全局异常处理最佳实践

Spring Boot @RestControllerAdvice全局异常处理最佳实践

《SpringBoot@RestControllerAdvice全局异常处理最佳实践》本文详解SpringBoot中通过@RestControllerAdvice实现全局异常处理,强调代码复用、统... 目录前言一、为什么要使用全局异常处理？二、核心注解解析1. @RestControllerAdvice2
阅读更多...
Spring IoC 容器的使用详解(最新整理)

Spring IoC 容器的使用详解(最新整理)

《SpringIoC容器的使用详解(最新整理)》文章介绍了Spring框架中的应用分层思想与IoC容器原理,通过分层解耦业务逻辑、数据访问等模块,IoC容器利用@Component注解管理Bean... 目录1. 应用分层2. IoC 的介绍3. IoC 容器的使用3.1. bean 的存储3.2. 方法注
阅读更多...
Spring事务传播机制最佳实践

Spring事务传播机制最佳实践

《Spring事务传播机制最佳实践》Spring的事务传播机制为我们提供了优雅的解决方案,本文将带您深入理解这一机制,掌握不同场景下的最佳实践,感兴趣的朋友一起看看吧... 目录1. 什么是事务传播行为2. Spring支持的七种事务传播行为2.1 REQUIRED（默认）2.2 SUPPORTS2
阅读更多...
怎样通过分析GC日志来定位Java进程的内存问题

怎样通过分析GC日志来定位Java进程的内存问题

《怎样通过分析GC日志来定位Java进程的内存问题》：本文主要介绍怎样通过分析GC日志来定位Java进程的内存问题,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录一、GC 日志基础配置1. 启用详细 GC 日志2. 不同收集器的日志格式二、关键指标与分析维度1.
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2