安科网

Ribbon负载均衡及Feign消费者调用服务

zllbirdonland

zllbirdonland

2019-12-08

关注 关注

微服务调用Ribbon

简介

前面讲了eureka服务注册与发现，但是结合eureka集群的服务调用没讲。

这里的话 就要用到Ribbon，结合eureka，来实现服务的调用；

Ribbon是Netflix发布的负载均衡器，它有助于控制HTTP和TCP的客户端的行为。为Ribbon配置服务提供者地址后，Ribbon就可基于某种负载均衡算法，自动地帮助服务消费者去请求。Ribbon默认为我们提供了很多负载均衡算法，例如轮询、随机等。当然，我们也可为Ribbon实现自定义的负载均衡算法。

在Spring Cloud中，当Ribbon与Eureka配合使用时，Ribbon可自动从Eureka Server获取服务提供者地址列表，并基于负载均衡算法，请求其中一个服务提供者实例。展示了Ribbon与Eureka配合使用时的架构。

Ribbon负载均衡及Feign消费者调用服务

初步应用

Ribbon是客户端负载均衡，所以肯定集成再消费端，也就是consumer端

我们修改microservice-student-consumer-80

首先，引入依赖，pom.xml 加入 ribbon相关依赖

<!--ribbon相关依赖-->
<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-eureka</artifactId>
</dependency>
<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-ribbon</artifactId>
</dependency>
<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-config</artifactId>
</dependency>

application.yml

server:
  port: 8080
  context-path: /
eureka:
  client:
    service-url:
      defaultZone: http://eureka2001.huang.com:2001/eureka/,http://eureka2002.huang.com:2002/eureka/,http://eureka2003.huang.com:2003/eureka/
    register-with-eureka: false

ribbon结合eureka来调用服务提供者；

SpringCloudConfig也改成 要加个负载均衡配置 @LoadBalanced

package com.huang.microservicestudentconsumer80.config;

import org.springframework.cloud.client.loadbalancer.LoadBalanced;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.web.client.RestTemplate;

@Configuration
public class SpringCloudConfig {

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

因为和eureka整合，所以启动类StudentConsumerApplication_80 加个注解 @EnableEurekaClient

这里还有一个，要修改下StudentConsumerController的PRE_HOST，改成指定的微服务应用名称；

当然这里要先在服务提供者microservice-student-provider-1001的application.yml加下配置，指定下应用名称：

application:

    name: microservice-student

Ribbon负载均衡及Feign消费者调用服务

我们的微服务应用名称是 microservice-student

所以服务调用者这边的控制器里PRE_HOST改成 http://MICROSERVICE-STUDENT即可；

MICROSERVICE-STUDENT为Eureka注册中心的应用名称

@RestController
@RequestMapping("/student")
public class StudentConsumerController {

    //    private final static String SERVER_IP_PORT = "http://localhost:1001";
    private final static String SERVER_IP_PORT = "http://MICROSERVICE-STUDENT";

上面配置好后，我们可以测试下；

先启动三个eureka，然后再启动服务提供者，再启动服务消费者；

Ribbon负载均衡及Feign消费者调用服务

Ribbon负载均衡及Feign消费者调用服务

结果就出来了，说明配置OK；

Ribbon负载均衡

按照它microservice-student-provider-1001建立一个microservice-student-provider子项目，然后将microservice-student-provider-1001这个子项目干掉；

前面搭建了初步例子，但是还没实现真正负载均衡，我们这里要先搞三个服务提供者集群，然后才能演示负载均衡，以及负载均衡策略；

新建项目microservice-student-provider-1002，microservice-student-provider-1003

pom.xml，application.yml，以及java类都复制一份，启动类名称对应的改下；

yml配置文件有两处要对应的改下，port端口改下，以及服务实例名称改下；

 Ribbon负载均衡及Feign消费者调用服务

相关代码如下

相关pom

<properties>
    <java.version>1.8</java.version>
</properties>
<dependencies>
    <dependency>
        <groupId>com.huang</groupId>
        <artifactId>microservice-common</artifactId>
    </dependency>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-web</artifactId>
    </dependency>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-test</artifactId>
        <scope>test</scope>
    </dependency>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-data-jpa</artifactId>
    </dependency>
    <dependency>
        <groupId>mysql</groupId>
        <artifactId>mysql-connector-java</artifactId>
    </dependency>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-tomcat</artifactId>
    </dependency>
    <dependency>
        <groupId>com.alibaba</groupId>
        <artifactId>druid-spring-boot-starter</artifactId>
    </dependency>
    <!--  修改后立即生效，热部署  -->
    <dependency>
        <groupId>org.springframework</groupId>
        <artifactId>springloaded</artifactId>
    </dependency>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-devtools</artifactId>
    </dependency>
    <dependency>
        <groupId>com.huang</groupId>
        <artifactId>microservice-common</artifactId>
        <version>1.0-SNAPSHOT</version>
        <scope>compile</scope>
    </dependency>

    <!--添加注册中心Eureka相关配置-->
    <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-starter-eureka</artifactId>
    </dependency>
    <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-starter-config</artifactId>
    </dependency>

    <!-- actuator监控引入 -->
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-actuator</artifactId>
    </dependency>
</dependencies>

Yml文件

---
server:
  port: 1001
  context-path: /
spring:
  datasource:
    type: com.alibaba.druid.pool.DruidDataSource
    driver-class-name: com.mysql.jdbc.Driver
    url: jdbc:mysql://localhost:3306/huang?useUnicode=true&characterEncoding=utf8
    username: root
    password: 123
  jpa:
    hibernate:
      ddl-auto: update
    show-sql: true
  application:
    name: microservice-student
  profiles: provider-1001

eureka:
  instance:
    hostname: localhost
    appname: microservice-student
    instance-id: microservice-student:1001
    prefer-ip-address: true
  client:
    service-url:
      defaultZone: http://eureka2001.huang.com:2001/eureka/,http://eureka2002.huang.com:2002/eureka/,http://eureka2003.huang.com:2003/eureka/

info:
  groupId: com.huang.testSpringcloud
  artifactId: microservice-student-provider-1001
  version: 1.0-SNAPSHOT
  userName: http://huang.com
  phone: 123456

---
server:
  port: 1002
  context-path: /
spring:
  datasource:
    type: com.alibaba.druid.pool.DruidDataSource
    driver-class-name: com.mysql.jdbc.Driver
    url: jdbc:mysql://localhost:3306/huang?useUnicode=true&characterEncoding=utf8
    username: root
    password: 123
  jpa:
    hibernate:
      ddl-auto: update
    show-sql: true
  application:
    name: microservice-student
  profiles: provider-1002

eureka:
  instance:
    hostname: localhost
    appname: microservice-student
    instance-id: microservice-student:1002
    prefer-ip-address: true
  client:
    service-url:
      defaultZone: http://eureka2001.huang.com:2001/eureka/,http://eureka2002.huang.com:2002/eureka/,http://eureka2003.huang.com:2003/eureka/

info:
  groupId: com.huang.testSpringcloud
  artifactId: microservice-student-provider-1002
  version: 1.0-SNAPSHOT
  userName: http://huang.com
  phone: 123456

---
server:
  port: 1003
  context-path: /
spring:
  datasource:
    type: com.alibaba.druid.pool.DruidDataSource
    driver-class-name: com.mysql.jdbc.Driver
    url: jdbc:mysql://localhost:3306/huang?useUnicode=true&characterEncoding=utf8
    username: root
    password: 123
  jpa:
    hibernate:
      ddl-auto: update
    show-sql: true
  application:
    name: microservice-student
  profiles: provider-1003

eureka:
  instance:
    hostname: localhost
    appname: microservice-student
    instance-id: microservice-student:1003
    prefer-ip-address: true
  client:
    service-url:
      defaultZone: http://eureka2001.huang.com:2001/eureka/,http://eureka2002.huang.com:2002/eureka/,http://eureka2003.huang.com:2003/eureka/

info:
  groupId: com.huang.testSpringcloud
  artifactId: microservice-student-provider-1003
  version: 1.0-SNAPSHOT
  userName: http://huang.com
  phone: 123456

启动类

package com.huang.microservicestudentprovider;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.boot.autoconfigure.domain.EntityScan;
import org.springframework.cloud.netflix.eureka.EnableEurekaClient;

@EntityScan("com.huang.*.*")
@EnableEurekaClient
@SpringBootApplication
public class MicroserviceStudentProviderApplication {

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

}

StudentProviderController.java

@Value("${server.port}")
private String port;

@RequestMapping("/ribbon")
public String ribbon(){
    return "工号【"+port+"】正在为您服务";
}

StudentConsumerController.java

@RequestMapping("/ribbon")
public String ribbon(){
    return restTemplate.getForObject(SERVER_IP_PORT + "/student/ribbon", String.class);
}

先测试服务提供者：

http://localhost:1001/student/list

http://localhost:1002/student/list

http://localhost:1003/student/list

看看是否有结果；

再测试下 eureka：

http://eureka2001.javaxl.com:2001/

http://eureka2002.javaxl.com:2002/

http://eureka2003.javaxl.com:2003/

Ribbon负载均衡及Feign消费者调用服务

有这种的话，就说明没问题；

然后再启动服务消费者：

http://localhost/student/list  多刷新几次 看控制台，我们看到 有默认的轮询策略，访问对应的服务提供者；

但是这种默认的轮询策略肯定是不能满足实际需求的，比如有3个服务提供者，突然挂了一个，这样的话，默认轮询 ，总有1/3的概率访问失败； 所以我们看下ribbon默认给我们提供的策略有哪些；

策略名

策略声明

策略描述

BestAvailableRule

public class BestAvailableRule extends ClientConfigEnabledRoundRobinRule

选择一个最小的并发请求的server

AvailabilityFilteringRule

public class AvailabilityFilteringRule extends PredicateBasedRule

过滤掉那些因为一直连接失败的被标记为circuit tripped的后端server，并过滤掉那些高并发的的后端server（active connections 超过配置的阈值）

WeightedResponseTimeRule

public class WeightedResponseTimeRule extends RoundRobinRule

根据响应时间分配一个weight，响应时间越长，weight越小，被选中的可能性越低。

RetryRule

public class RetryRule extends AbstractLoadBalancerRule

对选定的负载均衡策略机上重试机制。

RoundRobinRule

public class RoundRobinRule extends AbstractLoadBalancerRule

roundRobin方式轮询选择server

RandomRule

public class RandomRule extends AbstractLoadBalancerRule

随机选择一个server

ZoneAvoidanceRule

public class ZoneAvoidanceRule extends PredicateBasedRule

复合判断server所在区域的性能和server的可用性选择server

默认7个策略，根据具体产品需求，我们选用；

代码中如何假如呢；

服务消费端 SpringCloudConfig配置类  

指定IRule实现；

这里我们演示用 RetryRule，大伙可以自行测试；

package com.huang.microservicestudentconsumer80.config;

import com.netflix.loadbalancer.IRule;
import com.netflix.loadbalancer.RetryRule;
import org.springframework.cloud.client.loadbalancer.LoadBalanced;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.web.client.RestTemplate;

@Configuration
public class SpringCloudConfig {

    @LoadBalanced  // 引入ribbon负载均衡
    @Bean
    public RestTemplate getRestTemplate() {
        return new RestTemplate();
    }

    /**
     * 自定义轮询算法
     * @return
     */
    @Bean
    public IRule myRule(){
        return new RetryRule();
    }
}

负载均衡 eureka eureka服务发现

zllbirdonland

zllbirdonland

0 关注 0 粉丝 0 动态

关注 关注

相关推荐

ASP.NET Core3.1 Ocelot负载均衡的实现

Ocelot可以在每个路由的可用下游服务中实现负载均衡，这使我们更有效地选择下游服务来处理请求。LeastConnection：根据服务正在处理请求量的情况来决定哪个服务来处理新请求，即将新请求发送到具有最少现有请求的服务去处理。算法状态没有分布在Ocel

azhuye 2020-11-12

TCP接入层的负载均衡、高可用、扩展性架构

今天和大家系统性聊聊TCP的负载均衡，高可用，与扩展性架构。互联网架构中，web-server接入一般使用nginx来做反向代理，实施负载均衡。整个架构分三层：。上游调用层，一般是browser或者APP;中间反向代理层，nginx;下游真实接入集群，we

liupengqwert 2020-10-28

Kubernetns LB方案：无需云厂商的动态DNS和负载均衡

本文转载自微信公众号「新钛云服」，作者祝祥 翻译 。我们经常谈论托管Kubernetes或在云中运行的Kubernetes，但我们也在非云的环境上运行Kubernetes。您可能还会听到很多有关云供应商集成的经典案例：您可以获取无密码凭据来访问托管服务，无

YzhilongY 2020-08-31

.Net Core + Nginx实现项目负载均衡的全步骤

nginx大家如果没用过那或多或少都应该听过，vue的部署、反向代理、负载均衡nginx都能帮你做到。今天主要说一下nginx负载均衡我们的项目，如下图所示,请求到达nginx，nginx再帮我们转发。运行容器，将本地的8080端口映射到容器内部的 80

crazyjingling 2020-08-16

nginx实现负载均衡

负载均衡初步完成了。upstream按照轮询（默认）方式进行负载，每个请求按时间顺序逐一分配到不同的后端服务器，如果后端服务器down掉，能自动剔除。增加 weight 参数，指定轮询几率，weight和访问比率成正比，用于后端服务器性能不均的情况。如下所

swtIrene 2020-08-14

nginx实现负载均衡，引入第三方fair

nginx实现负载均衡，按后端服务器的响应时间来分配请求，响应时间短的优先分配。需要使用fair参数（第三方）；放入指定目录中。进入nginx目录执行操作，注：安装了nginx和还未安装nginx执行的命令不一样，这里用的是已经安装了nginx使用的命令。

slovyz 2020-08-14

双机热备和负载均衡的区别

好处在于成本投入低，安装配置跟管理上要轻松许多

YzhilongY 2020-08-13

Azure Application Gateway（一）对后端 Web App 进行负载均衡

　　今天，我们学习一个新的知识点-----Azure Application Gateway，通过Azure 应用程序网关为我么后端的服务提供负载均衡的功能。我们再文章头中大概先了解一下什么是应用程序网关。2，SKU为 “Standard” 或者 “WAF

tinydu 2020-08-09

关于Nginx的正向代理与反向代理

Nginx是一款自由的、开源的、高性能的HTTP服务器和反向代理服务器；同时也是一个IMAP、POP3、SMTP代理服务器；Nginx可以作为一个HTTP服务器进行网站的发布处理，另外Nginx可以作为反向代理进行负载均衡的实现。说反向代理之前，我们先看看

tinydu 2020-08-03

nginx 负载均衡

nginx可以实例负载均衡。准备工作操作系统：欧拉2.8 armecs-cecd-0002：192.168.0.141 #Nginx服务器ecs-cecd-0001：192.168.0.8 #Web服务器ecs-cecd-0003：192.168

Studynutlee 2020-08-03

对 AWS Google Azure 三家全球负载均衡的延迟情况做个评测

说到 AWS、Google、Azure 的全球负载均衡，那我们需要了解一下 Anycast IP。我们知道，在互联网中的公网 IP 是唯一的，正常来说，一个网络中不应该有两个相同的 IP，那么 Anycast protocol 就是这么一项可以让一个 IP

快乐de馒头 2020-07-29

软件开发中的负载均衡

优先权的方式是将服务分组，优先权是针对组的，组内仍使用负载算法。当整个组达到访问阈值时，切换到另一分组。通过应用层（七层）http/https/ws，三次握手后，通过解析应用层内容数据信息进行负载， nginx、HAProxy等如果服务不是基于应用层，那么

yungame 2020-07-27

CDN简介

cdn是把原本需要集中获取的资源缓存到边缘节点，使用户就近访问。通过在网络中增加一层缓存层，通过全局负载技术将源站的资源分发到里用户最近的网络边缘节点上，使缓存服务器响应用户请求，从而达到快速访问的目的。广泛分布的CDN节点及只能冗余机制能有效地防止黑客入

buaichidoufu 2020-07-28

lvs-dr实现mysql负载均衡集群

服务器的操作系统均为centos7,vip和rip在同一网段,使用lvs-dr模型来实现mysql集群服务。MariaDB []> grant all on *.* to ‘root‘@‘192.168.%.%‘ identified by ‘123

wanjichun 2020-07-26

Azure Load Balancer（一） 为我们的Web项目提供负载均衡

　　上节，我们讲到使用 Azure Traffic Manager 为我们的 Demo 项目提供负载均衡，以及流量转发的功能。但是Azure 提供类似的功能的服务远远不止这一个，今天我们就来讲一下 Azure Load Balance ,通过它来实现负载均

极地雪狼 2020-07-26

Nginx -负载均衡配置

在两台 tomcat 里面 webapps 目录中，创建名称是 edu 文件夹，在 edu 文件夹中创建 页面 a.html，用于测试。第一种 轮询（默认） 每个请求按时间顺序逐一分配到不同的后端服务器，如果后端服务器 down 掉，能自动剔除。　　指定轮

yungame 2020-07-04

nginx负载均衡的5种策略

nginx可以根据客户端IP进行负载均衡，在upstream里设置ip_hash，就可以针对同一个C类地址段中的客户端选择同一个后端服务器，除非那个后端服务器宕了才会换一个。upstream backserver {server 192.168.0.14;

畅聊架构 2020-06-28

golang实现负载均衡算法

data := fmt.Sprintf("[%s] http://%s%s \n\n",rs.Addr,rs.Addr,r.RequestURI). fmt.Println("Http server tart to serve

极地雪狼 2020-06-27

一篇文章让你搞懂 Nginx 的负载均衡

所谓负载均衡，就是 Nginx 把请求均匀的分摊给上游的应用服务器，这样即使某一个服务器宕机也不会影响请求的处理，或者当应用服务器扛不住了，可以随时进行扩容。在 x 轴上，可以通过横向扩展应用服务器集群，Nginx 基于 Round-Robin 或者 L

廖先贵 2020-06-23

openresty用haproxy2.0实现负载均衡

yum install pcre-devel openssl-devel gcc curl wget. built by gcc 8.3.1 20190311 (Red Hat 8.3.1-3) (GCC). listen 801;server_name

zllbirdonland 2020-06-16
zllbirdonland

zllbirdonland

W3CSchool教程
HTML 教程
CSS 教程
Bootstrap 教程
Javascript 教程
jQuery 教程
后端教程
C 教程
Java 教程
PHP 教程
Python 教程
Go 教程
移动开发
Android 教程
Swift 教程
Kotlin 教程
jQuery Mobile 教程
ionic 教程
关于我们
新闻动态
联系方式
招聘英才
安科实验室
帮助与反馈

安科网(Ancii)，中国第一极客网

Copyright © 2013 - 2019 Ancii.com

京ICP备18063983号 京公网安备11010802014868号