在之前，已经完成了 hello-world 得项目，对 spring cloud kubernetes 和 kubernetes 有了一定得了解，接下来，进行使用ribbon调用内部项目已经使用hystrix进行容错回退得学习。

先创建一个spring boot 项目，名字为 name_service，这是一个简单得 spring boot 项目，里面得依赖只有spring web：

    <dependency>
          <groupId>org.springframework.boot</groupId>
          <artifactId>spring-boot-starter-web</artifactId>
      </dependency>

在项目中，创建一个 NameController：

@RestController
public class NameController {

    private static final Logger LOG = LoggerFactory.getLogger(NameController.class);

    private final String hostName = System.getenv("HOSTNAME");

    @RequestMapping("/")
    public String ribbonPing() {
        LOG.info("Ribbon ping");
        return this.hostName;
    }

    @RequestMapping("/name")
    public String getName(@RequestParam(value = "delay", defaultValue = "0") int delayValue) {
        LOG.info(String.format("Returning a name '%s' with a delay '%d'", this.hostName, delayValue));
        delay(delayValue);
        return this.hostName;
    }

    private void delay(int delayValue) {
        try {
            Thread.sleep(delayValue);
        }
        catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}

像之前hello-world一样，建立 Dockerfile ，这里就不再重复。
建立name-service.yaml：

kind: Service
apiVersion: v1
metadata:
  name: name-service
spec:
  selector:
    app: name-service
  ports:
  - protocol: TCP
    port: 8081
  type: ClusterIP
---
apiVersion: apps/v1
kind: Deployment
metadata:
  name: name-service
spec:
  selector:
    matchLabels:
      app: name-service
  replicas: 3
  template:
    metadata:
      labels:
        app: name-service
    spec:
      containers:
      - name: name-service
        image: name-service:latest
        imagePullPolicy: Never
        ports:
        - containerPort: 8081

这里跟hello-world得配置只有一处不一样，type：ClusterIP 并删除了 nodePort 属性，ClusterIP 表示该 Service 不提供外部服务，只能在容器内部进行访问。

接着创建一个spring cloud 项目，名字为 greeting_service，这是调用者服务，需要得引入：

        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-ribbon</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-hystrix</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-kubernetes-ribbon</artifactId>
            <version>${kubernetes-version}</version>
        </dependency>

像之前一样，开启 hystrix 需要在Application上标记 @EnableCircuitBreaker 注解，并注入 开启负载均衡得 RestTemplate ：

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

创建 NameService，调用 name-service得远程服务：

@Service
public class NameService {

    private final RestTemplate restTemplate;

    public NameService(RestTemplate restTemplate) {
        this.restTemplate = restTemplate;
    }

    @HystrixCommand(fallbackMethod = "getFallbackName", commandProperties = {
            @HystrixProperty(name = "execution.isolation.thread.timeoutInMilliseconds", value = "1000")
    })
    public String getName(int delay) {
        return this.restTemplate.getForObject(String.format("http://name-service/name?delay=%d", delay), String.class);
    }

    private String getFallbackName(int delay) {
        return "Fallback";
    }
}

编写 NameController，提供调用接口：

@RestController
public class NameController {
    @Resource
    private NameService nameService;

    @Resource
    private NameRemoteService nameRemoteService;

    @RequestMapping("/greeting")
    public String getGreeting(@RequestParam(value = "delay", defaultValue = "0") int delay) {
        return String.format("Hello from %s!", this.nameService.getName(delay));
    }
}

这就是普通得 ribbon 和 hystrix 代码，在此就不过多介绍。
然后编写 Dockerfile与 yaml，这与之前得hello-world基本一致，在此跳过，直接来到调用服务，查看效果。

pods

查看 pod 可以看到，name-service开启了3个进行负载均衡。

service

查看 services 可以看到，name-service得type为 ClusterIP，在port上，也只有 8081，没有显示两个端口，这就表示该服务是无法被外部访问得，并且 greeting-serivce得port为30002，接下来，调用接口试下。

调用结果

上面，我们进行了三次调用，通过结果可以看到，3次调用都是不同得服务进行调用，这说明了在 kubernetes中，负载均衡得策略是轮询， 再进行3次调用，顺序依然是这样。

接下来，我们将 name-service 开启得节点调为 0 个，测试 hystrix：

kubectl scale --replicas=0 deployment/name-service

查看 name-service得节点，都消失之后，再次请求接口：

hystrix

可以看到，调用失败，并且进入到 Fallback 代码中。