spring-cloud 基本使用(一)

本文主要讲了

  • spring-cloud 注册中心基本使用
  • spring-cloud 注册中心的一些基本配置及实现集群
  • spring-cloud 注册中心的使用,即通过注册中心注册及访问
  • spring-cloud 通过Ribbon实现负载均衡
  • spring-cloud 通过Retry实现重试机制

1、spring-cloud 注册中心基本使用

spring-cload使用的注册中心是Eureka,其使用方法是

  • 在父项目pom.xml添加maven坐标管理,注意spring-cloud跟spring-boot会有版本兼容问题
	
		
            
			
				org.springframework.cloud
				spring-cloud-dependencies
				${spring-cloud.version}
				pom
				import
			
		
	
  • 创建Eureka项目,在pom文件中引入具体的坐标
	
        
		
			org.springframework.cloud
			spring-cloud-starter-netflix-eureka-server
		
	
  • 在启动类上面加上Eureka服务端的标志(然后启动即可,不过如果什么都不配置,会报错,但是访问http://127.0.0.1:8080可以访问)

@SpringBootApplication
@EnableEurekaServer // 声明这个应用是一个EurekaServer
public class EurekaDemoApplication {

	public static void main(String[] args) {
		SpringApplication.run(EurekaDemoApplication.class, args);
	}
}

2、spring-cloud 注册中心的一些基本配置及实现集群

  • Eureka如果单单实现上面的基本启用,可以访问Eureka界面,之所以报错,是因为Eureka默认也会把自己注册到注册中心,但是没有地址,因此会报错,因此当只有一个注册中心的时候,可以把自己地址写上去,也可以选择不注册(例如加入只是服务消费者,就没必要注册到注册中心)
server:
  port: 10086 # 端口
spring:
  application:
    name: eureka-server # 应用名称,会在Eureka中显示
eureka:
  client:
    register-with-eureka: false # 是否注册自己的信息到EurekaServer(如果集群是true),默认是true
    fetch-registry: false # 是否拉取其它服务的信息(如果集群是true),默认是true
    service-url: # EurekaServer的地址,现在是自己的地址,如果是集群,需要加上其它Server的地址,使用逗号隔开
      defaultZone: http://127.0.0.1:${server.port}/eureka
  • (判断服务是否存活)当服务注册到Eureka上之后,会通过长连接,心跳针判断服务是否存活,即一般会服务提供者会每30秒像Eureka发送一次信息,提示自己还存活,当90秒没有发送,Eureka就会认为服务提供者已经挂了,可以通过配置文件改变时间
eureka:
  instance:
    lease-expiration-duration-in-seconds: 10 # 10秒即过期
    lease-renewal-interval-in-seconds: 5 # 5秒一次心跳
  • (instance-id)因为服务会做集群,这个时候这些服务的服务名称是一样的,但是在status列,每一个服务都会对应一个instance-id,这个是每一个固定服务的唯一标示,默认是 ${hostname} + ${spring.application.name} + ${server.port},可以使用配置文件给修改了

eureka:
  instance:
    instance-id: ${spring.application.name}:${server.port}
  • (拉取服务列表)服务的消费者,当配置了 eureka.client.fetch-registry=true 会从Eureka拉取服务列表,缓存到本地,默认是30秒拉取一次,可以通过配置文件修改

eureka:
  client:
    registry-fetch-interval-seconds: 5
  • (失效剔除)当服务90秒没有像Eureka发送信息,Eureka会认为这个服务挂了,每60秒Eureka会把这些宕机的服务剔除掉,这个时间可以配置。

  • (自我保护)但是有的时候,服务提供方会因为网络原因,没有及时向Eureka发送信息,例如第32秒才把信息发送过去,Eureka会统计最近15分钟心跳失败的服务实例的比例是否超过了85%,如果没有,就不予剔除,可以通过配置将自我保护关闭

eureka:
  server:
    enable-self-preservation: false # 关闭自我保护模式(缺省为打开)
    eviction-interval-timer-in-ms: 1000 # 扫描失效服务的间隔时间(缺省为60*1000ms)

3、spring-cloud 注册中心的使用,即通过注册中心注册及访问

  • (服务提供者)

(一),无论服务提供方还是服务调用方,对于Eureka来说都是客户端,因此都需要加上


    org.springframework.cloud
    spring-cloud-starter-netflix-eureka-client

(二),在启动类上加上

@SpringBootApplication
@EnableDiscoveryClient // 开启EurekaClient功能
public class UserServiceDemoApplication {
	public static void main(String[] args) {
		SpringApplication.run(UserServiceDemoApplication.class, args);
	}
}

            (三)配置yml文件,如果只是单纯的服务提供者,可以不用拉取Eureka服务列表,具体配置参考Eureka基本配置

spring:  
  application:
    name: user-service # 应用名称
eureka:
  client:
    service-url: # EurekaServer地址,假如Eureka需要配置多个
      defaultZone: http://127.0.0.1:10086/eureka
  instance:
    prefer-ip-address: true # 当调用getHostname获取实例的hostname时,返回ip而不是host名称
    ip-address: 127.0.0.1 # 指定自己的ip信息,不指定的话会自己寻找
  • 服务调用者

(一) 服务调用者,前三步配置可以参考上面信息,但是因为是服务调用者,可以不注册到Eureka上面

(二) 使用spring提供的调用模板,把模板类加入到spring中管理

   @Bean
    public RestTemplate restTemplate() {
        return new RestTemplate(new OkHttp3ClientHttpRequestFactory());
    }

(三) 服务调用

    @Autowired
    private RestTemplate restTemplate;

    @Autowired
    private DiscoveryClient discoveryClient;// Eureka客户端,可以获取到服务实例信息

    public List queryUserByIds(List ids) { 
        // 根据服务名称,获取服务实例
        List instances = discoveryClient.getInstances("user-service");
        // 因为只有一个UserService,因此我们直接get(0)获取
        ServiceInstance instance = instances.get(0);
        // 获取ip和端口信息
        String baseUrl = "http://"+instance.getHost() + ":" + instance.getPort()+"/user/";
        User user = this.restTemplate.getForObject(baseUrl + id, User.class)
        return user;
    }

4 、spring-cloud 实现负载均衡

  • 因为服务提供方一般都会是集群,这个时候就需要使用负载均衡算法,而spring-cloud已经通过Ribbon实现该算法,因为Eureka中已经集成了Ribbon,所以我们无需引入新的依赖,具体使用如下

(一)在spring模板访问类的时候,加入注解@LoadBalanced

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

(二)在调用的时候,不需要使用ip跟端口号,只需要服务名称即可调用服务

String baseUrl = "http://user-service/user/";

Uses user = this.restTemplate.getForObject(baseUrl + id, User.class)
  • 更改负载均衡算法,默认算法是轮询,可以将轮询改成随机等
user-service:
  ribbon:
    NFLoadBalancerRuleClassName: com.netflix.loadbalancer.RandomRule

5 、spring-cloud 通过Retry实现重试机制

  • Eureka的服务治理强调了CAP原则中的AP,即可用性和可靠性,因此牺牲了一致性,即当某一个服务挂掉,并不会立马清除,这个时候,这个服务可能会被调用,那么当调用失败,我们可以通过Retry,实现重新连接该服务集群下面的其他服务,具体实现

(一)引入pom依赖


    org.springframework.retry
    spring-retry

(二)配置yml文件,根据如下配置,当访问到某个服务超时后,它会再次尝试访问,如果不行就再换一个实例,如果不行,则返回失败。切换次数取决于`MaxAutoRetriesNextServer`参数的值

spring:
  cloud:
    loadbalancer:
      retry:
        enabled: true # 开启Spring Cloud的重试功能
user-service:
  ribbon:
    ConnectTimeout: 250 # Ribbon的连接超时时间
    ReadTimeout: 1000 # Ribbon的数据读取超时时间
    OkToRetryOnAllOperations: true # 是否对所有操作都进行重试
    MaxAutoRetriesNextServer: 1 # 切换实例的重试次数
    MaxAutoRetries: 1 # 对当前实例的重试次数

 

你可能感兴趣的