Spring Cloud 参考文档(Spring Cloud Commons:通用的抽象)

Spring Cloud Commons:通用的抽象

服务发现、负载均衡和断路器等模式适用于所有Spring Cloud客户端都可以使用的通用抽象层,独立于实现(例如,使用Eureka或Consul发现)。

@EnableDiscoveryClient

Spring Cloud Commons提供 @EnableDiscoveryClient
注解,这将使用 META-INF/spring.factories
查找 DiscoveryClient
接口的实现。Discovery Client的实现将配置类添加到 org.springframework.cloud.client.discovery.EnableDiscoveryClient
键下的 spring.factories
DiscoveryClient
实现的示例包括Spring Cloud Netflix Eureka,Spring Cloud Consul Discovery和Spring Cloud Zookeeper Discovery。

默认情况下, DiscoveryClient
的实现会使用远程发现服务器自动注册本地Spring Boot服务器,通过在 @EnableDiscoveryClient
中设置 autoRegister=false
可以禁用此行为。

@EnableDiscoveryClient
已不再需要,你可以在类路径上放置 DiscoveryClient
实现,以使Spring Boot应用程序向服务发现服务器注册。

健康指示器

Commons创建了一个Spring Boot HealthIndicator
DiscoveryClient
实现可以通过实现 DiscoveryHealthIndicator
来参与,要禁用混合 HealthIndicator
,请设置 spring.cloud.discovery.client.composite-indicator.enabled=false
。基于 DiscoveryClient
的通用 HealthIndicator
是自动配置的( DiscoveryClientHealthIndicator
)。要禁用它,请设置 spring.cloud.discovery.client.health-indicator.enabled=false
,要禁用 DiscoveryClientHealthIndicator
description
字段,请设置 spring.cloud.discovery.client.health-indicator.include-description=false
,否则,它可能会像卷起的 HealthIndicator
description
一样冒出来。

排序DiscoveryClient实例

DiscoveryClient
接口扩展了 Ordered
,这在使用多个发现客户端时很有用,因为它允许你定义返回的发现客户端的顺序,类似于你可以如何排序Spring应用程序加载的bean。默认情况下,任何 DiscoveryClient
的顺序都设置为 0
,如果要为自定义 DiscoveryClient
实现设置不同的顺序,只需重写 getOrder()
方法,以便它返回适合你的设置的值。除此之外,你还可以使用属性来设置Spring Cloud提供的 DiscoveryClient
实现的顺序,其中包括 ConsulDiscoveryClient
EurekaDiscoveryClient
ZookeeperDiscoveryClient
,为此,你只需将 spring.cloud.{clientIdentifier}.discovery.order
(或Eureka的 eureka.client.order
)属性设置为所需的值。

ServiceRegistry

Commons现在提供一个 ServiceRegistry
接口,提供 register(Registration)
deregister(Registration)
等方法,让你提供自定义注册服务, Registration
是一个标记接口。

以下示例显示 ServiceRegistry
的使用:

@Configuration
@EnableDiscoveryClient(autoRegister=false)
public class MyConfiguration {
    private ServiceRegistry registry;

    public MyConfiguration(ServiceRegistry registry) {
        this.registry = registry;
    }

    // called through some external process, such as an event or a custom actuator endpoint
    public void register() {
        Registration registration = constructRegistration();
        this.registry.register(registration);
    }
}

每个 ServiceRegistry
实现都有自己的 Registry
实现。

  • ZookeeperRegistration
    ZookeeperServiceRegistry
    一起使用
  • EurekaRegistration
    EurekaServiceRegistry
    一起使用
  • ConsulRegistration
    ConsulServiceRegistry
    一起使用

如果你使用的是 ServiceRegistry
接口,则需要为正在使用的 ServiceRegistry
实现传递正确的 Registry
实现。

ServiceRegistry自动注册

默认情况下, ServiceRegistry
实现会自动注册正在运行的服务,要禁用该行为,你可以设置: @EnableDiscoveryClient(autoRegister=false)
永久禁用自动注册, spring.cloud.service-registry.auto-registration.enabled=false
通过配置禁用行为。

ServiceRegistry自动注册事件

当服务自动注册时,将触发两个事件,第一个事件名为 InstancePreRegisteredEvent
,在注册服务之前触发,第二个事件名为 InstanceRegisteredEvent
,在注册服务后触发,你可以注册一个 ApplicationListener
来监听并响应这些事件。

如果 spring.cloud.service-registry.auto-registration.enabled
设置为 false
,则不会触发这些事件。

Service Registry Actuator端点

Spring Cloud Commons提供 /service-registry
执行器端点,此端点依赖于Spring Application Context中的 Registration
bean,使用GET调用 /service-registry
返回 Registration
的状态,将POST用于具有JSON体的同一端点会将当前 Registration
的状态更改为新值,JSON体必须包含具有首选值的 status
字段。在更新状态和为状态返回的值时,请参阅用于允许值的 ServiceRegistry
实现的文档,例如,Eureka支持的状态是 UP
DOWN
OUT_OF_SERVICE
UNKNOWN

Spring RestTemplate作为负载均衡客户端

RestTemplate
可以自动配置为使用ribbon,要创建负载均衡的 RestTemplate
,请创建 RestTemplate
@Bean
并使用 @LoadBalanced
限定符,如以下示例所示:

@Configuration
public class MyConfiguration {

    @LoadBalanced
    @Bean
    RestTemplate restTemplate() {
        return new RestTemplate();
    }
}

public class MyClass {
    @Autowired
    private RestTemplate restTemplate;

    public String doOtherStuff() {
        String results = restTemplate.getForObject("http://stores/stores", String.class);
        return results;
    }
}

不再通过自动配置创建 RestTemplate
bean,单个应用程序必须创建它。

URI需要使用虚拟主机名(即服务名称,而不是主机名),Ribbon客户端用于创建完整的物理地址,有关如何设置 RestTemplate
的详细信息,请参见 RibbonAutoConfiguration

Spring WebClient作为负载均衡客户端

WebClient
可以自动配置为使用 LoadBalancerClient
,要创建负载均衡的 WebClient
,请创建 WebClient.Builder
@Bean
并使用 @LoadBalanced
限定符,如以下示例所示:

@Configuration
public class MyConfiguration {

    @Bean
    @LoadBalanced
    public WebClient.Builder loadBalancedWebClientBuilder() {
        return WebClient.builder();
    }
}

public class MyClass {
    @Autowired
    private WebClient.Builder webClientBuilder;

    public Mono<String> doOtherStuff() {
        return webClientBuilder.build().get().uri("http://stores/stores")
                        .retrieve().bodyToMono(String.class);
    }
}

URI需要使用虚拟主机名(即服务名称,而不是主机名),Ribbon客户端用于创建完整的物理地址。

重试失败的请求

可以将负载均衡的 RestTemplate
配置为重试失败的请求,默认情况下,禁用此逻辑,你可以通过将 Spring Retry
添加到应用程序的类路径来启用它。负载均衡的 RestTemplate
支持与重试失败的请求相关的一些Ribbon配置值,你可以使用 client.ribbon.MaxAutoRetries
client.ribbon.MaxAutoRetriesNextServer
client.ribbon.OkToRetryOnAllOperations
属性,如果要在类路径上使用Spring Retry禁用重试逻辑,可以设置 spring.cloud.loadbalancer.retry.enabled=false
,有关这些属性的说明,请参阅 Ribbon文档

如果要在重试中实现 BackOffPolicy
,则需要创建 LoadBalancedRetryFactory
类型的bean并覆盖 createBackOffPolicy
方法:

@Configuration
public class MyConfiguration {
    @Bean
    LoadBalancedRetryFactory retryFactory() {
        return new LoadBalancedRetryFactory() {
            @Override
            public BackOffPolicy createBackOffPolicy(String service) {
                return new ExponentialBackOffPolicy();
            }
        };
    }
}

前面示例中的 client
应替换为你的Ribbon客户端的名称。

如果要将一个或多个 RetryListener
实现添加到重试功能中,你需要创建一个类型为 LoadBalancedRetryListenerFactory
的bean并返回你要用于给定服务的 RetryListener
数组,如以下示例所示:

@Configuration
public class MyConfiguration {
    @Bean
    LoadBalancedRetryListenerFactory retryListenerFactory() {
        return new LoadBalancedRetryListenerFactory() {
            @Override
            public RetryListener[] createRetryListeners(String service) {
                return new RetryListener[]{new RetryListener() {
                    @Override
                    public <T, E extends Throwable> boolean open(RetryContext context, RetryCallback<T, E> callback) {
                        //TODO Do you business...
                        return true;
                    }

                    @Override
                     public <T, E extends Throwable> void close(RetryContext context, RetryCallback<T, E> callback, Throwable throwable) {
                        //TODO Do you business...
                    }

                    @Override
                    public <T, E extends Throwable> void onError(RetryContext context, RetryCallback<T, E> callback, Throwable throwable) {
                        //TODO Do you business...
                    }
                }};
            }
        };
    }
}

多个RestTemplate对象

如果你想要一个非负载均衡的 RestTemplate
,请创建一个 RestTemplate
bean并将其注入,要访问负载均衡的 RestTemplate
,请在创建 @Bean
时使用 @LoadBalanced
限定符,如以下示例所示:

@Configuration
public class MyConfiguration {

    @LoadBalanced
    @Bean
    RestTemplate loadBalanced() {
        return new RestTemplate();
    }

    @Primary
    @Bean
    RestTemplate restTemplate() {
        return new RestTemplate();
    }
}

public class MyClass {
    @Autowired
    private RestTemplate restTemplate;

    @Autowired
    @LoadBalanced
    private RestTemplate loadBalanced;

    public String doOtherStuff() {
        return loadBalanced.getForObject("http://stores/stores", String.class);
    }

    public String doStuff() {
        return restTemplate.getForObject("http://example.com", String.class);
    }
}

请注意在前面示例中的普通 RestTemplate
声明中使用 @Primary
注解来消除无条件的 @Autowired
注入的歧义。

如果你看到 java.lang.IllegalArgumentException: Can not set org.springframework.web.client.RestTemplate field com.my.app.Foo.restTemplate to com.sun.proxy.$Proxy89
,尝试注入 RestOperations
或设置 spring.aop.proxyTargetClass=true

Spring WebFlux WebClient作为负载均衡客户端

可以将 WebClient
配置为使用 LoadBalancerClient
,如果 spring-webflux
位于类路径上,则自动配置 LoadBalancerExchangeFilterFunction
,以下示例显示如何配置 WebClient
以使用负载均衡:

public class MyClass {
    @Autowired
    private LoadBalancerExchangeFilterFunction lbFunction;

    public Mono<String> doOtherStuff() {
        return WebClient.builder().baseUrl("http://stores")
            .filter(lbFunction)
            .build()
            .get()
            .uri("/stores")
            .retrieve()
            .bodyToMono(String.class);
    }
}

URI需要使用虚拟主机名(即服务名称,而不是主机名), LoadBalancerClient
用于创建完整的物理地址。

忽略网络接口

有时,忽略某些命名的网络接口以便从Service Discovery注册中排除它们(例如,在Docker容器中运行时)是有用的,可以设置正则表达式列表以使所需的网络接口被忽略,以下配置忽略 docker0
接口和以 veth
开头的所有接口:

application.yml

spring:
  cloud:
    inetutils:
      ignoredInterfaces:
        - docker0
        - veth.*

你还可以使用正则表达式列表强制仅使用指定的网络地址,如以下示例所示:

bootstrap.yml

spring:
  cloud:
    inetutils:
      preferredNetworks:
        - 192.168
        - 10.0

你还可以强制仅使用站点本地地址,如以下示例所示:

application.yml

spring:
  cloud:
    inetutils:
      useOnlySiteLocalInterfaces: true

有关构成站点本地地址的更多详细信息,请参阅 Inet4Address.html.isSiteLocalAddress()

HTTP客户端工厂

Spring Cloud Commons提供用于创建Apache HTTP客户端( ApacheHttpClientFactory
)和OK HTTP客户端( OkHttpClientFactory
)的bean,仅当OK HTTP jar位于类路径上时,才会创建 OkHttpClientFactory
bean。此外,Spring Cloud Commons提供了创建用于两个客户端使用的连接管理器的bean:Apache HTTP客户端的 ApacheHttpClientConnectionManagerFactory
和OK HTTP客户端的 OkHttpClientConnectionPoolFactory
。如果要自定义在下游项目中创建HTTP客户端的方式,可以提供自己的这些bean实现,此外,如果你提供类型为 HttpClientBuilder
OkHttpClient.Builder
的bean,则默认工厂使用这些构建器作为返回到下游项目的构建器的基础,你还可以通过将 spring.cloud.httpclientfactories.apache.enabled
spring.cloud.httpclientfactories.ok.enabled
设置为 false
来禁用这些bean的创建。

启用功能

Spring Cloud Commons提供 /features
执行器端点,此端点返回类路径上可用的功能以及它们是否已启用,返回的信息包括功能类型、名称、版本和供应商。

功能类型

有两种类型的’功能’:抽象和命名。

抽象功能是定义接口或抽象类并创建实现(如 DiscoveryClient
LoadBalancerClient
LockService
)的功能,抽象类或接口用于在上下文中查找该类型的bean,显示的版本是 bean.getClass().getPackage().getImplementationVersion()

命名功能是没有他们实现的特定类的功能,例如“断路器”,“API网关”,“Spring Cloud Bus”等,这些功能需要名称和bean类型。

声明功能

任何模块都可以声明任意数量的 HasFeature
bean,如以下示例所示:

@Bean
public HasFeatures commonsFeatures() {
  return HasFeatures.abstractFeatures(DiscoveryClient.class, LoadBalancerClient.class);
}

@Bean
public HasFeatures consulFeatures() {
  return HasFeatures.namedFeatures(
    new NamedFeature("Spring Cloud Bus", ConsulBusAutoConfiguration.class),
    new NamedFeature("Circuit Breaker", HystrixCommandAspect.class));
}

@Bean
HasFeatures localFeatures() {
  return HasFeatures.builder()
      .abstractFeature(Foo.class)
      .namedFeature(new NamedFeature("Bar Feature", Bar.class))
      .abstractFeature(Baz.class)
      .build();
}

这些bean中的每一个都应该放在一个受到适当保护的 @Configuration
中。

Spring Cloud兼容性验证

由于某些用户在设置Spring Cloud应用程序时遇到问题,因此决定添加兼容性验证机制,如果你当前的设置与Spring Cloud要求不兼容,并且报告显示出现了什么问题,它将会中断。

目前我们验证哪个版本的Spring Boot被添加到你的类路径中。

报告示例

***************************
APPLICATION FAILED TO START
***************************

Description:

Your project setup is incompatible with our requirements due to following reasons:

- Spring Boot [2.1.0.RELEASE] is not compatible with this Spring Cloud release train


Action:

Consider applying the following actions:

- Change Spring Boot version to one of the following versions [1.2.x, 1.3.x] .
You can find the latest Spring Boot versions here [https://spring.io/projects/spring-boot#learn].
If you want to learn more about the Spring Cloud Release train compatibility, you can visit this page [https://spring.io/projects/spring-cloud#overview] and check the [Release Trains] section.

要禁用此功能,请将 spring.cloud.compatibility-verifier.enabled
设置为 false
,如果要覆盖兼容的Spring Boot版本,只需使用逗号分隔的兼容Spring Boot版本列表设置 spring.cloud.compatibility-verifier.compatible-boot-versions
属性。

上一篇:Spring Cloud Context:应用程序上下文服务

原文 

https://segmentfault.com/a/1190000018850162

本站部分文章源于互联网,本着传播知识、有益学习和研究的目的进行的转载,为网友免费提供。如有著作权人或出版方提出异议,本站将立即删除。如果您对文章转载有任何疑问请告之我们,以便我们及时纠正。

PS:推荐一个微信公众号: askHarries 或者qq群:474807195,里面会分享一些资深架构师录制的视频录像:有Spring,MyBatis,Netty源码分析,高并发、高性能、分布式、微服务架构的原理,JVM性能优化这些成为架构师必备的知识体系。还能领取免费的学习资源,目前受益良多

转载请注明原文出处:Harries Blog™ » Spring Cloud 参考文档(Spring Cloud Commons:通用的抽象)

赞 (0)
分享到:更多 ()

评论 0

  • 昵称 (必填)
  • 邮箱 (必填)
  • 网址