投稿
  1. 极客之音首页
  2. 技术随笔

SpringCloud入门（三）之Ribbon（上）

小半 • • 技术随笔 • 阅读 190

导读：本篇文章讲解 SpringCloud入门（三）之Ribbon（上），希望对大家有帮助，欢迎收藏，转发！站点地址：www.bmabk.com

Spring Cloud Ribbon是基于Netflix Ribbon实现的一套客户端 负载均衡的工具。

​ 简单的说，Ribbon是Netflix发布的开源项目，主要功能是提供客户端的软件负载均衡算法，将Netflix的中间层服务连接在一起。Ribbon客户端组件提供一系列完善的配置项如连接超时，重试等。简单的说，就是在配置文件中列出Load Balancer（简称LB）后面所有的机器，Ribbon会自动的帮助你基于某种规则（如简单轮询，随机连接等）去连接这些机器。我们也很容易使用Ribbon实现自定义的负载均衡算法。

文章目录

一，负载均衡（LB）概念

负载均衡分为集中式LB和进程式LB两种

  • 集中式LB： 即在服务的消费方和提供方之间使用独立的LB设施(可以是硬件，如F5, 也可以是软件，如nginx), 由该设施负责把访问请求通过某种策略转发至服务的提供方；

  • 进程式LB：将LB逻辑集成到消费方，消费方从服务注册中心获知有哪些地址可用，然后自己再从这些地址中选择出一个合适的服务器。

Ribbon就属于进程内LB，它只是一个类库，集成于消费方进程，消费方通过它来获取到服务提供方的地址。

二，Ribbon初步配置

2.1 pom.xml

修改servicecloud-consumer-dept-80工程的pom.xml

<!-- 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>

2.2 application.yml

修改application.yml 追加eureka的服务注册地址：

server:
   port: 80
   
eureka:
  client:
    register-with-eureka: false
    service-url: 
      defaultZone: http://eureka7001.com:7001/eureka/,http://eureka7002.com:7002/eureka/,http://eureka7003.com:7003/eureka/

2.3 @LoadBalanced

对ConfigBean进行新注解@LoadBalanced 获得Rest时加入Ribbon的配置：

package com.lmc.springcloud.cfgbeans;

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 ConfigBean {
	
	@Bean
	@LoadBalanced
    public RestTemplate getRestTemplate()
    {
         return new RestTemplate();
    }

}

2.4 启动类

主启动类DeptConsumer80_App添加@EnableEurekaClient：

package com.lmc.springcloud;

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

@SpringBootApplication
@EnableEurekaClient
public class DeptConsumer80_App {

	public static void main(String[] args) {
		// TODO Auto-generated method stub
		SpringApplication.run(DeptConsumer80_App.class, args);

	}

}

2.5 Controller

修改DeptController_Consumer客户端访问类的主机名称：

//private static final String REST_URL_PREFIX = "http://localhost:8001";
	private static final String REST_URL_PREFIX = "http://SERVICECLOUD-DEPT";

修改之后，Ribbon和Eureka整合后Consumer可以直接调用服务而不用再关心地址和端口号

2.6 测试

http://localhost/consumer/dept/get/1

三，Ribbon负载均衡

Ribbon在工作时分成两步

第一步先选择 EurekaServer ,它优先选择在同一个区域内负载较少的server.

第二步再根据用户指定的策略，在从server取到的服务注册列表中选择一个地址。

其中Ribbon提供了多种策略：比如轮询、随机和根据响应时间加权。

3.1 pom.xml

参考servicecloud-provider-dept-8001，新建两份，分别命名为8002，8003，将8001pom.xml中的坐标加入到8002和8003里面。

8002：

<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/xsd/maven-4.0.0.xsd">
  <modelVersion>4.0.0</modelVersion>
  <parent>
    <groupId>com.lmc</groupId>
    <artifactId>servicecloud</artifactId>
    <version>0.0.1-SNAPSHOT</version>
  </parent>
  <artifactId>servicecloud-provider-dept-8002</artifactId>
  
  <dependencies>

	<!-- 引入自己定义的api通用包，可以使用Dept部门Entity -->
   <dependency>
     <groupId>com.lmc</groupId>
     <artifactId>servicecloud-api</artifactId>
     <version>${project.version}</version>
   </dependency>
   
      <!-- 将微服务provider侧注册进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>   

   <dependency>
     <groupId>junit</groupId>
     <artifactId>junit</artifactId>
   </dependency>

   <dependency>
     <groupId>mysql</groupId>
     <artifactId>mysql-connector-java</artifactId>
   </dependency>

   <dependency>
     <groupId>com.alibaba</groupId>
     <artifactId>druid</artifactId>
   </dependency>

   <dependency>
     <groupId>ch.qos.logback</groupId>
     <artifactId>logback-core</artifactId>
   </dependency>

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

   <dependency>
     <groupId>org.springframework.boot</groupId>
     <artifactId>spring-boot-starter-jetty</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>
   </dependency>

   <!-- 修改后立即生效，热部署 -->
   <dependency>
     <groupId>org.springframework</groupId>
     <artifactId>springloaded</artifactId>
   </dependency>
   <dependency>
     <groupId>org.springframework.boot</groupId>
     <artifactId>spring-boot-devtools</artifactId>
   </dependency>
   
  </dependencies>
  
</project>

3.2 数据库

新建clouddb2和clouddb3数据库，各自微服务分别连各自的数据库。

clouddb2：

 

DROP DATABASE IF EXISTS cloudDB02;
 
CREATE DATABASE cloudDB02 CHARACTER SET UTF8;
USE cloudDB02;
CREATE TABLE dept
(
  deptno BIGINT NOT NULL PRIMARY KEY AUTO_INCREMENT,
  dname VARCHAR(60),
  db_source   VARCHAR(60)
);
 
INSERT INTO dept(dname,db_source) VALUES('开发部',DATABASE());
INSERT INTO dept(dname,db_source) VALUES('人事部',DATABASE());
INSERT INTO dept(dname,db_source) VALUES('财务部',DATABASE());
INSERT INTO dept(dname,db_source) VALUES('市场部',DATABASE());
INSERT INTO dept(dname,db_source) VALUES('运维部',DATABASE()); 

SELECT * FROM dept;

clouddb3：

 

DROP DATABASE IF EXISTS cloudDB03;
 
CREATE DATABASE cloudDB03 CHARACTER SET UTF8;
USE cloudDB03;
CREATE TABLE dept
(
  deptno BIGINT NOT NULL PRIMARY KEY AUTO_INCREMENT,
  dname VARCHAR(60),
  db_source   VARCHAR(60)
);
 
INSERT INTO dept(dname,db_source) VALUES('开发部',DATABASE());
INSERT INTO dept(dname,db_source) VALUES('人事部',DATABASE());
INSERT INTO dept(dname,db_source) VALUES('财务部',DATABASE());
INSERT INTO dept(dname,db_source) VALUES('市场部',DATABASE());
INSERT INTO dept(dname,db_source) VALUES('运维部',DATABASE()); 

SELECT * FROM dept;

3.3 application.yml

修改8002/8003各自YML，主要修改端口号，数据库名，和自定义服务名称。

8002：

server:
  port: 8002
  
mybatis:
  config-location: classpath:mybatis/mybatis.cfg.xml        # mybatis配置文件所在路径
  type-aliases-package: com.lmc.springcloud.entities    # 所有Entity别名类所在包
  mapper-locations: classpath*:mybatis/mapper/**/*.xml     # mapper映射文件
    
spring:
    application:
       name: servicecloud-dept 
    datasource:
       type: com.alibaba.druid.pool.DruidDataSource            # 当前数据源操作类型
       driver-class-name: com.mysql.jdbc.Driver              # mysql驱动包
       url: jdbc:mysql://localhost:3306/clouddb02              # 数据库名称
       username: root
       password: root
    dbcp2:
      min-idle: 5                                           # 数据库连接池的最小维持连接数
      initial-size: 5                                       # 初始化连接数
      max-total: 5                                          # 最大连接数
      max-wait-millis: 200                                  # 等待连接获取的最大超时时间

eureka:
   client: 
      service-url: 
         defaultZone: http://eureka7001.com:7001/eureka/,http://eureka7002.com:7002/eureka/,http://eureka7003.com:7003/eureka/
         # defaultZone: http://localhost:7001/eureka		#客户端注册进eureka服务列表内
   instance:
      instance-id: servicecloud-dept8002				#自定义服务名称信息
      prefer-ip-address: true     						#访问路径可以显示IP地址

info:
   app.name: lmc-servicecloud
   company.name: www.lmc.com
   build.artifactId: $project.artifactId$
   build.version: $project.version$

8003：

server:
  port: 8003
  
mybatis:
  config-location: classpath:mybatis/mybatis.cfg.xml        # mybatis配置文件所在路径
  type-aliases-package: com.lmc.springcloud.entities    # 所有Entity别名类所在包
  mapper-locations: classpath*:mybatis/mapper/**/*.xml     # mapper映射文件
    
spring:
    application:
       name: servicecloud-dept 
    datasource:
       type: com.alibaba.druid.pool.DruidDataSource            # 当前数据源操作类型
       driver-class-name: com.mysql.jdbc.Driver              # mysql驱动包
       url: jdbc:mysql://localhost:3306/clouddb03              # 数据库名称
       username: root
       password: root
    dbcp2:
      min-idle: 5                                           # 数据库连接池的最小维持连接数
      initial-size: 5                                       # 初始化连接数
      max-total: 5                                          # 最大连接数
      max-wait-millis: 200                                  # 等待连接获取的最大超时时间

eureka:
   client: 
      service-url: 
         defaultZone: http://eureka7001.com:7001/eureka/,http://eureka7002.com:7002/eureka/,http://eureka7003.com:7003/eureka/
         # defaultZone: http://localhost:7001/eureka		#客户端注册进eureka服务列表内
   instance:
      instance-id: servicecloud-dept8003				#自定义服务名称信息
      prefer-ip-address: true     						#访问路径可以显示IP地址

info:
   app.name: lmc-servicecloud
   company.name: www.lmc.com
   build.artifactId: $project.artifactId$
   build.version: $project.version$

3.4 测试

先启动3个eureka集群配置区（7001/7002/7003），再启动3个Dept微服务（8001/8002/8003）启动并各自测试通过。

http://localhost:8001/dept/list

http://localhost:8002/dept/list

http://localhost:8003/dept/list

若访问成功，再启动servicecloud-consumer-dept-80服务消费者。

http://localhost/consumer/dept/list

不断刷新页面，注意观察看到返回的数据库名字，若各不相同，负载均衡实现（默认是轮询算法）。

版权声明：本文内容由互联网用户自发贡献，该文观点仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 举报，一经查实，本站将立刻删除。

文章由极客之音整理，本文链接：https://www.bmabk.com/index.php/post/81643.html

赞 (0)
小半的头像小半
0 0

相关推荐

极客之音——专业性很强的中文编程技术网站，欢迎收藏到浏览器，订阅我们！