SpringCloud之Ribbon

jiezi

5 年前

【 前面的话 】书接上文，本文的某些知识依赖我的上一篇文章：SpringCloud 之 Eureka，如果没有看过可以先移步去看一下。另外在微服务架构中，业务都会被拆分成一个个独立的服务，服务与服务的通讯是基于 http restful 的。Spring cloud 有两种服务调用方式，一种是 ribbon+restTemplate，另一种是 feign。在这一篇文章首先讲解下基于 ribbon+rest。

ribbon 是一个负载均衡客户端，可以很好的控制 htt 和 tcp 的一些行为。Feign 默认集成了 ribbon。
ribbon 已经默认实现了这些配置 bean：


IClientConfig ribbonClientConfig: DefaultClientConfigImpl

IRule ribbonRule: ZoneAvoidanceRule

IPing ribbonPing: NoOpPing

ServerList ribbonServerList: ConfigurationBasedServerList

ServerListFilter ribbonServerListFilter: ZonePreferenceServerListFilter

ILoadBalancer ribbonLoadBalancer: ZoneAwareLoadBalancer

新建一个 ribbon 子工程 lovin-ribbon-client，用于后面的操作。下面是主要的 pom 依赖

<parent>
        <artifactId>lovincloud</artifactId>
        <groupId>com.eelve.lovincloud</groupId>
        <version>1.0-SNAPSHOT</version>
    </parent>
    <modelVersion>4.0.0</modelVersion>

    <artifactId>lovin-ribbon-client</artifactId>
    <packaging>jar</packaging>
    <name>ribbonclient</name>
    <version>0.0.1</version>
    <description>ribbon 的 client</description>

    <dependencies>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-security</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-ribbon</artifactId>
        </dependency>
    </dependencies>

    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
            </plugin>
        </plugins>
    </build>

这里为了安全，我这里还是添加 spring-boot-starter-security

server:
  port: 8805   # 服务端口号
spring:
  application:
    name: lovinribbonclient     # 服务名称
  security:
    basic:
      enabled: true
    user:
      name: lovin
      password: ${REGISTRY_SERVER_PASSWORD:lovin}
eureka:
  client:
    serviceUrl:
      defaultZone: http://lovin:lovin@localhost:8881/eureka/   # 注册到的 eureka 服务地址

配置 spring-boot-starter-security，这里为了方便我这里放开所有请求

package com.eelve.lovin.cofig;

import org.springframework.context.annotation.Configuration;
import org.springframework.core.annotation.Order;
import org.springframework.security.config.annotation.web.builders.HttpSecurity;
import org.springframework.security.config.annotation.web.configuration.WebSecurityConfigurerAdapter;

/**
 * @ClassName SecurityConfig
 * @Description TDO
 * @Author zhao.zhilue
 * @Date 2019/8/16 14:12
 * @Version 1.0
 **/
@Configuration
@Order(0)
public class WebSecurityConfig extends WebSecurityConfigurerAdapter {

    @Override
    protected void configure(HttpSecurity http) throws Exception {http.authorizeRequests().anyRequest().permitAll()
                .and().csrf().disable();}
}

然后向程序的 ioc 容器中注入一个 bean: restTemplate; 并通过 @LoadBalanced 注解表明这个 restRemplate 开启负载均衡的功能。

package com.eelve.lovin;

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 LovinRibbonClientApplication
 * @Description TDO
 * @Author zhao.zhilue
 * @Date 2019/8/15 16:59
 * @Version 1.0
 **/
@SpringBootApplication
@EnableDiscoveryClient
public class LovinRibbonClientApplication {public static void main(String[] args) {SpringApplication.run(LovinRibbonClientApplication.class,args);
    }

    @Bean
    @LoadBalanced
    RestTemplate restTemplate() {return new RestTemplate();
    }
}

然后编写一个 HelloService

package com.eelve.lovin.service;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.web.client.RestTemplate;

/**
 * @ClassName HelloService
 * @Description TDO
 * @Author zhao.zhilue
 * @Date 2019/8/15 17:02
 * @Version 1.0
 **/
@Service
public class HelloService {
    @Autowired
    RestTemplate restTemplate;

    public String getHello() {
        // 这里的 **lovineurkaclient** 是我上一篇文章新建的 eureka 客户端的名称
        return restTemplate.getForObject("http://lovineurkaclient/hello",String.class);
    }
}

再编写一个 HelloController

package com.eelve.lovin.controller;

import com.eelve.lovin.service.HelloService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

/**
 * @ClassName HelloController
 * @Description TDO
 * @Author zhao.zhilue
 * @Date 2019/8/15 17:05
 * @Version 1.0
 **/
@RestController
public class HelloController {

    @Autowired
    HelloService helloService;

    @RequestMapping("hello")
    public String hello(){return helloService.getHello();
    }
}

依次启动 eureka 的服务端和两个客户端，以及新建的 lovin-ribbon-client

我们可以看到服务已经全部启动成功

然后访问 http://localhost:8805/hello

我们可以看到已经可以通过 ribbon 调到我们建立的 eureka 客户端了

再次请求接口观察返回

我们可以看到我们调到了通过 ribbon 负载的另外一个接口了，到这里我们就已经弄好了一个简单的 ribbon 负载。

我们可以看到我们调用的服务不再是像再上一篇文章中的直接访问对应的服务，而是通过 Ribbon 的负载均衡的去调用的，而且这里说明一点，Ribbon 的默认机制是轮询。

最后的最后是本博客的源码, 欢迎关注这一套 SpringCloud 的实践

SpringCloud之Ribbon

壹、Ribbon 简介

贰、准备工作

叁、启动测试

肆、网络架构