Ribbon实现负载均衡和服务调用

2020-09-23  本文已影响0人  Angle_洛熙

Ribbon的工作原理

Ribbon是Netfix公司的开源项目，是基于HTTP和TCP的客户端负载均衡组件，她是不可以独立部署的。Spring Cloud Ribbon基于Ribbon实现，基于轮训、随机等规则自动调用服务，也可以自定义负载均衡算法。

Ribbon支持的负载均衡策略

负载均衡策略主要有几种：

自定义负载均衡策略

1.添加依赖和配置

添加Web和Ribbon的依赖

  <dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-web</artifactId>
  </dependency>
  <!--Ribbon 依赖-->
  <dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-netflix-ribbon</artifactId>
  </dependency>

添加配置项

spring.application.name=RibbonRule
server.port=9003
logging.level.root=DEBUG
provider.ribbon.listOfServers=localhost:8504,localhost:8505

2.开启负载均衡支持

在启动类中添加注解#@LoadBalnced以开启客户端负载均衡，然后实例化RestTemplate见以下代码：

    /**
     * 表示开启客户端负载均衡
     */
    @LoadBalanced
    @Bean
    RestTemplate restTemplate() {
        return new RestTemplate();
    }

3.编写配置类，配置规则

配置类注解@Configuration，并用注解@RibbonClient配置服务名，然后实例了Ribbon规则

@Configuration
@RibbonClient(name = "provider", configuration = RibbonClientConfiguration.class)
public class RibbonConfig {
    @Bean
    public IRule iRule() {
        return new RandomRule();
    }
}

除配置方式以外，还可以用配置文件的方式进行配置

ServiceA.ribbon.NFLoadBalancerRuleClassName:com.netflix.loadbalance.RandomRule

其中“ServiceA”代表对服务A进行配置。

4.编写控制器

在控制器中编写测试代码，用于测试自定义的负载均衡策略。

@RestController
public class TestController {
    @Autowired
    private LoadBalancerClient loadBalancerClient;
    private static final SimpleDateFormat SDF = new SimpleDateFormat("yyyy-MM-dd hh:mm:ss");

    @GetMapping("/test")
    public String test() {
        ServiceInstance serviceInstance = loadBalancerClient.choose("provider");
        String result = serviceInstance.getHost() + serviceInstance.getPort() + " " + SDF.format(new Date());
        System.out.println(result);
        return result;
    }
}

5.测试策略

多次访问http://localhost:9003/test，可以查看轮训结果。

Feign

SpringCloud的“服务发现”除可以用RestTemplate客户端实现外，还可以用Feign客户端实现。Feign是一个声明式Web Service客户端，它使得编写Web Service客户端变得容易。
Feign客户端过程：
（1）建立与“服务提供者”的网络连接
（2）构造请求
（3）发送请求到“服务提供者”
（4）处理“服务提供者”返回的响应结果。
在项目中，在接口中使用了注解@FeignClient，则Feign客户端会针对这个接口创建一个动态代理。调用该接口，实质就是调用Feign客户端创建的动态代理：Feign客户端的动态代理会根据接口上的@RequestMapping等注解动态构造要请求的服务地址和方法，并针对这个地址发起请求并解析响应。

添加依赖和配置

  <!--Consul 依赖-->
  <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-starter-consul-discovery</artifactId>
 </dependency>

   <!--Openfeign 依赖-->
        <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-starter-openfeign</artifactId>
        <version>2.1.2.RELEASE</version>
  </dependency>

spring.application.name=Feign Configuration
server.port=8701
spring.cloud.consul.host=127.0.0.1
spring.cloud.consul.port=8500
#因为不提供，所以设置不需要将其注册到Consul
spring.cloud.consul.discovery.register=false
logging.level.com.ping.feign=DEBUG

添加支持

在启动类中添加注解@EnableDiscoveryClient（用于支持“服务中心”）和@EnableFeignClients（用于支持Feign）。

自定义Feign的配置

@Configuration
public class FeignConfig {
    @Bean
    Logger.Level feignLoggerLevel() {
        // 记录请求响应的标题，正文和元数据
        return Logger.Level.FULL;
    }
}

用feign.Contract.Default将契约改为Feign原生的契约，然后即可使用Feign自带的注解了。

自定义的Feign的接口

因为上面配置了"feign.Contract.Default"，所以在接口中可以使用Feign原生的注解@RequestLine了。

@FeignClient(contextId = "feignClient", name = "service-provider", configuration = FeignConfiguration.class)
public interface MyFeignClient {
    /**
     * Spring MVC注解修改为Feign自带的注解；
     * 使用feign自带的注解@RequestLine；
     */
    @RequestLine("GET /hello")
    public String hello();
}

用post方式构建多参数请求

如果“服务提供者”是通过注解@RequestBody获取数据的，则可以通过以下代码来发送请求：

@FeignClient(name="service-provider")
public interface MyFeignClient {
      @PostMapping(value="/post")
      public User post(@RequestBody User user);
}

Ribbon和Feign的区别

上一篇 下一篇

猜你喜欢

热点阅读