四:服务消费(LoadBalancerClient、Ribbon、Feign)

通过上一篇《三:服务的注册与发现(Eureka》,我们已经成功地将服务提供者:provider-test注册到了Eureka服务注册中心上了,那么接下来我们要学习的就是:如何去消费服务提供者的接口?

4.1使用LoadBalancerClient

在Spring Cloud Commons中提供了大量的与服务治理相关的抽象接口,包括DiscoveryClient、LoadBalancerClient等。从LoadBalancerClient接口的命名中,可以看出这是一个负载均衡客户端的抽象定义,下面笔者将使用Spring Cloud提供的负载均衡器客户端接口来实现服务的消费。

首先,将利用上一篇中构建的eureka-server作为服务注册中心、provider-test作为服务提供者为基础。

  • 创建一个叫voyer-consumer-test的Spring Boot项目,引入相关maven包。
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>

    <groupId>com.voyer</groupId>
    <artifactId>voyer-consumer-test</artifactId>
    <version>0.0.1-SNAPSHOT</version>
    <packaging>jar</packaging>

    <name>voyer-consumer-test</name>
    <description>Demo project for Spring Boot</description>

    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.0.0.RELEASE</version>
        <relativePath/> <!-- lookup parent from repository -->
    </parent>

    <properties>
        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
        <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
        <java.version>1.8</java.version>
        <spring-cloud.version>Finchley.M9</spring-cloud.version>
    </properties>


    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-actuator</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
        </dependency>

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>
    </dependencies>

    <dependencyManagement>
        <dependencies>
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-dependencies</artifactId>
                <version>${spring-cloud.version}</version>
                <type>pom</type>
                <scope>import</scope>
            </dependency>
        </dependencies>
    </dependencyManagement>

    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
            </plugin>
        </plugins>
    </build>

    <repositories>
        <repository>
            <id>spring-snapshots</id>
            <name>Spring Snapshots</name>
            <url>https://repo.spring.io/snapshot</url>
            <snapshots>
                <enabled>true</enabled>
            </snapshots>
        </repository>
        <repository>
            <id>spring-milestones</id>
            <name>Spring Milestones</name>
            <url>https://repo.spring.io/milestone</url>
            <snapshots>
                <enabled>false</enabled>
            </snapshots>
        </repository>
    </repositories>


</project>
  • 然后配置application.yml,指定服务注册中心地址、端口号以及名称
eureka:
  client:
    serviceUrl:
      defaultZone: http://localhost:8761/eureka/
server:
  port: 8764
spring:
  application:
    name: consumer-test
  • 在默认的启动程序中注入RestTemplate
@SpringBootApplication
public class VoyerConsumerTestApplication {

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

    @Bean
    public RestTemplate restTemplate() {
        return new RestTemplate();
    }
}
  • 创建com.voyer.web包路径,创建ConsumerController,并注入 LoadBalancerClientRestTemplate,并在/hi接口的实现中,先通过loadBalancerClientchoose函数来负载均衡的选出一个provider-test的服务实例,这个服务实例的基本信息存储在ServiceInstance中,然后通过这些对象中的信息拼接出访问/hi接口的详细地址,最后再利用RestTemplate对象实现对服务提供者接口的调用:
@RestController
public class ConsumerController {
    @Autowired
    LoadBalancerClient loadBalancerClient;
    @Autowired
    RestTemplate restTemplate;

    @RequestMapping("/hi")
    public String hello(){
        ServiceInstance serviceInstance = loadBalancerClient.choose("provider-test");
        String url = "http://" + serviceInstance.getHost() + ":" + serviceInstance.getPort() + "/hi";
        System.out.println(url);
        return restTemplate.getForObject(url, String.class);
    }
}

访问http://localhost::8764/hi ,会发现每次访问的返回的信息会循环输出hello world! I am from 8763hello world! I am from 8762

4.2使用Ribbon

Spring Cloud Ribbon是基于Netflix Ribbon实现的一套客户端负载均衡的工具。它是一个基于HTTP和TCP的客户端负载均衡器。它可以通过在客户端中配置ribbonServerList来设置服务端列表去轮询访问以达到均衡负载的作用。
每个load balancer都是组件的一部分,这些组件协同工作,Spring Cloud通过使用RibbonClientConfiguration为每个指定的客户端创建一个新的套装,这包括ILoadBalancer、RestClient和ServerListFilter。

  • 创建一个叫voyer-consumer-ribbon的Spring Boot项目,(操作顺序同上)引入相关maven包
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-ribbon</artifactId>
        </dependency>
  • 修改默认启动类。增加为@EnableEurekaClient注解(此处为什么不用@EnableDiscoveryClient,读者可以百度一下这两者的区别),RestTemplate增加@LoadBalanced注解:
@SpringBootApplication
@EnableEurekaClient
public class VoyerConsumerRibbonApplication {

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

    @Bean
    @LoadBalanced
    public RestTemplate restTemplate() {
        return new RestTemplate();
    }
}
  • 修改配置文件application.yml
eureka:
  client:
    registerWithEureka: false
    serviceUrl:
      defaultZone: http://localhost:8761/eureka/
server:
  port: 8765
spring:
  application:
    name: consumer-ribbon
  • 修改ConsumerController:
@RestController
public class ConsumerController {
    @Autowired
    RestTemplate restTemplate;
    @RequestMapping("/hi")
    public String hello(){
        return restTemplate.getForObject("http://PROVIDER-TEST/hi", String.class);
    }
}

启动程序,然后访问http://localhost:8765,会发现

hello world! I am from 8762
hello world! I am from 8763

这两个循环出现。到此ribbon消费者成功。

4.3使用Feign

Feign是一个声明性的web服务客户端,它使编写web服务客户机变得更容易。使用Feign创建接口并对其进行注释。它有可插入的注释支持,包括Feign注释和JAX-RS注释。Feign还支持可插入式的编码器和解码器。Spring Cloud增加了对Spring MVC注释的支持,并支持在Spring Web中使用默认的HttpMessageConverters。Spring Cloud集成了Ribbon和Eureka,在使用Feign时提供负载平衡的http客户端。(来自有道翻译)
总结两点:1、Feign采用的是接口加注解;2、Feign 整合了ribbon

  • 创建一个叫voyer-consumer-feign的Spring Boot项目,(操作顺序同上)引入相关maven包
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-feign</artifactId>
        </dependency>
  • 配置文件:registerWithEureka: false自身是消费者,不注册为服务提供者。
eureka:
  client:
    registerWithEureka: false
    serviceUrl:
      defaultZone: http://localhost:8761/eureka/
server:
  port: 8766
spring:
  application:
    name: consumer-feign
  • 默认启动类增加@EnableDiscoveryClient@EnableFeignClients注解:
@SpringBootApplication
@EnableDiscoveryClient
@EnableFeignClients
public class VoyerConsumerFeignApplication {

    public static void main(String[] args) {
        SpringApplication.run(VoyerConsumerFeignApplication.class, args);
    }
}
  • 创建service包路径,然后新建一个ConsumerService的接口,通过@ FeignClient(“服务名”),来指定调用哪个服务:
@FeignClient(value = "provider-test")
public interface ConsumerService {
    @RequestMapping(value = "/hi",method = RequestMethod.GET)
    String hiFromProvider();
}
  • 创建com.voyer.web包路径,创建ConsumerController:
@RestController
public class ConsumerController {
    @Autowired
    ConsumerService consumerService;
    @RequestMapping(value = "/hi",method = RequestMethod.GET)
    public String hi(){
        return consumerService.hiFromProvider();
    }
}

启动程序,然后访问http://localhost:8766,会发现

hello world! I am from 8762
hello world! I am from 8763

这两个循环出现。到此feign消费者成功。

最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 214,904评论 6 497
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 91,581评论 3 389
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 160,527评论 0 350
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 57,463评论 1 288
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 66,546评论 6 386
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 50,572评论 1 293
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 39,582评论 3 414
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 38,330评论 0 270
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 44,776评论 1 307
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 37,087评论 2 330
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 39,257评论 1 344
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 34,923评论 5 338
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 40,571评论 3 322
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 31,192评论 0 21
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 32,436评论 1 268
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 47,145评论 2 366
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 44,127评论 2 352

推荐阅读更多精彩内容

  • Spring Cloud为开发人员提供了快速构建分布式系统中一些常见模式的工具(例如配置管理,服务发现,断路器,智...
    卡卡罗2017阅读 134,647评论 18 139
  • (git上的源码:https://gitee.com/rain7564/spring_microservices_...
    sprainkle阅读 15,088评论 17 20
  • 1 为什么需要服务发现 简单来说,服务化的核心就是将传统的一站式应用根据业务拆分成一个一个的服务,而微服务在这个基...
    谦小易阅读 25,086评论 4 93
  • 软件是有生命的,你做出来的架构决定了这个软件它这一生是坎坷还是幸福。 本文不是讲解如何使用Spring Cloud...
    Bobby0322阅读 22,637评论 3 166
  • 文字它真的是虚拟 我只是恰好拿来装逼 别问我沾染了墨水几滴 我就好执笔你别去质疑 我能否写上几行佳句 连我都无法洞...
    柚宝妈咪阅读 221评论 8 3