一、簡介
1、介紹
????????Spring Cloud Ribbon是Netflix發布的開源項目,是基于Netflix Ribbon實現的一套客戶端負載均衡的工具。主要功能是提供客戶端的軟件負載均衡算法,將Netflix的中間層服務連接在一起。Ribbon客戶端組件提供一系列完善的配置項如連接超時,重試等。簡單的說,就是在配置文件中列出Load Balancer(簡稱LB)后面所有的機器,Ribbon會自動的幫助你基于某種規則(如簡單輪詢,隨機連接等)去連接這些機器。我們也很容易使用Ribbon實現自定義的負載均衡算法。
2、負載均衡
????????Load Balance:即負載均衡(LB),在微服務或分布式集群中經常用的一種應用。就是將用戶的請求平攤的分配到多個服務上,從而達到系統的HA(高可用)。常見的負載均衡有軟件Nginx,LVS,硬件F5等。例如:dubbo和SpringCloud中均提供了負載均衡,SpringCloud的負載均衡算法是可以自定義。?
gitHub地址
?二、配置使用
1、修改之前講的80工程
(1)修改pom.xml文件
<!-- eureka相關 --><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-eureka</artifactId></dependency><!-- Ribbon相關 --><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)修改application.yml文件
# eureka配置
eureka:client:# false表示不向注冊中心注冊自己。register-with-eureka: falseservice-url:defaultZone: http://localhost:7001/eureka/,http://localhost:7002/eureka/,http://localhost:7003/eureka/
(3)修改RestTemplate配置類
@Configuration
public class ConfigBean {@Bean@LoadBalancedpublic RestTemplate getRestTemplate() {return new RestTemplate();}
}
(4)修改啟動類
@SpringBootApplication
@EnableEurekaClient
public class DeptConsumer80_App {public static void main(String[] args) {SpringApplication.run(DeptConsumer80_App.class, args);}
}
(5)修改controller
@RestController
@RequestMapping("/consumer/dept")
public class DeptConsumerController {// private static final String REST_URL_PREFIX = "http://localhost:8001";private static final String REST_URL_PREFIX = "http://MICROSERVICECLOUD-DEPT";@Autowiredprivate RestTemplate restTemplate;@RequestMapping(value="/add")public boolean add(Dept dept) {return restTemplate.postForObject(REST_URL_PREFIX+"/dept/add", dept, Boolean.class);}@RequestMapping(value="/get/{id}")public Dept get(@PathVariable("id") Long id) {return restTemplate.getForObject(REST_URL_PREFIX+"/dept/get/"+id, Dept.class);}@RequestMapping(value="/list")public List<Dept> list() {return restTemplate.getForObject(REST_URL_PREFIX+"/dept/list", List.class);}
}
(6)啟動3個eureka集群和8001服務
?(7)啟動80服務測試
Ribbon和Eureka整合后Consumer可以直接調用服務而不用再關心地址和端口號
三、Ribbon負載均衡
1、架構說明
第一步先選擇 EurekaServer ,優先選擇在同一個區域內負載較少的server.
第二步再根據用戶指定的策略,在從server取到的服務注冊列表中選擇一個地址。其中Ribbon提供了多種策略:比如輪詢、隨機和根據響應時間加權。
2、創建多個數據庫
hk-cloud-demo庫的dept表
hk-cloud-demo2庫的dept表
hk-cloud-demo3庫的dept表
3、創建多個生產者
在之前8001服務的基礎上復制8002服務和8003服務
4、修改8002和8003的application.yml文件
注意:8001、8002、8003的應用名要保持一致
spring:application:name: microservicecloud-dept
server:port: 8002mybatis:# mybatis配置文件所在路徑config-location: classpath:mybatis/mybatis.cfg.xml# 所有Entity別名類所在包type-aliases-package: com.hk.clouddemo.entities# mapper映射文件mapper-locations:- classpath:mapper/**/*.xmlspring:application:name: microservicecloud-deptdatasource:# 當前數據源操作類型type: com.alibaba.druid.pool.DruidDataSource# mysql驅動包driver-class-name: com.mysql.cj.jdbc.Driver# 數據庫名稱url: jdbc:mysql://localhost:3306/hk-cloud-demo2username: rootpassword: rootdbcp2:# 數據庫連接池的最小維持連接數min-idle: 5# 初始化連接數initial-size: 5# 最大連接數max-total: 5# 等待連接獲取的最大超時時間max-wait-millis: 200eureka:client: #客戶端注冊進eureka服務列表內service-url:defaultZone: http://eureka-7001.com:7001/eureka/,http://eureka-7002.com:7002/eureka/,http://eureka-7003.com:7003/eureka/instance:# 自定義服務名稱信息instance-id: microservicecloud-dept8002# 訪問路徑可以顯示IP地址prefer-ip-address: trueinfo:app.name: microservicecloudcompany.name: microservicecloud.hk.combuild.artifactId: @project.artifactId@build.version: @project.version@
server:port: 8003mybatis:# mybatis配置文件所在路徑config-location: classpath:mybatis/mybatis.cfg.xml# 所有Entity別名類所在包type-aliases-package: com.hk.clouddemo.entities# mapper映射文件mapper-locations:- classpath:mapper/**/*.xmlspring:application:name: microservicecloud-deptdatasource:# 當前數據源操作類型type: com.alibaba.druid.pool.DruidDataSource# mysql驅動包driver-class-name: com.mysql.cj.jdbc.Driver# 數據庫名稱url: jdbc:mysql://localhost:3306/hk-cloud-demo3username: rootpassword: rootdbcp2:# 數據庫連接池的最小維持連接數min-idle: 5# 初始化連接數initial-size: 5# 最大連接數max-total: 5# 等待連接獲取的最大超時時間max-wait-millis: 200eureka:client: #客戶端注冊進eureka服務列表內service-url:defaultZone: http://eureka-7001.com:7001/eureka/,http://eureka-7002.com:7002/eureka/,http://eureka-7003.com:7003/eureka/instance:# 自定義服務名稱信息instance-id: microservicecloud-dept8003# 訪問路徑可以顯示IP地址prefer-ip-address: trueinfo:app.name: microservicecloudcompany.name: microservicecloud.hk.combuild.artifactId: @project.artifactId@build.version: @project.version@
5、啟動8002和8003
觀察eureka
6、測試
?