首页 > > 程序设计 > Java技术 >

手把手带你利用Ribbon实现客户端的负载均衡

2019-10-12 08:32:36来源：博客园 阅读 ()

新老客户大回馈,云服务器低至5折

手把手带你利用Ribbon实现客户端的负载均衡

之前的文章《SpringCloud搭建注册中心与服务注册》介绍了注册中心的搭建和服务的注册，本文将介绍下服务消费者通过Ribbon调用服务实现负载均衡的过程。

本文目录

一、Ribbon服务调用流程二、搭建注册中心三、服务提供者四、服务消费者五、服务调用实战

一、Ribbon服务调用流程

Ribbon是一个客户端负载均衡器，它有几种负载均衡机制,默认是轮询，我们也可以自定义规则,通过合理的分配网络请求来减小服务器的压力。

总体流程是首先启动注册中心，服务提供者提供服务并注册到注册中心，消费者从注册中心中获取服务并执行。

实现服务调用需要有三个角色：服务注册中心、服务提供者和服务消费者。

二、搭建注册中心

首先新建一个SpringBoot项目，命名spring-cloud-eureka，然后按照下面步骤编写代码即可。

  1. pom.xml代码

添加eureka-server的依赖，代码如下：

    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter</artifactId>
        </dependency>

        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-eureka-server</artifactId>
        </dependency>

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>
    </dependencies>

    <dependencyManagement>
        <dependencies>
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-dependencies</artifactId>
                <version>Finchley.RELEASE</version><!-- eureka版本 -->
                <type>pom</type>
                <scope>import</scope>
            </dependency>
        </dependencies>
    </dependencyManagement>
  1. 启动类代码

启动类添加注解@EnableEurekaServer即可，代码如下：

@EnableEurekaServer
@SpringBootApplication
public class SpringCloudEurekaApplication {
    public static void main(String[] args) {
        SpringApplication.run(SpringCloudEurekaApplication.class, args);
    }
}
  1. 配置文件

使用yml的配置文件，application.yml配置如下：

server:
  port: 9001 #服务端口
eureka:
  instance:
    hostname: localhost
  client:
    register-with-eureka: false #是否将eureka自身作为应用注册到eureka注册中心
    fetch-registry: false #为true时，可以启动，但报异常：Cannot execute request on any known server
    serviceUrl:
      defaultZone: http://${eureka.instance.hostname}:${server.port}/eureka/

配置项说明：

1. server.port=9001表示设置该服务注册中心的端口号 

2. eureka.instance.hostname=localhost表示设置该服务注册中心的hostname 

3. eureka.client.register-with-eureka=false,由于我们目前创建的应用是一个服务注册中心，而不是普通的应用。默认情况下，这个应用会向注册中心（也是它自己）注册它自己，设置为false表示禁止这种默认行为 

4. eureka.client.fetch-registry=false,表示不去检索其他的服务，因为服务注册中心本身的职责就是维护服务实例，它也不需要去检索其他服务
  1. 运行截图

打开浏览器访问http://localhost:9001/，可以看到注册中心以及启动，运行截图如下：


注册中心运行截图

三、服务提供者

服务注册中心有了之后，我们可以向这个服务注册中心注册一个服务提供者，新建一个SpringBoot项目，命名spring-cloud-user-service，提供用户查询服务，然后按照下面步骤编写代码即可。

  1. pom.xml代码

添加eureka-client的依赖，代码如下：

<dependencies>
    <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>com.alibaba</groupId>
        <artifactId>fastjson</artifactId>
        <version>1.2.60</version>
    </dependency>

    <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
    </dependency>

    <dependency>
        <groupId>org.projectlombok</groupId>
        <artifactId>lombok</artifactId>
        <optional>true</optional>
    </dependency>
</dependencies>

<dependencyManagement>
    <dependencies>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-dependencies</artifactId>
            <version>Finchley.RELEASE</version><!-- eureka版本 -->
            <type>pom</type>
            <scope>import</scope>
        </dependency>
    </dependencies>
</dependencyManagement>
  1. 启动类代码

启动类添加注解@EnableEurekaClient即可，代码如下：

@EnableEurekaClient
@SpringBootApplication
public class UserServiceDemoApplication {

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

添加一个提供用户服务的UserController，代码如下：

/**
 * 用户服务
 */
@Slf4j
@RestController
@RequestMapping("/provider")
public class UserController {

    static Map<Integer, User> userMap = new HashMap<>();

    static {
        //模拟数据库
        User user1 = new User(1, "张三", "123456");
        userMap.put(1, user1);
        User user2 = new User(2, "李四", "123123");
        userMap.put(2, user2);
    }

    /**
     * 根据id 查询
     */
    @RequestMapping("/getUser")
    public String getUser(Integer id) {
        log.info("调用getUser接口,id={}",id);
        User user = userMap.get(id);
        return JSON.toJSONString(user);
    }
  1. 配置文件

使用yml的配置文件，application.yml配置如下：

server:
  port: 8100 #服务端口
eureka:
  client:
    serviceUrl:
      defaultZone: http://localhost:9001/eureka/
spring:
  application:
    name: user-service

四、服务消费者

首先新建一个SpringBoot项目，命名spring-cloud-consumer-ribbon，然后按照下面步骤编写代码即可。

  1. pom.xml代码

添加eureka-client的依赖，代码如下：

    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>

        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
        </dependency>

        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
            <optional>true</optional>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>
    </dependencies>

    <dependencyManagement>
        <dependencies>
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-dependencies</artifactId>
                <version>Finchley.RELEASE</version><!-- eureka版本 -->
                <type>pom</type>
                <scope>import</scope>
            </dependency>
        </dependencies>
    </dependencyManagement>
  1. 启动类代码

配置RestTemplate时候添加@LoadBalanced注解，就代表启动Ribbon,进行负载均衡。

启动类添加注解@EnableEurekaClient，也注册到注册中心，代码如下：

@EnableEurekaClient
@SpringBootApplication
public class RibbonConsumerApplication {

    //当添加@LoadBalanced注解，就代表启动Ribbon,进行负载均衡
    @LoadBalanced
    @Bean
    public RestTemplate restTemplate() {
        return new RestTemplate();
    }

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

}
  1. Controller代码
    添加一个Controller，用于调用服务提供者。
/**
 * 消费者Controller
 */
@Slf4j
@RestController
@RequestMapping("/consumer")
public class RibbonConsumerController {

    @Autowired
    private RestTemplate restTemplate;

    @Autowired
    private LoadBalancerClient loadBalancerClient;

    /**
     * 调用 user微服务
     */
    @GetMapping("getUser")
    public String getUser(Integer id) {
        String url = "http://user-service/provider/getUser?id=" + id;
        return restTemplate.getForObject(url, String.class);
    }
}
  1. 配置文件

使用yml的配置文件，application.yml配置如下：

server:
  port: 8082 #服务端口
eureka:
  client:
    serviceUrl:
      defaultZone: http://localhost:9001/eureka/
spring:
  application:
    name: user-service-consumer-ribbon

五、服务调用实战

  1. 启动服务中心并注册服务

代码编写之后，按顺序启动spring-cloud-eureka、spring-cloud-user-service和spring-cloud-consumer-ribbon，先访问注册中心http://localhost:9001/，出现下图说明注册中心和两个服务已经注册成功。

注册中心运行截图注册中心运行截图

需要注意的是为了演示负载均衡，启动spring-cloud-user-service时候启动两个服务8100和8200，启动命令如下：

java -jar spring-cloud-user-service-0.0.1-SNAPSHOT.jar --server.port=8100

java -jar spring-cloud-user-service-0.0.1-SNAPSHOT.jar --server.port=8200
  1. 服务调用

打开浏览器访问连续访问几次http://localhost:8082/consumer/getUser?id=1，我们可以看到每次处理请求的者user-service实例每次都是不一样的，这里就是客户端负载均衡策略的体现，我把调用过程做成了gif图片，效果如下：


调用gif图片

 

到此SpringCloud通过Ribbon调用服务实现负载均衡的过程已经全部实现，有问题欢迎留言沟通哦！

完整源码地址： https://github.com/suisui2019/springboot-study

推荐阅读
1.SpringCloud搭建注册中心与服务注册
2.SpringCloud实现服务间调用（RestTemplate方式）
3.别在 Java 代码里乱打日志了，这才是正确的打日志姿势！
4.编码神器Lombok，学会后开发效率至少提高一倍！
5.利用Spring Boot+zxing，生成二维码还能这么简单

限时领取免费Java相关资料，涵盖了Java、Redis、MongoDB、MySQL、Zookeeper、Spring Cloud、Dubbo/Kafka、Hadoop、Hbase、Flink等高并发分布式、大数据、机器学习等技术。
关注下方公众号即可免费领取：

Java碎碎念公众号Java碎碎念公众号

 


原文链接:https://www.cnblogs.com/haha12/p/11652038.html
如有疑问请与原作者联系

标签：

版权申明：本站文章部分自网络，如有侵权，请联系：west999com@outlook.com
特别注意：本站所有转载文章言论不代表本站观点，本站所提供的摄影照片，插画，设计作品，如需使用，请与原作者联系，版权归原作者所有

上一篇：SpringBoot源码解析系列文章汇总

下一篇：redis 发布订阅

相关文章

IDC资讯： 主机资讯 注册资讯 托管资讯 vps资讯 网站建设

网站运营： 建站经验 策划盈利 搜索优化 网站推广 免费资源

网站联盟： 联盟新闻 联盟介绍 联盟点评 网赚技巧

行业资讯： 搜索引擎 网络游戏 电子商务 广告传媒

网络编程： Asp.Net编程 Asp编程 Php编程 Xml编程 Access Mssql Mysql 其它

服务器技术： Web服务器 Ftp服务器 Mail服务器 Dns服务器 安全防护

软件技巧： 其它软件 Word Excel Powerpoint Ghost Vista QQ空间 QQ FlashGet 迅雷

网页制作： FrontPages Dreamweaver Javascript css photoshop fireworks Flash

程序设计： Java技术 C/C++ VB delphi

网络知识： 网络协议 网络安全 网络管理 组网方案 Cisco技术

操作系统： Win2000 WinXP Win2003 Mac OS Linux FreeBSD

热门词条
最新资讯
热门关注
热门标签