SpringCloudZuul

soulballad约 2363 字大约 8 分钟

Zuul 基本使用

@EnableEurekaClient：注册到 Eureka 服务去

@EnableDiscoveryClient：注册到任意注册中心

Nginx + Lua

Lua：控制规则（A/B Test）

Spring Cloud 学习技巧：

善于定位应用：Feign、Config Server、Eureka、Zuul 、Ribbon定位应用，配置方式是不同

激活 Zuul 代理

增加 @EnableZuulProxy

@SpringBootApplication
@EnableZuulProxy
public class SpringCloudZuulDemoApplication {

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

配置路由规则

基本模式：zuul.routes.${app-name} = /${app-url-prefix}/**

zuul.routes.person-service=/person-service/**

整合 Ribbon

启动应用

spring-cloud-feign-eureka：feign 一章的 eureka 服务器

person-service：服务提供者

调用链路

zuul -> person-service

配置方式

## Zuul 服务端口
server.port = 7070

## Zuul 基本配置模式
# zuul.routes.${app-name}: /${app-url-prefix}/**
## Zuul 配置 person-service 服务调用
zuul.routes.person-service = /person-service/**

# 整合 Ribbon
## Ribbon 取消 Eureka 整合
ribbon.eureka.enabled = false
## 配置 "person-service" 的负载均衡服务器列表
person-service.ribbon.listOfServers = \
  http://localhost:9090

注意：http://localhost:7070/person-service/person/find/all
person-service 的 app-url-prefix : /person-service/
/person/find/all 是 person-service 具体的 URI

测试：

直接访问服务提供者：
使用 zuul 代理访问：

整合 Eureka

配置方式

引入 eureka-client 依赖

引入 spring-cloud-starter-eureka 依赖

<!-- 增加 Eureka 客户端的依赖 -->
<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
</dependency>

激活服务注册、发现客户端

@SpringBootApplication
@EnableZuulProxy
@EnableDiscoveryClient
public class SpringCloudZuulDemoApplication {

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

配置服务注册、发现客户端

# Zuul 服务端口
server.port=7070
# 基本配置模式
#zuul.routes.${app-name} = /${app-url-prefix}/**
# Zuul 配置 person-service 服务调用
zuul.routes.person-service=/person-service/**

# 整合 Ribbon
## Ribbon 取消与 Eureka 整合
#ribbon.eureka.enabled=false
## 配置 person-service 的负载均衡服务器列表
#person-service.ribbon.listOfServers = \
#  http://localhost:9090

# 整合Eureka
# Eureka Server 服务 URL，用于客户端注册
eureka.client.service-url.defaultZone=\
  http://localhost:12345/eureka

效果测试

直接访问服务提供者：
使用 zuul 代理访问：

整合 Hystrix

服务端提供方：person-service

激活 Hystrix

@SpringBootApplication
@EnableEurekaClient
@EnableHystrix
public class PersonServiceProviderApplication {

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

配置 Hystrix 规则

@RestController
public class PersonServiceController {

    private final ConcurrentMap<Long, Person> persons = new ConcurrentHashMap<>();
    private final Random random = new Random();

    @PostMapping(value = "/person/save")
    public boolean save(@RequestBody Person person){
        return persons.putIfAbsent(person.getId(), person) == null;
    }

    @GetMapping(value = "/person/find/all")
    @HystrixCommand(fallbackMethod = "fallbackForFindAll",
            commandProperties = {@HystrixProperty(
                    name = "execution.isolation.thread.timeoutInMilliseconds",
                    value = "100"
            )}
    )
    public Collection<Person> findAll() throws InterruptedException {
        // 如果随机时间 大于 100 ，那么触发容错
        int value = random.nextInt(200);
        System.err.println("findAllPersons() costs " + value + " ms.");
        Thread.sleep(value);
        return persons.values();
    }

    public Collection<Person> fallbackForFindAll() {
        System.err.println("fallbackForFindAll() is invoked!");
        return Collections.emptyList();
    }
}

效果测试：

1570346129803

整合 Feign

person-client

调用链路

spring-cloud-zuul -> person-client -> person-service

注册到 EurekaServer

端口信息：
spring-cloud-zuul 端口：7070
person-client 端口：8080
person-service 端口：9090
Eureka Server 端口：12345

启动 person-client

spring.application.name = person-client
server.port = 8080

## Eureka Server 服务 URL,用于客户端注册
eureka.client.serviceUrl.defaultZone=\
  http://localhost:12345/eureka

management.endpoint.health.show-details=always
management.endpoints.web.exposure.include=*