Spring Cloud Ribbon是Spring Cloud Netflix子项目的核心组件之一，主要为服务间调用及API网关转发提供负载均衡的功能，此处将采用适当的进行详细介绍。
简介
在微服务架构中，很多服务都会部署多个，其他服务去调用该服务的时候，如何保证负载均衡是个不得不去考虑的问题。负载均衡可以增加系统的可用性和扩展性，当我们使用RestTemplate来调用其他服务时，Ribbon可以很方便的实现负载均衡功能。
创建一个用户服务模块
首先我们创建一个用户服务，用于给Ribbon提供服务调用。
在pom.xml中添加相关依赖
<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-web</artifactId></dependency>
在application.yml进行配置
server:port: 8201spring:application:name: user-serviceeureka:client:register-with-eureka: truefetch-registry: trueservice-url:defaultZone: http://localhost:8001/eureka/
添加UserController为提供调用接口 ```java @RestController @RequestMapping(“/user”) publicclass UserController {
private Logger LOGGER = LoggerFactory.getLogger(this.getClass());
@Autowired private UserService userService;
@PostMapping(“/create”) public CommonResult create(@RequestBody User user) {
userService.create(user);returnnew CommonResult("操作成功", 200);
}
@GetMapping(“/{id}”) public CommonResult
getUser(@PathVariable Long id) { User user = userService.getUser(id);LOGGER.info("根据id获取用户信息，用户名称为：{}",user.getUsername());returnnew CommonResult<>(user);
}
@GetMapping(“/getUserByIds”) public CommonResult
ids) { List<User> userList= userService.getUserByIds(ids);LOGGER.info("根据ids获取用户信息，用户列表为：{}",userList);returnnew CommonResult<>(userList);
}
@GetMapping(“/getByUsername”) public CommonResult
getByUsername(@RequestParam String username) { User user = userService.getByUsername(username);returnnew CommonResult<>(user);
}
@PostMapping(“/update”) public CommonResult update(@RequestBody User user) {
userService.update(user);returnnew CommonResult("操作成功", 200);
}
@PostMapping(“/delete/{id}”) public CommonResult delete(@PathVariable Long id) {
userService.delete(id);returnnew CommonResult("操作成功", 200);
} }
<a name="P3SMC"></a>### 创建一个ribbon-service模块> 这里我们创建一个ribbon-service模块来调用用户服务模块演示负载均衡的服务调用。- 在pom.xml中添加相关依赖```xml<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.springframework.cloud</groupId><artifactId>spring-cloud-starter-netflix-ribbon</artifactId></dependency>
- 在application.yml进行配置
```yaml
server:
port:8301
spring:
application:
name: ribbon-service
eureka:
client:
register-with-eureka: true
fetch-registry: true
service-url:
service-url: user-service: http://user-service ##用户服务地址defaultZone: http://localhost:8001/eureka/
- 使用@LoadBalanced注解可以恢复RestTemplate负载均衡的能力```java@Configurationpublicclass RibbonConfig {@Bean@LoadBalancedpublic RestTemplate restTemplate(){returnnew RestTemplate();}}
- 添加UserRibbonController类
注入RestTemplate，使用其调用用户服务中提供的相关接口，此处对GET和POST进行进行了演示，其他方法调用称为参考。
@RestController@RequestMapping("/user")publicclass UserRibbonController {@Autowiredprivate RestTemplate restTemplate;@Value("${service-url.user-service}")private String userServiceUrl;@GetMapping("/{id}")public CommonResult getUser(@PathVariable Long id) {return restTemplate.getForObject(userServiceUrl + "/user/{1}", CommonResult.class, id);}@GetMapping("/getByUsername")public CommonResult getByUsername(@RequestParam String username) {return restTemplate.getForObject(userServiceUrl + "/user/getByUsername?username={1}", CommonResult.class, username);}@GetMapping("/getEntityByUsername")public CommonResult getEntityByUsername(@RequestParam String username) {ResponseEntity<CommonResult> entity = restTemplate.getForEntity(userServiceUrl + "/user/getByUsername?username={1}", CommonResult.class, username);if (entity.getStatusCode().is2xxSuccessful()) {return entity.getBody();} else {returnnew CommonResult("操作失败", 500);}}@PostMapping("/create")public CommonResult create(@RequestBody User user) {return restTemplate.postForObject(userServiceUrl + "/user/create", user, CommonResult.class);}@PostMapping("/update")public CommonResult update(@RequestBody User user) {return restTemplate.postForObject(userServiceUrl + "/user/update", user, CommonResult.class);}@PostMapping("/delete/{id}")public CommonResult delete(@PathVariable Long id) {return restTemplate.postForObject(userServiceUrl + "/user/delete/{1}", null, CommonResult.class, id);}}
负载均衡功能演示
- 启动eureka-server于8001端口；
- 启动user-service于8201端口；
- 启动另一个用户服务于8202端口，可以通过修改IDEA中的SpringBoot的启动配置实现：
- 调用接口进行测试：http://localhost:8301/user/1
- 可以发现运行在8201和8202的用户服务控制台交替打印日志
功能区的常用配置
总体配置
ribbon:ConnectTimeout: 1000 #服务请求连接超时时间（毫秒）ReadTimeout: 3000 #服务请求处理超时时间（毫秒）OkToRetryOnAllOperations: true #对超时请求启用重试机制MaxAutoRetriesNextServer: 1 #切换重试实例的最大个数MaxAutoRetries: 1 # 切换实例后重试最大次数NFLoadBalancerRuleClassName: com.netflix.loadbalancer.RandomRule #修改负载均衡算法
指定服务进行配置
与总体配置的区别就是ribbon例程挂在服务名称下面，如下是对ribbon-service调用用户服务时的单独配置。
user-service:ribbon:ConnectTimeout: 1000 #服务请求连接超时时间（毫秒）ReadTimeout: 3000 #服务请求处理超时时间（毫秒）OkToRetryOnAllOperations: true #对超时请求启用重试机制MaxAutoRetriesNextServer: 1 #切换重试实例的最大个数MaxAutoRetries: 1 # 切换实例后重试最大次数NFLoadBalancerRuleClassName: com.netflix.loadbalancer.RandomRule #修改负载均衡算法
功能区的负载均衡策略
所谓的负载均衡策略，就是当A服务调用B服务时，此时B服务有多个实例，这时A服务以交替方式来选择调用的B实例，功能区可以选择以下多个负载均衡策略。
- com.netflix.loadbalancer.RandomRule：从提供服务的实例中以随机的方式；
- com.netflix.loadbalancer.RoundRobinRule：以线性步进的方式，就是维护一个计数器，从提供服务的实例中按顺序选择，第一次选择第一个，第二次选第二个，以此类推，到最后一个以后再从头来过；
- com.netflix.loadbalancer.RetryRule：在RoundRobinRule的基础上添加重试机制，即在指定的重试时间，反复使用线性策略来选择可用实例；
- com.netflix.loadbalancer.WeightedResponseTimeRule：对RoundRobinRule的扩展，响应速度越快的实例选择权重重，更容易被选择；
- com.netflix.loadbalancer.BestAvailableRule：选择并发较小的实例；
- com.netflix.loadbalancer.AvailabilityFilteringRule：先过滤掉故障实例，再选择并发较少实例；
- com.netflix.loadbalancer.ZoneAwareLoadBalancer：采用双重过滤，同时过滤不是同一区域的实例和故障实例，选择并发较小的实例。
使用到的模块
springcloud-study├── eureka-server -- eureka注册中心├── user-service -- 提供User对象CRUD接口的服务└── ribbon-service -- ribbon服务调用测试服务
若有收获，就点个赞吧
0 人点赞
