SpringCloud学习系列之二 ----- 服务消费者(Feign)和负载均衡(Ribbon)

前言

本篇主要介绍的是SpringCloud中的服务消费者(Feign)和负载均衡(Ribbon)功能的实现以及使用Feign结合Ribbon实现负载均衡。

SpringCloud Feign

Feign 介绍

开发准备

开发环境

• JDK:1.8
• SpringBoot:2.1.1.RELEASE
• SpringCloud：Finchley

注:不一定非要用上述的版本，可以根据情况进行相应的调整。需要注意的是SpringBoot2.x以后，jdk的版本必须是1.8以上！

确认了开发环境之后，我们再来添加相关的pom依赖。

<dependencies>
    <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-starter</artifactId>
    </dependency>
    <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-starter-netflix-eureka-server</artifactId>
    </dependency>
    <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-starter-openfeign</artifactId>
    </dependency>
</dependencies>

注: 基于SpringBoot1.x以上SpringCloud是Dalston版本的eureka 依赖是 <artifactId>spring-cloud-starter-eureka</artifactId>，feign 依赖是 <artifactId>spring-cloud-starter-feign</artifactId> ，少了个 netflix 。SpringCloud的版本命名方式是通过伦敦的地方来命名的，版本顺序是根据首字母的顺序来的。

SpringCloud Feign 示例

服务端

首先建立一个springcloud-feign-eureka服务的工程，用于做注册中心。配置和之前的基本一样。application.properties添加如下的配置:

配置信息:

spring.application.name=springcloud-feign-eureka-server
server.port=8001
eureka.client.register-with-eureka=false
eureka.client.fetch-registry=false
eureka.client.serviceUrl.defaultZone=http://localhost:8001/eureka/

配置说明:

• spring.application.name： 这个是指定服务名称。
• server.port:服务指定的端口。
• eureka.client.register-with-eureka：表示是否将自己注册到Eureka Server，默认是true。
• eureka.client.fetch-registry：表示是否从Eureka Server获取注册信息，默认为true。
• eureka.client.serviceUrl.defaultZone： 这个是设置与Eureka Server交互的地址，客户端的查询服务和注册服务都需要依赖这个地址。

完成配置信息的添加后，我们再来看代码如何实现。
在服务端这边只需要在SpringBoot启动类添加@EnableEurekaServer注解就可以了，该注解表示此服务是一个服务注册中心服务。

代码示例:

    @EnableEurekaServer
    @SpringBootApplication
    public class FeignEurekaApplication {
      public static void main(String[] args) {
          SpringApplication.run(FeignEurekaApplication.class, args);
          System.out.println("feign注册中心服务启动...");
      }
    }

客户端

这里我们定义两个消费者，springcloud-feign-consumer和springcloud-feign-consumer2，一个使用feign做转发，另一个为一个普通的项目。 添加如上的依赖之后，在application.properties添加如下的配置:

consumer 配置信息:

spring.application.name=springcloud-feign-consumer
server.port=9002
eureka.client.serviceUrl.defaultZone=http://localhost:8001/eureka/

consumer2 配置信息:

spring.application.name=springcloud-feign-consumer2
server.port=9003
eureka.client.serviceUrl.defaultZone=http://localhost:8001/eureka/

配置说明:

• spring.application.name： 这个是客户端的服务名称。如果有多个服务使用同一个名称但是访问地址不同，结合ribbon 使用，则可以实现负载均衡功能。
• server.port:服务指定的端口。
• eureka.client.serviceUrl.defaultZone： 注册中心服务端的地址。

springcloud-feign-consumer

springcloud-feign-consumer服务因为要实现fegin的功能，因此需要在启动类上添加@EnableFeignClients该注解，使用该注解表示启用feign进行远程调用。

启动类代码示例:

    @SpringBootApplication
    @EnableDiscoveryClient
    @EnableFeignClients
    public class FeignConsumerApplication {
        public static void main(String[] args) {
            SpringApplication.run(FeignConsumerApplication.class, args);
              System.out.println("feign第一个消费者服务启动...");
        }
    }

需要定义转发的服务，这里使用@FeignClient注解来实现，该注解表示需要转发服务的名称，该名称在application.properties中进行配置。
这里我们把请求转发到第二个服务springcloud-feign-consumer2。

转发类代码示例:

    @FeignClient(name= "springcloud-feign-consumer2")
    public interface HelloRemote {
        @RequestMapping(value = "/hello")
         public String hello(@RequestParam(value = "name") String name);
    }

我们还需要提供一个入口供外部调用，然后调用上述的的方法进行转发。

控制层代码示例:

    @RestController
    public class ConsumerController {

        @Autowired
        HelloRemote helloRemote;

        @RequestMapping("/hello/{name}")
        public String index(@PathVariable("name") String name) {
            System.out.println("接受到请求参数:"+name+",进行转发到其他服务");
            return helloRemote.hello(name);
        }
    }

springcloud-feign-consumer2

这个服务的代码就比较简单了，只是一个普通的服务，提供一个接口然后打印信息即可。

启动类代码示例:

    @SpringBootApplication
    @EnableDiscoveryClient
    public class FeignConsumerApplication2 {
        public static void main(String[] args) {
            SpringApplication.run(FeignConsumerApplication2.class, args);
              System.out.println("feign第二个消费者服务启动...");
        }
    }

控制层代码示例:

    @RestController
    public class ConsumerController {

        @RequestMapping("/hello")
        public String index(@RequestParam String name) {
            return name+",Hello World";
        }
    }

功能测试

完成如上的工程开发之后，我们依次启动服务端和客户端的三个程序，然后在浏览器界面输入:http://localhost:8001/，即可查看注册中心的信息。

在浏览器输入：

返回:

pancm,Hello World

说明可以直接访问第二个消费服务。

然后再输入:

通过第一个消费服务调用第二个服务。

控制台打印:

接受到请求参数:pancm,进行转发到其他服务

界面返回结果:

pancm,Hello World

示例图:

出现以上结果说明客户端已经成功的通过feign调用了远程服务hello，并且将结果返回到了浏览器。

SpringCloud Ribbon

Ribbon 介绍

开发准备

开发环境

• JDK:1.8
• SpringBoot:2.1.1.RELEASE
• SpringCloud：Finchley

注:不一定非要用上述的版本，可以根据情况进行相应的调整。需要注意的是SpringBoot2.x以后，jdk的版本必须是1.8以上！

确认了开发环境之后，我们再来添加相关的pom依赖。

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

注: 基于SpringBoot1.x以上SpringCloud是Dalston版本的eureka 依赖是 <artifactId>spring-cloud-starter-eureka</artifactId>，feign 依赖是 <artifactId>spring-cloud-starter-ribbon</artifactId> ，少了个 netflix 。SpringCloud的版本命名方式是通过伦敦的地方来命名的，版本顺序是根据首字母的顺序来的。

SpringCloud Ribbon 示例

服务端

首先建立一个springcloud-ribbon-eureka服务的工程，用于做注册中心。配置和代码之前的基本一样，除了端口和打印信息，这里就不在说明了。

客户端

这里我们定义三个服务，一个服务使用Ribbon做负载均衡，另外两个做普通的服务，服务名称依次为springcloud-ribbon-consumer、springcloud-ribbon-consumer2和springcloud-ribbon-consumer3。 添加如上的依赖之后，在application.properties添加如下的配置:

consumer 配置信息:

spring.application.name=springcloud-ribbon-consumer
server.port=9006
eureka.client.serviceUrl.defaultZone=http://localhost:8003/eureka/

consumer2 配置信息:

spring.application.name=springcloud-ribbon-consumer2
server.port=9007
eureka.client.serviceUrl.defaultZone=http://localhost:8003/eureka/

consumer3 配置信息:

这里的服务名称和另一个服务的名称保持一致才能实现负载均衡功能。

spring.application.name=springcloud-ribbon-consumer2
server.port=9008
eureka.client.serviceUrl.defaultZone=http://localhost:8003/eureka/

配置说明:

• spring.application.name： 这个是客户端的服务名称。如果有多个服务使用同一个名称但是访问地址不同，结合ribbon 使用，则可以实现负载均衡功能。
• server.port:服务指定的端口。
• eureka.client.serviceUrl.defaultZone： 注册中心服务端的地址。

springcloud-ribbon-consumer

使用Ribbon实现负载均衡，只需要在启动类中实例化RestTemplate，通过@LoadBalanced注解开启均衡负载能力.。

启动类代码示例:

    @SpringBootApplication
    @EnableDiscoveryClient
    public class RibbonConsumerApplication {
        public static void main(String[] args) {
            SpringApplication.run(RibbonConsumerApplication.class, args);
            System.out.println("ribbon第一个消费者服务启动...");
        }

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

需要定义转发的服务，这里使用RestTemplate来进行调用，调用另外一个服务的名称。

转发类代码示例:

    @RestController
    public class ConsumerController {

        @Autowired
        RestTemplate restTemplate;

        @RequestMapping("/hello")
        public String hello() {
            //进行远程调用
            return restTemplate.getForObject("http://springcloud-ribbon-consumer2/hello/?name=xuwujing", String.class);
        }
    }
    

springcloud-ribbon-consumer2和springcloud-ribbon-consumer3代码基本和fegin中的springcloud-feign-consumer一样，因此这里就不在贴代码了。

功能测试

完成如上的工程开发之后，我们依次启动服务端和客户端的四个程序，然后在浏览器界面输入:http://localhost:8003/，即可查看注册中心的信息。

在浏览器输入：

然后进行重复访问，返回如下结果:

xuwujing,Hello World!
xuwujing,Hello World! 这是另一个服务！
xuwujing,Hello World!
xuwujing,Hello World! 这是另一个服务！
xuwujing,Hello World!
xuwujing,Hello World! 这是另一个服务！

说明已经实现了负载均衡功能了。

我们从上述的结果中发现了一点，这个调用貌似是有规律的，两个服务进行来回调用。那么根据这个我们发现了，负载均衡是由策略的。上述的这个示例的策略就是其中的一个RoundRobinRule轮询策略。

这里就顺便说下Ribbon的策略，Ribbon一共有7中策略，默认使用的策略是轮询。策略说明如下表格:

这里也顺便说明如何指定一个策略使用方法。

最简单的方式

在application.properties添加如下配置:

springcloud-ribbon-consumer2.ribbon.NFLoadBalancerRuleClassName=com.netflix.loadbalancer.RandomRule

该配置的意思是为springcloud-ribbon-consumer2服务指定随机策略。

另一种方式

新建一个类，通过@Bean注解指定策略。

    @Configuration
    public class RibbonConfiguration{
          @Bean
          public IRule ribbonRule(){
              return new RandomRule();
         }
    }

然后再通过@RibbonClien注解指定服务。

    @RibbonClient(name="springcloud-ribbon-consumer2", configuration=RibbonConfiguration.class)
    public class HelloRibbon{
    }

注: 如果有的服务没有在Eureka进行注册，可以使用ribbon.listOfServers方式在配置文件中来指定服务。

例如:

springcloud-ribbon-consumer2.ribbon.listOfServers:localhost:9007,localhost:9008

添加好了该配置之后，我们重启springcloud-ribbon-consumer服务，然后依旧重复访问 http://localhost:9006//hello 该地址，
访问的结果如下:

xuwujing,Hello World!
xuwujing,Hello World! 这是另一个服务！
xuwujing,Hello World! 这是另一个服务！
xuwujing,Hello World!
xuwujing,Hello World!
xuwujing,Hello World!

可以看到已经成功实现了随机访问的策略！

SpringCloud Fegin结合Ribbon实现负载均衡

Fegin包含了Ribbon，可以直接实现负载均衡功能。这里我们就在Ribbon的项目稍微进行改造下实现该功能。

首先在pom文件添加Fegin的依赖包。

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

然后在springcloud-ribbon-consumer项目的启动类上添加@EnableFeignClients注解，启用feign进行远程调用。

添加完成之后，新建一个类，实现feign远程调用。
代码如下:

    @FeignClient(name= "springcloud-ribbon-consumer2")
    public interface HelloRemote {
        @RequestMapping(value = "/hello")
        public String hello(@RequestParam(value = "name") String name);
    }

最后在提供一个新的接口供外部调用。这里就直接在之前的代码上新加一个接口了。
代码如下:

    @RestController
    public class ConsumerController {

        @Autowired
        RestTemplate restTemplate;

        @RequestMapping("/hello")
        public String hello() {
            return restTemplate.getForObject("http://springcloud-ribbon-consumer2/hello/?name=xuwujing", String.class);
        }


        @Autowired
        HelloRemote helloRemote;

        @RequestMapping("/hello/{name}")
        public String index(@PathVariable("name") String name) {
            System.out.println("接受到请求参数:"+name+",进行转发到其他服务!");
            return helloRemote.hello(name);
        }
    }

添加完之后，重启springcloud-ribbon-consumer服务，然后依旧重复访问 http://localhost:9006//hello/pancm 该地址，
访问的结果如下:

pancm,Hello World!
pancm,Hello World! 这是另一个服务！
pancm,Hello World!
pancm,Hello World! 这是另一个服务！
pancm,Hello World!
pancm,Hello World! 这是另一个服务！

示例图:

其他

项目地址

基于SpringBoot1.x、SpringCloud的Dalston版本开发的地址:https://github.com/xuwujing/springcloud-study

基于SpringBoot1.x、SpringCloud 的Dalston版本开发的地址: https://github.com/xuwujing/springcloud-study-old

如果感觉项目不错，希望能给个star，谢谢!

音乐推荐

一首非常棒的纯音乐 NEXT TO YOU ，强烈推荐！

原创不易，如果感觉不错，希望给个推荐！您的支持是我写作的最大动力！

作者：虚无境
博客园出处：http://www.cnblogs.com/xuwujing
CSDN出处：http://blog.csdn.net/qazwsxpcm　　　　
个人博客出处：http://www.panchengming.com