SpringCloud之服务提供与调用(Ribbon,Feign)

本系列介绍的配置均基于 Spring Boot 2.0.1.RELEASE 版本和 Spring Cloud Finchley.SR1

eureka注册续约流程

启动注册中心

服务提供者生产服务并注册到服务中心中

消费者从服务中心中获取服务并执行

服务提供

1.在spring-cloud-manage下创建一个子项目producer-service

pom.xml文件如下

<?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">

    <parent>

        <artifactId>spring-cloud-manage</artifactId>

        <groupId>org.springcloudmanage</groupId>

        <version>1.0</version>

    </parent>

    <modelVersion>4.0.0</modelVersion>

    <artifactId>producer-service</artifactId>

    <properties>

        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>

        <maven.compiler.source>1.8</maven.compiler.source>

        <maven.compiler.target>1.8</maven.compiler.target>

    </properties>

    <dependencies>

        <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>

    </dependencies>

    <build>

        <finalName>producer-service</finalName>

        <plugins>

            <plugin>

                <groupId>org.springframework.boot</groupId>

                <artifactId>spring-boot-maven-plugin</artifactId>

            </plugin>

        </plugins>

    </build>

</project>

2.创建启动类

Finchley版本已经不需要添加@EnableDiscoveryClient注解,Spring Cloud会自动识别。

@SpringBootApplication

public class ProducerServiceApplication {

    public static void main(String[] args) {

        SpringApplication.run(ProducerServiceApplication.class, args);

    }

}

3.配置文件

spring.application.name=producer-service

server.port=9001

#eureka

eureka.client.serviceUrl.defaultZone=http://localhost:8001/eureka/

spring.application.name服务提供者的名字

server.por服务端口号

eureka.client.serviceUrl.defaultZoneeureka的服务注册地址，如果eureka是多节点，多个地址逗号分隔，具体可以看上一篇博客:服务注册与发现。

多节点eureka服务注册如下：

eureka.client.serviceUrl.defaultZone=http://localhost:8001/eureka/,http://localhost:8002/eureka/

4.Action or Controller类

@RestController

@RequestMapping(value = "/test")

public class ProducerAction {

    @RequestMapping(value = "", method = RequestMethod.GET)

    public String test(String param) {

        return "param is " + param;

    }

}

5.启动服务

服务启动后，访问eureka主页http://localhost:8001/，即可看到如下页面，说明服务已经注册到eureka上了 

6.调用下试试

访问http://localhost:9001/test?param=test，看到返回结果如下

param is test

服务消费 ribbon

Ribbon 了，它是一个基于 HTTP 和 TCP 的客户端负载均衡器。它可以通过在客户端中配置ribbonServerList 来设置服务端列表去轮询访问以达到均衡负载的作用。

当 Ribbon 与 Eureka联合使用时，ribbonServerList会被DiscoveryEnabledNIWSServerList 重写，扩展成从 Eureka 注册中心中获取服务实例列表。同时它也会用 NIWSDiscoveryPing 来取代 IPing，它将职责委托给 Eureka 来确定服务端是否已经启动。

1.在spring-cloud-manage下创建一个子项目consumer-service

pom.xml文件如下

<?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">

    <parent>

        <artifactId>spring-cloud-manage</artifactId>

        <groupId>org.springcloudmanage</groupId>

        <version>1.0</version>

    </parent>

    <modelVersion>4.0.0</modelVersion>

    <artifactId>consumer-service</artifactId>

    <properties>

        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>

        <maven.compiler.source>1.8</maven.compiler.source>

        <maven.compiler.target>1.8</maven.compiler.target>

    </properties>

    <dependencies>

        <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>

    </dependencies>

    <build>

        <plugins>

            <plugin>

                <groupId>org.springframework.boot</groupId>

                <artifactId>spring-boot-maven-plugin</artifactId>

            </plugin>

        </plugins>

    </build>

</project>

spring-cloud-starter-netflix-eureka-client中已经引用了ribbon先关的jar，所需不需要再引入了

2.创建启动类

@SpringBootApplication

public class ConsumerServiceApplication {

    @LoadBalanced

    @Bean

    public RestTemplate restTemplate() {

        return new RestTemplate();

    }

    public static void main(String[] args) {

        SpringApplication.run(ConsumerServiceApplication.class, args);

    }

}

3.配置文件

spring.application.name=consumer-service

server.port=9002

#eureka

eureka.client.serviceUrl.defaultZone=http://localhost:8001/eureka/

4.Action or Controller类

这里注入restTemplate，Spring Cloud Ribbon 自己有拦截器会对 服务名producer-service做解析，自动的去选取服务实例负载均衡调用，并将服务名替换成实际要请求的IP地址和端口

@RestController

@RequestMapping(value = "/ribbon/test")

public class ConsumerAction {

    @Autowired

    private RestTemplate restTemplate;

    @RequestMapping(value = "", method = RequestMethod.GET)

    public String test(String param) {

        String url = "http://producer-service/test/?param=" + param;

        return restTemplate.getForObject(url, String.class);

    }


}

5.启动服务

消费端服务启动成功后，可以看到erueka时已经显示注册成功了

5.调用消费端服务

访问http://localhost:9002/ribbon/test?param=ribbon-test ,可以看到如下结果，说明消费端服务接收到参数后，通过ribbon负载均衡，调用到producer-service的接口。

param is ribbon-test

控制台日志

2018-08-28 16:25:23.397  INFO 3791 --- [nio-9002-exec-1] c.netflix.config.ChainedDynamicProperty  : Flipping property: producer-service.ribbon.ActiveConnectionsLimit to use NEXT property: niws.loadbalancer.availabilityFilteringRule.activeConnectionsLimit = 2147483647

2018-08-28 16:25:23.414  INFO 3791 --- [nio-9002-exec-1] c.n.u.concurrent.ShutdownEnabledTimer    : Shutdown hook installed for: NFLoadBalancer-PingTimer-producer-service

2018-08-28 16:25:23.433  INFO 3791 --- [nio-9002-exec-1] c.netflix.loadbalancer.BaseLoadBalancer  : Client: producer-service instantiated a LoadBalancer: DynamicServerListLoadBalancer:{NFLoadBalancer:name=producer-service,current list of Servers=[],Load balancer stats=Zone stats: {},Server stats: []}ServerList:null

2018-08-28 16:25:23.440  INFO 3791 --- [nio-9002-exec-1] c.n.l.DynamicServerListLoadBalancer      : Using serverListUpdater PollingServerListUpdater

2018-08-28 16:25:23.462  INFO 3791 --- [nio-9002-exec-1] c.netflix.config.ChainedDynamicProperty  : Flipping property: producer-service.ribbon.ActiveConnectionsLimit to use NEXT property: niws.loadbalancer.availabilityFilteringRule.activeConnectionsLimit = 2147483647

2018-08-28 16:25:23.463  INFO 3791 --- [nio-9002-exec-1] c.n.l.DynamicServerListLoadBalancer      : DynamicServerListLoadBalancer for client producer-service initialized: DynamicServerListLoadBalancer:{NFLoadBalancer:name=producer-service,current list of Servers=[192.168.101.238:9001],Load balancer stats=Zone stats: {defaultzone=[Zone:defaultzone; Instance count:1; Active connections count: 0; Circuit breaker tripped count: 0; Active connections per server: 0.0;]

},Server stats: [[Server:192.168.101.238:9001; Zone:defaultZone; Total Requests:0; Successive connection failure:0; Total blackout seconds:0; Last connection made:Thu Jan 01 08:00:00 CST 1970; First connection made: Thu Jan 01 08:00:00 CST 1970; Active Connections:0; total failure count in last (1000) msecs:0; average resp time:0.0; 90 percentile resp time:0.0; 95 percentile resp time:0.0; min resp time:0.0; max resp time:0.0; stddev resp time:0.0]

]}ServerList:org.springframework.cloud.netflix.ribbon.eureka.DomainExtractingServerList@12e48993

2018-08-28 16:25:24.447  INFO 3791 --- [erListUpdater-0] c.netflix.config.ChainedDynamicProperty  : Flipping property: producer-service.ribbon.ActiveConnectionsLimit to use NEXT property: niws.loadbalancer.availabilityFilteringRule.activeConnectionsLimit = 2147483647

可以启动多个producer-service服务测试下实际的负载均衡效果。

服务消费 feign

Feign是一个声明式的Web Service客户端，它使得编写Web Serivce客户端变得更加简单。我们只需要使用Feign来创建一个接口并用注解来配置它既可完成。它具备可插拔的注解支持，包括Feign注解和JAX-RS注解。Feign也支持可插拔的编码和解码。Spring Cloud为Feign增加了对Spring MVC注解的支持，还整合了Ribbon和Eureka来提供均衡负载的HTTP客户端实现。

在实际工作中，我们基本上都是使用Feign来完成调用的。我们通过一个例子来展现 Feign 如何方便的声明对 eureka-producer 服务的定义和调用。

1.consumer-service添加对feign的依赖

<?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">

    <parent>

        <artifactId>spring-cloud-manage</artifactId>

        <groupId>org.springcloudmanage</groupId>

        <version>1.0</version>

    </parent>

    <modelVersion>4.0.0</modelVersion>

    <artifactId>consumer-service</artifactId>

    <properties>

        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>

        <maven.compiler.source>1.8</maven.compiler.source>

        <maven.compiler.target>1.8</maven.compiler.target>

    </properties>

    <dependencies>

        <dependency>

            <groupId>org.springframework.boot</groupId>

            <artifactId>spring-boot-starter-web</artifactId>

        </dependency>

        <dependency>

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

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

        </dependency>

        <dependency>

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

            <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>

        </dependency>

    </dependencies>

    <build>

        <plugins>

            <plugin>

                <groupId>org.springframework.boot</groupId>

                <artifactId>spring-boot-maven-plugin</artifactId>

            </plugin>

        </plugins>

    </build>

</project>

2.启动类上加上feign所需注解

@EnableFeignClients

@SpringBootApplication

public class ConsumerServiceApplication {

    public static void main(String[] args) {

        SpringApplication.run(ConsumerServiceApplication.class, args);

    }

}

3.配置文件

spring.application.name=consumer-service

server.port=9002

#eureka

eureka.client.serviceUrl.defaultZone=http://localhost:8001/eureka/

#开启Hystrix断路器

feign.hystrix.enabled=true

#断路器的超时时间需要大于ribbon的超时时间，不然不会触发重试,缺省为1000

hystrix.command.default.execution.isolation.thread.timeoutInMilliseconds=5000

4.feign 调用

创建feign客户端调用类，其中name为所需调用的服务名，fallback使用Hystrix，当producer-service不可用时，对服务做降级，并返回友好提示

@FeignClient(name = "producer-service", fallback = ProducerServiceFeignClientHystrix.class)

public interface ProducerServiceFeignClient {

    @RequestMapping(value = "/test", method = RequestMethod.GET)

    String test(@RequestParam("param") String param);

}

==注意@RequestParam("param")中name必须要和producer-service服务中的参数名一致==

@Component

public class ProducerServiceFeignClientHystrix implements ProducerServiceFeignClient {

    @Override

    public String test(String param) {

        return "服务[producer-service]无法访问";

    }

}

访问http://localhost:9002/feign/test?param=feign-test，可以看到如下结果

param is feign-test

停止producer-service，再次访问http://localhost:9002/feign/test?param=feign-test，可以看到如下结果，说明fallback已经生效了

服务[producer-service]无法访问

欢迎工作一到五年的Java工程师朋友们加入Java程序员开发： 721575865

群内提供免费的Java架构学习资料（里面有高可用、高并发、高性能及分布式、Jvm性能调优、Spring源码，MyBatis，Netty,Redis,Kafka,Mysql,Zookeeper,Tomcat,Docker,Dubbo,Nginx等多个知识点的架构资料）合理利用自己每一分每一秒的时间来学习提升自己，不要再用"没有时间“来掩饰自己思想上的懒惰！趁年轻，使劲拼，给未来的自己一个交代！

©著作权归作者所有,转载或内容合作请联系作者
  • 人面猴
    序言：七十年代末，一起剥皮案震惊了整个滨河市，随后出现的几起案子，更是在滨河造成了极大的恐慌，老刑警刘岩，带你破解...
    沈念sama阅读 215,723评论 6赞 498
  • 死咒
    序言：滨河连续发生了三起死亡事件，死亡现场离奇诡异，居然都是意外死亡，警方通过查阅死者的电脑和手机，发现死者居然都...
    沈念sama阅读 92,003评论 3赞 391
  • 救了他两次的神仙让他今天三更去死
    文/潘晓璐 我一进店门，熙熙楼的掌柜王于贵愁眉苦脸地迎上来，“玉大人，你说我怎么就摊上这事。” “怎么了？”我有些...
    开封第一讲书人阅读 161,512评论 0赞 351
  • 道士缉凶录：失踪的卖姜人
    文/不坏的土叔 我叫张陵，是天一观的道长。 经常有香客问我，道长，这世上最难降的妖魔是什么？ 我笑而不...
    开封第一讲书人阅读 57,825评论 1赞 290
  • 港岛之恋（遗憾婚礼）
    正文 为了忘掉前任，我火速办了婚礼，结果婚礼上，老公的妹妹穿的比我还像新娘。我一直安慰自己，他们只是感情好，可当我...
    茶点故事阅读 66,874评论 6赞 388
  • 恶毒庶女顶嫁案：这布局不是一般人想出来的
    文/花漫 我一把揭开白布。 她就那样静静地躺着，像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上，一...
    开封第一讲书人阅读 50,841评论 1赞 295
  • 城市分裂传说
    那天，我揣着相机与录音，去河边找鬼。 笑死，一个胖子当着我的面吹牛，可吹牛的内容都是我干的。 我是一名探鬼主播，决...
    沈念sama阅读 39,812评论 3赞 416
  • 双鸳鸯连环套：你想象不到人心有多黑
    文/苍兰香墨 我猛地睁开眼，长吁一口气：“原来是场噩梦啊……” “哼！你这毒妇竟也来了？” 一声冷哼从身侧响起，我...
    开封第一讲书人阅读 38,582评论 0赞 271
  • 万荣杀人案实录
    序言：老挝万荣一对情侣失踪，失踪者是张志新（化名）和其女友刘颖，没想到半个月后，有当地人在树林里发现了一具尸体，经...
    沈念sama阅读 45,033评论 1赞 308
  • 护林员之死
    正文 独居荒郊野岭守林人离奇死亡，尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 37,309评论 2赞 331
  • 白月光启示录
    正文 我和宋清朗相恋三年，在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 39,450评论 1赞 345
  • 活死人
    序言：一个原本活蹦乱跳的男人离奇死亡，死状恐怖，灵堂内的尸体忽然破棺而出，到底是诈尸还是另有隐情，我是刑警宁泽，带...
    沈念sama阅读 35,158评论 5赞 341
  • 日本核电站爆炸内幕
    正文 年R本政府宣布，位于F岛的核电站，受9级特大地震影响，放射性物质发生泄漏。R本人自食恶果不足惜，却给世界环境...
    茶点故事阅读 40,789评论 3赞 325
  • 男人毒药：我在死后第九天来索命
    文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹，春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 31,409评论 0赞 21
  • 一桩弑父案，背后竟有这般阴谋
    文/苍兰香墨 我抬头看了看天上的太阳。三九已至，却和暖如春，着一层夹袄步出监牢的瞬间，已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 32,609评论 1赞 268
  • 情欲美人皮
    我被黑心中介骗来泰国打工， 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留，地道东北人。 一个月前我还...
    沈念sama阅读 47,440评论 2赞 368
  • 代替公主和亲
    正文 我出身青楼，却偏偏与公主长得像，于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子，可洞房花烛夜当晚...
    茶点故事阅读 44,357评论 2赞 352

推荐阅读更多精彩内容