spring Cloud Ribbon

Ribbon是一个基于HTTP和TCP协议的客户端负载均衡工具，他也是基于Netflix Ribbon实现。通过Spring Cloud的封装，可以让我们很容易的将面向服务的REST模板请求自动转换成客户端负载均衡的调用。虽然Ribbon只是一个工具类框架，不像服务注册中心、配置中心、API网关那样需要独立部署，但是他几乎存在于每一个Srping Cloud构建的微服务和基础设施中。

客户端负载均衡

负载均衡在系统架构中是一个非常重要的，并且是不得不去实施的内容。因为负载均衡是对系统的高可用、网络压力的缓解和处理能力的扩容的一个重要的手段之一。我们通常说的负载均衡都是指服务端的负载均衡，其中服务端的负载均衡分为硬件负载均衡和软件负载均衡。硬件负载均衡主要通过服务器节点之间安装专门的负载均衡设备，而软件负载均衡则是通过在服务器安装一些具有负载均衡的软件来实现，比如：Nginx；
而客户端的负载均衡和服务端的负载均衡最大的不同点在于服务清单所存储的位置。在客户端负载均衡中，所有的客户端节点都维护着自己要访问的服务端清单。而这些服务清单均来自服务注册中心。

入门案例

我们接着上一篇的创建的service-user项目。我们在该项目中写一个业务接口实现。

创建一个UserManagementController类。并且暴露一个get请求的服务接口；模拟返回用户数据。代码如下

@RestController
@Log
public class UserManagementController {

    @Value("${server.port}")
    String serverPort;
    
    @GetMapping("/listUsers")
    public String ListUsers() throws InterruptedException {
        /**
         * 模拟从数据库查询
         */
        List<Map<String, Object>> users = new ArrayList<Map<String, Object>>();
        for (int i = 1; i < 5; i++) {
            Map<String, Object> user = new HashMap<String, Object>();
            user.put("id", i);
            user.put("name", "小明" + i);
            users.add(user);
        }
        log.info("/listUsers, host:"+serverPort);
        return "服务器端口号：   " + serverPort + "   |   用户信息：   " + users.toString();
    }
}

这里说一个日志输出，我比较喜欢使用lombok，所以项目中的日志输出我都会使用这种方式来输出日志。
使用的方式很简单；
在pom.xml添加lombok的依赖

 <dependency>
    <groupId>org.projectlombok</groupId>
    <artifactId>lombok</artifactId>
 </dependency>

然后我们在类名添加@Log注解就可以了，关于其他更多的用户，大家可以网上了解一下。

重启项目，访问http://localhost:8802/listUsers，如果有数据返回，则说明服务接口正常了。

到这里service-user的服务接口已经写好了。接下来我们就创建一个新的springBoot 类型的module，命名为"eureka-bussniss-service-user-client-ribbon"做为服务消费者。
创建的过程中我们选中Eureka-server和Ribbon两个依赖即可：

创建项目成功后，修改application.yml

spring:
  application:
    name: service-user-ribbon
server:
  port: 8901
eureka:
  client:
    serviceUrl:
      defaultZone: http://peer1:8762/eureka/,http://peer2:8763/eureka/

项目主类名添加@EnableEurekaClient注解，并且注入RestTemplate类。主类的代码如下：

@SpringBootApplication
@EnableEurekaClient
public class EurekaBussnissServiceUserClientRibbonApplication {

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

    @Bean
    @LoadBalanced //开启客户端负载均衡
    RestTemplate restTemplate() {
        return new RestTemplate();
    }
}

上面的@LoadBalanced 注解表示开启客户端的负载均衡。
接下来，我们新建一个UserManagementRibbonClient请求类，实现负载均衡请求service-user服务，代码如下：

@RestController
@Log
public class UserManagementRibbonClient {

    @Value("${server.port}")
    private String port;

    @Autowired
    RestTemplate restTemplate;

    @GetMapping("/listUsersByRibbon")
    public String ListUsersByRibbon() {

        long start = System.currentTimeMillis();
        String result = this.restTemplate.getForObject("http://service-user/listUsers", String.class);
        long end = System.currentTimeMillis();
        log.info("Spend Time ："+(end-start));
        return result;
    }
}

说明：service-user 为服务名称， 一个服务名称对应多个主机IP和端口号，这样根据服务名调用就实现了负载均衡的功能。
这样服务消费者就已经创建好了，接下来我们来验证测试Ribbon负载均衡的请求。

我们先把服务提供者service-user开启两个分别对应端口8802和8803。启动的方式可以向之前服务注册中心的方式，也可以直接在Idea里面启动，这里我们选择在Idea启动。启动的方式：

修改这里，把single instance only的勾去掉。

启动完8802端口后，我们修改一个application.yml的port为8803，即可启动8803对应的服务了。
接着把"eureka-bussniss-service-user-client-ribbon"服务也启动了。
这个时候我们访问注册中心的面板信息，可以看到相关的服务实例已经注册到了注册中心了。

这个时候我们访问service-user-ribbon的接口地址：http://localhost:8901/listUsersByRibbon
这里可以看到接口响应信息轮询的返回8802和8803的信息。

到这里说明Ribbon已经实现负载均衡请求了。
项目的源码

接口的负载均衡已经实现了，当时这里就会有一个问题了，如果服务提供者service-user其中一个服务挂了，ribbon还是会负载均衡到这个挂掉的服务的。例如：8把002端口停掉，然后继续访问http://localhost:8901/listUsersByRibbon。我们会看到当接口负载到8802的时候就报错了。

只有负载到8803才正常，这里如果是生产环境是可能不能出现这张情况的。

如果我们使用过Nginx，就会知道Nginx有一种容灾的功能，就是如果nginx反向代理的其中一个服务节点挂了不能访问了，nginx会自动踢掉这个节点，不会代理到这个节点的。在spring cloud中的Hystrix组件的主要作用就是服务容错保护来实现这个功能的。

所以我们下一篇会使用Hystrix组件来实现客户端负载均衡的服务容错保护。