查看原文
其他

Spring Cloud Alibaba基础教程:支持的几种服务消费方式

The following article is from 程序猿DD Author 翟永超


程序员DD

读完需要

10分钟

速读仅需4分钟

通过 Spring Cloud Alibaba基础教程:使用Nacos实现服务注册与发现 一文的学习,我们已经学会如何使用Nacos来实现服务的注册与发现,同时也介绍如何通过LoadBalancerClient接口来获取某个服务的具体实例,并根据实例信息来发起服务接口消费请求。但是这样的做法需要我们手工的去编写服务选取、链接拼接等繁琐的工作,对于开发人员来说非常的不友好。所以接下来,我们再来看看除此之外,还支持哪些其他的服务消费方式。

1


   

使用RestTemplate

在之前的例子中,已经使用过RestTemplate来向服务的某个具体实例发起HTTP请求,但是具体的请求路径是通过拼接完成的,对于开发体验并不好。但是,实际上,在Spring Cloud中对RestTemplate做了增强,只需要稍加配置,就能简化之前的调用方式。

比如:

  1. @EnableDiscoveryClient

  2. @SpringBootApplication

  3. public class TestApplication {


  4.    public static void main(String[] args) {

  5.        SpringApplication.run(TestApplication.class, args);

  6.    }


  7.    @Slf4j

  8.    @RestController

  9.    static class TestController {


  10.        @Autowired

  11.        RestTemplate restTemplate;


  12.        @GetMapping("/test")

  13.        public String test() {

  14.            String result = restTemplate.getForObject("http://alibaba-nacos-discovery-server/hello?name=didi", String.class);

  15.            return "Return : " + result;

  16.        }

  17.    }


  18.    @Bean

  19.    @LoadBalanced

  20.    public RestTemplate restTemplate() {

  21.        return new RestTemplate();

  22.    }


  23. }

可以看到,在定义RestTemplate的时候,增加了@LoadBalanced注解,而在真正调用服务接口的时候,原来host部分是通过手工拼接ip和端口的,直接采用服务名的时候来写请求路径即可。在真正调用的时候,Spring Cloud会将请求拦截下来,然后通过负载均衡器选出节点,并替换服务名部分为具体的ip和端口,从而实现基于服务名的负载均衡调用。

关于这种方式,可在文末仓库查看完整代码示例。而对于这种方式的实现原理,可以参考我之前写的这篇文章的前半部分:Spring Cloud源码分析(二)Ribbon

2


   

使用WebClient

WebClient是Spring 5中最新引入的,可以将其理解为reactive版的RestTemplate。下面举个具体的例子,它将实现与上面RestTemplate一样的请求调用:

  1. @EnableDiscoveryClient

  2. @SpringBootApplication

  3. public class TestApplication {


  4.    public static void main(String[] args) {

  5.        SpringApplication.run(TestApplication.class, args);

  6.    }


  7.    @Slf4j

  8.    @RestController

  9.    static class TestController {


  10.        @Autowired

  11.        private WebClient.Builder webClientBuilder;


  12.        @GetMapping("/test")

  13.        public Mono<String> test() {

  14.            Mono<String> result = webClientBuilder.build()

  15.                    .get()

  16.                    .uri("http://alibaba-nacos-discovery-server/hello?name=didi")

  17.                    .retrieve()

  18.                    .bodyToMono(String.class);

  19.            return result;

  20.        }

  21.    }


  22.    @Bean

  23.    @LoadBalanced

  24.    public WebClient.Builder loadBalancedWebClientBuilder() {

  25.        return WebClient.builder();

  26.    }


  27. }

可以看到,在定义WebClient.Builder的时候,也增加了@LoadBalanced注解,其原理与之前的RestTemplate时一样的。关于WebClient的完整例子也可以通过在文末的仓库中查看。

3


   

使用Feign

上面介绍的RestTemplate和WebClient都是Spring自己封装的工具,下面介绍一个Netflix OSS中的成员,通过它可以更方便的定义和使用服务消费客户端。下面也举一个具体的例子,其实现内容与上面两种方式结果一致:

第一步:在pom.xml中增加openfeign的依赖:

  1. <dependency>

  2.    <groupId>org.springframework.cloud</groupId>

  3.    <artifactId>spring-cloud-starter-openfeign</artifactId>

  4. </dependency>

第二步:定义Feign客户端和使用Feign客户端:

  1. @EnableDiscoveryClient

  2. @SpringBootApplication

  3. @EnableFeignClients

  4. public class TestApplication {


  5.    public static void main(String[] args) {

  6.        SpringApplication.run(TestApplication.class, args);

  7.    }


  8.    @Slf4j

  9.    @RestController

  10.    static class TestController {


  11.        @Autowired

  12.        Client client;


  13.        @GetMapping("/test")

  14.        public String test() {

  15.            String result = client.hello("didi");

  16.            return "Return : " + result;

  17.        }

  18.    }



  19.    @FeignClient("alibaba-nacos-discovery-server")

  20.    interface Client {


  21.        @GetMapping("/hello")

  22.        String hello(@RequestParam(name = "name") String name);


  23.    }


  24. }

这里主要先通过@EnableFeignClients注解开启扫描Spring Cloud Feign客户端的功能;然后又创建一个Feign的客户端接口定义。使用@FeignClient注解来指定这个接口所要调用的服务名称,接口中定义的各个函数使用Spring MVC的注解就可以来绑定服务提供方的REST接口,比如下面就是绑定alibaba-nacos-discovery-server服务的/hello接口的例子。最后,在Controller中,注入了Client接口的实现,并调用hello方法来触发对服务提供方的调用。关于使用Feign的完整例子也可以通过在文末的仓库中查看。

4


   

深入思考

如果之前已经用过Spring Cloud的读者,肯定会这样的感受:不论我用的是RestTempalte也好、还是用的WebClient也好,还是用的Feign也好,似乎跟我用不用Nacos没啥关系?我们在之前介绍Eureka和Consul的时候,也都是用同样的方法来实现服务调用的,不是吗?

确实是这样,对于Spring Cloud老手来说,就算我们更换了Nacos作为新的服务注册中心,其实对于我们应用层面的代码是没有影响的。那么为什么Spring Cloud可以带给我们这样的完美编码体验呢?实际上,这完全归功于Spring Cloud Common的封装,由于在服务注册与发现、客户端负载均衡等方面都做了很好的抽象,而上层应用方面依赖的都是这些抽象接口,而非针对某个具体中间件的实现。所以,在Spring Cloud中,我们可以很方便的去切换服务治理方面的中间件。

5


   

代码示例

本文示例读者可以通过查看下面仓库:

  • Github:https://github.com/dyc87112/SpringCloud-Learning/

  • Gitee:https://gitee.com/didispace/SpringCloud-Learning/

其中,本文的几种示例可查看下面的几个项目:

  • alibaba-nacos-discovery-server:服务提供者,必须启动

  • alibaba-nacos-discovery-client-resttemplate:使用RestTemplate消费

  • alibaba-nacos-discovery-client-webclient:使用WebClient消费

  • alibaba-nacos-discovery-client-feign:使用Feign消费

如果您对这些感兴趣,欢迎star、follow、收藏、转发给予支持!

6


   

以下专题教程也许您会有兴趣

  • Spring Boot基础教程

  • Spring Cloud基础教程


推荐: Spring Cloud Alibaba基础教程:使用Nacos实现服务注册与发现

上一篇:了解一下Spring中用了哪些设计模式?这样回答面试官才稳


 关注公众号

点击原文阅读更多



    您可能也对以下帖子感兴趣

    文章有问题?点此查看未经处理的缓存