SpringCloud无废话入门02:Ribbon负载均衡

1.白话负载均衡web

        在上一篇的介绍中,咱们建立了两个如出一辙的服务提供者:Provider1和Provider2,而后它们提供的服务也如出一辙,都叫Hello-Service。为何同样的服务咱们要部署两遍?其实理由很简单:算法

        好比,在一个电商网站中,一开始的时候,用户并无那么多,咱们只须要把网站部署在一台服务器上就能够了。可是随着用户量愈来愈大,一台服务器就再也知足不了要求了,这样,咱们就须要把这个如出一辙的网站部署在多台服务器上,可是对外它们提供的服务却都是同样的,包括域名(或者说IP地址)也必须是惟一的。spring

        因此,上一篇中的两个provider,在实际生产环境中,甚至是同一个项目的复制而已,仅仅只是改了配置文件。在咱们的介绍中,咱们只是为了介绍方便,或者说便于调试,才建立了两个项目。固然,里面的服务和代码都是如出一辙的。apache

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

        若是必定要画一个图来表示,那么它大体长这样,架构

2.Ribbonapp

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

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

3.Ribbon负载均衡实现maven

        要让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中不停的切换了~~

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

相关文章
相关标签/搜索