Spring Cloud Eureka+Ribbon+Hystrix

短命女 2022-06-09 03:59 138阅读 0赞

把这三个那来一起讲，是因为这是Spring cloud中最基础的架构，后续的高级配件都是围绕它们来做出优化和升级。

Eureka：注册中心，单个微服务将自己注册到eureka上供其它服务调用。

Ribbon：客户端负载均衡，负责对eureka中的服务进行调用。

Hystrix：客户端容错保护，负责当ribbon出现问题时保证整个服务的畅通。

基于代码来学习下，创建3个服务：

服务A作为服务中心：https://github.com/yejingtao/forblog/tree/master/demo-eureka-register

服务B作为服务注册到服务A中：https://github.com/yejingtao/forblog/tree/master/demo-eureka-server

服务C调用服务B：https://github.com/yejingtao/forblog/tree/master/demo-eureka-consumer

服务A Eureka中心：

Pom依赖

<dependencies>
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-starter-eureka-server</artifactId>
            </dependency>
        </dependencies>
    
        <dependencyManagement>
            <dependencies>
                <dependency>
                    <groupId>org.springframework.cloud</groupId>
                    <artifactId>spring-cloud-dependencies</artifactId>
                    <version>Dalston.SR1</version>
                    <type>pom</type>
                    <scope>import</scope>
                </dependency>
            </dependencies>
        </dependencyManagement>

（注意cloud的Dalston版本对应boot的1.5版本）

配置文件有3个，其中pee1+peer2是高可用性集群，application.properties是单结点注册中心。

application-peer1.properties

server.port:1111
    spring.application.name:eureka-register
    eureka.instance.hostname:peer1
    eureka.client.serviceUrl.defaultZone:http://peer2:1112/eureka/

application-peer2.properties

server.port:1112
    spring.application.name:eureka-register
    eureka.instance.hostname:peer2
    eureka.client.serviceUrl.defaultZone:http://peer1:1111/eureka/

application.properties

server.port:1111
    spring.application.name:eureka-register
    eureka.instance.hostname:peer1
    eureka.client.registerWithEureka=false
    eureka.client.fetchRegistry=false
    eureka.client.serviceUrl.defaultZone:http://peer1:1111/eureka/

配置的区别终于在与2个：

eureka.client.registerWithEureka //要不要把自己作为服务注册到eureka

eureka.client.fetchRegistry //要不要去检索服务

这两个默认都是true，多个eureka可以互相注册互相检索组成一个高可用性的集群，如果要搭建单结点注册中心这俩需要配置成false。

eureka.client.serviceUrl.defaultZone//注册中心地址，留给微服务结点配置的地址。

这里peer1和peer2因为要做集群所以要互相注册，配置对方的地址。

服务组测不需要任何逻辑，所以代码很简单只是启动一个SpringBoot的服务，增加一个@EnableEurekaServer注解启动eureka。

为了架构的高可用性我这里决定使用peer1+peer2双结点，eureka启动命令是：

java –jar demo-eureka-register.jar –spring.profiles.active=peer1

java –jar demo-eureka-register.jar –spring.profiles.active=peer2

服务B：代码很简单，只是提供一个RestFul服务。

Pom依赖

<dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-starter-eureka</artifactId>
            </dependency>

application.yml

server:
      port: 8081
    spring:
      application:
        name: hello-service   
    eureka:
      client:
        serviceUrl:
          defaultZone: http://peer1:1111/eureka/,http://peer2:1112/eureka/

配置主要有2个，自己注册到eureka上的服务名;Eureka server的地址，多个地址以逗号隔开.

服务代码

@SpringBootApplication
    @EnableEurekaClient
    @RestController
    public class ServiceDemoApplication {
    	
    	public static void main(String[] args) {
    		SpringApplication.run(ServiceDemoApplication.class, args);
    	}	
    	
    	@Value("${server.port}")
        String port;
    	
    	
        @RequestMapping("/hi")
        public String home(@RequestParam String name) {
            return "hi "+name+",i am from port:" +port;
        }
    }

@EnableEurekaClient代表自己是注册中心的客户端

服务C：Ribbon+Hystrix作为客户端访问注册中心上的服务B

Pom依赖

<dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-starter-eureka</artifactId>
            </dependency>
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-starter-ribbon</artifactId>
            </dependency>
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-starter-hystrix</artifactId>
            </dependency>

依赖了eureka、ribbon和hystrix。

配置没有特殊的，最主要的就是eureka的地址。

主程序：

//@SpringBootApplication
    //@EnableEurekaClient
    //@EnableCircuitBreaker
    @SpringCloudApplication
    public class ConsumerApplication {
    	
    	public static void main(String[] args) {
    		SpringApplication.run(ConsumerApplication.class,args);
    	}
    	
    	@Bean
    	@LoadBalanced
    	RestTemplate restTemplate() {
    		return new RestTemplate();
    	}
    }

这里只用了@SpringCloudApplication一个注解，因为它包含了其它3个，从名字也可以看得出这是Spring cloud代码的标配。其中@EnableCircuitBreaker是Hystrix的服务熔断。

restTemplate是访问eureka上应用的客户端，因为我的eureka服务端是peer1+peer2双结点的，所以用了@LoadBalanced负责均衡（这里的是客户端负载均衡，与F5、Apache等服务端负载均衡原理差异性很大）。

@Service
    public class HelloService {
    	
    	@Autowired
    	private RestTemplate restTemplate;
    	
    	@HystrixCommand(fallbackMethod="hellServiceFallback")
    	public String sayHello() {
    		return restTemplate.getForEntity("http://HELLO-SERVICE/hi?name=yejingtao", String.class).getBody();
    	}
    	
    	@SuppressWarnings("unused")
    	private String hellServiceFallback() {
    		return "error";
    	}
    
    }

restTemplate.getForEntity("http://HELLO-SERVICE/hi?name=yejingtao", String.class).getBody()//用get的方式访问eureka上hello-service上的服务，返回类型是String。

@HystrixCommand(fallbackMethod="hellServiceFallback")//hystrix熔断后服务降级为hellServiceFallback来提供服务。

下面介绍下这几个服务的需要加强学习的知识点。

Eureka：

eureka.instance.lease-renewal-interval-in-seconds=30

eureka.instance.lease-expiratioin-duration-in-seconds=90

失效剔除：超过90秒eureka没有收到客户端上来的心跳就认为此服务挂了，从注册中心剔除出去（心跳是主动上报的，而不是eureka去访问客户端的/health）

自我保护：如果一段时间内eureka管理的85%的服务都失去了心跳，eureka会启动保护机制，它会认为是eureka服务自己所在的网络出现了问题，而不去启用失效剔除机制，继续让注册上来的应用提供服务。

Ribbon的几个特性：

1， 区域亲和策略。可以将同一机房的微服务结点配置成同一个zone，ribbon在对服务进行请求时优先选择跟自己同一个zone的结点。eureka.instance.metadataMap.zone=zoneName

2， 重试机制

默认关闭的，需要配置手动打开：spring.cloud.loadbalance.retry.enabled=true