参考资料
前置知识：
- Docker
- rancher
springboot与springcloud之间存在版本对应关系，创建项目时，选择好springboot版本后，在选择其他组件时，就会自动匹配合适的springcloud版本
- 用于服务注册发现
- 分为服务端和客户端，服务端用于管理有哪些可用的服务，客户端用于将自己注册到服务端
-
创建moudle时选择
eureka服务的server端
这会自动引入如下依赖
<dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-netflix-eureka-server</artifactId> </dependency>
-
在启动类上增加
@EnableEurekaServer注解，将该项目作为eureka server启动 -
application.propertiesserver.port=20001 spring.application.name=cloud-customer eureka.instance.prefer-ip-address=true eureka.instance.instance-id=${spring.cloud.client.ip-address}:${server.port} # 指定集群中所有eureka server节点 eureka.client.service-url.defaultZone=http://localhost:10000/eureka
很多课程会在本节课将
eureka.client.register-with-eureka和eureka.client.fetch-registry设置为false；如果不设置，单个eureka server服务启动时，只能自己把自己注册到自己身上，但是在启动过程中会有几次注册不上，会产生几次报错，尝试几次就能注册上了；我觉得问题不大，可以不用设置 -
启动项目，并访问http://localhost:10000，即可看见`springcloud`提供的集群中各节点信息管理界面
-
DS Replicas
全称
discovery server replicas，译为发现服务副本这里显示的内容，取决于
eureka.client.service-url.defaultZone的配置，如该配置项配置为：eureka.client.service-url.defaultZone=http://peer1:10000/eureka,http://peer1:10001/eureka,http://peer2:10000/eureka则此处会显示2个副本：
peer1，peer2，点击peer1时，会跳转带peer1主机上其中1个服务地址上 -
Instances currently registered with Eureka
当前在集群的eureka服务上注册的所有实例
-
application
该列显示每个实例的应用名称，可以通过
spring.application.name和eureka.instance.appname进行配置，前者优先级更高 -
status
该列显示每个实例的
instance ID和实例状态
-
-
General Info
当前实例基本状况
-
Instancce Info
实例信息
-
-
创建
module并选择eureka服务的client端
这会自动引入如下依赖
<dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId> </dependency>
-
配置文件
server.port=20001 spring.application.name=cloud-customer eureka.instance.prefer-ip-address=true eureka.instance.instance-id=${spring.cloud.client.ip-address}:${server.port} # 指定集群中所有eureka server节点 eureka.client.service-url.defaultZone=http://localhost:10000/eureka
-
spring.application.name
指定实例名称（优先级较高）；推荐使用
这个必须指定，服务间通过实例名称找到对方
-
eureka.instance.appname
指定实例名称（优先级较低）
-
eureka.instance.prefer-ip-address
集群中各服务之间互相访问默认使用hostname进行，但是这样需要在各个机器上配置
hosts文件，将该配置设为true，可以尽量使用ip进行通信 -
eureka.instance.hostname
用于指定本机的主机名，当前实例以主机名的形式向外暴露地址时，主机名使用该值
（初步觉得使用ip地址更好，该选项应该用不到）
-
eureka.client.fetch-registry
是否从
eureka server上获取信息 -
eureka.client.register-with-eureka
是否注册到
eureka server上 -
eureka.client.serviceUrl.defaultZone
用于设置集群中所有
eureka server节点的服务地址 -
eureka.instance.instance-id
用于设置
Instance IDInstance ID默认取值为：# 主机名;应用名:端口 eureka.instance.instance-id=${spring.cloud.client.hostname}:${spring.application.name}:${server.port}}
我们可以自行指定：
# ip:port eureka.instance.instance-id=${spring.cloud.client.ip-address}:${server.port}
这个
Instance ID目前为止知道的作用仅是显示
-
配置
RestTemplate@Bean public RestTemplate restTemplate(){ return new RestTemplate(); }
-
服务提供方
正常写接口
@RestController @RequestMapping("/user") public class UserController { @GetMapping("/name") public String getUserName(){ return "tom"; } }
-
服务调用方
@Resource private EurekaClient eurekaClient; @Resource private RestTemplate restTemplate; @GetMapping("/customer/name") public String getCustomerName(){ // 从eureka获取服务的地址 InstanceInfo instanceInfo = eurekaClient.getNextServerFromEureka("cloud-producer", false); String homePageUrl = instanceInfo.getHomePageUrl(); // 组装请求 return restTemplate.getForObject(homePageUrl + "/user/name", String.class); }
两者功能差不多，如果服务发现使用的是eureka，则使用@EnableEurekaClient，否则使用@EnableDiscoveryClient
用于服务间负载均衡
-
依赖
eureka的server和client端依赖中均包含了ribbon的依赖，这里不需要单独引入 -
在声名
RestTemplate的bean上加上@LoadBalanced注解@Bean @LoadBalanced public RestTemplate restTemplate(){ return new RestTemplate(); }
-
此时，
restTemplate就具备了根据应用名称请求服务和负载均衡的能力@Resource private RestTemplate restTemplate; @GetMapping("/customer/name") public String getCustomerName(){ // 其中 cloud-producer 是服务提供者的应用名称 return restTemplate.getForObject("http://cloud-producer/user/name", String.class); }
指定负载均衡策略
内置7种算法：
根据我认为的从最差到最好的顺序进行排序，后3个应该不相上下，一般使用默认即可
-
RandomRule
随机规则
-
RoundRobinRule
轮训规则
-
ReryRule
重试（先按照轮询规则获取服务，如果获取服务失败则在指定时间内进行重试)
-
AvailabilityFilteringRule
先过滤掉不可用或处于高并发状态的服务，然后进行轮询
-
WeightedResponseTimeRule
根据响应时间计算权重，选择响应最快的服务
刚启动时因为统计信息不足，会先使用轮训策略
-
BestAvailableRule
先过滤掉由于多次访问故障而处于断路器跳闸状态的服务，然后选择一个并发量最小的服务
-
ZoneAvoidanceRule
==默认规则==
复合判断Server所在区域的性能和Server的可用性选择服务器
如何检查应用是否还活着
内置5种实现
-
NoOpPing
永远返回true
-
PingConstant
指定什么就返回什么
-
DummyPing
==默认实现==
也是永远返回true
-
NIWSDiscoveryPing
不执行真正的ping，以服务发现客户端认为的状态为准
-
PingUrl
执行真正的ping，以ping命令的结果为准
用于获取服务列表
内置4种实现
-
StaticServerList
静态服务列表
-
ConfigurationBasedServerList
从配置文件中获取服务列表
<clientName>.ribbon.listOfServers=www.microsoft.com:80,www.yahoo.com:80,www.google.com:80 -
DiscoveryEnabledNIWSServerList
从Eureka Client中获取服务列表。此值必须通过属性中的VipAddress来标识服务器集群
-
DomainExtractingServerList
代理类，根据ServerList的值实现具体的逻辑
==默认实现是使用该类代理DiscoveryEnabledNIWSServerList==
对服务列表进行过滤
内置4实现
-
ZoneAffinityServerListFilter
过滤掉所有的不和客户端在相同zone的服务，如果和客户端相同的zone不存在，才不过滤不同zone有服务
-
DefaultNIWSServerListFilter
跟
ZoneAffinityServerListFilter一模一样，重写了，但是没有重写任何方法 -
ZonePreferenceServerListFilter
==默认实现==
ZoneAffinityServerListFilter的子类。和``ZoneAffinityServerListFilter`相似，但是比较的zone是发布环境里面的zone。过滤掉所有和客户端环境里的配置的zone的不同的服务，如果和客户端相同的zone不存在，才不进行过滤。 -
ServerListSubsetFilter
ZoneAffinityServerListFilter的子类。此过滤器确保客户端仅看到由ServerList实现返回的整个服务器的固定子集。 它还可以定期用新服务器替代可用性差的子集中的服务器。
用于动态的更新服务列表。
内置2种实现
-
PollingServerListUpdater
==默认实现==
启动一个定时线程池，定时（默认30s）执行更新策略
-
EurekaNotificationServerListUpdater
当收到缓存刷新的通知，会更新服务列表。
用于定义包括上述5种组件的配置信息
目前只有1个实现：DefaultClientConfigImpl
负载均衡调度器，用于使用上面配置的5种组件统一进行调度
内置4种实现
-
NoOpLoadBalancer
不做任何操作的调度器（不用管，谁会用这样的调度器）
-
BaseLoadBalancer
-
DynamicServerListLoadBalancer
组合Rule、IPing、ServerList、ServerListFilter、ServerListUpdater 实现类，实现动态更新和过滤更新服务列表
-
ZoneAwareLoadBalancer
==默认实现==
这是DynamicServerListLoadBalancer的子类，主要加入zone的因素。统计每个zone的平均请求的情况，保证从所有zone选取对当前客户端服务最好的服务组列表
- 在
RibbonClientConfiguration中使用ZoneAvoidanceRule配置了1个类型为IRule的Bean，但是经过测试，这个Bean并不是启动的时候就加载的，是在调用了restTemplate之后才加载 - 经过debug发现，调用
restTemplate.getForObject方法后，执行了SpringClientFactory的父类NamedContextFactory的createContext方法（108行）；在该类中维护了1个用于维护应用上下文的Map集合，key是要请求的服务的应用名，value是请求该服务时使用的应用上下文，而每个服务使用的负载均衡策略（类型为IRule的bean）就被注册到了这些上下文中。这些上下文与applicationContext是独立的，所以，是无法在代码中使用@Resource注入的。
-
全局
-
注解
使用
@RibbonClients注解的defaultConfiguration属性配置（不仅限于IRule）@RibbonClients(defaultConfiguration = BestAvailableRule.class) -
配置类
被应用上下文扫描到的，关于ribbon相关的Bean会被作为默认配置
@Bean public IRule iRule(){ return new BestAvailableRule(); }
-
-
为每个单独配置
-
注解
使用
@RibbonClient为1个应用指定配置（不仅限于IRule）@RibbonClient(value = "cloud-producer",configuration = BestAvailableRule.class)
当需要为多个应用指定时，需要与
@RibbonClients注解结合使用@RibbonClients(defaultConfiguration = WeightedResponseTimeRule.class, value = { @RibbonClient(value = "cloud-producer", configuration = BestAvailableRule.class) })
注意：如果需要单独定义配置某个应用的Ribbon配置时，不要被应用上下文扫描到（不要放在可扫描包下，或使用
@Configuration等注解），否则会作为全局配置 -
配置文件
ribbon相关配置可以通过
<clientName>.<nameSpace>.<property>进行配置，其中：clientName：应用名称
nameSpace：ribbon配置使用的命名空间（专用的应用上下文），默认
ribbonproperty：可以配置的属性
- NFLoadBalancerClassName：
- NFLoadBalancerRuleClassName
- NFLoadBalancerPingClassName
- NIWSServerListClassName
- NIWSServerListFilterClassName
举个🌰：
# 配置负载均衡策略 <clientName>.ribbon.NFLoadBalancerRuleClassName=com.netflix.loadbalancer.BestAvailableRule
-
声名式远程服务调用，用于使用注解调用远程接口
-
引入依赖
也可在创建项目时选择
openfeign<dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-openfeign</artifactId> </dependency>
-
在启动类上增加
@EnableFeignClients注解，启用feign功能 -
使用
@FeignClient注解对其他服务提供的接口进行声名/** * @author shuyan */ @FeignClient("cloud-producer") public interface UserFeignClient { /** * 获取用户名 * @return 用户名 */ @GetMapping("/user/name") String getUserName(@RequestParam("id") Integer id); }
-
调用服务
@Resource private UserFeignClient userFeignClient; @GetMapping("/customer/name") public String getCustomerName(){ return userFeignClient.getUserName(1); }
注意：使用
FeignClient传递参数时，必须使用@RequestParam等注解对请求参数进行标注，pojo类必须使用@RequestBody进行标注（包括get请求）；并且可以指定参数名称的，必须指定参数名称（如：@RequestParam("id")）
-
只能作用在接口或类上
-
属性
-
name
指定应用名称
-
value
name属性的别名 -
serverId
与
name属性作用相同，已弃用 -
contextId
当项目中存在两个同类名的
FeignClient时，会以相同的bean名称进行注册，此时会报错：The bean 'cloud-producer.FeignClientSpecification' could not be registered. A bean with that name has already been defined and overriding is disabled. Action: Consider renaming one of the beans or enabling overriding by setting spring.main.allow-bean-definition-overriding=true
此时可以使用该属性将这个bean指定为其他名称，即可避免冲突
-
qualifier
使用该属性指定1个值后，使用
@Qualifier注解进行注入时，可以使用该值注入 -
url
url属性一般用于调试程序，允许我们手动指定@FeignClient调用的地址
-
decode404
默认情况下，当从1个接口调用1个不存在的服务时，那个服务返回404，这个接口返回的是500
当
decode404设置true时，会对服务返回的信息进行解析，如果服务返回404，则接口也返回404使用此功能需要配置
feign的decoder -
configuration
用于单独指定这个
feignClient的配置类 -
fallBack
定义容错的处理类，当调用远程接口失败或超时时，会调用对应接口的容错逻辑，fallback指定的类必须实现@FeignClient标记的接口
==详情参见Hystrix相关内容==
-
fallbackFactory
用于生成fallback类示例，通过这个属性我们可以实现每个接口通用的容错逻辑，减少重复的代码
==详情参见Hystrix相关内容==
-
path
指定路径的统一前缀，对应controller上面的
@RequestMapping指定的路径 -
primary
是否作为主bean，应该是bean出现冲突时使用的，先不管他
-
不建议使用
-
作用
指定声名的接口的请求方法及路径
@RequestLine("GET /user/info") # 相当于 @GetMapping("/user/info")
-
需要全局配置
Contract@Bean public Contract contract(){ // 这样配置后，只能使用 @RequestLine 注解了 return new feign.Contract.Default(); }
参考资料：feign自定义组件（2）
用于编码如何向请求体中封装请求，默认SpringEncoder，默认就好
当响应状态码为2xx时，将响应转为需要的类型的对象
默认实现：
new OptionalDecoder(new ResponseEntityDecoder(new SpringDecoder(this.messageConverters)))这种链式构造，目的是当OptionalDecoder无法解码时，使用ResponseEntityDecoder解码，再无法解码时，使用SpringDecoder解码
-
默认实现类：Slf4jlogger
-
日志级别
NONE：不做任何记录（默认）
BASIC：只记录输出Http 方法名称、请求URL、返回状态码和执行时间
HEADERS：记录输出Http 方法名称、请求URL、返回状态码和执行时间 和 Header 信息
FULL：记录Request 和Response的Header，Body和一些请求元数据
用于将接口中定义的注解、参数等转换为http协议需要的元数据
默认实现：SpringMvcContract
重试器，当HTTP请求出现IO异常时，Feign会有一个最大尝试次数发送请求
默认实现：Retryer.NEVER_RETRY
当响应状态码不是2xx时，将响应转为Exception异常
默认实现：ErrorDecoder.Default
-
作用
请求拦截器，用于在请求发出之前，对请求进行配置
-
实现类
-
BaseRequestInterceptor
定义了addHeader方法，往requestTemplate添加非重名的header
-
FeignAcceptGzipEncodingInterceptor
- 用于告诉服务提供者，你可以使用指定的压缩哟格式对响应进行压缩再回传
- 继承了BaseRequestInterceptor，它的apply方法往RequestTemplate添加了名为
Accept-Encoding，值为gzip,deflate的header - 原理参见
Accept-Encoding请求头作用
-
FeignContentGzipEncodingInterceptor
- 告诉服务提供者，我使用指定的格式对请求进行了压缩
- 继承了BaseRequestInterceptor，其apply方法先判断是否需要compression，即mimeType是否符合要求以及content大小是否超出阈值，需要compress的话则添加名为
Content-Encoding，值为gzip,deflate的header - 具体在哪进行的压缩暂时未找到
-
BasicAuthRequestInterceptor
- 使用指定的用户名密码，使用Basic认证的方式生成
Authorization请求头
- 使用指定的用户名密码，使用Basic认证的方式生成
-
-
配置文件启用压缩
使用
feign.compression相关配置 -
自定义
RequestInterceptor传递请求头
/**
- 将接收到的 X-Auth-Token 请求头传递下去 */ @Bean public RequestInterceptor headerInterceptor() { return requestTemplate -> { ServletRequestAttributes attributes = (ServletRequestAttributes) RequestContextHolder .getRequestAttributes(); if (attributes == null) { return; } HttpServletRequest request = attributes.getRequest(); String token= request.getHeader("X-Auth-Token"); if (!StringUtils.isEmpty(token)) { requestTemplate.header("X-Auth-Token", token); } }; }
### 配置feign
#### 配置类
+ 全局
直接在配置类中声名Bean
+ 单独
在没有被扫描进`application context`的类中声名bean
```java
public class MyFeignClientConfiguration {
@Bean
public Retryer retryer(){
return new Retryer.Default();
}
}
使用@FeignClient的configuration属性指定该客户端的配置
@FeignClient(value = "provider",path = "/user",configuration = MyFeignClientConfiguration.class)源码参见FeignClientProperties，可配置属性都在这里
- 全局：使用
feign.default进行配置 - 单独：使用
feign.<clientName>进行配置
参见FeignClientFactoryBean.configureFeign()方法
protected void configureFeign(FeignContext context, Feign.Builder builder) {
FeignClientProperties properties = this.applicationContext
.getBean(FeignClientProperties.class);
if (properties != null) {
/**
* 下面主要是设值的优先级
*/
if (properties.isDefaultToProperties()) {
//先将子容器中存在bean设入builder中
configureUsingConfiguration(context, builder);
//加载默认的属性值替换刚刚设入builder的值
configureUsingProperties(
properties.getConfig().get(properties.getDefaultConfig()),
builder);
//加载对应contextId(这个就是@FeignClient里面的contextId属性)的配置替换刚刚设入builder的值
configureUsingProperties(properties.getConfig().get(this.contextId),
builder);
}
else {
//同上
configureUsingProperties(
properties.getConfig().get(properties.getDefaultConfig()),
builder);
configureUsingProperties(properties.getConfig().get(this.contextId),
builder);
configureUsingConfiguration(context, builder);
}
}
else {
configureUsingConfiguration(context, builder);
}
}
-
当需要将
@FeignClient标注的接口类抽离出来时，由于跨包，无法被应用上下文扫描到 -
但是由于
@FeignClient标注的是接口，无法实例化，所以使用常规的@ComponentScan注解指定扫描路径，是无效的 -
此时可以使用
@EnableFeignClients注解指定扫描路径@EnableFeignClients("com.learn.cloud.common.feign")
@Component
public class FeignFormatterRegister implements FeignFormatterRegistrar {
@Override
public void registerFormatters(@NonNull FormatterRegistry registry) {
registry.addConverter(Instant.class, String.class, new Instant2StringConverter());
}
private class Instant2StringConverter implements Converter<Instant,String> {
@Override
public String convert(@NonNull Instant source) {
return source.toString();
}
}
}加入如下依赖
<dependency>
<groupId>io.github.openfeign</groupId>
<artifactId>feign-httpclient</artifactId>
</dependency>-
问题
get请求直接使用请求参数传递Date类型请求参数时，接到的时间会相差14小时，而使用pojo类传参则不会
-
解决方案
注册1个类型转换器，指定如何将Date类型转换为字符串
另外建议使用
Instant传递时间，而不是Date
-
由于
Hystrix已停止更新，需要使用其他产品替换，Hystrix官方推荐resilience4j，但是很多人选择了Alibaba的Sentinel，对比3者的github星数，果断选择sentinel- hystrix：18.8k
- resilience4j：4.8k
- sentinel：10.2k
-
断路器
上述3种中间件都是断路器
如果A服务出现问题，B服务请求A服务，则B服务也会阻塞住，C调用B时，C也会阻塞住，这样造成
雪崩效应，导致整个集群瘫痪熔断器的作用就是，当1个服务不可用时，即时放弃请求，避免蔓延到整个集群
common模块的配置类想要在其他进行引用时，由于application context是相互独立的，无法生效
可以使用
@Import注解，将需要的配置类引入自己的应用上下文也可以使用
@ComponentScan注解扫描某包下的bean但是该注解不能用在启动类上，否则原来的包路径就无法扫描到了
该注解必须与
@Configuration一起使用，否则无法生效
使用@ComponentScan注解的excludeFilters属性进行排除
React
Typescript
Django
Laravel
Facebook
Microsoft
Google
Alibaba
D3
Tencent