spring cloud服务调用 spring cloud服务之间的调用之ribbon详解

前言

昨天，我们通过一个实例演示了，spring-cloud服务注册组件——Eureka的基本配置和简单用法，但是服务注册就是为了方便后期的发现和调用，所以今天我们趁热打铁，分享下spring-cloud服务之间的调用。

服务间的调用

关于spring-cloud的服务调用，我们首先需要了解它的两个核心组件Ribbon和Feign。

我们都知道，spring boot的接口都是基于REST实现的，但是在实际线上运行的时候，考虑到用户规模、服务可用性等方面的因素，我们一般很少是单节点运行的，通常都是以集群模式部署的，但是在集群部署中，又有一个核心的问题必须解决——负载均衡。关于负载均衡，各位小伙伴应该不陌生，最常用的组件之一nginx其中一个很核心的用途就是做负载均衡，但是nginx在实际做负载均衡的时候，确实不够方便，需要手动配置服务地址，如果服务地址发生变化，相关配置也需要修改，所以不够灵活。

当然spring cloud作为一款微服务综合框架，它自然也提供了自己的一套负载均衡解决方案，所以接下来我们就来看下spring cloud的负载均衡组件——Ribbon。

Ribbon

Ribbon中文的意思是丝带、带状物，正如它的含义，它就是连接调用方和服务之间的纽带。

依赖

我们先通过一个简单实例，来演示下，然后在示例的过程中来解释，首先是它的核心依赖：

<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-netflix-ribbon</artifactId>
    <version>2.2.9.RELEASE</version>
</dependency>

配置

这个组件你需要添加到服务调用方的依赖中。同时，还需要增加它的配置：

@Configuration
public class RibbonConfig {

    // 多节点负载
    @LoadBalanced
    @Bean(name = "restTemplate")
    public RestTemplate restTemplate() {
        return new RestTemplate();
    }
}

@LoadBalanced注解的作用是启用多节点负载，这样后期我们在调用的时候，RestTemplate客户端其实就是通过负载均衡的方式在调用服务提供者。

服务调用方

然后，在服务调用方，我们通过RestTemplate去调用我们的服务提供者：

@Autowired
private RestTemplate restTemplate;

@GetMapping("/ribbon")
public Object queryUserByProductId() {
    List<JSONObject> jsonObjectList = Lists.newArrayList();
    for (int i = 0; i < 10; i++) {
        JSONObject forObject = restTemplate.getForObject("http://user-center/user/" + (i + 1), JSONObject.class);
        jsonObjectList.add(forObject);
    }
    return jsonObjectList;
}

这里我们通过前面配置的restTemplate来调用我们的用户服务，接口的地址就是我们eureka注册中心显示的地址：

这里的地址不区分大小写，都可以正常访问。调用十次，主要是为了测试负载均衡的效果。

服务提供者

首先我们看下服务提供者配置：

server.port=8776
eureka.client.service-url.defaultZone=http://localhost:8999/eureka, http://localhost:9000/eureka

第一个配置是指定服务的端口，如果在本地启动的话，需要每启动一次改一个端口，否则会提示端口冲突，如果你用的是IDEA的话，要先运行多应用启动：

第二个配置就是设定我们的注册中心，我们有两个注册中心，所以指定了两个地址。

服务提供者就是一个简单的controller，在controller内部，我们通过DiscoveryClient打印出被调用者的信息，方便我们查看。

@RestController
public class UserController {
    private Logger logger = LoggerFactory.getLogger(UserController.class);

    @Autowired
    private DiscoveryClient discoveryClient;

    @GetMapping("/user/{id}")
    public JSONObject getUserById(@PathVariable(name = "id") Long id) {
        List<ServiceInstance> instances = discoveryClient.getInstances("user-center");
        logger.info("instances = {}",  instances);
        JSONObject user = new JSONObject();
        user.put("id", id);
        user.put("name", "syske");
        return user;
    }
}

这里需要注意的是，我们导入的DiscoveryClient是org.springframework.cloud.client.discovery包下的，如果不是同这个类，启动的时候会报错：

Consider defining a bean of type 'com.netflix.discovery.DiscoveryClient' in your configuration.

测试

我们分别启动服务调用发和被调用方，这里我启动了5个user-center，同时eureka服务也启动了两个，这个两个注册中心互相注册监控，在实际应用中也可以确保服务稳定性。5个user-center有2个注册在8999的注册中心上，有3个注册在9000的注册中心上：

然后，我们访问product的ribbon接口：

http://localhost:8881/ribbon

浏览器返回结果如下：

同时，在user-center端口为8771和8775的控制台，会看到如下信息：

为什么只有8771和8775收到了请求，因为8771和8775都注册到了8999的注册中心，而且我们的product-service也注册在该服务中心，所以就只调用了8771和8775这两个服务：

根据运行结果，我们还发现在10次请求中，8771和8775各处理五次，这里面还有一个潜藏的知识点：Ribbon默认的负载策略是轮询策略，这样可以确保同一个注册中心下的所有服务节点接收到同样的请求频次。

如果你把user-center（5个服务）、product-serive都注册在同一个注册中心，那么你会发现每个服务都会被调用2次。

总结

总体来说，Ribbon对用户来说感知确实不够强，而且经过我的测试，我发现就算拿掉ribbon的依赖，依然可以正常负载均衡，这是因为eureka-client的依赖，已经添加过ribbon的依赖了：

好了，今天的Ribbon分享就先到这里吧，我们明天分享基于Feign的声明式调用。