zoukankan      html  css  js  c++  java
  • SpringCloud无废话入门02:Ribbon负载均衡

    1.白话负载均衡

            在上一篇的介绍中,我们创建了两个一模一样的服务提供者:Provider1和Provider2,然后它们提供的服务也一模一样,都叫Hello-Service。为什么一样的服务我们要部署两遍?其实理由很简单:

            比如,在一个电商网站中,一开始的时候,用户并没有那么多,我们只需要把网站部署在一台服务器上就可以了。但是随着用户量越来越大,一台服务器就再也满足不了要求了,这样,我们就需要把这个一模一样的网站部署在多台服务器上,但是对外它们提供的服务却都是一样的,包括域名(或者说IP地址)也必须是唯一的。

            所以,上一篇中的两个provider,在实际生产环境中,甚至是同一个项目的复制而已,仅仅只是改了配置文件。在我们的介绍中,我们只是为了介绍方便,或者说便于调试,才创建了两个项目。当然,里面的服务和代码都是一模一样的。

            以上,如果用白话来讲就是:将相同的服务部署在多台服务器上,对外又只暴露一个唯一的地址,这种实现就叫做:负载均衡。

            如果一定要画一个图来表示,那么它大致长这样,

    2.Ribbon

            那我们怎么把负载均衡引入到我们的软件架构中呢?一种当时是自己写代码实现。另一种当然是利用前人已经写好的框架了。Ribbon就是这样一个框架。

            Ribbon是Netflix发布的开源项目,主要功能就是提供客户端的软件负载均衡算法,将其它服务提供者连接在一起。Ribbon通过在配置文件中列出Load Balancer(简称LB)后面所有的服务提供者,然后帮助我们基于某种规则(如简单轮询,随即连接等)去连接这些机器。

    3.Ribbon负载均衡实现

            要让ribbon实现负载均衡,首先就需要将ribbon本身当成一个服务引入到eureka中。

            创建一个web的子模块,如下:

            它跟其它的项目,从类型上来说没什么区别。

            Pom:

    <?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/maven-v4_0_0.xsd">

        <parent>

            <artifactId>springcloud.parent</artifactId>

            <groupId>com.zuikc</groupId>

            <version>1.0-SNAPSHOT</version>

        </parent>

        <modelVersion>4.0.0</modelVersion>

        <packaging>war</packaging>

        <name>ribbon</name>

        <artifactId>ribbon</artifactId>

        <dependencyManagement>

            <dependencies>

                <dependency>

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

                    <artifactId>spring-cloud-dependencies</artifactId>

                    <version>Greenwich.RELEASE</version>

                    <type>pom</type>

                    <scope>import</scope>

                </dependency>

            </dependencies>

        </dependencyManagement>

        <dependencies>

            <dependency>

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

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

            </dependency>

            <dependency>

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

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

                <version>1.4.6.RELEASE</version>

            </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-web</artifactId>

            </dependency>

        </dependencies>

    </project>

            application.yml,

    server:

      port: 9291

    spring:

      application:

        name: Ribbon-Consumer

    eureka:

      client:

        service-url:

          defaultZone: http://localhost:9091/eureka/

    providers:

      ribbon:

        listOfServers: http://localhost:9191/eureka,http://localhost:9192/eureka

            可以看到,在这个配置文件中,我们干了两件事情,

            1:将自己注册都eureka中;

            2:在listOfServers中,将要负载的两个服务地址配置出来;

            现在,让我们创建ServiceRibbonApplication,

    package com.zuikc;

    import org.springframework.boot.SpringApplication;

    import org.springframework.boot.autoconfigure.SpringBootApplication;

    import org.springframework.cloud.client.discovery.EnableDiscoveryClient;

    import org.springframework.cloud.client.loadbalancer.LoadBalanced;

    import org.springframework.context.annotation.Bean;

    import org.springframework.web.client.RestTemplate;

    /**

     * @ClassName ServiceRibbonApplication

     * @Description 我们提供咨询和培训服务,关于本文有任何困惑,请关注并联系“码农星球”

     * @Author 码农星球

     **/

    @SpringBootApplication

    @EnableDiscoveryClient

    public class ServiceRibbonApplication {

        public static void main(String[] args) {

            SpringApplication.run(ServiceRibbonApplication.class, args);

        }

        @Bean

        @LoadBalanced

        RestTemplate restTemplate() {

            return new RestTemplate();

        }

    }

            所有代码都跟其它的provider一样,唯独多了一个bean的配置。我们先不说这个RestTemplate是什么,我们先看我们的HelloService,

    package com.zuikc;

    import org.springframework.beans.factory.annotation.Autowired;

    import org.springframework.web.bind.annotation.RequestMapping;

    import org.springframework.web.bind.annotation.RestController;

    import org.springframework.web.client.RestTemplate;

    /**

     * @ClassName HelloService

     * @Description 我们提供咨询和培训服务,关于本文有任何困惑,请关注并联系“码农星球”

     * @Author 码农星球

     **/

    @RestController

    public class HelloService {

        @Autowired RestTemplate restTemplate;

        @RequestMapping(value = "/hello")

        public String getHelloContent() {

            return restTemplate.getForObject("http://hello-service/hello",String.class);

        }

    }

            在这个HelloService中,我们要完成一件事情,就是将http://localhost:9291/hello的请求,随机分发到两个provider。而这个分发,在代码层面就是通过RestTemplate去实现的。

            注意这个getForObject的方法中的第一个参数是个url,这个url中的hello-service就是我们配置正在eureka中的服务名。

            现在,让我们启动这个ribbon application,首先可以看到eureka中有个这个ribbon服务,

            其次,让我们打开地址:http://localhost:9291/hello,就可以看到ribbon的这个服务,是在provider1和provider2中不停的切换了~~

            感谢关注“码农星球”。本文版权属于“码农星球”。我们提供咨询和培训服务,关于本文有任何困惑,请关注并联系我们。

  • 相关阅读:
    Containers vs Serverless:本质区别是什么?
    博云 x 某农商行 | 银行信息化运维系统升级的最佳实践
    兼容传统应用,蓄力边缘云——博云胖容器解决方案
    使用Bookinfo应用测试Kuma服务网格
    干货 | 博云基于OVS自研容器网络插件在金融企业的落地实践
    开源分布式事务中间件Seata使用指南
    调研 | 5种分布式事务解决方案优缺点对比
    Ambassador,云原生应用的“门神”
    容器网络插件那么多,博云为什么基于OVS深度自研?
    观察 | 边缘云计算的概念理解
  • 原文地址:https://www.cnblogs.com/luminji/p/10600279.html
Copyright © 2011-2022 走看看