文章/答案/技术大牛

发布

社区首页 >专栏 >微服务之间的通信的方式

微服务之间的通信的方式

端碗吹水

发布于 2020-09-24 03:16:36

83100

代码可运行

文章被收录于专栏：程序猿的大杂烩程序猿的大杂烩

运行总次数：0

代码可运行

RestTemplate的三种使用方式

SpringCloud中服务之间的两种调用RESTful接口通信的方式：

RestTemplate
Feign

RestTemplate是一个Http客户端，类似于HTTPClient，org但比HTTPClient更简单。我们通过RestTemplate来简单演示一下服务之间的调用，我们使用两个服务来做演示。一个商品服务，一个订单服务。首先创建一个商品服务工程：

选择相应的依赖：

项目创建完成后，编辑配置文件，需要配置服务的名称以及服务注册中心的地址：

spring:
  application:
    name: product

eureka:
  client:
    service-url:
      defaultZone: http://localhost:8761/eureka/
  instance:
    prefer-ip-address: true

注：如果对eureka还不太清楚的话，可以参考我的另一篇关于eureka的文章：Spring Cloud Eureka-服务注册与发现

不要忘了在启动类中，加上@EnableEurekaClient注解：

package org.zero.example.product;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.netflix.eureka.EnableEurekaClient;

@SpringBootApplication
@EnableEurekaClient
public class ProductApplication {

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

接着创建一个controller类，用于模拟商品列表接口，提供给订单服务调用。代码如下：

package org.zero.example.product.controller;

import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

import java.util.ArrayList;
import java.util.List;

/**
 * @program: product
 * @description: product demo
 * @author: 01
 * @create: 2018-09-06 22:09
 **/
@RestController
@RequestMapping("/product")
public class ProductController {

    /**
     * 模拟商品列表接口
     *
     * @return product list
     */
    @GetMapping("/list")
    public List<String> list() {
        List<String> productList = new ArrayList<>();
        productList.add("肥皂");
        productList.add("可乐");

        return productList;
    }
}

然后启动项目，启动完成后，此时，在eureka的信息面板上应该可以看到product注册上去了，如下：

商品服务准备好后，使用同样的步骤创建order项目，这里就不再赘述了。配置文件中除了服务名称需为order，其他的配置项和product一样。因为8080已经被product服务占用了，所以还需要手动设置一下项目的端口号：

新建一个ClientController类，我们来看看RestTemplate的第一种使用方式，代码如下：

package org.zero.example.order.controller;

import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.client.RestTemplate;

import java.util.List;

/**
 * @program: order
 * @description: order demo
 * @author: 01
 * @create: 2018-09-06 22:24
 **/
@RestController
@RequestMapping("/order")
public class OrderController {

    @GetMapping("/info")
    public List info() {
        // 1.第一种方式，直接使用。缺点：需要指定url地址，不灵活，也无法适应多个地址
        RestTemplate restTemplate = new RestTemplate();
        return restTemplate.getForObject("http://localhost:8080/product/list", List.class);
    }
}

写完后启动项目，可以看到order服务也注册到eureka上了：

接口测试结果如下，可以看到成功调用了商品服务的接口：

然后是RestTemplate的第二种使用方式，代码如下：

...

import org.springframework.cloud.client.loadbalancer.LoadBalancerClient;

@RestController
@RequestMapping("/order")
public class OrderController {

    @Autowired
    private LoadBalancerClient loadBalancerClient;

    @GetMapping("/info")
    public List info() {
        // 2.第二种方式，借助LoadBalancerClient获取服务实例，缺点：需要拼接url依旧不灵活
        RestTemplate restTemplate = new RestTemplate();
        // 参数传的是服务注册的id
        ServiceInstance serviceInstance = loadBalancerClient.choose("PRODUCT");
        String url = String.format("http://%s:%s", serviceInstance.getHost(), serviceInstance.getPort() + "/product/list");

        return restTemplate.getForObject(url, List.class);
    }
}

接着是RestTemplate的第三种使用方式，这种方式下我们需要先创建一个配置类，代码如下：

package org.zero.example.order.config;

import org.springframework.cloud.client.loadbalancer.LoadBalanced;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.web.client.RestTemplate;

/**
 * @program: order
 * @description: RestTemplate Config
 * @author: 01
 * @create: 2018-09-06 22:47
 **/
@Configuration
public class RestTemplateConfig {

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

然后在controller中注入使用，这种方式虽然最简洁，其实本质上还是第二种方式：

...
@RestController
@RequestMapping("/order")
public class OrderController {

    @Autowired
    private RestTemplate restTemplate;

    @GetMapping("/info")
    public List info() {
        // 3.第三种方式，利用@LoadBalanced注解，可在restTemplate里使用应用名称进行调用
        return restTemplate.getForObject("http://PRODUCT/product/list", List.class);
    }
}

负载均衡器：Ribbon

eureka是客户端发现机制的，所以使用的是客户端负载均衡器，所谓客户端负载均衡，也就是说负载的策略在客户端完成，俗称软负载。如果我们的商品服务部署在多个节点上的话，当使用Feign进行服务调用的时候，默认会使用Ribbon来做负载均衡。当然使用RestTemplate的时候也是可以结合Ribbon做负载均衡的，例如上一小节中演示的第二、三种使用RestTemplate的方式就是结合了Ribbon。

Ribbon是Netflix发布的负载均衡器，是一种客户端负载均衡器，运行在客户端上，它有助于控制HTTP和TCP的客户端的行为。为Ribbon配置服务提供者地址后，Ribbon就可基于某种负载均衡算法，自动地帮助服务消费者去请求。Ribbon默认为我们提供了很多负载均衡算法，例如轮询、随机等。当然，我们也可为Ribbon实现自定义的负载均衡算法。

我们在配置文件中可以自定义负载均衡策略，如下：

PRODUCT:  # 服务的名称
  ribbon:  # 负载均衡器
    NFLoadBalancerRuleClassName: com.netflix.loadbalancer.RandomRule  # 规则完整的类名，这里使用的是随机

注：如非必须，一般使用默认的轮询策略即可

Ribbon特性：

服务发现
服务选择规则
服务监听
ServerList，获取可用服务列表
IRule，选择最终调用，即负载策略
ServerListFilter，过滤不可用地址

在Spring Cloud中，当Ribbon与Eureka配合使用时，Ribbon可自动从Eureka Server获取服务提供者地址列表，并基于负载均衡算法，请求其中一个服务提供者实例。下图展示了Ribbon与Eureka配合使用时的架构：

Feign的使用

Feign是从Netflix中分离出来的轻量级项目，是一个声明式的REST客户端，它的出现使得我们在服务中编写REST客户端变得更加容易。利用 Feign 可以创建一个接口并对它进行注解，该接口就会具有可插拔的注解支持包括Feign注解与JAX-RS注解，Feign还支持可插拔的编码器与×××。Feign 灵感来源于Retrofit、JAXRS-2.0和WebSocket，Feign 最初是为了降低统一绑定 Denominator 到 HTTP API 的复杂度，不区分是否支持 Restful。

Spring Cloud 增加了对 Spring MVC的注解，Spring Web 默认使用了HttpMessageConverters, Spring Cloud 集成 Ribbon 和 Eureka 提供的负载均衡的HTTP客户端 Feign。

Feign特性：

声明式REST客户端（伪RPC）
采用了基于接口的注解
同样使用ribbon做负载均衡器

接下来我们尝试一下使用Feign编写REST客户端，实现订单服务调用商品服务接口，看看Feign到底有多方便。在商品和订单服务的项目中，都加入Feign的依赖，pom.xml文件配置的依赖如下：

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

注：若出现使用阿里云的仓库地址不能下载到该依赖的话，可以尝试使用maven中央仓库的地址进行下载

首先到商品服务工程中，新建一个client包。本来应该是新建一个Client模块的，但是为了方便演示，我就直接用包了。在client包下新建一个 ProductClinet 接口，编写代码如下：

package org.zero.example.product.client;

import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.web.bind.annotation.GetMapping;

import java.util.List;

@Component
// 此注解用于声明一个Feign客户端，name属性指定服务的名称
@FeignClient(name = "PRODUCT")
public interface ProductClinet {

    /**
     * 商品列表接口，注意这里的uri要写全
     *
     * @return Product List
     */
    @GetMapping("/product/list")
    List<String> list();
}

我们在使用RestTemplate的时候，都是在订单服务上编写接口调用相关代码的，但是为什么使用Feign就在商品服务上去写这个代码呢？这是因为使用Feign的时候，只需要通过注解就能在接口上声明客户端，当我们在订单服务里面使用的时候，注入这个ProductClinet接口调用相应的方法即可实现商品服务接口的调用。而这些接口属于商品服务对外暴露的接口，由于职责的关系，所以都应该由商品服务去维护，不应该写在订单服务里。

编写好ProductClinet接口的代码后，使用如下命令将这个项目安装到本地的maven仓库中：

mvn clean -Dmaven.test.skip=true install

接着到订单服务的工程中，加入商品服务的依赖，如下：

<dependency>
    <groupId>org.zero.example</groupId>
    <artifactId>product</artifactId>
    <version>0.0.1-SNAPSHOT</version>
</dependency>

然后在启动类中，加上@EnableFeignClients注解表示开启 Feign 客户端以及配置client包的路径，如下：

package org.zero.example.order;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.netflix.eureka.EnableEurekaClient;
import org.springframework.cloud.openfeign.EnableFeignClients;

@EnableEurekaClient
@SpringBootApplication
@EnableFeignClients(basePackages = "org.zero.example.product.client")
public class OrderApplication {

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

修改 OrderController 代码如下：

...

import org.zero.example.product.client.ProductClinet;

@RestController
@RequestMapping("/order")
public class OrderController {

    @Autowired
    private ProductClinet productClinet;

    @GetMapping("/info")
    public List info() {
        return productClinet.list();
    }
}