Ribbon如何负载均衡地消费microservice-provider-user
更新:HHH   时间:2023-1-7


这篇文章给大家介绍Ribbon如何负载均衡地消费microservice-provider-user,内容非常详细,感兴趣的小伙伴们可以参考借鉴,希望对大家能有所帮助。

  要想消费microservice-provider-user的服务是很简单的,我们只需要使用RestTemplate即可,或者例如HttpClient之类的http工具也是可以的。但是在集群环境下,我们必然是每个服务部署多个实例,那么服务消费者消费服务提供者时的负载均衡又要如何做呢?

  1.准备工作

  启动注册中心:microservice-discovery-eureka

  启动服务提供方:microservice-provider-user

  修改microservice-provider-user的端口为8001,另外启动一个实例

  此时,访问http://discovery:8761

  可以在Eureka中看到microservice-provider-user有两个实例在运行。

  下面我们创建一个新的微服务(microservice-consumer-movie-*),负载均衡地消费microservice-provider-user的服务。

  2.Ribbon介绍

  Ribbon是Netflix发布的开源项目,主要功能是提供客户端的软件负载均衡算法,将Netflix的中间层服务连接在一起。Ribbon客户端组件提供一系列完善的配置项如连接超时,重试等。简单的说,就是在配置文件中列出Load Balancer后面所有的机器,Ribbon会自动的帮助你基于某种规则(如简单轮询,随即连接等)去连接这些机器。我们也很容易使用Ribbon实现自定义的负载均衡算法。简单地说,Ribbon是一个客户端负载均衡器。Ribbon工作时分为两步:第一步先选择 Eureka Server, 它优先选择在同一个Zone且负载较少的Server;第二步再根据用户指定的策略,在从Server取到的服务注册列表中选择一个地址。其中Ribbon提供了三种策略:轮询、断路器和根据响应时间加权。

  3.开发

  创建一个Maven项目,并在pom.xml中加入如下内容:

  xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://m

  aven.apache.org/xsd/maven-4.0.0.xsd">

  4.0.0

  microservice-consumer-movie-ribbon

  jar

  com.itmuch.cloud

  spring-cloud-microservice-study

  0.0.1-SNAPSHOT

  org.springframework.cloud

  spring-cloud-starter-eureka

  org.springframework.cloud

  spring-cloud-starter-ribbon

  org.springframework.boot

  spring-boot-starter-actuator

  启动类:MovieRibbonApplication.java。使用@LoadBalanced注解,为RestTemplate开启负载均衡的能力。

  @SpringBootApplication

  @EnableDiscoveryClient

  public class MovieRibbonApplication {

  /**

  * 实例化RestTemplate,通过@LoadBalanced注解开启均衡负载能力.

  * @return restTemplate

  */

  @Bean

  @LoadBalanced

  public RestTemplate restTemplate() {

  return new RestTemplate();

  }

  public static void main(String[] args) {

  SpringApplication.run(MovieRibbonApplication.class, args);

  }

  }

  实体类:User.java

  public class User {

  private Long id;

  private String username;

  private Integer age;

  ...

  // getters and setters

  }

  Ribbon的测试类:RibbonService.java

  @Service

  public class RibbonService {

  @Autowired

  private RestTemplate restTemplate;

  public User findById(Long id) {

  // http://服务提供者的serviceId/url

  return this.restTemplate.getForObject("http://microservice-p

  rovider-user/" + id, User.class);

  }无锡×××医院 https://yyk.familydoctor.com.cn/20612/

  }

  controller:RibbonController.java

  @RestController

  public class RibbonController {

  @Autowired

  private RibbonService ribbonService;

  @GetMapping("/ribbon/{id}")

  public User findById(@PathVariable Long id) {

  return this.ribbonService.findById(id);

  }

  }

  application.yml

  server:

  port: 8010

  spring:

  application:

  name: microservice-consumer-movie-ribbon

  eureka:

  client:

  serviceUrl:

  instance:

  preferIpAddress: true

  启动后,访问多次http://localhost:8010/ribbon/1,返回结果:

  {

  "id": 1,

  "username": "Tom",

  "age": 12

  }

  然后打开两个microservice-provider-user实例的控制台,发现两个实例都输出了类似如下的日志内容:

  Hibernate: select user0_.id as id1_0_0_, user0_.age as age2_0_0_,

  user0_.username as username3_0_0_ from user user0_ where user0_.id=?

  2016-09-13 21:38:56.719 TRACE 17404 --- [nio-8000-exec-1] o.h.type.descriptor.sql.BasicBinder :

  binding parameter [1] as [BIGINT] - [1]

  2016-09-13 21:38:56.720 TRACE 17404 --- [nio-8000-exec-1] o.h.type.descriptor.sql.BasicExtractor :

  extracted value ([age2_0_0_] : [INTEGER]) - [12]

  2016-09-13 21:38:56.720 TRACE 17404 --- [nio-8000-exec-1] o.h.type.descriptor.sql.BasicExtractor :

  extracted value ([username3_0_0_] : [VARCHAR]) - [Tom]

  2016-09-13 21:39:10.588 INFO 17404 --- [trap-executor-0] c.n.d.s.r.aws.ConfigClusterResolver :

  Resolving eureka endpoints

  via configuration

  至此,我们已经通过Ribbon在客户端侧实现了均衡负载。

关于Ribbon如何负载均衡地消费microservice-provider-user就分享到这里了,希望以上内容可以对大家有一定的帮助,可以学到更多知识。如果觉得文章不错,可以把它分享出去让更多的人看到。

返回开发技术教程...